Lines Matching defs:tq

207 				      struct rxrpc_txqueue *tq,
210 	ktime_t xmit_ts = ktime_add_us(tq->xmit_ts_base, tq->segment_xmit_ts[ix]);
215 	__clear_bit(ix, &tq->rtt_samples); /* Prevent repeat RTT sample */
224 	struct rxrpc_txqueue *tq = call->tx_queue;
231 	trace_rxrpc_tq(call, tq, seq, rxrpc_tq_rotate);
248 		call->tx_queue = tq->next;
249 		trace_rxrpc_tq(call, tq, seq, rxrpc_tq_rotate_and_free);
250 		kfree(tq);
251 		tq = call->tx_queue;
257 		_debug("tq=%x seq=%x i=%d f=%x", tq->qbase, seq, ix, tq->bufs[ix]->flags);
258 		if (tq->bufs[ix]->flags & RXRPC_LAST_PACKET) {
263 		if (summary->acked_serial == tq->segment_serial[ix] &&
264 		    test_bit(ix, &tq->rtt_samples))
265 			rxrpc_add_data_rtt_sample(call, summary, tq, ix);
267 		if (ix == tq->nr_reported_acks) {
269 			tq->nr_reported_acks++;
270 			rxrpc_input_rack_one(call, summary, tq, ix);
274 			__set_bit(ix, &tq->segment_acked);
275 			trace_rxrpc_rotate(call, tq, summary, seq, rxrpc_rotate_trace_hack);
276 		} else if (test_bit(ix, &tq->segment_acked)) {
279 			trace_rxrpc_rotate(call, tq, summary, seq, rxrpc_rotate_trace_sack);
283 			rxrpc_input_rack_one(call, summary, tq, ix);
287 			__set_bit(ix, &tq->segment_acked);
288 			trace_rxrpc_rotate(call, tq, summary, seq, rxrpc_rotate_trace_snak);
292 		if (__test_and_clear_bit(ix, &tq->segment_lost))
294 		if (__test_and_clear_bit(ix, &tq->segment_retransmitted))
296 		__clear_bit(ix, &tq->ever_retransmitted);
298 		rxrpc_put_txbuf(tq->bufs[ix], rxrpc_txbuf_put_rotated);
299 		tq->bufs[ix] = NULL;
311 			prefetch(tq->next);
312 			if (tq != call->tx_qtail) {
314 				call->tx_queue = tq->next;
315 				trace_rxrpc_tq(call, tq, seq, rxrpc_tq_rotate_and_free);
316 				kfree(tq);
317 				tq = call->tx_queue;
319 				trace_rxrpc_tq(call, tq, seq, rxrpc_tq_rotate_and_keep);
320 				tq = NULL;
331 		if (tq) {
332 			trace_rxrpc_tq(call, tq, seq, rxrpc_tq_rotate_and_free);
333 			kfree(tq);
872 				 struct rxrpc_txqueue *tq)
875 		if (summary->acked_serial == tq->segment_serial[ix])
876 			return rxrpc_add_data_rtt_sample(call, summary, tq, ix);
884 				    struct rxrpc_txqueue *tq,
894 	if (tq->nr_reported_acks > 0)
895 		old_reported = ~0UL >> (RXRPC_NR_TXQUEUE - tq->nr_reported_acks);
898 	       tq->qbase, tq->segment_acked, tq->nr_reported_acks,
901 	_debug("[%x]", tq->qbase);
902 	_debug("tq    %16lx %u", tq->segment_acked, tq->nr_reported_acks);
906 	flipped = (tq->segment_acked ^ extracted_acks) & old_reported;
908 		n_to_a = ~tq->segment_acked & flipped; /* Old NAK -> ACK */
909 		a_to_n =  tq->segment_acked & flipped; /* Old ACK -> NAK */
922 	new = nr_reported - tq->nr_reported_acks;
939 	tq->nr_reported_acks = nr_reported;
940 	tq->segment_acked = extracted_acks;
941 	trace_rxrpc_apply_acks(call, tq);
951 		rxrpc_input_soft_rtt(call, summary, tq);
955 		rxrpc_input_rack(call, summary, tq, new_acks);
958 	    rxrpc_seq_in_txq(tq, call->tlp_seq) &&
959 	    test_bit(call->tlp_seq - tq->qbase, &new_acks))
977 	struct rxrpc_txqueue *tq = call->tx_queue;
985 	_enter("%x,%x,%u", tq->qbase, seq, sp->ack.nr_acks);
987 	while (after(seq, tq->qbase + RXRPC_NR_TXQUEUE - 1))
988 		tq = tq->next;
1014 		rxrpc_input_soft_ack_tq(call, summary, tq, extracted, RXRPC_NR_TXQUEUE,
1018 		tq = tq->next;
1019 		prefetch(tq);
1027 		rxrpc_input_soft_ack_tq(call, summary, tq, extracted, nr_reported,