RE: [RDMA for-next v2 1/6] IB/MAD: Add send path trace points

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

 



> > +
> > +	switch (attr.type) {
> > +	case RDMA_AH_ATTR_TYPE_IB:
> > +		addr->dlid = attr.ib.dlid;
> > +		memset(addr->dmac, 0, sizeof(attr.roce.dmac));
> 
> I'm curious to why you use sizeof(attr.roce.dmac) and not sizeof(addr-
> >dmac), as I don't see a reason to assume the two will always be the same
> size. Or is it that attr.roce.dmac, is always smaller?
> 
> Perhaps we should add a:
> 
> 	BUILD_BUG_ON(sizeof(addr->dmac) < sizeof(attr.roce.dmac));

They should always be equal.  Looking at it I think it is better to use the type already defined, roce_ah_attr, which makes them guaranteed to be the same, thusly...

struct rdma_mad_trace_addr {
        u32 dlid;
        struct roce_ah_attr roce_addr;
        u8 sl;
        u16 pkey;
        u32 rqpn;
        u32 rqkey; 
};

And then use sizeof(addr->roce_addr)

Thanks for the catch,
Ira

> 
> 
> > +		break;
> > +	case RDMA_AH_ATTR_TYPE_OPA:
> > +		addr->dlid = attr.opa.dlid;
> > +		memset(addr->dmac, 0, sizeof(attr.roce.dmac));
> > +		break;
> > +	case RDMA_AH_ATTR_TYPE_ROCE:
> > +		addr->dlid = 0;
> > +		memcpy(addr->dmac, attr.roce.dmac, sizeof(attr.roce.dmac));
> > +		break;
> > +	case RDMA_AH_ATTR_TYPE_UNDEFINED:
> > +		addr->dlid = 0;
> > +		memset(addr->dmac, 0, sizeof(attr.roce.dmac));
> > +		break;
> > +	}
> > +}
> > +#define CREATE_TRACE_POINTS
> > +#include <trace/events/ib_mad.h>
> > +
> >  static int mad_sendq_size = IB_MAD_QP_SEND_SIZE;  static int
> > mad_recvq_size = IB_MAD_QP_RECV_SIZE;
> >
> > @@ -1223,6 +1268,14 @@ int ib_send_mad(struct
> ib_mad_send_wr_private
> > *mad_send_wr)
> >
> >  	spin_lock_irqsave(&qp_info->send_queue.lock, flags);
> >  	if (qp_info->send_queue.count < qp_info->send_queue.max_active) {
> > +		if (trace_ib_mad_ib_send_mad_enabled()) {
> > +			struct rdma_mad_trace_addr addr;
> > +
> > +			trace_create_mad_addr(qp_info->port_priv->device,
> > +					      qp_info->port_priv->port_num,
> > +					      &mad_send_wr->send_wr,
> &addr);
> > +			trace_ib_mad_ib_send_mad(mad_send_wr, &addr);
> > +		}
> >  		ret = ib_post_send(mad_agent->qp, &mad_send_wr-
> >send_wr.wr,
> >  				   NULL);
> >  		list = &qp_info->send_queue.list;
> > @@ -2498,6 +2551,8 @@ static void ib_mad_send_done(struct ib_cq *cq,
> struct ib_wc *wc)
> >  	send_queue = mad_list->mad_queue;
> >  	qp_info = send_queue->qp_info;
> >
> > +	trace_ib_mad_send_done_handler(mad_send_wr, wc);
> > +
> >  retry:
> >  	ib_dma_unmap_single(mad_send_wr->send_buf.mad_agent-
> >device,
> >  			    mad_send_wr->header_mapping,
> > @@ -2529,6 +2584,14 @@ static void ib_mad_send_done(struct ib_cq
> *cq, struct ib_wc *wc)
> >  	ib_mad_complete_send_wr(mad_send_wr, &mad_send_wc);
> >
> >  	if (queued_send_wr) {
> > +		if (trace_ib_mad_send_done_resend_enabled()) {
> > +			struct rdma_mad_trace_addr addr;
> > +
> > +			trace_create_mad_addr(qp_info->port_priv->device,
> > +					      qp_info->port_priv->port_num,
> > +					      &mad_send_wr->send_wr,
> &addr);
> > +			trace_ib_mad_send_done_resend(queued_send_wr,
> &addr);
> > +		}
> >  		ret = ib_post_send(qp_info->qp, &queued_send_wr-
> >send_wr.wr,
> >  				   NULL);
> >  		if (ret) {
> > @@ -2576,6 +2639,14 @@ static bool ib_mad_send_error(struct
> ib_mad_port_private *port_priv,
> >  		if (mad_send_wr->retry) {
> >  			/* Repost send */
> >  			mad_send_wr->retry = 0;
> > +			if (trace_ib_mad_error_handler_enabled()) {
> > +				struct rdma_mad_trace_addr addr;
> > +
> > +				trace_create_mad_addr(qp_info->port_priv-
> >device,
> > +						      qp_info->port_priv-
> >port_num,
> > +						      &mad_send_wr-
> >send_wr, &addr);
> > +				trace_ib_mad_error_handler(mad_send_wr,
> &addr);
> > +			}
> >  			ret = ib_post_send(qp_info->qp, &mad_send_wr-
> >send_wr.wr,
> >  					   NULL);
> >  			if (!ret)
> > diff --git a/include/trace/events/ib_mad.h
> > b/include/trace/events/ib_mad.h new file mode 100644 index
> > 000000000000..8c08eaefbc08
> > --- /dev/null
> > +++ b/include/trace/events/ib_mad.h
> > @@ -0,0 +1,193 @@
> > +/*
> > + * Copyright (c) 2018 Intel Corporation.  All rights reserved.
> > + *
> > + * This software is available to you under a choice of one of two
> > + * licenses.  You may choose to be licensed under the terms of the
> > +GNU
> > + * General Public License (GPL) Version 2, available from the file
> > + * COPYING in the main directory of this source tree, or the
> > + * OpenIB.org BSD license below:
> 
> Please use:
> 
> // SPDX-License-Identifier: GPL-2.0 OR Linux-OpenIB
> 
> At the top of the file, and do not add other License text in the file.
> 
> 
> > + *
> > + *     Redistribution and use in source and binary forms, with or
> > + *     without modification, are permitted provided that the following
> > + *     conditions are met:
> > + *
> > + *      - Redistributions of source code must retain the above
> > + *        copyright notice, this list of conditions and the following
> > + *        disclaimer.
> > + *
> > + *      - Redistributions in binary form must reproduce the above
> > + *        copyright notice, this list of conditions and the following
> > + *        disclaimer in the documentation and/or other materials
> > + *        provided with the distribution.
> > + *
> > + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY
> KIND,
> > + * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE
> WARRANTIES OF
> > + * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
> > + * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
> > + HOLDERS
> > + * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
> AN
> > + * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF
> OR IN
> > + * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
> THE
> > + * SOFTWARE.
> > + *
> > + */
> > +
> > +#undef TRACE_SYSTEM
> > +#define TRACE_SYSTEM ib_mad
> > +
> > +#if !defined(_TRACE_IB_MAD_H) ||
> defined(TRACE_HEADER_MULTI_READ)
> > +#define _TRACE_IB_MAD_H
> > +
> > +#include <linux/tracepoint.h>
> > +#include <rdma/ib_mad.h>
> > +
> > +DECLARE_EVENT_CLASS(ib_mad_send_template,
> > +	TP_PROTO(struct ib_mad_send_wr_private *wr, struct
> rdma_mad_trace_addr *addr),
> > +	TP_ARGS(wr, addr),
> > +
> > +	TP_STRUCT__entry(
> > +		__array(char,           dev_name, IB_DEVICE_NAME_MAX)
> 
> IB_DEVICE_NAME_MAX is 64 bytes. That's quite a bit, and much bigger than
> what it would be normally. Using __string() which is dynamic is a better
> option.
> 
> > +		__field(u8,             port_num)
> > +		__field(u32,            qp_num)
> 
> Order of fields by size matters, because architectures will likely pad them
> wasting ring buffer space.
> 
> Group u8 by 4 or 8, and try to keep pointers and u64 on 8 byte alignments
> (assuming a 64 bit architecture.)
> 
> The current order will produce a lot of unnecessary padding by the compiler.
> 
> > +		__field(void *,         agent_priv)
> > +		__field(u64,            wrtid)
> > +		__field(int,            retries_left)
> > +		__field(int,            max_retries)
> > +		__field(int,            retry)
> > +		__field(unsigned long,  timeout)
> > +		__field(u32,            length)
> > +		__field(u8,             base_version)
> > +		__field(u8,             mgmt_class)
> > +		__field(u8,             class_version)
> > +		__field(u8,             method)
> > +		__field(u16,            status)
> > +		__field(u16,            class_specific)
> > +		__field(u64,            tid)
> > +		__field(u16,            attr_id)
> > +		__field(u32,            attr_mod)
> > +		__field(u32,            dlid)
> > +		__field(u8,             sl)
> > +		__field(u16,            pkey)
> > +		__field(u32,            rqpn)
> > +		__field(u32,            rqkey)
> > +	),
> > +
> > +	TP_fast_assign(
> > +		memcpy(__entry->dev_name, wr->mad_agent_priv-
> >agent.device->name,
> > +		       IB_DEVICE_NAME_MAX);
> > +		__entry->port_num = wr->mad_agent_priv-
> >agent.port_num;
> > +		__entry->qp_num = wr->mad_agent_priv->qp_info->qp-
> >qp_num;
> > +		__entry->agent_priv = wr->mad_agent_priv;
> > +		__entry->wrtid = wr->tid;
> > +		__entry->max_retries = wr->max_retries;
> > +		__entry->retries_left = wr->retries_left;
> > +		__entry->retry = wr->retry;
> > +		__entry->timeout = wr->timeout;
> > +		__entry->length = wr->send_buf.hdr_len +
> > +				  wr->send_buf.data_len;
> > +		__entry->base_version = ((struct ib_mad_hdr *)wr-
> >send_buf.mad)->base_version;
> > +		__entry->mgmt_class = ((struct ib_mad_hdr *)wr-
> >send_buf.mad)->mgmt_class;
> > +		__entry->class_version = ((struct ib_mad_hdr *)wr-
> >send_buf.mad)->class_version;
> > +		__entry->method = ((struct ib_mad_hdr *)wr-
> >send_buf.mad)->method;
> > +		__entry->status = ((struct ib_mad_hdr *)wr-
> >send_buf.mad)->status;
> > +		__entry->class_specific = ((struct ib_mad_hdr *)wr-
> >send_buf.mad)->class_specific;
> > +		__entry->tid = ((struct ib_mad_hdr *)wr->send_buf.mad)-
> >tid;
> > +		__entry->attr_id = ((struct ib_mad_hdr *)wr-
> >send_buf.mad)->attr_id;
> > +		__entry->attr_mod = ((struct ib_mad_hdr *)wr-
> >send_buf.mad)->attr_mod;
> > +		__entry->dlid = addr->dlid;
> > +		__entry->sl = addr->sl;
> > +		__entry->pkey = addr->pkey;
> > +		__entry->rqpn = addr->rqpn;
> > +		__entry->rqkey = addr->rqkey;
> > +	),
> > +
> > +	TP_printk("%s:%d QP%d agent %p: " \
> > +		  "wrtid 0x%llx; %d/%d retries(%d); timeout %lu length %d :
> hdr : " \
> > +		  "base_ver 0x%x class 0x%x class_ver 0x%x method 0x%x " \
> > +		  "status 0x%x class_specific 0x%x tid 0x%llx attr_id 0x%x
> attr_mod 0x%x " \
> > +		  " => dlid 0x%08x sl %d pkey 0x%x rpqn 0x%x rqpkey 0x%x",
> > +		__entry->dev_name, __entry->port_num, __entry-
> >qp_num,
> > +		__entry->agent_priv, be64_to_cpu(__entry->wrtid),
> > +		__entry->retries_left, __entry->max_retries,
> > +		__entry->retry, __entry->timeout, __entry->length,
> > +		__entry->base_version, __entry->mgmt_class, __entry-
> >class_version,
> > +		__entry->method, be16_to_cpu(__entry->status),
> > +		be16_to_cpu(__entry->class_specific),
> > +		be64_to_cpu(__entry->tid), be16_to_cpu(__entry->attr_id),
> > +		be32_to_cpu(__entry->attr_mod),
> > +		be32_to_cpu(__entry->dlid), __entry->sl, __entry->pkey,
> __entry->rqpn,
> > +		__entry->rqkey
> > +	)
> > +);
> > +
> > +DEFINE_EVENT(ib_mad_send_template, ib_mad_error_handler,
> > +	TP_PROTO(struct ib_mad_send_wr_private *wr, struct
> rdma_mad_trace_addr *addr),
> > +	TP_ARGS(wr, addr));
> > +DEFINE_EVENT(ib_mad_send_template, ib_mad_ib_send_mad,
> > +	TP_PROTO(struct ib_mad_send_wr_private *wr, struct
> rdma_mad_trace_addr *addr),
> > +	TP_ARGS(wr, addr));
> > +DEFINE_EVENT(ib_mad_send_template, ib_mad_send_done_resend,
> > +	TP_PROTO(struct ib_mad_send_wr_private *wr, struct
> rdma_mad_trace_addr *addr),
> > +	TP_ARGS(wr, addr));
> > +
> > +TRACE_EVENT(ib_mad_send_done_handler,
> > +	TP_PROTO(struct ib_mad_send_wr_private *wr, struct ib_wc *wc),
> > +	TP_ARGS(wr, wc),
> > +
> > +	TP_STRUCT__entry(
> > +		__array(char,           dev_name, IB_DEVICE_NAME_MAX)
> 
> Same  here, for __string() and order.
> 
> -- Steve
> 
> > +		__field(u8,             port_num)
> > +		__field(u32,            qp_num)
> > +		__field(void *,         agent_priv)
> > +		__field(u64,            wrtid)
> > +		__field(int,            retries_left)
> > +		__field(int,            max_retries)
> > +		__field(int,            retry)
> > +		__field(unsigned long,  timeout)
> > +		__field(u8,             base_version)
> > +		__field(u8,             mgmt_class)
> > +		__field(u8,             class_version)
> > +		__field(u8,             method)
> > +		__field(u16,            status)
> > +		__field(u16,            wc_status)
> > +		__field(u32,            length)
> > +	),
> > +
> > +	TP_fast_assign(
> > +		memcpy(__entry->dev_name, wr->mad_agent_priv-
> >agent.device->name,
> > +		       IB_DEVICE_NAME_MAX);
> > +		__entry->port_num = wr->mad_agent_priv-
> >agent.port_num;
> > +		__entry->qp_num = wr->mad_agent_priv->qp_info->qp-
> >qp_num;
> > +		__entry->agent_priv = wr->mad_agent_priv;
> > +		__entry->wrtid = wr->tid;
> > +		__entry->max_retries = wr->max_retries;
> > +		__entry->retries_left = wr->retries_left;
> > +		__entry->retry = wr->retry;
> > +		__entry->timeout = wr->timeout;
> > +		__entry->base_version = ((struct ib_mad_hdr *)wr-
> >send_buf.mad)->base_version;
> > +		__entry->mgmt_class = ((struct ib_mad_hdr *)wr-
> >send_buf.mad)->mgmt_class;
> > +		__entry->class_version = ((struct ib_mad_hdr *)wr-
> >send_buf.mad)->class_version;
> > +		__entry->method = ((struct ib_mad_hdr *)wr-
> >send_buf.mad)->method;
> > +		__entry->status = ((struct ib_mad_hdr *)wr-
> >send_buf.mad)->status;
> > +		__entry->wc_status = wc->status;
> > +		__entry->length = wc->byte_len;
> > +	),
> > +
> > +	TP_printk("%s:%d QP%d : SEND WC Status %d : agent %p: " \
> > +		  "wrtid 0x%llx %d/%d retries(%d) timeout %lu length %d: hdr
> : " \
> > +		  "base_ver 0x%x class 0x%x class_ver 0x%x method 0x%x " \
> > +		  "status 0x%x",
> > +		__entry->dev_name, __entry->port_num, __entry-
> >qp_num,
> > +		__entry->wc_status,
> > +		__entry->agent_priv, be64_to_cpu(__entry->wrtid),
> > +		__entry->retries_left, __entry->max_retries,
> > +		__entry->retry, __entry->timeout,
> > +		__entry->length,
> > +		__entry->base_version, __entry->mgmt_class, __entry-
> >class_version,
> > +		__entry->method, be16_to_cpu(__entry->status)
> > +	)
> > +);
> > +
> > +
> > +#endif /* _TRACE_IB_MAD_H */
> > +
> > +#include <trace/define_trace.h>




[Index of Archives]     [Linux USB Devel]     [Video for Linux]     [Linux Audio Users]     [Photo]     [Yosemite News]     [Yosemite Photos]     [Linux Kernel]     [Linux SCSI]     [XFree86]

  Powered by Linux