net/rxrpc/input_rack.c

24 				 struct rxrpc_txqueue *tq, unsigned int ix)
26 	if (__test_and_set_bit(ix, &tq->segment_lost)) {
27 		if (__test_and_clear_bit(ix, &tq->segment_retransmitted))
32 	tq->segment_xmit_ts[ix] = UINT_MAX;
38 static ktime_t rxrpc_get_xmit_ts(const struct rxrpc_txqueue *tq, unsigned int ix)
40 	if (tq->segment_xmit_ts[ix] == UINT_MAX)
42 	return ktime_add_us(tq->xmit_ts_base, tq->segment_xmit_ts[ix]);
65 			      unsigned int ix)
67 	rxrpc_seq_t seq = tq->qbase + ix;
68 	ktime_t xmit_ts = rxrpc_get_xmit_ts(tq, ix);
71 	if (__test_and_clear_bit(ix, &tq->segment_lost))
74 	if (test_bit(ix, &tq->segment_retransmitted)) {
76 		if (before(call->acks_highest_serial, tq->segment_serial[ix]))
106 					 unsigned int ix)
108 	rxrpc_seq_t seq = tq->qbase + ix;
117 		 test_bit(ix, &tq->segment_retransmitted))
124 			  unsigned int ix)
126 	rxrpc_rack_update(call, summary, tq, ix);
127 	rxrpc_rack_detect_reordering(call, summary, tq, ix);
136 		unsigned int ix = __ffs(new_acks);
138 		__clear_bit(ix, &new_acks);
139 		rxrpc_input_rack_one(call, summary, tq, ix);
218 			unsigned int ix = __ffs(nacks);
219 			rxrpc_seq_t seq = tq->qbase + ix;
221 			ktime_t xmit_ts = rxrpc_get_xmit_ts(tq, ix);
223 			__clear_bit(ix, &nacks);
229 					rxrpc_rack_mark_lost(call, tq, ix);
272 			unsigned int ix = __ffs(unacked);
273 			rxrpc_seq_t seq = tq->qbase + ix;
274 			ktime_t xmit_ts = rxrpc_get_xmit_ts(tq, ix);
278 			__clear_bit(ix, &unacked);
282 				rxrpc_rack_mark_lost(call, tq, ix);