/linux-master/net/tipc/ |
H A D | name_distr.h | 74 u16 *rcv_nxt, bool *open);
|
H A D | link.c | 102 * @rcv_nxt: next sequence number to expect for inbound messages 182 u16 rcv_nxt; member in struct:tipc_link 413 if (more(l->snd_nxt, l->rcv_nxt)) 414 gap = l->snd_nxt - l->rcv_nxt; 416 gap = buf_seqno(skb) - l->rcv_nxt; 441 return l->rcv_nxt; 997 l->rcv_nxt = 1; 1027 u16 bc_ack = l->bc_rcvlink->rcv_nxt - 1; 1028 u16 ack = l->rcv_nxt - 1; 1158 u16 bc_ack = l->bc_rcvlink->rcv_nxt 1776 u16 seqno, rcv_nxt, win_lim; local 2194 u16 rcv_nxt = l->rcv_nxt; local [all...] |
H A D | name_distr.c | 314 u16 *rcv_nxt, bool *open) 330 *rcv_nxt = seqno; 340 if (*open && (*rcv_nxt == seqno)) { 341 (*rcv_nxt)++; 347 if (less(seqno, *rcv_nxt)) { 361 * @rcv_nxt: store last received seqno here 365 u16 *rcv_nxt, bool *open) 374 while ((skb = tipc_named_dequeue(namedq, rcv_nxt, open))) { 313 tipc_named_dequeue(struct sk_buff_head *namedq, u16 *rcv_nxt, bool *open) argument 364 tipc_named_rcv(struct net *net, struct sk_buff_head *namedq, u16 *rcv_nxt, bool *open) argument
|
/linux-master/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, argument 214 packet.tcph.seq = htonl(rcv_nxt); 293 static void icmp6_interfere(int type, int code, uint32_t rcv_nxt, argument 326 packet.tcph.seq = htonl(rcv_nxt); 362 static void icmp_interfere(const size_t nr, uint32_t rcv_nxt, void *src, void *dst) argument 376 rcv_nxt, saddr4, daddr4); 378 rcv_nxt, saddr4, daddr4); 380 rcv_nxt, saddr4, daddr4); 385 rcv_nxt, saddr6, daddr6); 388 rcv_nxt, saddr 410 uint32_t rcv_nxt; local [all...] |
H A D | icmps-discard.c | 179 static void icmp_interfere4(uint8_t type, uint8_t code, uint32_t rcv_nxt, argument 214 packet.tcph.seq = htonl(rcv_nxt); 293 static void icmp6_interfere(int type, int code, uint32_t rcv_nxt, argument 326 packet.tcph.seq = htonl(rcv_nxt); 362 static void icmp_interfere(const size_t nr, uint32_t rcv_nxt, void *src, void *dst) argument 376 rcv_nxt, saddr4, daddr4); 378 rcv_nxt, saddr4, daddr4); 380 rcv_nxt, saddr4, daddr4); 385 rcv_nxt, saddr6, daddr6); 388 rcv_nxt, saddr 410 uint32_t rcv_nxt; local [all...] |
/linux-master/net/ipv4/ |
H A D | tcp_dctcp.h | 35 *prior_rcv_nxt = tcp_sk(sk)->rcv_nxt;
|
H A D | tcp_fastopen.c | 173 if (TCP_SKB_CB(skb)->end_seq == tp->rcv_nxt) 196 tp->rcv_nxt = TCP_SKB_CB(skb)->end_seq; 284 tp->rcv_nxt = TCP_SKB_CB(skb)->seq + 1; 288 tcp_rsk(req)->rcv_nxt = tp->rcv_nxt; 289 tp->rcv_wup = tp->rcv_nxt;
|
H A D | bpf_tcp_ca.c | 134 BPF_CALL_2(bpf_tcp_send_ack, struct tcp_sock *, tp, u32, rcv_nxt) 137 __tcp_send_ack((struct sock *)tp, rcv_nxt);
|
H A D | tcp_input.c | 677 if (before(tp->rcv_nxt, tp->rcv_rtt_est.seq)) 685 tp->rcv_rtt_est.seq = tp->rcv_nxt + tp->rcv_wnd; 3604 if (ao && seq < tp->rcv_nxt) 3609 /* If we update tp->rcv_nxt, also update tp->bytes_received */ 3612 u32 delta = seq - tp->rcv_nxt; 3617 WRITE_ONCE(tp->rcv_nxt, seq); 4389 (th->ack && seq == TCP_SKB_CB(skb)->end_seq && seq == tp->rcv_nxt) && 4430 if (after(seq, tp->rcv_nxt + tcp_receive_window(tp))) 4572 if (before(seq, tp->rcv_nxt)) 4623 before(TCP_SKB_CB(skb)->seq, tp->rcv_nxt)) { [all...] |
H A D | tcp_minisocks.c | 242 * and new good SYN with random sequence number <rcv_nxt. 309 tcptw->tw_rcv_nxt = tp->rcv_nxt; 537 WRITE_ONCE(newtp->rcv_nxt, seq); 787 tcp_rsk(req)->rcv_nxt, tcp_rsk(req)->rcv_nxt + req->rsk_rcv_wnd)) { 804 if (tmp_opt.saw_tstamp && !after(TCP_SKB_CB(skb)->seq, tcp_rsk(req)->rcv_nxt))
|
H A D | tcp_output.c | 180 static inline void tcp_event_ack_sent(struct sock *sk, u32 rcv_nxt) argument 192 if (unlikely(rcv_nxt != tp->rcv_nxt)) 289 tp->rcv_wup = tp->rcv_nxt; 1282 int clone_it, gfp_t gfp_mask, u32 rcv_nxt) 1379 th->ack_seq = htonl(rcv_nxt); 1436 tcp_event_ack_sent(sk, rcv_nxt); 1481 tcp_sk(sk)->rcv_nxt); 3777 th->ack_seq = htonl(tcp_rsk(req)->rcv_nxt); 3894 tp->rcv_nxt 1281 __tcp_transmit_skb(struct sock *sk, struct sk_buff *skb, int clone_it, gfp_t gfp_mask, u32 rcv_nxt) argument 4194 __tcp_send_ack(struct sock *sk, u32 rcv_nxt) argument [all...] |
H A D | tcp_dctcp.c | 87 ca->prior_rcv_nxt = tp->rcv_nxt;
|
H A D | tcp_diag.c | 29 r->idiag_rqueue = max_t(int, READ_ONCE(tp->rcv_nxt) -
|
H A D | tcp.c | 1454 tp->rcv_nxt - tp->rcv_wup > icsk->icsk_ack.rcv_mss || 1502 tp->copied_seq, TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt); 2293 u32 rcv_nxt = READ_ONCE(tp->rcv_nxt); local 2296 inq = rcv_nxt - copied_seq; 2299 inq = tp->rcv_nxt - tp->copied_seq; 2393 *seq, TCP_SKB_CB(skb)->seq, tp->rcv_nxt, 2408 *seq, TCP_SKB_CB(skb)->seq, tp->rcv_nxt, flags); 3009 WRITE_ONCE(tp->copied_seq, tp->rcv_nxt); 3134 if (after(opt.snd_wl1, tp->rcv_nxt [all...] |
/linux-master/tools/testing/selftests/bpf/progs/ |
H A D | bpf_dctcp.c | 94 ca->prior_rcv_nxt = tp->rcv_nxt; 199 *prior_rcv_nxt = tcp_sk(sk)->rcv_nxt;
|
H A D | test_sock_fields.c | 92 dst->rcv_nxt = src->rcv_nxt;
|
H A D | bpf_iter_tcp6.c | 118 rx_queue = tp->tcp.rcv_nxt - tp->tcp.copied_seq;
|
H A D | bpf_iter_tcp4.c | 118 rx_queue = tp->rcv_nxt - tp->copied_seq;
|
/linux-master/arch/sparc/kernel/ |
H A D | ldc.c | 136 u32 rcv_nxt; member in struct:ldc_channel 437 lp->rcv_nxt = 0; 476 p->u.r.ackid = lp->rcv_nxt; 500 p->u.r.ackid = lp->rcv_nxt; 681 lp->rcv_nxt = p->seqid; 709 return lp->rcv_nxt + 1 == seqid; 722 lp->rcv_nxt = p->seqid; 1496 lp->rcv_nxt, lp->snd_nxt); 1647 lp->rcv_nxt = first_frag->seqid - 1; 1731 p->u.r.ackid = lp->rcv_nxt; [all...] |
/linux-master/drivers/infiniband/hw/irdma/ |
H A D | cm.c | 354 cm_node->tcp_cntxt.loc_ack_num = cm_node->tcp_cntxt.rcv_nxt; 542 cm_node->tcp_cntxt.loc_ack_num = cm_node->tcp_cntxt.rcv_nxt; 2456 cm_node->tcp_cntxt.rcv_nxt++; 2463 cm_node->tcp_cntxt.rcv_nxt++; 2470 cm_node->tcp_cntxt.rcv_nxt++; 2481 cm_node->tcp_cntxt.rcv_nxt++; 2489 cm_node->tcp_cntxt.rcv_nxt++; 2639 u32 rcv_nxt = cm_node->tcp_cntxt.rcv_nxt; local 2647 !between(seq, rcv_nxt, (rcv_nx [all...] |
H A D | puda.c | 1413 pfpdu->rcv_nxt = seqnum + fpdu_len; 1512 pfpdu->rcv_nxt = buf->seqnum + len; 1519 pfpdu->rcv_nxt = buf->seqnum; 1548 if (buf->seqnum != pfpdu->rcv_nxt) { 1625 pfpdu->rcv_nxt = fps; 1637 if (!(rcv_wnd >= (buf->seqnum - pfpdu->rcv_nxt))) {
|
/linux-master/drivers/net/ethernet/chelsio/inline_crypto/chtls/ |
H A D | chtls_cm.c | 259 if (send_tx_flowc_wr(sk, 0, tp->snd_nxt, tp->rcv_nxt) < 0) 1647 tp->copied_seq != tp->rcv_nxt) { 1704 handle_urg_ptr(sk, tp->rcv_nxt + ntohs(hdr->urg)); 1706 tp->urg_seq - tp->rcv_nxt < skb->len)) 1708 skb->data[tp->urg_seq - tp->rcv_nxt]; 1712 csk->delack_seq = tp->rcv_nxt; 1716 tp->rcv_nxt += skb->len; 1769 tp->rcv_nxt < skb->len)) 1771 skb->data[tp->urg_seq - tp->rcv_nxt]; 1827 tp->rcv_nxt [all...] |
/linux-master/include/linux/ |
H A D | tcp.h | 164 u32 rcv_nxt; /* the ack # by SYNACK. For member in struct:tcp_request_sock 287 u32 rcv_nxt; /* What we want to receive next */ member in struct:tcp_sock 310 * sum(delta(rcv_nxt)), or how many bytes 319 u32 rcv_wup; /* rcv_nxt on last window update sent */
|
/linux-master/tools/testing/selftests/bpf/ |
H A D | bpf_tcp_helpers.h | 65 __u32 rcv_nxt; member in struct:tcp_sock
|
/linux-master/drivers/net/ethernet/sun/ |
H A D | sunvnet_common.c | 266 dr->rcv_nxt = 1; 270 dr->rcv_nxt = 1; 651 viodbg(DATA, "vnet_rx stype_env[%04x] seq[%016llx] rcv_nxt[%016llx]\n", 652 pkt->tag.stype_env, pkt->seq, dr->rcv_nxt); 656 if (unlikely(pkt->seq != dr->rcv_nxt)) { 657 pr_err("RX out of sequence seq[0x%llx] rcv_nxt[0x%llx]\n", 658 pkt->seq, dr->rcv_nxt); 663 dr->rcv_nxt++; 851 pkt->seq = dr->rcv_nxt;
|