mirror of
https://github.com/torvalds/linux.git
synced 2026-07-27 09:36:22 +02:00
RDMA/rxe: add SENT/RCVD bytes
There is a lack of sent/received counter in bytes. Signed-off-by: zhenwei pi <zhenwei.pi@linux.dev> Link: https://patch.msgid.link/20260414062948.671658-3-zhenwei.pi@linux.dev Signed-off-by: Leon Romanovsky <leon@kernel.org>
This commit is contained in:
parent
dd67760975
commit
ed7e5e4a93
|
|
@ -22,6 +22,8 @@ static const struct rdma_stat_desc rxe_counter_descs[] = {
|
|||
[RXE_CNT_LINK_DOWNED].name = "link_downed",
|
||||
[RXE_CNT_RDMA_SEND].name = "rdma_sends",
|
||||
[RXE_CNT_RDMA_RECV].name = "rdma_recvs",
|
||||
[RXE_CNT_SENT_BYTES].name = "sent_bytes",
|
||||
[RXE_CNT_RCVD_BYTES].name = "rcvd_bytes",
|
||||
};
|
||||
|
||||
int rxe_ib_get_hw_stats(struct ib_device *ibdev,
|
||||
|
|
|
|||
|
|
@ -26,6 +26,8 @@ enum rxe_counters {
|
|||
RXE_CNT_LINK_DOWNED,
|
||||
RXE_CNT_RDMA_SEND,
|
||||
RXE_CNT_RDMA_RECV,
|
||||
RXE_CNT_SENT_BYTES,
|
||||
RXE_CNT_RCVD_BYTES,
|
||||
RXE_NUM_OF_COUNTERS
|
||||
};
|
||||
|
||||
|
|
|
|||
|
|
@ -501,6 +501,7 @@ int rxe_xmit_packet(struct rxe_qp *qp, struct rxe_pkt_info *pkt,
|
|||
int err;
|
||||
int is_request = pkt->mask & RXE_REQ_MASK;
|
||||
struct rxe_dev *rxe = to_rdev(qp->ibqp.device);
|
||||
unsigned int skblen = skb->len;
|
||||
unsigned long flags;
|
||||
|
||||
spin_lock_irqsave(&qp->state_lock, flags);
|
||||
|
|
@ -524,6 +525,7 @@ int rxe_xmit_packet(struct rxe_qp *qp, struct rxe_pkt_info *pkt,
|
|||
}
|
||||
|
||||
rxe_counter_inc(rxe, RXE_CNT_SENT_PKTS);
|
||||
rxe_counter_add(rxe, RXE_CNT_SENT_BYTES, skblen);
|
||||
goto done;
|
||||
|
||||
drop:
|
||||
|
|
|
|||
|
|
@ -318,6 +318,7 @@ void rxe_rcv(struct sk_buff *skb)
|
|||
int err;
|
||||
struct rxe_pkt_info *pkt = SKB_TO_PKT(skb);
|
||||
struct rxe_dev *rxe = pkt->rxe;
|
||||
unsigned int skblen = skb->len - skb_network_offset(skb);
|
||||
|
||||
if (unlikely(skb->len < RXE_BTH_BYTES))
|
||||
goto drop;
|
||||
|
|
@ -342,6 +343,7 @@ void rxe_rcv(struct sk_buff *skb)
|
|||
if (unlikely(err))
|
||||
goto drop;
|
||||
|
||||
rxe_counter_add(rxe, RXE_CNT_RCVD_BYTES, skblen);
|
||||
rxe_counter_inc(rxe, RXE_CNT_RCVD_PKTS);
|
||||
|
||||
if (unlikely(bth_qpn(pkt) == IB_MULTICAST_QPN))
|
||||
|
|
|
|||
|
|
@ -455,6 +455,12 @@ static inline void rxe_counter_inc(struct rxe_dev *rxe, enum rxe_counters index)
|
|||
atomic64_inc(&rxe->stats_counters[index]);
|
||||
}
|
||||
|
||||
static inline void rxe_counter_add(struct rxe_dev *rxe, enum rxe_counters index,
|
||||
s64 val)
|
||||
{
|
||||
atomic64_add(val, &rxe->stats_counters[index]);
|
||||
}
|
||||
|
||||
static inline struct rxe_dev *to_rdev(struct ib_device *dev)
|
||||
{
|
||||
return dev ? container_of(dev, struct rxe_dev, ib_dev) : NULL;
|
||||
|
|
|
|||
Loading…
Reference in New Issue
Block a user