Searched refs:rxrpc_seq_t (Results 1 – 11 of 11) sorted by relevance
/linux-6.1.9/include/trace/events/ |
D | rxrpc.h | 525 rxrpc_seq_t seq, int abort_code, int error), 534 __field(rxrpc_seq_t, seq ) 589 __field(rxrpc_seq_t, tx_hard_ack ) 590 __field(rxrpc_seq_t, tx_top ) 611 TP_PROTO(unsigned int call, rxrpc_seq_t seq, 618 __field(rxrpc_seq_t, seq ) 643 rxrpc_seq_t first, rxrpc_seq_t prev, u8 reason, u8 n_acks), 651 __field(rxrpc_seq_t, first ) 652 __field(rxrpc_seq_t, prev ) 761 TP_PROTO(struct rxrpc_call *call, rxrpc_seq_t seq, [all …]
|
/linux-6.1.9/net/rxrpc/ |
D | ar-internal.h | 240 unsigned int, unsigned int, rxrpc_seq_t, u16); 640 rxrpc_seq_t tx_hard_ack; /* Dead slot in buffer; the first transmitted but 643 rxrpc_seq_t tx_top; /* Highest Tx slot allocated. */ 659 rxrpc_seq_t rx_hard_ack; /* Dead slot in buffer; the first received but not 662 rxrpc_seq_t rx_top; /* Highest Rx slot allocated. */ 663 rxrpc_seq_t rx_expect_next; /* Expected next packet sequence number */ 675 rxrpc_seq_t ackr_highest_seq; /* Higest sequence number received */ 689 rxrpc_seq_t acks_first_seq; /* first sequence number received */ 690 rxrpc_seq_t acks_prev_seq; /* Highest previousPacket received */ 691 rxrpc_seq_t acks_lowest_nak; /* Lowest NACK in the buffer (or ==tx_hard_ack) */ [all …]
|
D | input.c | 27 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_pkt) in rxrpc_is_ack_valid() 824 rxrpc_seq_t base = READ_ONCE(call->acks_first_seq); in rxrpc_is_ack_valid() [all …]
|
D | recvmsg.c | 121 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()
|
D | insecure.c | 36 rxrpc_seq_t seq, u16 expected_cksum) in none_verify_packet()
|
D | protocol.h | 11 typedef u32 rxrpc_seq_t; /* Rx message sequence number */ typedef
|
D | output.c | 72 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()
|
D | sendmsg.c | 23 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()
|
D | proc.c | 57 rxrpc_seq_t tx_hard_ack, rx_hard_ack; in rxrpc_call_seq_show()
|
D | rxkad.c | 443 rxrpc_seq_t seq, in rxkad_verify_packet_1() 519 rxrpc_seq_t seq, in rxkad_verify_packet_2() 617 rxrpc_seq_t seq, u16 expected_cksum) in rxkad_verify_packet()
|
D | call_event.c | 161 rxrpc_seq_t cursor, seq, top; in rxrpc_resend()
|