Lines Matching refs:txb
70 struct rxrpc_txbuf *txb;
77 txb = rxrpc_alloc_txbuf(call, RXRPC_PACKET_TYPE_ACK,
79 if (!txb) {
84 txb->ack_why = why;
85 txb->wire.seq = 0;
86 txb->wire.type = RXRPC_PACKET_TYPE_ACK;
87 txb->wire.flags |= RXRPC_SLOW_START_OK;
88 txb->ack.bufferSpace = 0;
89 txb->ack.maxSkew = 0;
90 txb->ack.firstPacket = 0;
91 txb->ack.previousPacket = 0;
92 txb->ack.serial = htonl(serial);
93 txb->ack.reason = ack_reason;
94 txb->ack.nAcks = 0;
97 rxrpc_send_ack_packet(call, txb);
98 rxrpc_put_txbuf(txb, rxrpc_txbuf_put_ack_tx);
116 struct rxrpc_txbuf *txb;
137 txb = list_first_entry(&call->tx_buffer, struct rxrpc_txbuf, call_link);
152 if (after(txb->seq, transmitted))
154 if (after(txb->seq, seq))
156 list_for_each_entry_from(txb, &call->tx_buffer, call_link) {
157 if (txb->seq == seq)
163 if (after(ntohl(txb->wire.serial), call->acks_highest_serial))
166 rxrpc_see_txbuf(txb, rxrpc_txbuf_see_unacked);
168 if (list_empty(&txb->tx_link)) {
169 list_add_tail(&txb->tx_link, &retrans_queue);
170 set_bit(RXRPC_TXBUF_RESENT, &txb->flags);
173 trace_rxrpc_retransmit(call, txb->seq,
174 ktime_to_ns(ktime_sub(txb->last_sent,
177 if (list_is_last(&txb->call_link, &call->tx_buffer))
179 txb = list_next_entry(txb, call_link);
193 list_for_each_entry_from(txb, &call->tx_buffer, call_link) {
194 if (before_eq(txb->seq, READ_ONCE(call->acks_prev_seq)))
196 if (after(txb->seq, READ_ONCE(call->tx_transmitted)))
200 before(ntohl(txb->wire.serial), ntohl(ack->serial)))
203 if (ktime_after(txb->last_sent, max_age)) {
204 if (ktime_before(txb->last_sent, oldest))
205 oldest = txb->last_sent;
211 if (list_empty(&txb->tx_link)) {
212 list_add_tail(&txb->tx_link, &retrans_queue);
213 set_bit(RXRPC_TXBUF_RESENT, &txb->flags);
244 while ((txb = list_first_entry_or_null(&retrans_queue,
246 list_del_init(&txb->tx_link);
247 rxrpc_transmit_one(call, txb);
306 struct rxrpc_txbuf *txb;
314 while ((txb = list_first_entry_or_null(&call->tx_sendmsg,
317 list_del(&txb->call_link);
320 call->tx_top = txb->seq;
321 list_add_tail(&txb->call_link, &call->tx_buffer);
323 if (txb->wire.flags & RXRPC_LAST_PACKET)
326 rxrpc_transmit_one(call, txb);