| /linux-6.1.9/net/tipc/ |
| D | name_distr.c | 314 u16 *rcv_nxt, bool *open) in tipc_named_dequeue() argument
330 *rcv_nxt = seqno; in tipc_named_dequeue()
340 if (*open && (*rcv_nxt == seqno)) { in tipc_named_dequeue()
341 (*rcv_nxt)++; in tipc_named_dequeue()
347 if (less(seqno, *rcv_nxt)) { in tipc_named_dequeue()
365 u16 *rcv_nxt, bool *open) in tipc_named_rcv() argument
374 while ((skb = tipc_named_dequeue(namedq, rcv_nxt, open))) { in tipc_named_rcv()
|
| D | link.c | 197 u16 rcv_nxt; member
428 if (more(l->snd_nxt, l->rcv_nxt)) in link_bc_rcv_gap()
429 gap = l->snd_nxt - l->rcv_nxt; in link_bc_rcv_gap()
431 gap = buf_seqno(skb) - l->rcv_nxt; in link_bc_rcv_gap()
456 return l->rcv_nxt; in tipc_link_rcv_nxt()
1012 l->rcv_nxt = 1; in tipc_link_reset()
1042 u16 bc_ack = l->bc_rcvlink->rcv_nxt - 1; in tipc_link_xmit()
1043 u16 ack = l->rcv_nxt - 1; in tipc_link_xmit()
1173 u16 bc_ack = l->bc_rcvlink->rcv_nxt - 1; in tipc_link_advance_backlog()
1176 u16 ack = l->rcv_nxt - 1; in tipc_link_advance_backlog()
[all …]
|
| D | name_distr.h | 75 u16 *rcv_nxt, bool *open);
|
| /linux-6.1.9/net/ipv4/ |
| D | tcp_fastopen.c | 173 if (TCP_SKB_CB(skb)->end_seq == tp->rcv_nxt) in tcp_fastopen_add_skb()
196 tp->rcv_nxt = TCP_SKB_CB(skb)->end_seq; in tcp_fastopen_add_skb()
284 tp->rcv_nxt = TCP_SKB_CB(skb)->seq + 1; in tcp_fastopen_create_child()
288 tcp_rsk(req)->rcv_nxt = tp->rcv_nxt; in tcp_fastopen_create_child()
289 tp->rcv_wup = tp->rcv_nxt; in tcp_fastopen_create_child()
|
| D | tcp_input.c | 662 if (before(tp->rcv_nxt, tp->rcv_rtt_est.seq)) in tcp_rcv_rtt_measure()
670 tp->rcv_rtt_est.seq = tp->rcv_nxt + tp->rcv_wnd; in tcp_rcv_rtt_measure()
3540 u32 delta = seq - tp->rcv_nxt; in tcp_rcv_nxt_update()
3544 WRITE_ONCE(tp->rcv_nxt, seq); in tcp_rcv_nxt_update()
4270 (th->ack && seq == TCP_SKB_CB(skb)->end_seq && seq == tp->rcv_nxt) && in tcp_disordered_ack()
4307 !after(seq, tp->rcv_nxt + tcp_receive_window(tp)); in tcp_sequence()
4446 if (before(seq, tp->rcv_nxt)) in tcp_dsack_set()
4486 before(TCP_SKB_CB(skb)->seq, tp->rcv_nxt)) { in tcp_send_dupack()
4494 if (after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt)) in tcp_send_dupack()
4495 end_seq = tp->rcv_nxt; in tcp_send_dupack()
[all …]
|
| D | tcp_dctcp.h | 35 *prior_rcv_nxt = tcp_sk(sk)->rcv_nxt; in dctcp_ece_ack_update()
|
| D | tcp_minisocks.c | 264 tcptw->tw_rcv_nxt = tp->rcv_nxt; in tcp_time_wait()
496 WRITE_ONCE(newtp->rcv_nxt, seq); in tcp_create_openreq_child()
726 tcp_rsk(req)->rcv_nxt, tcp_rsk(req)->rcv_nxt + req->rsk_rcv_wnd)) { in tcp_check_req()
740 if (tmp_opt.saw_tstamp && !after(TCP_SKB_CB(skb)->seq, tcp_rsk(req)->rcv_nxt)) in tcp_check_req()
|
| D | bpf_tcp_ca.c | 130 BPF_CALL_2(bpf_tcp_send_ack, struct tcp_sock *, tp, u32, rcv_nxt) in BPF_CALL_2() argument
133 __tcp_send_ack((struct sock *)tp, rcv_nxt); in BPF_CALL_2()
|
| D | tcp_output.c | 181 u32 rcv_nxt) in tcp_event_ack_sent() argument
193 if (unlikely(rcv_nxt != tp->rcv_nxt)) in tcp_event_ack_sent()
279 tp->rcv_wup = tp->rcv_nxt; in tcp_select_window()
1238 int clone_it, gfp_t gfp_mask, u32 rcv_nxt) in __tcp_transmit_skb() argument
1328 th->ack_seq = htonl(rcv_nxt); in __tcp_transmit_skb()
1376 tcp_event_ack_sent(sk, tcp_skb_pcount(skb), rcv_nxt); in __tcp_transmit_skb()
1421 tcp_sk(sk)->rcv_nxt); in tcp_transmit_skb()
3605 th->ack_seq = htonl(tcp_rsk(req)->rcv_nxt); in tcp_make_synack()
3716 tp->rcv_nxt = 0; in tcp_connect_init()
3719 tp->rcv_wup = tp->rcv_nxt; in tcp_connect_init()
[all …]
|
| D | tcp.c | 1580 tp->rcv_nxt - tp->rcv_wup > icsk->icsk_ack.rcv_mss || in __tcp_cleanup_rbuf()
1628 tp->copied_seq, TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt); in tcp_cleanup_rbuf()
2399 u32 rcv_nxt = READ_ONCE(tp->rcv_nxt); in tcp_inq_hint() local
2402 inq = rcv_nxt - copied_seq; in tcp_inq_hint()
2405 inq = tp->rcv_nxt - tp->copied_seq; in tcp_inq_hint()
2499 *seq, TCP_SKB_CB(skb)->seq, tp->rcv_nxt, in tcp_recvmsg_locked()
2514 *seq, TCP_SKB_CB(skb)->seq, tp->rcv_nxt, flags); in tcp_recvmsg_locked()
3110 WRITE_ONCE(tp->copied_seq, tp->rcv_nxt); in tcp_disconnect()
3234 if (after(opt.snd_wl1, tp->rcv_nxt + opt.rcv_wnd)) in tcp_repair_set_window()
3237 if (after(opt.rcv_wup, tp->rcv_nxt)) in tcp_repair_set_window()
[all …]
|
| D | tcp_dctcp.c | 86 ca->prior_rcv_nxt = tp->rcv_nxt; in dctcp_init()
|
| D | tcp_diag.c | 29 r->idiag_rqueue = max_t(int, READ_ONCE(tp->rcv_nxt) - in tcp_diag_get_info()
|
| /linux-6.1.9/arch/sparc/kernel/ |
| D | ldc.c | 136 u32 rcv_nxt; member
437 lp->rcv_nxt = 0; in send_rts()
476 p->u.r.ackid = lp->rcv_nxt; in send_rdx()
500 p->u.r.ackid = lp->rcv_nxt; in send_data_nack()
681 lp->rcv_nxt = p->seqid; in process_rts()
709 return lp->rcv_nxt + 1 == seqid; in rx_seq_ok()
722 lp->rcv_nxt = p->seqid; in process_rdx()
1496 lp->rcv_nxt, lp->snd_nxt); in __ldc_print()
1647 lp->rcv_nxt = first_frag->seqid - 1; in rx_bad_seq()
1731 p->u.r.ackid = lp->rcv_nxt; in send_data_ack()
[all …]
|
| /linux-6.1.9/tools/testing/selftests/bpf/progs/ |
| D | bpf_dctcp.c | 94 ca->prior_rcv_nxt = tp->rcv_nxt; in BPF_PROG()
199 *prior_rcv_nxt = tcp_sk(sk)->rcv_nxt; in dctcp_ece_ack_update()
|
| D | test_sock_fields.c | 92 dst->rcv_nxt = src->rcv_nxt; in tpcpy()
|
| D | bpf_iter_tcp4.c | 118 rx_queue = tp->rcv_nxt - tp->copied_seq; in dump_tcp_sock()
|
| D | bpf_iter_tcp6.c | 118 rx_queue = tp->tcp.rcv_nxt - tp->tcp.copied_seq; in dump_tcp6_sock()
|
| /linux-6.1.9/drivers/net/ethernet/chelsio/inline_crypto/chtls/ |
| D | chtls_cm.c | 259 if (send_tx_flowc_wr(sk, 0, tp->snd_nxt, tp->rcv_nxt) < 0) in chtls_send_reset()
1647 tp->copied_seq != tp->rcv_nxt) { in handle_urg_ptr()
1704 handle_urg_ptr(sk, tp->rcv_nxt + ntohs(hdr->urg)); in chtls_recv_data()
1706 tp->urg_seq - tp->rcv_nxt < skb->len)) in chtls_recv_data()
1708 skb->data[tp->urg_seq - tp->rcv_nxt]; in chtls_recv_data()
1712 csk->delack_seq = tp->rcv_nxt; in chtls_recv_data()
1716 tp->rcv_nxt += skb->len; in chtls_recv_data()
1769 tp->rcv_nxt < skb->len)) in chtls_recv_pdu()
1771 skb->data[tp->urg_seq - tp->rcv_nxt]; in chtls_recv_pdu()
1827 tp->rcv_nxt += in chtls_rx_hdr()
[all …]
|
| /linux-6.1.9/drivers/infiniband/hw/irdma/ |
| D | cm.c | 354 cm_node->tcp_cntxt.loc_ack_num = cm_node->tcp_cntxt.rcv_nxt; in irdma_form_ah_cm_frame()
542 cm_node->tcp_cntxt.loc_ack_num = cm_node->tcp_cntxt.rcv_nxt; in irdma_form_uda_cm_frame()
2404 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2411 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2418 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2429 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2437 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2587 u32 rcv_nxt = cm_node->tcp_cntxt.rcv_nxt; in irdma_check_seq() local
2595 !between(seq, rcv_nxt, (rcv_nxt + rcv_wnd))) in irdma_check_seq()
2659 cm_node->tcp_cntxt.rcv_nxt = inc_sequence + 1; in irdma_handle_syn_pkt()
[all …]
|
| D | puda.c | 1407 pfpdu->rcv_nxt = seqnum + fpdu_len; in irdma_ieq_handle_partial()
1506 pfpdu->rcv_nxt = buf->seqnum + len; in irdma_ieq_process_buf()
1513 pfpdu->rcv_nxt = buf->seqnum; in irdma_ieq_process_buf()
1542 if (buf->seqnum != pfpdu->rcv_nxt) { in irdma_ieq_process_fpdus()
1619 pfpdu->rcv_nxt = fps; in irdma_ieq_handle_exception()
1631 if (!(rcv_wnd >= (buf->seqnum - pfpdu->rcv_nxt))) { in irdma_ieq_handle_exception()
|
| /linux-6.1.9/include/linux/ |
| D | tcp.h | 163 u32 rcv_nxt; /* the ack # by SYNACK. For member
202 u32 rcv_nxt; /* What we want to receive next */ member
|
| /linux-6.1.9/drivers/net/ethernet/sun/ |
| D | sunvnet_common.c | 265 dr->rcv_nxt = 1; in sunvnet_handshake_complete_common()
269 dr->rcv_nxt = 1; in sunvnet_handshake_complete_common()
651 pkt->tag.stype_env, pkt->seq, dr->rcv_nxt); in vnet_rx()
655 if (unlikely(pkt->seq != dr->rcv_nxt)) { in vnet_rx()
657 pkt->seq, dr->rcv_nxt); in vnet_rx()
662 dr->rcv_nxt++; in vnet_rx()
850 pkt->seq = dr->rcv_nxt; in vnet_event_napi()
|
| /linux-6.1.9/tools/testing/selftests/bpf/ |
| D | bpf_tcp_helpers.h | 65 __u32 rcv_nxt; member
|
| /linux-6.1.9/drivers/target/iscsi/cxgbit/ |
| D | cxgbit.h | 219 u32 rcv_nxt; member
|
| /linux-6.1.9/drivers/scsi/cxgbi/cxgb4i/ |
| D | cxgb4i.c | 641 flowc->mnemval[5].val = htonl(csk->rcv_nxt); in send_tx_flowc_wr()
670 csk->snd_nxt, csk->rcv_nxt, csk->snd_win, in send_tx_flowc_wr()
937 csk->copied_seq = csk->rcv_wup = csk->rcv_nxt = rcv_isn; in do_act_establish()
1295 (cxgbi_skcb_tcp_seq(skb) != csk->rcv_nxt)) { in do_rx_iscsi_hdr()
1298 csk->rcv_nxt); in do_rx_iscsi_hdr()
1321 csk->rcv_nxt += cxgbi_skcb_rx_pdulen(skb); in do_rx_iscsi_hdr()
1557 csk->rcv_nxt = seq + pdu_len_ddp; in do_rx_iscsi_cmp()
|