Home
last modified time | relevance | path

Searched refs:rcv_nxt (Results 1 - 25 of 109) sorted by relevance

12345

/kernel/linux/common_modules/newip/third_party/linux-5.10/net/newip/
H A Dtcp_nip_input.c197 u32 diff = tp->rcv_nxt - TCP_SKB_CB(skb)->seq; in tcp_nip_overlap_handle()
229 /* If we update tp->rcv_nxt, also update tp->bytes_received */
232 u32 delta = seq - tp->rcv_nxt; in tcp_nip_rcv_nxt_update()
236 WRITE_ONCE(tp->rcv_nxt, seq); in tcp_nip_rcv_nxt_update()
322 if (after(TCP_SKB_CB(skb)->seq, tp->rcv_nxt)) { in tcp_nip_ofo_queue()
323 nip_dbg("nodes are all after rcv_nxt"); in tcp_nip_ofo_queue()
330 if (unlikely(!after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt))) { in tcp_nip_ofo_queue()
331 nip_dbg("this node is before rcv_nxt, drop skb"); in tcp_nip_ofo_queue()
540 u32 seq_max = tp->rcv_nxt + cur_win; in tcp_nip_data_queue()
548 tp->snd_up = (TCP_SKB_CB(skb)->seq - tcp_sk(sk)->rcv_nxt) / ms in tcp_nip_data_queue()
[all...]
H A Dtcp_nip_output.c257 tp->rcv_wup = tp->rcv_nxt; in nip_tcp_select_window()
337 tp->rcv_nxt = 0; in tcp_nip_connect_init()
338 tp->rcv_wup = tp->rcv_nxt; in tcp_nip_connect_init()
339 tp->copied_seq = tp->rcv_nxt; in tcp_nip_connect_init()
462 u32 rcv_nxt) in tcp_nip_event_ack_sent()
466 if (unlikely(rcv_nxt != tp->rcv_nxt)) in tcp_nip_event_ack_sent()
486 int clone_it, gfp_t gfp_mask, u32 rcv_nxt) in __tcp_nip_transmit_skb()
550 th->ack_seq = htonl(rcv_nxt); in __tcp_nip_transmit_skb()
584 tcp_nip_event_ack_sent(sk, tcp_skb_pcount(skb), rcv_nxt); in __tcp_nip_transmit_skb()
461 tcp_nip_event_ack_sent(struct sock *sk, unsigned int pkts, u32 rcv_nxt) tcp_nip_event_ack_sent() argument
485 __tcp_nip_transmit_skb(struct sock *sk, struct sk_buff *skb, int clone_it, gfp_t gfp_mask, u32 rcv_nxt) __tcp_nip_transmit_skb() argument
961 __tcp_nip_send_ack(struct sock *sk, u32 rcv_nxt) __tcp_nip_send_ack() argument
[all...]
/kernel/linux/linux-5.10/net/tipc/
H A Dlink.c112 * @rcv_nxt: next sequence number to expect for inbound messages
169 u16 rcv_nxt; member
400 if (more(l->snd_nxt, l->rcv_nxt)) in link_bc_rcv_gap()
401 gap = l->snd_nxt - l->rcv_nxt; in link_bc_rcv_gap()
403 gap = buf_seqno(skb) - l->rcv_nxt; in link_bc_rcv_gap()
428 return l->rcv_nxt; in tipc_link_rcv_nxt()
977 l->rcv_nxt = 1; in tipc_link_reset()
1007 u16 bc_ack = l->bc_rcvlink->rcv_nxt - 1; in tipc_link_xmit()
1008 u16 ack = l->rcv_nxt - 1; in tipc_link_xmit()
1138 u16 bc_ack = l->bc_rcvlink->rcv_nxt in tipc_link_advance_backlog()
1755 u16 seqno, rcv_nxt, win_lim; tipc_link_rcv() local
2173 u16 rcv_nxt = l->rcv_nxt; tipc_link_proto_rcv() local
[all...]
H A Dname_distr.c324 u16 *rcv_nxt, bool *open) in tipc_named_dequeue()
340 *rcv_nxt = seqno; in tipc_named_dequeue()
350 if (*open && (*rcv_nxt == seqno)) { in tipc_named_dequeue()
351 (*rcv_nxt)++; in tipc_named_dequeue()
357 if (less(seqno, *rcv_nxt)) { in tipc_named_dequeue()
371 u16 *rcv_nxt, bool *open) in tipc_named_rcv()
380 while ((skb = tipc_named_dequeue(namedq, rcv_nxt, open))) { in tipc_named_rcv()
323 tipc_named_dequeue(struct sk_buff_head *namedq, u16 *rcv_nxt, bool *open) tipc_named_dequeue() argument
370 tipc_named_rcv(struct net *net, struct sk_buff_head *namedq, u16 *rcv_nxt, bool *open) tipc_named_rcv() argument
H A Dname_distr.h75 u16 *rcv_nxt, bool *open);
/kernel/linux/linux-6.6/net/tipc/
H A Dlink.c112 * @rcv_nxt: next sequence number to expect for inbound messages
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 in tipc_link_advance_backlog()
1791 u16 seqno, rcv_nxt, win_lim; tipc_link_rcv() local
2209 u16 rcv_nxt = l->rcv_nxt; tipc_link_proto_rcv() local
[all...]
H A Dname_distr.c314 u16 *rcv_nxt, bool *open) in tipc_named_dequeue()
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()
361 * @rcv_nxt: store last received seqno here
365 u16 *rcv_nxt, bool *open) in tipc_named_rcv()
374 while ((skb = tipc_named_dequeue(namedq, rcv_nxt, open))) { in tipc_named_rcv()
313 tipc_named_dequeue(struct sk_buff_head *namedq, u16 *rcv_nxt, bool *open) tipc_named_dequeue() argument
364 tipc_named_rcv(struct net *net, struct sk_buff_head *namedq, u16 *rcv_nxt, bool *open) tipc_named_rcv() argument
H A Dname_distr.h74 u16 *rcv_nxt, bool *open);
/kernel/linux/linux-5.10/net/ipv4/
H A Dtcp_fastopen.c190 if (TCP_SKB_CB(skb)->end_seq == tp->rcv_nxt) in tcp_fastopen_add_skb()
213 tp->rcv_nxt = TCP_SKB_CB(skb)->end_seq; in tcp_fastopen_add_skb()
300 tp->rcv_nxt = TCP_SKB_CB(skb)->seq + 1; in tcp_fastopen_create_child()
304 tcp_rsk(req)->rcv_nxt = tp->rcv_nxt; in tcp_fastopen_create_child()
305 tp->rcv_wup = tp->rcv_nxt; in tcp_fastopen_create_child()
H A Dtcp_minisocks.c236 * and new good SYN with random sequence number <rcv_nxt. in tcp_timewait_state_process()
271 tcptw->tw_rcv_nxt = tp->rcv_nxt; in tcp_time_wait()
482 WRITE_ONCE(newtp->rcv_nxt, seq); in tcp_create_openreq_child()
715 tcp_rsk(req)->rcv_nxt, tcp_rsk(req)->rcv_nxt + req->rsk_rcv_wnd)) { in tcp_check_req()
732 if (tmp_opt.saw_tstamp && !after(TCP_SKB_CB(skb)->seq, tcp_rsk(req)->rcv_nxt)) in tcp_check_req()
H A Dtcp_dctcp.h35 *prior_rcv_nxt = tcp_sk(sk)->rcv_nxt; in dctcp_ece_ack_update()
H A Dbpf_tcp_ca.c147 BPF_CALL_2(bpf_tcp_send_ack, struct tcp_sock *, tp, u32, rcv_nxt) in BPF_CALL_2()
150 __tcp_send_ack((struct sock *)tp, rcv_nxt); in BPF_CALL_2()
H A Dtcp_input.c668 if (before(tp->rcv_nxt, tp->rcv_rtt_est.seq)) in tcp_rcv_rtt_measure()
676 tp->rcv_rtt_est.seq = tp->rcv_nxt + tp->rcv_wnd; in tcp_rcv_rtt_measure()
3523 /* If we update tp->rcv_nxt, also update tp->bytes_received */
3526 u32 delta = seq - tp->rcv_nxt; in tcp_rcv_nxt_update()
3530 WRITE_ONCE(tp->rcv_nxt, seq); in tcp_rcv_nxt_update()
4264 (th->ack && seq == TCP_SKB_CB(skb)->end_seq && seq == tp->rcv_nxt) && in tcp_disordered_ack()
4301 !after(seq, tp->rcv_nxt + tcp_receive_window(tp)); in tcp_sequence()
4435 if (before(seq, tp->rcv_nxt)) in tcp_dsack_set()
4475 before(TCP_SKB_CB(skb)->seq, tp->rcv_nxt)) { in tcp_send_dupack()
4483 if (after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt)) in tcp_send_dupack()
[all...]
/kernel/linux/linux-6.6/net/ipv4/
H A Dtcp_fastopen.c173 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()
H A Dtcp_minisocks.c229 * and new good SYN with random sequence number <rcv_nxt. in tcp_timewait_state_process()
297 tcptw->tw_rcv_nxt = tp->rcv_nxt; in tcp_time_wait()
509 WRITE_ONCE(newtp->rcv_nxt, seq); in tcp_create_openreq_child()
740 tcp_rsk(req)->rcv_nxt, tcp_rsk(req)->rcv_nxt + req->rsk_rcv_wnd)) { in tcp_check_req()
757 if (tmp_opt.saw_tstamp && !after(TCP_SKB_CB(skb)->seq, tcp_rsk(req)->rcv_nxt)) in tcp_check_req()
H A Dtcp_dctcp.h35 *prior_rcv_nxt = tcp_sk(sk)->rcv_nxt; in dctcp_ece_ack_update()
H A Dbpf_tcp_ca.c128 BPF_CALL_2(bpf_tcp_send_ack, struct tcp_sock *, tp, u32, rcv_nxt) in BPF_CALL_2()
131 __tcp_send_ack((struct sock *)tp, rcv_nxt); in BPF_CALL_2()
H A Dtcp_input.c684 if (before(tp->rcv_nxt, tp->rcv_rtt_est.seq)) in tcp_rcv_rtt_measure()
692 tp->rcv_rtt_est.seq = tp->rcv_nxt + tp->rcv_wnd; in tcp_rcv_rtt_measure()
3555 /* If we update tp->rcv_nxt, also update tp->bytes_received */
3558 u32 delta = seq - tp->rcv_nxt; in tcp_rcv_nxt_update()
3562 WRITE_ONCE(tp->rcv_nxt, seq); in tcp_rcv_nxt_update()
4298 (th->ack && seq == TCP_SKB_CB(skb)->end_seq && seq == tp->rcv_nxt) && in tcp_disordered_ack()
4338 if (after(seq, tp->rcv_nxt + tcp_receive_window(tp))) in tcp_sequence()
4480 if (before(seq, tp->rcv_nxt)) in tcp_dsack_set()
4520 before(TCP_SKB_CB(skb)->seq, tp->rcv_nxt)) { in tcp_send_dupack()
4528 if (after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt)) in tcp_send_dupack()
[all...]
/kernel/linux/linux-5.10/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()
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...]
/kernel/linux/linux-6.6/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()
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...]
/kernel/linux/linux-5.10/tools/testing/selftests/bpf/progs/
H A Dbpf_dctcp.c60 ca->prior_rcv_nxt = tp->rcv_nxt; in BPF_PROG()
165 *prior_rcv_nxt = tcp_sk(sk)->rcv_nxt; in dctcp_ece_ack_update()
H A Dtest_sock_fields.c92 dst->rcv_nxt = src->rcv_nxt; in tpcpy()
/kernel/linux/linux-6.6/tools/testing/selftests/bpf/progs/
H A Dbpf_dctcp.c94 ca->prior_rcv_nxt = tp->rcv_nxt; in BPF_PROG()
199 *prior_rcv_nxt = tcp_sk(sk)->rcv_nxt; in dctcp_ece_ack_update()
H A Dtest_sock_fields.c92 dst->rcv_nxt = src->rcv_nxt; in tpcpy()
/kernel/linux/linux-5.10/include/linux/
H A Dtcp.h133 u32 rcv_nxt; /* the ack # by SYNACK. For member
163 * sum(delta(rcv_nxt)), or how many bytes
172 u32 rcv_nxt; /* What we want to receive next */ member
174 u32 rcv_wup; /* rcv_nxt on last window update sent */

Completed in 37 milliseconds

12345