Lines Matching defs:tq

520 static unsigned int rxrpc_prepare_txqueue(struct rxrpc_txqueue *tq,
523 	if (!tq)
525 	if (tq->xmit_ts_base == KTIME_MIN) {
526 		tq->xmit_ts_base = req->now;
529 	return ktime_to_us(ktime_sub(req->now, tq->xmit_ts_base));
539 	struct rxrpc_txqueue *tq = req->tq;
546 	trace_rxrpc_tq(call, tq, seq, rxrpc_tq_transmit);
565 	xmit_ts = rxrpc_prepare_txqueue(tq, req);
566 	prefetch(tq->next);
570 		struct rxrpc_txbuf *txb = tq->bufs[seq & RXRPC_TXQ_MASK];
572 		_debug("prep[%u] tq=%x q=%x", i, tq->qbase, seq);
575 		if (__test_and_clear_bit(ix, &tq->segment_lost))
578 			__set_bit(ix, &tq->ever_retransmitted);
579 			__set_bit(ix, &tq->segment_retransmitted);
585 		tq->segment_xmit_ts[ix] = xmit_ts;
586 		tq->segment_serial[ix] = serial;
589 			__set_bit(ix, &tq->rtt_samples);
597 			tq = tq->next;
598 			trace_rxrpc_tq(call, tq, seq, rxrpc_tq_transmit_advance);
599 			xmit_ts = rxrpc_prepare_txqueue(tq, req);
644 	struct rxrpc_txqueue *tq = req->tq;
652 	_enter("%x,%x-%x", tq->qbase, seq, seq + req->n - 1);
665 	txb = tq->bufs[seq & RXRPC_TXQ_MASK];