Home
last modified time | relevance | path

Searched refs:hard_ack (Results 1 - 7 of 7) sorted by relevance

/kernel/linux/linux-5.10/net/rxrpc/
H A Drecvmsg.c227 rxrpc_seq_t hard_ack, top; in rxrpc_rotate_rx_window() local
234 hard_ack = call->rx_hard_ack; in rxrpc_rotate_rx_window()
236 ASSERT(before(hard_ack, top)); in rxrpc_rotate_rx_window()
238 hard_ack++; in rxrpc_rotate_rx_window()
239 ix = hard_ack & RXRPC_RXTX_BUFF_MASK; in rxrpc_rotate_rx_window()
254 smp_store_release(&call->rx_hard_ack, hard_ack); in rxrpc_rotate_rx_window()
258 trace_rxrpc_receive(call, rxrpc_receive_rotate, serial, hard_ack); in rxrpc_rotate_rx_window()
361 rxrpc_seq_t hard_ack, top, seq; in rxrpc_recvmsg_data() local
382 hard_ack = call->rx_hard_ack; in rxrpc_recvmsg_data()
383 seq = hard_ack in rxrpc_recvmsg_data()
787 rxrpc_seq_t hard_ack, top, seq; rxrpc_kernel_get_reply_time() local
[all...]
H A Doutput.c78 rxrpc_seq_t hard_ack, top, seq; in rxrpc_fill_out_ack() local
91 hard_ack = READ_ONCE(call->rx_hard_ack); in rxrpc_fill_out_ack()
93 *_hard_ack = hard_ack; in rxrpc_fill_out_ack()
98 pkt->ack.firstPacket = htonl(hard_ack + 1); in rxrpc_fill_out_ack()
102 pkt->ack.nAcks = top - hard_ack; in rxrpc_fill_out_ack()
107 if (after(top, hard_ack)) { in rxrpc_fill_out_ack()
108 seq = hard_ack + 1; in rxrpc_fill_out_ack()
130 return top - hard_ack + 3; in rxrpc_fill_out_ack()
187 rxrpc_seq_t hard_ack, top; in rxrpc_send_ack_packet() local
230 n = rxrpc_fill_out_ack(conn, call, pkt, &hard_ack, in rxrpc_send_ack_packet()
[all...]
H A Dinput.c417 rxrpc_seq_t seq0 = sp->hdr.seq, hard_ack; in rxrpc_input_data() local
456 hard_ack = READ_ONCE(call->rx_hard_ack); in rxrpc_input_data()
501 if (before_eq(seq, hard_ack)) { in rxrpc_input_data()
518 if (after(seq, hard_ack + call->rx_winsize)) { in rxrpc_input_data()
861 rxrpc_seq_t first_soft_ack, hard_ack, prev_pkt; in rxrpc_input_ack() local
877 hard_ack = first_soft_ack - 1; in rxrpc_input_ack()
963 if (before(hard_ack, call->tx_hard_ack) || in rxrpc_input_ack()
964 after(hard_ack, call->tx_top)) { in rxrpc_input_ack()
968 if (nr_acks > call->tx_top - hard_ack) { in rxrpc_input_ack()
973 if (after(hard_ack, cal in rxrpc_input_ack()
[all...]
/kernel/linux/linux-6.6/net/rxrpc/
H A Dtxbuf.c108 rxrpc_seq_t hard_ack = smp_load_acquire(&call->acks_hard_ack); in rxrpc_shrink_call_tx_buffer() local
115 hard_ack = smp_load_acquire(&call->acks_hard_ack); in rxrpc_shrink_call_tx_buffer()
116 if (before(hard_ack, txb->seq)) in rxrpc_shrink_call_tx_buffer()
H A Dinput.c842 rxrpc_seq_t first_soft_ack, hard_ack, prev_pkt, since; in rxrpc_input_ack() local
856 hard_ack = first_soft_ack - 1; in rxrpc_input_ack()
970 if (before(hard_ack, call->acks_hard_ack) || in rxrpc_input_ack()
971 after(hard_ack, call->tx_top)) in rxrpc_input_ack()
973 if (nr_acks > call->tx_top - hard_ack) in rxrpc_input_ack()
976 if (after(hard_ack, call->acks_hard_ack)) { in rxrpc_input_ack()
977 if (rxrpc_rotate_tx_window(call, hard_ack, &summary)) { in rxrpc_input_ack()
992 summary.nr_acks == call->tx_top - hard_ack && in rxrpc_input_ack()
/kernel/linux/linux-5.10/include/trace/events/
H A Drxrpc.h1023 __field(rxrpc_seq_t, hard_ack )
1032 __entry->hard_ack = call->rx_hard_ack;
1041 __entry->hard_ack,
1285 __field(rxrpc_seq_t, hard_ack )
1295 __entry->hard_ack = call->tx_hard_ack;
1306 __entry->hard_ack,
1313 __entry->top - __entry->hard_ack,
/kernel/linux/linux-6.6/include/trace/events/
H A Drxrpc.h1537 __field(rxrpc_seq_t, hard_ack)
1547 __entry->hard_ack = call->acks_hard_ack;
1558 __entry->hard_ack,
1565 __entry->top - __entry->hard_ack,
1583 __field(rxrpc_seq_t, hard_ack)
1594 __entry->hard_ack = call->acks_hard_ack;
1602 __entry->hard_ack,

Completed in 8 milliseconds