X-Git-Url: https://git.whamcloud.com/?p=fs%2Flustre-release.git;a=blobdiff_plain;f=lnet%2Flnet%2Flib-msg.c;h=a6ffe8e72c1f03a5000de7e926c34352a35f4227;hp=42099ccf7c22007527c3ca7d8e10a37db24bf833;hb=76adbed805e71995d521d1a26e1e3d93f3dfd7b7;hpb=8db1193f8e59ffe56e0a824faf4319de705ed672

diff --git a/lnet/lnet/lib-msg.c b/lnet/lnet/lib-msg.c
index 42099cc..a6ffe8e 100644
--- a/lnet/lnet/lib-msg.c
+++ b/lnet/lnet/lib-msg.c
@@ -216,6 +216,10 @@ lnet_msg_decommit_tx(lnet_msg_t *msg, int status)
 	}
 
 	counters->send_count++;
+	if (msg->msg_txpeer)
+		atomic_inc(&msg->msg_txpeer->lpni_stats.send_count);
+	if (msg->msg_txni)
+		atomic_inc(&msg->msg_txni->ni_stats.send_count);
  out:
 	lnet_return_tx_credits_locked(msg);
 	msg->msg_tx_committed = 0;
@@ -267,6 +271,10 @@ lnet_msg_decommit_rx(lnet_msg_t *msg, int status)
 	}
 
 	counters->recv_count++;
+	if (msg->msg_rxpeer)
+		atomic_inc(&msg->msg_rxpeer->lpni_stats.recv_count);
+	if (msg->msg_rxni)
+		atomic_inc(&msg->msg_rxni->ni_stats.recv_count);
 	if (ev->type == LNET_EVENT_PUT || ev->type == LNET_EVENT_REPLY)
 		counters->recv_length += msg->msg_wanted;