Searched refs:rcv_nxt (Results 1 – 11 of 11) sorted by relevance
/net/tipc/ |
D | link.c | 168 u16 rcv_nxt; member 381 if (more(l->snd_nxt, l->rcv_nxt)) in link_bc_rcv_gap() 382 gap = l->snd_nxt - l->rcv_nxt; in link_bc_rcv_gap() 384 gap = buf_seqno(skb) - l->rcv_nxt; in link_bc_rcv_gap() 400 return l->rcv_nxt; in tipc_link_rcv_nxt() 862 l->rcv_nxt = 1; in tipc_link_reset() 889 u16 ack = l->rcv_nxt - 1; in tipc_link_xmit() 891 u16 bc_ack = l->bc_rcvlink->rcv_nxt - 1; in tipc_link_xmit() 967 u16 ack = l->rcv_nxt - 1; in tipc_link_advance_backlog() 968 u16 bc_ack = l->bc_rcvlink->rcv_nxt - 1; in tipc_link_advance_backlog() [all …]
|
D | node.c | 1377 u16 rcv_nxt, syncpt, dlv_nxt, inputq_len; in tipc_node_check_state() local 1386 rcv_nxt = tipc_link_rcv_nxt(l); in tipc_node_check_state() 1420 if ((usr != LINK_PROTOCOL) && less(oseqno, rcv_nxt)) in tipc_node_check_state() 1438 if (!more(rcv_nxt, n->sync_point)) in tipc_node_check_state()
|
/net/ipv4/ |
D | tcp_fastopen.c | 137 if (TCP_SKB_CB(skb)->end_seq == tp->rcv_nxt) in tcp_fastopen_add_skb() 160 tp->rcv_nxt = TCP_SKB_CB(skb)->end_seq; in tcp_fastopen_add_skb() 227 tp->rcv_nxt = TCP_SKB_CB(skb)->seq + 1; in tcp_fastopen_create_child() 231 tcp_rsk(req)->rcv_nxt = tp->rcv_nxt; in tcp_fastopen_create_child() 232 tp->rcv_wup = tp->rcv_nxt; in tcp_fastopen_create_child()
|
D | tcp_input.c | 563 if (before(tp->rcv_nxt, tp->rcv_rtt_est.seq)) in tcp_rcv_rtt_measure() 571 tp->rcv_rtt_est.seq = tp->rcv_nxt + tp->rcv_wnd; in tcp_rcv_rtt_measure() 3382 u32 delta = seq - tp->rcv_nxt; in tcp_rcv_nxt_update() 3386 tp->rcv_nxt = seq; in tcp_rcv_nxt_update() 3989 (th->ack && seq == TCP_SKB_CB(skb)->end_seq && seq == tp->rcv_nxt) && in tcp_disordered_ack() 4026 !after(seq, tp->rcv_nxt + tcp_receive_window(tp)); in tcp_sequence() 4158 if (before(seq, tp->rcv_nxt)) in tcp_dsack_set() 4186 before(TCP_SKB_CB(skb)->seq, tp->rcv_nxt)) { in tcp_send_dupack() 4193 if (after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt)) in tcp_send_dupack() 4194 end_seq = tp->rcv_nxt; in tcp_send_dupack() [all …]
|
D | tcp_dctcp.c | 89 ca->prior_rcv_nxt = tp->rcv_nxt; in dctcp_init() 137 ca->prior_rcv_nxt = tp->rcv_nxt; in dctcp_ce_state_0_to_1() 158 ca->prior_rcv_nxt = tp->rcv_nxt; in dctcp_ce_state_1_to_0()
|
D | tcp_minisocks.c | 269 tcptw->tw_rcv_nxt = tp->rcv_nxt; in tcp_time_wait() 449 newtp->rcv_nxt = treq->rcv_isn + 1; in tcp_create_openreq_child() 704 tcp_rsk(req)->rcv_nxt, tcp_rsk(req)->rcv_nxt + req->rsk_rcv_wnd)) { in tcp_check_req() 718 if (tmp_opt.saw_tstamp && !after(TCP_SKB_CB(skb)->seq, tcp_rsk(req)->rcv_nxt)) in tcp_check_req()
|
D | tcp_output.c | 179 u32 rcv_nxt) in tcp_event_ack_sent() argument 183 if (unlikely(rcv_nxt != tp->rcv_nxt)) in tcp_event_ack_sent() 290 tp->rcv_wup = tp->rcv_nxt; in tcp_select_window() 994 int clone_it, gfp_t gfp_mask, u32 rcv_nxt) in __tcp_transmit_skb() argument 1066 th->ack_seq = htonl(rcv_nxt); in __tcp_transmit_skb() 1107 tcp_event_ack_sent(sk, tcp_skb_pcount(skb), rcv_nxt); in __tcp_transmit_skb() 1148 tcp_sk(sk)->rcv_nxt); in tcp_transmit_skb() 3272 th->ack_seq = htonl(tcp_rsk(req)->rcv_nxt); in tcp_make_synack() 3379 tp->rcv_nxt = 0; in tcp_connect_init() 3382 tp->rcv_wup = tp->rcv_nxt; in tcp_connect_init() [all …]
|
D | tcp.c | 544 if (tp->rcv_nxt - tp->copied_seq >= target) in tcp_poll() 1546 tp->copied_seq, TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt); in tcp_cleanup_rbuf() 1554 tp->rcv_nxt - tp->rcv_wup > icsk->icsk_ack.rcv_mss || in tcp_cleanup_rbuf() 1852 *seq, TCP_SKB_CB(skb)->seq, tp->rcv_nxt, in tcp_recvmsg() 1867 *seq, TCP_SKB_CB(skb)->seq, tp->rcv_nxt, flags); in tcp_recvmsg() 2428 if (after(opt.snd_wl1, tp->rcv_nxt + opt.rcv_wnd)) in tcp_repair_set_window() 2431 if (after(opt.rcv_wup, tp->rcv_nxt)) in tcp_repair_set_window() 2632 tp->rcv_nxt = val; in do_tcp_setsockopt() 3179 val = tp->rcv_nxt; in do_tcp_getsockopt()
|
D | tcp_diag.c | 33 r->idiag_rqueue = max_t(int, tp->rcv_nxt - tp->copied_seq, 0); in tcp_diag_get_info()
|
D | tcp_ipv4.c | 843 tcp_rsk(req)->rcv_nxt, in tcp_v4_reqsk_send_ack() 2284 rx_queue = max_t(int, tp->rcv_nxt - tp->copied_seq, 0); in get_tcp4_sock()
|
/net/ipv6/ |
D | tcp_ipv6.c | 988 tcp_rsk(req)->rcv_nxt, in tcp_v6_reqsk_send_ack() 1354 if (TCP_SKB_CB(opt_skb)->end_seq == tp->rcv_nxt && in tcp_v6_do_rcv() 1804 rx_queue = max_t(int, tp->rcv_nxt - tp->copied_seq, 0); in get_tcp6_sock()
|