Minki/linux
1
0
Fork 1
mirror of https://github.com/torvalds/linux.git synced 2024-11-23 04:31:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

rxrpc: Note serial number being ACK'd in the congestion management trace

Browse Source 
Note the serial number of the packet being ACK'd in the congestion
management trace rather than the serial number of the ACK packet.  Whilst
the serial number of the ACK packet is useful for matching ACK packet in
the output of wireshark, the serial number that the ACK is in response to
is of more use in working out how different trace lines relate.

Signed-off-by: David Howells <dhowells@redhat.com>
This commit is contained in:
David Howells 2016-09-29 22:37:16 +01:00
parent b112a67081
commit ed1e8679d8
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
net/rxrpc/input.c
View File

@ -41,10 +41,10 @@ static void rxrpc_proto_abort(const char *why,
*/ */
static void rxrpc_congestion_management(struct rxrpc_call *call, static void rxrpc_congestion_management(struct rxrpc_call *call,
struct sk_buff *skb, struct sk_buff *skb,
struct rxrpc_ack_summary *summary) struct rxrpc_ack_summary *summary,
rxrpc_serial_t acked_serial)
{ {
enum rxrpc_congest_change change = rxrpc_cong_no_change; enum rxrpc_congest_change change = rxrpc_cong_no_change;
struct rxrpc_skb_priv *sp = rxrpc_skb(skb);
unsigned int cumulative_acks = call->cong_cumul_acks; unsigned int cumulative_acks = call->cong_cumul_acks;
unsigned int cwnd = call->cong_cwnd; unsigned int cwnd = call->cong_cwnd;
bool resend = false; bool resend = false;
@ -172,7 +172,7 @@ out_no_clear_ca:
cwnd = RXRPC_RXTX_BUFF_SIZE - 1; cwnd = RXRPC_RXTX_BUFF_SIZE - 1;
call->cong_cwnd = cwnd; call->cong_cwnd = cwnd;
call->cong_cumul_acks = cumulative_acks; call->cong_cumul_acks = cumulative_acks;
trace_rxrpc_congest(call, summary, sp->hdr.serial, change); trace_rxrpc_congest(call, summary, acked_serial, change);
if (resend && !test_and_set_bit(RXRPC_CALL_EV_RESEND, &call->events)) if (resend && !test_and_set_bit(RXRPC_CALL_EV_RESEND, &call->events))
rxrpc_queue_call(call); rxrpc_queue_call(call);
return; return;
@ -848,7 +848,7 @@ static void rxrpc_input_ack(struct rxrpc_call *call, struct sk_buff *skb,
false, true, false, true,
rxrpc_propose_ack_ping_for_lost_reply); rxrpc_propose_ack_ping_for_lost_reply);
return rxrpc_congestion_management(call, skb, &summary); return rxrpc_congestion_management(call, skb, &summary, acked_serial);
} }
/* /*