Commit b0154246 authored by David Howells's avatar David Howells
Browse files

rxrpc: Add stats procfile and DATA packet stats 



Add a procfile, /proc/net/rxrpc/stats, to display some statistics about
what rxrpc has been doing.  Writing a blank line to the stats file will
clear the increment-only counters.  Allocated resource counters don't get
cleared.

Add some counters to count various things about DATA packets, including the
number created, transmitted and retransmitted and the number received, the
number of ACK-requests markings and the number of jumbo packets received.

Signed-off-by: default avatarDavid Howells <dhowells@redhat.com>
cc: Marc Dionne <marc.dionne@auristor.com>
cc: linux-afs@lists.infradead.org
parent 589a0c1e

net/rxrpc/ar-internal.h

+17 −0
Original line number Diff line number Diff line
@@ -93,6 +93,14 @@ struct rxrpc_net { 
	struct list_head	peer_keepalive_new;

	struct timer_list	peer_keepalive_timer;

	struct work_struct	peer_keepalive_work;



	atomic_t		stat_tx_data;

	atomic_t		stat_tx_data_retrans;

	atomic_t		stat_tx_data_send;

	atomic_t		stat_tx_data_send_frag;

	atomic_t		stat_rx_data;

	atomic_t		stat_rx_data_reqack;

	atomic_t		stat_rx_data_jumbo;

};



/*
@@ -1092,6 +1100,15 @@ void rxrpc_get_skb(struct sk_buff *, enum rxrpc_skb_trace); 
void rxrpc_free_skb(struct sk_buff *, enum rxrpc_skb_trace);

void rxrpc_purge_queue(struct sk_buff_head *);



/*

 * stats.c

 */

int rxrpc_stats_show(struct seq_file *seq, void *v);

int rxrpc_stats_clear(struct file *file, char *buf, size_t size);



#define rxrpc_inc_stat(rxnet, s) atomic_inc(&(rxnet)->s)

#define rxrpc_dec_stat(rxnet, s) atomic_dec(&(rxnet)->s)



/*

 * sysctl.c

 */

net/rxrpc/call_event.c

+1 −0
Original line number Diff line number Diff line
@@ -261,6 +261,7 @@ static void rxrpc_resend(struct rxrpc_call *call, unsigned long now_j) 
		rxrpc_get_skb(skb, rxrpc_skb_got);

		spin_unlock_bh(&call->lock);



		rxrpc_inc_stat(call->rxnet, stat_tx_data_retrans);

		if (rxrpc_send_data_packet(call, skb, true) < 0) {

			rxrpc_free_skb(skb, rxrpc_skb_freed);

			return;

net/rxrpc/input.c

+6 −0
Original line number Diff line number Diff line
@@ -443,6 +443,12 @@ static void rxrpc_input_data(struct rxrpc_call *call, struct sk_buff *skb) 
		}

	}



	rxrpc_inc_stat(call->rxnet, stat_rx_data);

	if (sp->hdr.flags & RXRPC_REQUEST_ACK)

		rxrpc_inc_stat(call->rxnet, stat_rx_data_reqack);

	if (sp->hdr.flags & RXRPC_JUMBO_PACKET)

		rxrpc_inc_stat(call->rxnet, stat_rx_data_jumbo);



	spin_lock(&call->input_lock);



	/* Received data implicitly ACKs all of the request packets we sent

net/rxrpc/net_ns.c

+2 −0
Original line number Diff line number Diff line
@@ -101,6 +101,8 @@ static __net_init int rxrpc_init_net(struct net *net) 
	proc_create_net("locals", 0444, rxnet->proc_net,

			&rxrpc_local_seq_ops,

			sizeof(struct seq_net_private));

	proc_create_net_single_write("stats", S_IFREG | 0644, rxnet->proc_net,

				     rxrpc_stats_show, rxrpc_stats_clear, NULL);

	return 0;



err_proc:

net/rxrpc/output.c

+2 −0
Original line number Diff line number Diff line
@@ -462,6 +462,7 @@ int rxrpc_send_data_packet(struct rxrpc_call *call, struct sk_buff *skb, 
	 *   - in which case, we'll have processed the ICMP error

	 *     message and update the peer record

	 */

	rxrpc_inc_stat(call->rxnet, stat_tx_data_send);

	ret = kernel_sendmsg(conn->params.local->socket, &msg, iov, 2, len);

	conn->params.peer->last_tx_at = ktime_get_seconds();
@@ -537,6 +538,7 @@ int rxrpc_send_data_packet(struct rxrpc_call *call, struct sk_buff *skb, 
	case AF_INET:

		ip_sock_set_mtu_discover(conn->params.local->socket->sk,

				IP_PMTUDISC_DONT);

		rxrpc_inc_stat(call->rxnet, stat_tx_data_send_frag);

		ret = kernel_sendmsg(conn->params.local->socket, &msg,

				     iov, 2, len);

		conn->params.peer->last_tx_at = ktime_get_seconds();