Home
last modified time | relevance | path

Searched refs:rcv_nxt (Results 1 – 25 of 58) sorted by relevance

123

/linux-6.15/tools/testing/selftests/net/tcp_ao/
H A Dicmps-accept.c214 packet.tcph.seq = htonl(rcv_nxt); in icmp_interfere4()
293 static void icmp6_interfere(int type, int code, uint32_t rcv_nxt, in icmp6_interfere() argument
326 packet.tcph.seq = htonl(rcv_nxt); in icmp6_interfere()
376 rcv_nxt, saddr4, daddr4); in icmp_interfere()
378 rcv_nxt, saddr4, daddr4); in icmp_interfere()
380 rcv_nxt, saddr4, daddr4); in icmp_interfere()
385 rcv_nxt, saddr6, daddr6); in icmp_interfere()
388 rcv_nxt, saddr6, daddr6); in icmp_interfere()
409 uint32_t rcv_nxt; in send_interfered() local
416 rcv_nxt = get_rcv_nxt(sk); in send_interfered()
[all …]
H A Dicmps-discard.c214 packet.tcph.seq = htonl(rcv_nxt); in icmp_interfere4()
293 static void icmp6_interfere(int type, int code, uint32_t rcv_nxt, in icmp6_interfere() argument
326 packet.tcph.seq = htonl(rcv_nxt); in icmp6_interfere()
376 rcv_nxt, saddr4, daddr4); in icmp_interfere()
378 rcv_nxt, saddr4, daddr4); in icmp_interfere()
380 rcv_nxt, saddr4, daddr4); in icmp_interfere()
385 rcv_nxt, saddr6, daddr6); in icmp_interfere()
388 rcv_nxt, saddr6, daddr6); in icmp_interfere()
409 uint32_t rcv_nxt; in send_interfered() local
416 rcv_nxt = get_rcv_nxt(sk); in send_interfered()
[all …]
/linux-6.15/net/ipv4/
H A Dtcp_minisocks.c56 u32 rcv_nxt) in twsk_rcv_nxt_update() argument
62 if (unlikely(ao && seq < rcv_nxt)) in twsk_rcv_nxt_update()
103 u32 rcv_nxt = READ_ONCE(tcptw->tw_rcv_nxt); in tcp_timewait_state_process() local
128 rcv_nxt, in tcp_timewait_state_process()
129 rcv_nxt + tcptw->tw_rcv_wnd)) in tcp_timewait_state_process()
157 rcv_nxt); in tcp_timewait_state_process()
191 (TCP_SKB_CB(skb)->seq == rcv_nxt && in tcp_timewait_state_process()
324 tcptw->tw_rcv_nxt = tp->rcv_nxt; in tcp_time_wait()
546 WRITE_ONCE(newtp->rcv_nxt, seq); in tcp_create_openreq_child()
805 tcp_rsk(req)->rcv_nxt, in tcp_check_req()
[all …]
H A Dtcp_fastopen.c174 if (TCP_SKB_CB(skb)->end_seq == tp->rcv_nxt) in tcp_fastopen_add_skb()
197 tp->rcv_nxt = TCP_SKB_CB(skb)->end_seq; in tcp_fastopen_add_skb()
285 tp->rcv_nxt = TCP_SKB_CB(skb)->seq + 1; in tcp_fastopen_create_child()
289 tcp_rsk(req)->rcv_nxt = tp->rcv_nxt; in tcp_fastopen_create_child()
290 tp->rcv_wup = tp->rcv_nxt; in tcp_fastopen_create_child()
H A Dtcp_input.c3677 if (ao && seq < tp->rcv_nxt) { in tcp_rcv_sne_update()
3687 u32 delta = seq - tp->rcv_nxt; in tcp_rcv_nxt_update()
3692 WRITE_ONCE(tp->rcv_nxt, seq); in tcp_rcv_nxt_update()
4491 if (seq != tp->rcv_nxt) in tcp_disordered_ack_check()
4492 return before(seq, tp->rcv_nxt) ? in tcp_disordered_ack_check()
4684 if (before(seq, tp->rcv_nxt)) in tcp_dsack_set()
4744 end_seq = tp->rcv_nxt; in tcp_send_dupack()
4967 __u32 dsack_high = tp->rcv_nxt; in tcp_ofo_queue()
5887 if (before(ptr, tp->rcv_nxt)) in tcp_check_urg()
6213 tp->rcv_nxt == tp->rcv_wup) in tcp_rcv_established()
[all …]
H A Dtcp_dctcp.h35 *prior_rcv_nxt = tcp_sk(sk)->rcv_nxt; in dctcp_ece_ack_update()
H A Dbpf_tcp_ca.c121 BPF_CALL_2(bpf_tcp_send_ack, struct tcp_sock *, tp, u32, rcv_nxt) in BPF_CALL_2() argument
124 __tcp_send_ack((struct sock *)tp, rcv_nxt, 0); in BPF_CALL_2()
H A Dtcp_output.c194 if (unlikely(rcv_nxt != tp->rcv_nxt)) in tcp_event_ack_sent()
273 tp->rcv_wup = tp->rcv_nxt; in tcp_select_window()
296 tp->rcv_wup = tp->rcv_nxt; in tcp_select_window()
1396 th->ack_seq = htonl(rcv_nxt); in __tcp_transmit_skb()
1453 tcp_event_ack_sent(sk, rcv_nxt); in __tcp_transmit_skb()
1498 tcp_sk(sk)->rcv_nxt); in tcp_transmit_skb()
3829 th->ack_seq = htonl(tcp_rsk(req)->rcv_nxt); in tcp_make_synack()
3946 tp->rcv_nxt = 0; in tcp_connect_init()
3949 tp->rcv_wup = tp->rcv_nxt; in tcp_connect_init()
3950 WRITE_ONCE(tp->copied_seq, tp->rcv_nxt); in tcp_connect_init()
[all …]
H A Dtcp.c2345 u32 rcv_nxt = READ_ONCE(tp->rcv_nxt); in tcp_inq_hint() local
2348 inq = rcv_nxt - copied_seq; in tcp_inq_hint()
2351 inq = tp->rcv_nxt - tp->copied_seq; in tcp_inq_hint()
2661 *seq, TCP_SKB_CB(skb)->seq, tp->rcv_nxt, in tcp_recvmsg_locked()
2676 *seq, TCP_SKB_CB(skb)->seq, tp->rcv_nxt, flags); in tcp_recvmsg_locked()
3329 WRITE_ONCE(tp->copied_seq, tp->rcv_nxt); in tcp_disconnect()
3455 if (after(opt.snd_wl1, tp->rcv_nxt + opt.rcv_wnd)) in tcp_repair_set_window()
3458 if (after(opt.rcv_wup, tp->rcv_nxt)) in tcp_repair_set_window()
3922 if (tp->rcv_nxt != tp->copied_seq) { in do_tcp_setsockopt()
3925 WRITE_ONCE(tp->rcv_nxt, val); in do_tcp_setsockopt()
[all …]
H A Dtcp_diag.c29 r->idiag_rqueue = max_t(int, READ_ONCE(tp->rcv_nxt) - in tcp_diag_get_info()
H A Dtcp_dctcp.c98 ca->prior_rcv_nxt = tp->rcv_nxt; in dctcp_init()
/linux-6.15/net/tipc/
H A Dname_distr.c314 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()
H A Dlink.c182 u16 rcv_nxt; member
434 return l->rcv_nxt; in tipc_link_rcv_nxt()
990 l->rcv_nxt = 1; in tipc_link_reset()
1021 u16 ack = l->rcv_nxt - 1; in tipc_link_xmit()
1155 u16 ack = l->rcv_nxt - 1; in tipc_link_advance_backlog()
1548 u16 ack = l->rcv_nxt - 1; in tipc_link_advance_transmq()
1703 l->snd_nxt = l->rcv_nxt; in tipc_link_build_state_msg()
1784 rcv_nxt = l->rcv_nxt; in tipc_link_rcv()
1812 l->rcv_nxt++; in tipc_link_rcv()
2189 u16 rcv_nxt = l->rcv_nxt; in tipc_link_proto_rcv() local
[all …]
H A Dname_distr.h74 u16 *rcv_nxt, bool *open);
/linux-6.15/arch/sparc/kernel/
H A Dldc.c136 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()
1731 p->u.r.ackid = lp->rcv_nxt; in send_data_ack()
1777 lp->rcv_nxt); in read_nonraw()
[all …]
/linux-6.15/tools/testing/selftests/bpf/progs/
H A Dbpf_dctcp.c101 ca->prior_rcv_nxt = tp->rcv_nxt; in BPF_PROG()
205 *prior_rcv_nxt = tcp_sk(sk)->rcv_nxt; in dctcp_ece_ack_update()
H A Dtest_sock_fields.c95 dst->rcv_nxt = src->rcv_nxt; in tpcpy()
H A Dbpf_iter_tcp4.c118 rx_queue = tp->rcv_nxt - tp->copied_seq; in dump_tcp_sock()
H A Dbpf_iter_tcp6.c118 rx_queue = tp->tcp.rcv_nxt - tp->tcp.copied_seq; in dump_tcp6_sock()
/linux-6.15/drivers/net/ethernet/chelsio/inline_crypto/chtls/
H A Dchtls_cm.c259 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.15/drivers/infiniband/hw/irdma/
H A Dcm.c2457 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2464 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2471 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2482 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2490 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2640 u32 rcv_nxt = cm_node->tcp_cntxt.rcv_nxt; in irdma_check_seq() local
2648 !between(seq, rcv_nxt, (rcv_nxt + rcv_wnd))) in irdma_check_seq()
2712 cm_node->tcp_cntxt.rcv_nxt = inc_sequence + 1; in irdma_handle_syn_pkt()
2770 cm_node->tcp_cntxt.rcv_nxt = inc_sequence + 1; in irdma_handle_synack_pkt()
3340 tcp_info->rcv_nxt = cm_node->tcp_cntxt.rcv_nxt; in irdma_init_tcp_ctx()
[all …]
H A Dpuda.c1408 pfpdu->rcv_nxt = seqnum + fpdu_len; in irdma_ieq_handle_partial()
1507 pfpdu->rcv_nxt = buf->seqnum + len; in irdma_ieq_process_buf()
1514 pfpdu->rcv_nxt = buf->seqnum; in irdma_ieq_process_buf()
1543 if (buf->seqnum != pfpdu->rcv_nxt) { in irdma_ieq_process_fpdus()
1620 pfpdu->rcv_nxt = fps; in irdma_ieq_handle_exception()
1632 if (!(rcv_wnd >= (buf->seqnum - pfpdu->rcv_nxt))) { in irdma_ieq_handle_exception()
/linux-6.15/include/linux/
H A Dtcp.h166 u32 rcv_nxt; /* the ack # by SYNACK. For member
292 u32 rcv_nxt; /* What we want to receive next */ member
/linux-6.15/drivers/net/ethernet/sun/
H A Dsunvnet_common.c266 dr->rcv_nxt = 1; in sunvnet_handshake_complete_common()
270 dr->rcv_nxt = 1; in sunvnet_handshake_complete_common()
652 pkt->tag.stype_env, pkt->seq, dr->rcv_nxt); in vnet_rx()
656 if (unlikely(pkt->seq != dr->rcv_nxt)) { in vnet_rx()
658 pkt->seq, dr->rcv_nxt); in vnet_rx()
663 dr->rcv_nxt++; in vnet_rx()
851 pkt->seq = dr->rcv_nxt; in vnet_event_napi()
/linux-6.15/drivers/target/iscsi/cxgbit/
H A Dcxgbit.h219 u32 rcv_nxt; member

123