Home
last modified time | relevance | path

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

/net/ipv4/
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()
104 u32 rcv_nxt = READ_ONCE(tcptw->tw_rcv_nxt); in tcp_timewait_state_process() local
129 rcv_nxt, in tcp_timewait_state_process()
130 rcv_nxt + tcptw->tw_rcv_wnd)) in tcp_timewait_state_process()
158 rcv_nxt); in tcp_timewait_state_process()
192 (TCP_SKB_CB(skb)->seq == rcv_nxt && in tcp_timewait_state_process()
327 tcptw->tw_rcv_nxt = tp->rcv_nxt; in tcp_time_wait()
549 WRITE_ONCE(newtp->rcv_nxt, seq); in tcp_create_openreq_child()
808 tcp_rsk(req)->rcv_nxt, in tcp_check_req()
[all …]
A Dtcp_fastopen.c175 if (TCP_SKB_CB(skb)->end_seq == tp->rcv_nxt) in tcp_fastopen_add_skb()
198 tp->rcv_nxt = TCP_SKB_CB(skb)->end_seq; in tcp_fastopen_add_skb()
288 tp->rcv_nxt = TCP_SKB_CB(skb)->seq + 1; in tcp_fastopen_create_child()
292 tcp_rsk(req)->rcv_nxt = tp->rcv_nxt; in tcp_fastopen_create_child()
293 tp->rcv_wup = tp->rcv_nxt; in tcp_fastopen_create_child()
A Dtcp_input.c686 if (tp->rcv_nxt != tp->copied_seq) in tcp_rcv_rtt_update()
792 inq = tp->rcv_nxt - tp->copied_seq; in tcp_rcv_space_adjust()
3545 if (ao && seq < tp->rcv_nxt) { in tcp_rcv_sne_update()
3555 u32 delta = seq - tp->rcv_nxt; in tcp_rcv_nxt_update()
3560 WRITE_ONCE(tp->rcv_nxt, seq); in tcp_rcv_nxt_update()
4359 if (seq != tp->rcv_nxt) in tcp_disordered_ack_check()
4560 if (before(seq, tp->rcv_nxt)) in tcp_dsack_set()
4620 end_seq = tp->rcv_nxt; in tcp_send_dupack()
4843 __u32 dsack_high = tp->rcv_nxt; in tcp_ofo_queue()
5782 if (before(ptr, tp->rcv_nxt)) in tcp_check_urg()
[all …]
A Dtcp_dctcp.h35 *prior_rcv_nxt = tcp_sk(sk)->rcv_nxt; in dctcp_ece_ack_update()
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()
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()
3834 th->ack_seq = htonl(tcp_rsk(req)->rcv_nxt); in tcp_make_synack()
3951 tp->rcv_nxt = 0; in tcp_connect_init()
3954 tp->rcv_wup = tp->rcv_nxt; in tcp_connect_init()
3955 WRITE_ONCE(tp->copied_seq, tp->rcv_nxt); in tcp_connect_init()
[all …]
A Dtcp.c2372 u32 rcv_nxt = READ_ONCE(tp->rcv_nxt); in tcp_inq_hint() local
2375 inq = rcv_nxt - copied_seq; in tcp_inq_hint()
2378 inq = tp->rcv_nxt - tp->copied_seq; in tcp_inq_hint()
2688 *seq, TCP_SKB_CB(skb)->seq, tp->rcv_nxt, in tcp_recvmsg_locked()
2703 *seq, TCP_SKB_CB(skb)->seq, tp->rcv_nxt, flags); in tcp_recvmsg_locked()
3356 WRITE_ONCE(tp->copied_seq, tp->rcv_nxt); in tcp_disconnect()
3483 if (after(opt.snd_wl1, tp->rcv_nxt + opt.rcv_wnd)) in tcp_repair_set_window()
3486 if (after(opt.rcv_wup, tp->rcv_nxt)) in tcp_repair_set_window()
3955 if (tp->rcv_nxt != tp->copied_seq) { in do_tcp_setsockopt()
3958 WRITE_ONCE(tp->rcv_nxt, val); in do_tcp_setsockopt()
[all …]
A Dtcp_diag.c29 r->idiag_rqueue = max_t(int, READ_ONCE(tp->rcv_nxt) - in tcp_diag_get_info()
A Dtcp_dctcp.c98 ca->prior_rcv_nxt = tp->rcv_nxt; in dctcp_init()
A Dtcp_ipv4.c1170 tcp_rsk(req)->rcv_nxt,
2951 rx_queue = max_t(int, READ_ONCE(tp->rcv_nxt) -
A Dtcp_ao.c992 sne = tcp_ao_compute_sne(info->rcv_sne, tcp_sk(sk)->rcv_nxt, in tcp_inbound_ao_hash()
/net/tipc/
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 …]
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()
A Dname_distr.h74 u16 *rcv_nxt, bool *open);
A Dnode.c1938 u16 rcv_nxt, syncpt, dlv_nxt, inputq_len; in tipc_node_check_state() local
1951 rcv_nxt = tipc_link_rcv_nxt(l); in tipc_node_check_state()
1991 if ((usr != LINK_PROTOCOL) && less(oseqno, rcv_nxt)) in tipc_node_check_state()
2021 if (!more(rcv_nxt, n->sync_point)) in tipc_node_check_state()
/net/ipv6/
A Dtcp_ipv6.c1287 tcp_rsk(req)->rcv_nxt,
1703 if (TCP_SKB_CB(opt_skb)->end_seq == tp->rcv_nxt &&
2217 rx_queue = max_t(int, READ_ONCE(tp->rcv_nxt) -
/net/mptcp/
A Dsubflow.c1525 (tcp_sk(sk)->rcv_nxt - tcp_sk(sk)->rcv_wup) > inet_csk(sk)->icsk_ack.rcv_mss) in subflow_data_ready()
A Dprotocol.c507 ((READ_ONCE(tp->rcv_nxt) - READ_ONCE(tp->rcv_wup) > in mptcp_subflow_could_cleanup()
/net/core/
A Dfilter.c7276 case offsetof(struct bpf_tcp_sock, rcv_nxt): in bpf_tcp_sock_convert_ctx_access()
7277 BPF_TCP_SOCK_GET_COMMON(rcv_nxt); in bpf_tcp_sock_convert_ctx_access()
10734 case offsetof(struct bpf_sock_ops, rcv_nxt): in sock_ops_convert_ctx_access()
10735 SOCK_OPS_GET_TCP_SOCK_FIELD(rcv_nxt); in sock_ops_convert_ctx_access()

Completed in 101 milliseconds