Lines Matching defs:txb
72 struct rxrpc_txbuf *txb;
87 txb = list_first_entry(&call->tx_buffer, struct rxrpc_txbuf, call_link);
102 if (after(txb->seq, transmitted))
104 if (after(txb->seq, seq))
106 list_for_each_entry_from(txb, &call->tx_buffer, call_link) {
107 if (txb->seq == seq)
113 resend_at = ktime_add(txb->last_sent, rto);
114 if (after(txb->serial, call->acks_highest_serial)) {
121 rxrpc_see_txbuf(txb, rxrpc_txbuf_see_unacked);
123 trace_rxrpc_retransmit(call, txb->seq, txb->serial,
126 txb->flags |= RXRPC_TXBUF_RESENT;
127 rxrpc_transmit_one(call, txb);
131 if (list_is_last(&txb->call_link, &call->tx_buffer))
133 txb = list_next_entry(txb, call_link);
145 list_for_each_entry_from(txb, &call->tx_buffer, call_link) {
146 resend_at = ktime_add(txb->last_sent, rto);
148 if (before_eq(txb->seq, call->acks_prev_seq))
150 if (after(txb->seq, call->tx_transmitted))
154 before(txb->serial, ntohl(ack->serial)))
166 txb->flags |= RXRPC_TXBUF_RESENT;
167 rxrpc_transmit_one(call, txb);
251 struct rxrpc_txbuf *txb;
259 while ((txb = list_first_entry_or_null(&call->tx_sendmsg,
262 list_del(&txb->call_link);
265 call->tx_top = txb->seq;
266 list_add_tail(&txb->call_link, &call->tx_buffer);
268 if (txb->flags & RXRPC_LAST_PACKET)
271 rxrpc_transmit_one(call, txb);