| /linux/tools/testing/selftests/net/tcp_ao/ |
| H A D | icmps-accept.c | 179 static void icmp_interfere4(uint8_t type, uint8_t code, uint32_t rcv_nxt, in icmp_interfere4() argument
214 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()
362 static void icmp_interfere(const size_t nr, uint32_t rcv_nxt, void *src, void *dst) in icmp_interfere() argument
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, saddr in icmp_interfere()
410 uint32_t rcv_nxt; send_interfered() local
[all...] |
| H A D | icmps-discard.c | 179 static void icmp_interfere4(uint8_t type, uint8_t code, uint32_t rcv_nxt, in icmp_interfere4() argument
214 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()
362 static void icmp_interfere(const size_t nr, uint32_t rcv_nxt, void *src, void *dst) in icmp_interfere() argument
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()
[all …]
|
| /linux/net/ipv4/ |
| H A D | tcp_minisocks.c | 58 u32 rcv_nxt) in twsk_rcv_nxt_update() argument
64 if (unlikely(ao && seq < rcv_nxt)) in twsk_rcv_nxt_update()
106 u32 rcv_nxt = READ_ONCE(tcptw->tw_rcv_nxt); in tcp_timewait_state_process() local
141 rcv_nxt, in tcp_timewait_state_process()
142 rcv_nxt + tcptw->tw_rcv_wnd)) in tcp_timewait_state_process()
149 if (th->syn && !before(TCP_SKB_CB(skb)->seq, rcv_nxt)) in tcp_timewait_state_process()
154 !after(TCP_SKB_CB(skb)->end_seq, rcv_nxt) || in tcp_timewait_state_process()
164 TCP_SKB_CB(skb)->end_seq != rcv_nxt + 1) in tcp_timewait_state_process()
170 rcv_nxt); in tcp_timewait_state_process()
204 (TCP_SKB_CB(skb)->seq == rcv_nxt in tcp_timewait_state_process()
[all...] |
| H A D | tcp_fastopen.c | 261 if (TCP_SKB_CB(skb)->end_seq == tp->rcv_nxt) in tcp_fastopen_add_skb()
284 tp->rcv_nxt = TCP_SKB_CB(skb)->end_seq; in tcp_fastopen_add_skb()
374 tp->rcv_nxt = TCP_SKB_CB(skb)->seq + 1; in tcp_fastopen_create_child()
378 tcp_rsk(req)->rcv_nxt = tp->rcv_nxt; in tcp_fastopen_create_child()
379 tp->rcv_wup = tp->rcv_nxt; in tcp_fastopen_create_child()
|
| H A D | tcp_input.c | 850 if (tp->rcv_nxt != tp->copied_seq) in tcp_rcv_rtt_update()
864 if (before(tp->rcv_nxt, tp->rcv_rtt_est.seq)) in tcp_rcv_rtt_measure()
872 tp->rcv_rtt_est.seq = tp->rcv_nxt + tp->rcv_wnd; in tcp_rcv_rtt_measure()
944 rcvwin += TCP_SKB_CB(tp->ooo_last_skb)->end_seq - tp->rcv_nxt; in tcp_rcvbuf_grow()
981 inq = tp->rcv_nxt - tp->copied_seq; in tcp_rcv_space_adjust()
3928 if (ao && seq < tp->rcv_nxt) { in tcp_rcv_sne_update()
3935 /* If we update tp->rcv_nxt, also update tp->bytes_received */
3938 u32 delta = seq - tp->rcv_nxt; in tcp_rcv_nxt_update()
3943 WRITE_ONCE(tp->rcv_nxt, seq); in tcp_rcv_nxt_update()
4038 __tcp_send_ack(sk, tp->rcv_nxt, flag in tcp_send_ack_reflect_ect()
[all...] |
| H A D | bpf_tcp_ca.c | 121 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 D | tcp_output.c | 198 static inline void tcp_event_ack_sent(struct sock *sk, u32 rcv_nxt) in tcp_event_data_sent()
210 if (unlikely(rcv_nxt != tp->rcv_nxt)) in tcp_event_ack_sent()
288 tp->rcv_wup = tp->rcv_nxt; in tcp_select_window()
312 tp->rcv_wup = tp->rcv_nxt; in tcp_select_window()
1537 int clone_it, gfp_t gfp_mask, u32 rcv_nxt) in __tcp_transmit_skb()
1634 th->ack_seq = htonl(rcv_nxt); in __tcp_transmit_skb()
1688 tcp_event_ack_sent(sk, rcv_nxt); in __tcp_transmit_skb()
1735 tcp_sk(sk)->rcv_nxt); in tcp_transmit_skb()
4047 th->ack_seq = htonl(tcp_rsk(req)->rcv_nxt); in tcp_make_synack()
204 tcp_event_ack_sent(struct sock * sk,u32 rcv_nxt) tcp_event_ack_sent() argument
1530 __tcp_transmit_skb(struct sock * sk,struct sk_buff * skb,int clone_it,gfp_t gfp_mask,u32 rcv_nxt) __tcp_transmit_skb() argument
4461 __tcp_send_ack(struct sock * sk,u32 rcv_nxt,u16 flags) __tcp_send_ack() argument
[all...] |
| H A D | tcp.c | 1560 tp->rcv_nxt - tp->rcv_wup > icsk->icsk_ack.rcv_mss || in __tcp_cleanup_rbuf()
1610 tp->copied_seq, TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt); in tcp_cleanup_rbuf()
2417 u32 rcv_nxt = READ_ONCE(tp->rcv_nxt); in tcp_inq_hint()
2420 inq = rcv_nxt - copied_seq; in tcp_inq_hint()
2423 inq = tp->rcv_nxt - tp->copied_seq; in tcp_inq_hint()
2731 *seq, TCP_SKB_CB(skb)->seq, tp->rcv_nxt, in tcp_recvmsg_locked()
2746 *seq, TCP_SKB_CB(skb)->seq, tp->rcv_nxt, flags); in tcp_recvmsg_locked()
3394 WRITE_ONCE(tp->copied_seq, tp->rcv_nxt); in tcp_disconnect()
3530 if (after(opt.snd_wl1, tp->rcv_nxt in tcp_repair_set_window()
2418 u32 rcv_nxt = READ_ONCE(tp->rcv_nxt); tcp_inq_hint() local
[all...] |
| /linux/net/tipc/ |
| H A D | link.c | 182 u16 rcv_nxt; member
406 if (more(l->snd_nxt, l->rcv_nxt)) in link_bc_rcv_gap()
407 gap = l->snd_nxt - l->rcv_nxt; in link_bc_rcv_gap()
409 gap = buf_seqno(skb) - l->rcv_nxt; in link_bc_rcv_gap()
434 return l->rcv_nxt; in tipc_link_rcv_nxt()
987 l->rcv_nxt = 1; in tipc_link_reset()
1017 u16 bc_ack = l->bc_rcvlink->rcv_nxt - 1; in tipc_link_xmit()
1018 u16 ack = l->rcv_nxt - 1; in tipc_link_xmit()
1149 u16 bc_ack = l->bc_rcvlink->rcv_nxt - 1; in tipc_link_advance_backlog()
1152 u16 ack = l->rcv_nxt - 1; in tipc_link_advance_backlog()
[all …]
|
| H A D | name_distr.c | 323 u16 *rcv_nxt, bool *open) in tipc_named_dequeue()
339 *rcv_nxt = seqno; in tipc_named_dequeue()
349 if (*open && (*rcv_nxt == seqno)) { in tipc_named_dequeue()
350 (*rcv_nxt)++; in tipc_named_dequeue()
356 if (less(seqno, *rcv_nxt)) {
370 * @rcv_nxt: store last received seqno here in tipc_named_rcv()
374 u16 *rcv_nxt, bool *open) in tipc_named_rcv()
383 while ((skb = tipc_named_dequeue(namedq, rcv_nxt, open))) { in tipc_named_rcv()
314 tipc_named_dequeue(struct sk_buff_head * namedq,u16 * rcv_nxt,bool * open) tipc_named_dequeue() argument
365 tipc_named_rcv(struct net * net,struct sk_buff_head * namedq,u16 * rcv_nxt,bool * open) tipc_named_rcv() argument
|
| H A D | name_distr.h | 74 u16 *rcv_nxt, bool *open);
|
| /linux/arch/sparc/kernel/ |
| H A 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/tools/testing/selftests/bpf/progs/ |
| H A D | bpf_dctcp.c | 95 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 D | test_sock_fields.c | 95 dst->rcv_nxt = src->rcv_nxt; in tpcpy()
|
| H A D | bpf_iter_tcp4.c | 118 rx_queue = tp->rcv_nxt - tp->copied_seq; in dump_tcp_sock()
|
| H A D | bpf_iter_tcp6.c | 118 rx_queue = tp->tcp.rcv_nxt - tp->tcp.copied_seq; in dump_tcp6_sock()
|
| /linux/drivers/net/ethernet/chelsio/inline_crypto/chtls/ |
| H A D | chtls_cm.c | |
| /linux/drivers/infiniband/hw/irdma/ |
| H A 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()
2461 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2468 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2475 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2486 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2494 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2644 u32 rcv_nxt = cm_node->tcp_cntxt.rcv_nxt; in irdma_check_seq() local
2652 !between(seq, rcv_nxt, (rcv_nxt + rcv_wnd))) in irdma_check_seq()
2716 cm_node->tcp_cntxt.rcv_nxt = inc_sequence + 1; in irdma_handle_syn_pkt()
[all …]
|
| H A D | cm.h | 226 u32 rcv_nxt; member
|
| /linux/drivers/net/ethernet/sun/ |
| H A D | sunvnet_common.c | 266 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/drivers/scsi/cxgbi/cxgb4i/ |
| H A 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()
|
| /linux/drivers/target/iscsi/cxgbit/ |
| H A D | cxgbit.h | 219 u32 rcv_nxt; member
|
| /linux/net/psp/ |
| H A D | psp_sock.c | 236 pas->upgrade_seq = tcp_sk(sk)->rcv_nxt; in psp_sock_assoc_set_tx()
|
| /linux/include/net/ |
| H A D | tcp.h | 772 void __tcp_send_ack(struct sock *sk, u32 rcv_nxt, u16 flags);
928 s32 win = tp->rcv_wup + tp->rcv_wnd - tp->rcv_nxt; in tcp_receive_window()
941 s32 win = tp->rcv_mwnd_seq - tp->rcv_nxt; in tcp_max_receive_window()
1826 int avail = READ_ONCE(tp->rcv_nxt) - READ_ONCE(tp->copied_seq);
2749 !before(tp->urg_seq, tp->rcv_nxt)) { in skb_is_tcp_pure_ack()
2751 answ = tp->rcv_nxt - tp->copied_seq; in skb_set_tcp_pure_ack()
|
| /linux/arch/sparc/include/asm/ |
| H A D | vio.h | 277 u64 rcv_nxt; member
|