Searched refs:send_top (Results 1 – 6 of 6) sorted by relevance
| /net/rxrpc/ |
| A D | call_event.c | 200 if (call->send_top == call->tx_top) in rxrpc_transmit_fresh_data()
214 rxrpc_seq_t send_top, seq; in rxrpc_transmit_fresh_data() local
220 send_top = smp_load_acquire(&call->send_top); in rxrpc_transmit_fresh_data()
221 if (call->tx_top == send_top) in rxrpc_transmit_fresh_data()
224 trace_rxrpc_transmit(call, send_top, space); in rxrpc_transmit_fresh_data()
245 } while (req.n < limit && before(seq, send_top)); in rxrpc_transmit_fresh_data()
264 if (call->tx_bottom == READ_ONCE(call->send_top)) in rxrpc_transmit_some_data()
273 if (call->tx_bottom == READ_ONCE(call->send_top)) { in rxrpc_transmit_some_data()
|
| A D | sendmsg.c | 101 return call->send_top - tx_bottom < 256; in rxrpc_check_tx_space()
251 ASSERTCMP(txb->seq, ==, call->send_top + 1); in rxrpc_queue_packet()
264 poke = (READ_ONCE(call->tx_bottom) == call->send_top); in rxrpc_queue_packet()
267 smp_store_release(&call->send_top, seq); in rxrpc_queue_packet()
294 tq->qbase = call->send_top + 1; in rxrpc_alloc_txqueue()
311 trace_rxrpc_tq(call, tq, call->send_top, rxrpc_tq_alloc); in rxrpc_alloc_txqueue()
397 if (!call->send_queue || !((call->send_top + 1) & RXRPC_TXQ_MASK)) { in rxrpc_send_data()
|
| A D | txbuf.c | 53 txb->seq = call->send_top + 1; in rxrpc_alloc_data_txbuf()
|
| A D | input_rack.c | 328 if (after(call->send_top, call->tx_transmitted) && in rxrpc_tlp_send_probe()
|
| A D | ar-internal.h | 753 rxrpc_seq_t send_top; /* Highest Tx slot filled by sendmsg. */ member
|
| A D | output.c | 480 else if (!last && !after(READ_ONCE(call->send_top), txb->seq)) in rxrpc_prepare_data_subpacket()
|
Completed in 16 milliseconds