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