net/rxrpc/input.c

23 					struct rxrpc_ack_summary *summary,
31 	summary->flight_size =
32 		(call->tx_top - call->acks_hard_ack) - summary->nr_acks;
35 		summary->retrans_timeo = true;
37 					    summary->flight_size / 2, 2);
47 	cumulative_acks += summary->nr_new_acks;
51 	summary->cwnd = call->cong_cwnd;
52 	summary->ssthresh = call->cong_ssthresh;
53 	summary->cumulative_acks = cumulative_acks;
54 	summary->dup_acks = call->cong_dup_acks;
58 		if (summary->saw_nacks)
60 		if (summary->cumulative_acks > 0)
69 		if (summary->saw_nacks)
88 		if (!summary->saw_nacks)
91 		if (summary->new_low_nack) {
106 					    summary->flight_size / 2, 2);
114 		if (!summary->new_low_nack) {
115 			if (summary->nr_new_acks == 0)
126 			if (!summary->saw_nacks)
152 	summary->mode = call->cong_mode;
153 	trace_rxrpc_congest(call, summary, acked_serial, change);
169 	    summary->nr_acks != call->tx_top - call->acks_hard_ack) {
207 				   struct rxrpc_ack_summary *summary)
231 		summary->new_low_nack = true;
293 	struct rxrpc_ack_summary summary = { 0 };
302 		if (!rxrpc_rotate_tx_window(call, top, &summary)) {
709 					      struct rxrpc_ack_summary *summary,
719 		summary->nr_new_acks += sp->ack.nr_nacks;
720 		summary->nr_new_acks += seq - (old_seq + sp->ack.nr_acks);
721 		summary->nr_retained_nacks = 0;
723 		summary->nr_retained_nacks = sp->ack.nr_nacks;
734 		summary->nr_new_acks += new_acks;
735 		summary->nr_retained_nacks = retained_nacks;
751 				  struct rxrpc_ack_summary *summary,
763 			summary->nr_acks++;
765 				summary->nr_new_acks++;
767 			summary->saw_nacks = true;
772 				summary->nr_new_nacks++;
784 		summary->new_low_nack = true;
792 	if (old_nacks < summary->nr_retained_nacks)
793 		summary->nr_new_acks += summary->nr_retained_nacks - old_nacks;
794 	summary->nr_retained_nacks = old_nacks;
833 	struct rxrpc_ack_summary summary = { 0 };
850 	summary.ack_reason = (sp->ack.reason < RXRPC_ACK__INVALID ?
855 			   summary.ack_reason, nr_acks);
856 	rxrpc_inc_stat(call->rxnet, stat_rx_acks[summary.ack_reason]);
859 		switch (summary.ack_reason) {
879 	if (unlikely(summary.ack_reason == RXRPC_ACK_EXCEEDS_WINDOW) &&
892 	if (unlikely(summary.ack_reason == RXRPC_ACK_OUT_OF_SEQUENCE) &&
920 		since = rxrpc_input_check_prev_ack(call, &summary, first_soft_ack);
924 		summary.nr_new_acks = first_soft_ack - call->acks_first_seq;
933 	switch (summary.ack_reason) {
967 		if (rxrpc_rotate_tx_window(call, hard_ack, &summary)) {
976 		rxrpc_input_soft_acks(call, &summary, skb, first_soft_ack, since);
982 	    summary.nr_acks == call->tx_top - hard_ack &&
987 	rxrpc_congestion_management(call, skb, &summary, acked_serial);
990 	if (summary.ack_reason == RXRPC_ACK_PING)
1003 	struct rxrpc_ack_summary summary = { 0 };
1005 	if (rxrpc_rotate_tx_window(call, call->tx_top, &summary))