Searched refs:rxrpc_seq_t (Results 1 – 12 of 12) sorted by relevance
| /net/rxrpc/ |
| A D | ar-internal.h | 220 rxrpc_seq_t first_ack; /* First packet in acks table */
221 rxrpc_seq_t prev_ack; /* Highest seq seen */
759 rxrpc_seq_t tx_qbase; /* First slot in tx_queue */
760 rxrpc_seq_t tx_bottom; /* First packet in buffer */
762 rxrpc_seq_t tx_top; /* Highest Tx slot allocated. */
805 rxrpc_seq_t rack_end_seq; /* Highest sequence seen */
812 rxrpc_seq_t tlp_seq; /* Sequence of TLP probe */
819 rxrpc_seq_t ackr_window; /* Base of SACK window */
820 rxrpc_seq_t ackr_wtop; /* Base of SACK window */
953 rxrpc_seq_t qbase;
[all …]
|
| A D | input_rack.c | 12 static bool rxrpc_rack_sent_after(ktime_t t1, rxrpc_seq_t seq1, in rxrpc_rack_sent_after()
13 ktime_t t2, rxrpc_seq_t seq2) in rxrpc_rack_sent_after()
67 rxrpc_seq_t seq = tq->qbase + ix; in rxrpc_rack_update()
108 rxrpc_seq_t seq = tq->qbase + ix; in rxrpc_rack_detect_reordering()
159 rxrpc_seq_t snd_una = call->acks_lowest_nak; /* Lowest unack'd seq */ in rxrpc_rack_update_reo_wnd()
160 rxrpc_seq_t snd_nxt = call->tx_transmitted + 1; /* Next seq to be sent */ in rxrpc_rack_update_reo_wnd()
219 rxrpc_seq_t seq = tq->qbase + ix; in rxrpc_rack_detect_loss()
263 rxrpc_seq_t snd_una = call->acks_lowest_nak; /* Lowest unack'd seq */ in rxrpc_rack_mark_losses_on_rto()
273 rxrpc_seq_t seq = tq->qbase + ix; in rxrpc_rack_mark_losses_on_rto()
|
| A D | input.c | 224 rxrpc_seq_t seq = call->tx_bottom + 1; in rxrpc_rotate_tx_window()
388 rxrpc_seq_t top = READ_ONCE(call->tx_top); in rxrpc_receiving_reply()
435 rxrpc_seq_t window, rxrpc_seq_t wtop) in rxrpc_input_update_ack_window()
445 rxrpc_seq_t window, rxrpc_seq_t wtop, in rxrpc_input_queue_data()
476 rxrpc_seq_t window = call->ackr_window; in rxrpc_input_data_one()
477 rxrpc_seq_t wtop = call->ackr_wtop; in rxrpc_input_data_one()
479 rxrpc_seq_t seq = sp->hdr.seq; in rxrpc_input_data_one()
686 rxrpc_seq_t seq0 = sp->hdr.seq; in rxrpc_input_data()
874 rxrpc_seq_t seq, in rxrpc_input_soft_ack_tq()
875 rxrpc_seq_t *lowest_nak) in rxrpc_input_soft_ack_tq()
[all …]
|
| A D | sendmsg.c | 95 static bool rxrpc_check_tx_space(struct rxrpc_call *call, rxrpc_seq_t *_tx_win) in rxrpc_check_tx_space()
97 rxrpc_seq_t tx_bottom = READ_ONCE(call->tx_bottom); in rxrpc_check_tx_space()
134 rxrpc_seq_t tx_start, tx_win; in rxrpc_wait_for_tx_window_waitall()
246 rxrpc_seq_t seq = txb->seq; in rxrpc_queue_packet()
|
| A D | call_state.c | 43 bool rxrpc_abort_call(struct rxrpc_call *call, rxrpc_seq_t seq, in rxrpc_abort_call()
|
| A D | protocol.h | 11 typedef u32 rxrpc_seq_t; /* Rx message sequence number */ typedef
|
| A D | txbuf.c | 83 rxrpc_seq_t seq; in rxrpc_put_txbuf()
|
| A D | recvmsg.c | 115 rxrpc_seq_t old_consumed = call->rx_consumed, tseq; in rxrpc_rotate_rx_window()
250 rxrpc_seq_t seq = 0; in rxrpc_recvmsg_data()
|
| A D | output.c | 160 rxrpc_seq_t window, wtop; in rxrpc_fill_out_ack()
542 rxrpc_seq_t seq = req->seq; in rxrpc_prepare_data_packet()
647 rxrpc_seq_t seq = req->seq; in rxrpc_send_data_packet()
|
| A D | rxkad.c | 425 rxrpc_seq_t seq, in rxkad_verify_packet_1()
488 rxrpc_seq_t seq, in rxkad_verify_packet_2()
577 rxrpc_seq_t seq = sp->hdr.seq; in rxkad_verify_packet()
|
| A D | call_event.c | 214 rxrpc_seq_t send_top, seq; in rxrpc_transmit_fresh_data()
|
| A D | proc.c | 55 rxrpc_seq_t tx_bottom; in rxrpc_call_seq_show()
|
Completed in 28 milliseconds