Lines Matching refs:req
61 struct rxrpc_send_data_req *req) in rxrpc_retransmit_data() argument
63 struct rxrpc_txqueue *tq = req->tq; in rxrpc_retransmit_data()
64 unsigned int ix = req->seq & RXRPC_TXQ_MASK; in rxrpc_retransmit_data()
67 _enter("%x,%x,%x,%x", tq->qbase, req->seq, ix, txb->debug_id); in rxrpc_retransmit_data()
69 req->retrans = true; in rxrpc_retransmit_data()
70 trace_rxrpc_retransmit(call, req, txb); in rxrpc_retransmit_data()
73 rxrpc_send_data_packet(call, req); in rxrpc_retransmit_data()
76 req->tq = NULL; in rxrpc_retransmit_data()
77 req->n = 0; in rxrpc_retransmit_data()
78 req->did_send = true; in rxrpc_retransmit_data()
79 req->now = ktime_get_real(); in rxrpc_retransmit_data()
88 struct rxrpc_send_data_req req = { in rxrpc_resend() local
117 req.tq = tq; in rxrpc_resend()
118 req.seq = tq->qbase + ix; in rxrpc_resend()
119 req.n = 1; in rxrpc_resend()
120 rxrpc_retransmit_data(call, &req); in rxrpc_resend()
124 rxrpc_get_rto_backoff(call, req.did_send); in rxrpc_resend()
133 struct rxrpc_send_data_req req = { in rxrpc_resend_tlp() local
142 req.tq = READ_ONCE(call->tx_qtail); in rxrpc_resend_tlp()
143 if (req.tq && in rxrpc_resend_tlp()
144 before(call->tx_transmitted, req.tq->qbase + RXRPC_NR_TXQUEUE)) { in rxrpc_resend_tlp()
145 rxrpc_retransmit_data(call, &req); in rxrpc_resend_tlp()
149 for (req.tq = call->tx_queue; req.tq; req.tq = req.tq->next) { in rxrpc_resend_tlp()
150 if (after_eq(call->tx_transmitted, req.tq->qbase) && in rxrpc_resend_tlp()
151 before(call->tx_transmitted, req.tq->qbase + RXRPC_NR_TXQUEUE)) { in rxrpc_resend_tlp()
152 rxrpc_retransmit_data(call, &req); in rxrpc_resend_tlp()
206 struct rxrpc_send_data_req req = { in rxrpc_transmit_fresh_data() local
239 if (!req.tq) in rxrpc_transmit_fresh_data()
240 req.tq = tq; in rxrpc_transmit_fresh_data()
242 req.n++; in rxrpc_transmit_fresh_data()
245 } while (req.n < limit && before(seq, send_top)); in rxrpc_transmit_fresh_data()
254 space -= req.n; in rxrpc_transmit_fresh_data()
255 rxrpc_send_data_packet(call, &req); in rxrpc_transmit_fresh_data()