Home
last modified time | relevance | path

Searched refs:rxrpc_seq_t (Results 1 - 23 of 23) sorted by relevance

/kernel/linux/linux-6.6/include/trace/events/
H A Drxrpc.h782 u32 cid, u32 call_id, rxrpc_seq_t seq, int abort_code, int error),
791 __field(rxrpc_seq_t, seq)
847 __field(rxrpc_seq_t, acks_hard_ack)
848 __field(rxrpc_seq_t, tx_bottom)
849 __field(rxrpc_seq_t, tx_top)
850 __field(rxrpc_seq_t, tx_prepared)
876 TP_PROTO(unsigned int call, rxrpc_seq_t seq,
883 __field(rxrpc_seq_t, seq)
905 rxrpc_seq_t first, rxrpc_seq_t pre
[all...]
/kernel/linux/linux-5.10/include/trace/events/
H A Drxrpc.h704 rxrpc_seq_t seq, int abort_code, int error),
713 __field(rxrpc_seq_t, seq )
768 __field(rxrpc_seq_t, tx_hard_ack )
769 __field(rxrpc_seq_t, tx_top )
790 TP_PROTO(unsigned int call, rxrpc_seq_t seq,
797 __field(rxrpc_seq_t, seq )
822 rxrpc_seq_t first, rxrpc_seq_t prev, u8 reason, u8 n_acks),
830 __field(rxrpc_seq_t, first )
831 __field(rxrpc_seq_t, pre
[all...]
/kernel/linux/linux-6.6/net/rxrpc/
H A Dinput.c12 static void rxrpc_proto_abort(struct rxrpc_call *call, rxrpc_seq_t seq, in rxrpc_proto_abort()
206 static bool rxrpc_rotate_tx_window(struct rxrpc_call *call, rxrpc_seq_t to, in rxrpc_rotate_tx_window()
292 rxrpc_seq_t top = READ_ONCE(call->tx_top); in rxrpc_receiving_reply()
318 rxrpc_seq_t whigh = READ_ONCE(call->rx_highest_seq); in rxrpc_end_rx_phase()
342 rxrpc_seq_t window, rxrpc_seq_t wtop) in rxrpc_input_update_ack_window()
352 rxrpc_seq_t window, rxrpc_seq_t wtop, in rxrpc_input_queue_data()
375 rxrpc_seq_t window = call->ackr_window; in rxrpc_input_data_one()
376 rxrpc_seq_t wto in rxrpc_input_data_one()
[all...]
H A Dar-internal.h209 rxrpc_seq_t first_ack; /* First packet in acks table */
649 rxrpc_seq_t send_abort_seq; /* DATA packet that incurred the abort (or 0) */
668 rxrpc_seq_t tx_bottom; /* First packet in buffer */
669 rxrpc_seq_t tx_transmitted; /* Highest packet transmitted */
670 rxrpc_seq_t tx_prepared; /* Highest Tx slot prepared. */
671 rxrpc_seq_t tx_top; /* Highest Tx slot allocated. */
681 rxrpc_seq_t rx_highest_seq; /* Higest sequence number received */
682 rxrpc_seq_t rx_consumed; /* Highest packet consumed */
704 rxrpc_seq_t ackr_window; /* Base of SACK window */
705 rxrpc_seq_t ackr_wto
[all...]
H A Dtxbuf.c87 rxrpc_seq_t seq; in rxrpc_put_txbuf()
108 rxrpc_seq_t hard_ack = smp_load_acquire(&call->acks_hard_ack); in rxrpc_shrink_call_tx_buffer()
H A Dcall_event.c118 rxrpc_seq_t transmitted = READ_ONCE(call->tx_transmitted); in rxrpc_resend()
147 rxrpc_seq_t seq; in rxrpc_resend()
293 rxrpc_seq_t window = call->acks_hard_ack, wtop = window + winsize; in rxrpc_tx_window_has_space()
294 rxrpc_seq_t tx_top = call->tx_top; in rxrpc_tx_window_has_space()
H A Dcall_state.c43 bool rxrpc_abort_call(struct rxrpc_call *call, rxrpc_seq_t seq, in rxrpc_abort_call()
H A Dprotocol.h11 typedef u32 rxrpc_seq_t; /* Rx message sequence number */ typedef
H A Dsendmsg.c94 static bool rxrpc_check_tx_space(struct rxrpc_call *call, rxrpc_seq_t *_tx_win) in rxrpc_check_tx_space()
131 rxrpc_seq_t tx_start, tx_win; in rxrpc_wait_for_tx_window_waitall()
242 rxrpc_seq_t seq = txb->seq; in rxrpc_queue_packet()
H A Drecvmsg.c111 rxrpc_seq_t old_consumed = call->rx_consumed, tseq; in rxrpc_rotate_rx_window()
169 rxrpc_seq_t seq = 0; in rxrpc_recvmsg_data()
H A Drxkad.c407 rxrpc_seq_t seq, in rxkad_verify_packet_1()
470 rxrpc_seq_t seq, in rxkad_verify_packet_2()
559 rxrpc_seq_t seq = sp->hdr.seq; in rxkad_verify_packet()
H A Dproc.c56 rxrpc_seq_t acks_hard_ack; in rxrpc_call_seq_show()
H A Doutput.c88 rxrpc_seq_t window, wtop; in rxrpc_fill_out_ack()
/kernel/linux/linux-5.10/net/rxrpc/
H A Dar-internal.h225 unsigned int, unsigned int, rxrpc_seq_t, u16);
623 rxrpc_seq_t tx_hard_ack; /* Dead slot in buffer; the first transmitted but
626 rxrpc_seq_t tx_top; /* Highest Tx slot allocated. */
642 rxrpc_seq_t rx_hard_ack; /* Dead slot in buffer; the first received but not
645 rxrpc_seq_t rx_top; /* Highest Rx slot allocated. */
646 rxrpc_seq_t rx_expect_next; /* Expected next packet sequence number */
658 rxrpc_seq_t ackr_highest_seq; /* Higest sequence number received */
672 rxrpc_seq_t acks_first_seq; /* first sequence number received */
673 rxrpc_seq_t acks_prev_seq; /* Highest previousPacket received */
674 rxrpc_seq_t acks_lowest_na
[all...]
H A Dinput.c27 struct rxrpc_call *call, rxrpc_seq_t seq) in rxrpc_proto_abort()
198 static bool rxrpc_rotate_tx_window(struct rxrpc_call *call, rxrpc_seq_t to, in rxrpc_rotate_tx_window()
307 rxrpc_seq_t top = READ_ONCE(call->tx_top); in rxrpc_receiving_reply()
390 static void rxrpc_input_dup_data(struct rxrpc_call *call, rxrpc_seq_t seq, in rxrpc_input_dup_data()
417 rxrpc_seq_t seq0 = sp->hdr.seq, hard_ack; in rxrpc_input_data()
469 rxrpc_seq_t seq = seq0 + j; in rxrpc_input_data()
682 rxrpc_seq_t top, bottom, seq; in rxrpc_input_check_for_lost_ack()
776 rxrpc_seq_t seq, int nr_acks, in rxrpc_input_soft_acks()
822 rxrpc_seq_t first_pkt, rxrpc_seq_t prev_pk in rxrpc_is_ack_valid()
[all...]
H A Drecvmsg.c121 rxrpc_seq_t seq, u32 abort_code, int error) in __rxrpc_abort_call()
130 rxrpc_seq_t seq, u32 abort_code, int error) in rxrpc_abort_call()
227 rxrpc_seq_t hard_ack, top; in rxrpc_rotate_rx_window()
283 rxrpc_seq_t seq = sp->hdr.seq; in rxrpc_verify_packet()
361 rxrpc_seq_t hard_ack, top, seq; in rxrpc_recvmsg_data()
787 rxrpc_seq_t hard_ack, top, seq; in rxrpc_kernel_get_reply_time()
H A Dinsecure.c31 rxrpc_seq_t seq, u16 expected_cksum) in none_verify_packet()
H A Dprotocol.h11 typedef u32 rxrpc_seq_t; /* Rx message sequence number */ typedef
H A Dsendmsg.c23 static bool rxrpc_check_tx_space(struct rxrpc_call *call, rxrpc_seq_t *_tx_win) in rxrpc_check_tx_space()
28 rxrpc_seq_t tx_win = READ_ONCE(call->tx_hard_ack); in rxrpc_check_tx_space()
65 rxrpc_seq_t tx_start, tx_win; in rxrpc_wait_for_tx_window_waitall()
197 rxrpc_seq_t seq = sp->hdr.seq; in rxrpc_queue_packet()
H A Doutput.c72 rxrpc_seq_t *_hard_ack, in rxrpc_fill_out_ack()
73 rxrpc_seq_t *_top, in rxrpc_fill_out_ack()
78 rxrpc_seq_t hard_ack, top, seq; in rxrpc_fill_out_ack()
187 rxrpc_seq_t hard_ack, top; in rxrpc_send_ack_packet()
H A Dproc.c63 rxrpc_seq_t tx_hard_ack, rx_hard_ack; in rxrpc_call_seq_show()
H A Drxkad.c353 rxrpc_seq_t seq, in rxkad_verify_packet_1()
430 rxrpc_seq_t seq, in rxkad_verify_packet_2()
529 rxrpc_seq_t seq, u16 expected_cksum) in rxkad_verify_packet()
H A Dcall_event.c161 rxrpc_seq_t cursor, seq, top; in rxrpc_resend()

Completed in 24 milliseconds