Home
last modified time | relevance | path

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

12

/freebsd-12-stable/sys/netinet/
Dtcp_timewait.c302 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt) && in tcp_twstart()
303 recwin < (tp->rcv_adv - tp->rcv_nxt)) in tcp_twstart()
304 recwin = (tp->rcv_adv - tp->rcv_nxt); in tcp_twstart()
320 tw->rcv_nxt = tp->rcv_nxt; in tcp_twstart()
439 if ((thflags & TH_SYN) && SEQ_GT(th->th_seq, tw->rcv_nxt)) { in tcp_twcheck()
466 if (seq + 1 == tw->rcv_nxt) in tcp_twcheck()
474 th->th_seq != tw->rcv_nxt || th->th_ack != tw->snd_nxt) { in tcp_twcheck()
615 th->th_ack = htonl(tw->rcv_nxt); in tcp_twrespond()
Dtcp_reass.c555 KASSERT(SEQ_GEQ(th->th_seq, tp->rcv_nxt), in tcp_reass()
588 if ((th->th_seq != tp->rcv_nxt || !TCPS_HAVEESTABLISHED(tp->t_state)) && in tcp_reass()
728 if (SEQ_LT(th->th_seq, tp->rcv_nxt)) { in tcp_reass()
737 th->th_seq, tp->rcv_nxt, tp); in tcp_reass()
739 i = tp->rcv_nxt - th->th_seq; in tcp_reass()
951 if (th->th_seq == tp->rcv_nxt && TCPS_HAVEESTABLISHED(tp->t_state)) { in tcp_reass()
952 tp->rcv_nxt += *tlenp; in tcp_reass()
1050 KASSERT(q == NULL || SEQ_GEQ(q->tqe_start, tp->rcv_nxt), in tcp_reass()
1052 if (!q || q->tqe_start != tp->rcv_nxt) { in tcp_reass()
1060 tp->rcv_nxt += q->tqe_len; in tcp_reass()
[all …]
Dtcp_sack.c168 if (SEQ_LT(rcv_end, tp->rcv_nxt) || in tcp_update_dsack_list()
169 ((rcv_end == tp->rcv_nxt) && in tcp_update_dsack_list()
171 (tp->sackblks[0].end == tp->rcv_nxt))) { in tcp_update_dsack_list()
194 if (SEQ_GT(tp->rcv_nxt, end)) { in tcp_update_dsack_list()
226 if ((SEQ_LT(tp->rcv_nxt, mid_blk.end) && in tcp_update_dsack_list()
236 (SEQ_GT(tp->sackblks[j].start, tp->rcv_nxt)))) in tcp_update_dsack_list()
290 if (SEQ_GEQ(start, end) || SEQ_LEQ(start, tp->rcv_nxt)) { in tcp_update_sack_list()
406 if (SEQ_GEQ(start, end) || SEQ_LEQ(start, tp->rcv_nxt)) { in tcp_clean_dsack_blocks()
Dtcp_input.c1764 th->th_seq == tp->rcv_nxt && in tcp_do_segment()
1901 tp->rcv_nxt += tlen; in tcp_do_segment()
1911 tp->rcv_up = tp->rcv_nxt; in tcp_do_segment()
1960 tp->rcv_wnd = imax(win, (int)(tp->rcv_adv - tp->rcv_nxt)); in tcp_do_segment()
2205 tp->rcv_nxt, tp->snd_nxt, TH_ACK); in tcp_do_segment()
2206 tp->last_ack_sent = tp->rcv_nxt; in tcp_do_segment()
2229 tcp_respond(tp, mtod(m, void *), th, m, tp->rcv_nxt, in tcp_do_segment()
2231 tp->last_ack_sent = tp->rcv_nxt; in tcp_do_segment()
2280 todrop = tp->rcv_nxt - th->th_seq; in tcp_do_segment()
2363 todrop = (th->th_seq + tlen) - (tp->rcv_nxt + tp->rcv_wnd); in tcp_do_segment()
[all …]
Dtcp_output.c660 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt)) { in tcp_output()
661 oldwin = (tp->rcv_adv - tp->rcv_nxt); in tcp_output()
1199 th->th_ack = htonl(tp->rcv_nxt); in tcp_output()
1216 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt) && in tcp_output()
1217 recwin < (tp->rcv_adv - tp->rcv_nxt)) in tcp_output()
1218 recwin = (tp->rcv_adv - tp->rcv_nxt); in tcp_output()
1632 if (SEQ_GT(tp->rcv_nxt + recwin, tp->rcv_adv)) in tcp_output()
1633 tp->rcv_adv = tp->rcv_nxt + recwin; in tcp_output()
1634 tp->last_ack_sent = tp->rcv_nxt; in tcp_output()
Dtcp_seq.h70 (tp)->rcv_adv = (tp)->rcv_nxt = (tp)->irs + 1
Dtcp_debug.c220 (u_long)tp->rcv_nxt, (u_long)tp->rcv_wnd, (u_long)tp->rcv_up, in tcp_trace()
Dtcp_var.h124 tcp_seq rcv_nxt; /* receive next */ member
447 tcp_seq rcv_nxt; member
Dtcp_timer.c457 tp->rcv_nxt, tp->snd_una - 1, 0); in tcp_timer_keep()
/freebsd-12-stable/sys/netinet/tcp_stacks/
Drack_bbr_common.c460 todrop = tp->rcv_nxt - th->th_seq; in ctf_drop_checks()
519 todrop = (th->th_seq + tlen) - (tp->rcv_nxt + tp->rcv_wnd); in ctf_drop_checks()
531 if (tp->rcv_wnd == 0 && th->th_seq == tp->rcv_nxt) { in ctf_drop_checks()
624 (tp->rcv_nxt == th->th_seq) || in ctf_process_rst()
651 tp->rcv_nxt, tp->snd_nxt, TH_ACK); in ctf_process_rst()
652 tp->last_ack_sent = tp->rcv_nxt; in ctf_process_rst()
680 tcp_respond(tp, mtod(m, void *), th, m, tp->rcv_nxt, in ctf_challenge_ack()
682 tp->last_ack_sent = tp->rcv_nxt; in ctf_challenge_ack()
741 tp->rcv_wnd = imax(win, (int)(tp->rcv_adv - tp->rcv_nxt)); in ctf_calc_rwin()
Drack.c1550 tp->rcv_wnd = imax(win, (int)(tp->rcv_adv - tp->rcv_nxt)); in rack_calc_rwin()
1642 (tp->rcv_nxt == th->th_seq) || in rack_process_rst()
1669 tp->rcv_nxt, tp->snd_nxt, TH_ACK); in rack_process_rst()
1670 tp->last_ack_sent = tp->rcv_nxt; in rack_process_rst()
1698 tcp_respond(tp, mtod(m, void *), th, m, tp->rcv_nxt, in rack_challenge_ack()
1700 tp->last_ack_sent = tp->rcv_nxt; in rack_challenge_ack()
1760 todrop = tp->rcv_nxt - th->th_seq; in rack_drop_checks()
1825 todrop = (th->th_seq + tlen) - (tp->rcv_nxt + tp->rcv_wnd); in rack_drop_checks()
1837 if (tp->rcv_wnd == 0 && th->th_seq == tp->rcv_nxt) { in rack_drop_checks()
2860 tp->rcv_nxt, tp->snd_una - 1, 0); in rack_timeout_keepalive()
[all …]
/freebsd-12-stable/usr.sbin/cxgbetool/
Dtcb_common.c275 unsigned rcv_nxt,unsigned rx_frag0_start_idx_raw) in decompress_val() argument
290 tvp->val=(rcv_nxt+rx_frag0_start_idx_raw+fragx) & 0xFFFFFFFF; in decompress_val()
292 tvp->val=(rcv_nxt - rawval) & 0xFFFFFFFF; in decompress_val()
461 unsigned tx_max=0, rcv_nxt=0, rx_frag0_start_idx_raw=0; in parse_tcb() local
473 rcv_nxt=tvp->val; in parse_tcb()
496 decompress_val(tvp,ulp_type,tx_max,rcv_nxt,rx_frag0_start_idx_raw); in parse_tcb()
/freebsd-12-stable/sys/dev/cxgbe/tom/
Dt4_ddp.c302 tp->rcv_nxt += n; in insert_ddp_data()
475 handle_ddp_data(struct toepcb *toep, __be32 ddp_report, __be32 rcv_nxt, int len) in handle_ddp_data() argument
509 __func__, toep->tid, be32toh(rcv_nxt), len, inp->inp_flags); in handle_ddp_data()
529 len += be32toh(rcv_nxt) - tp->rcv_nxt; in handle_ddp_data()
530 tp->rcv_nxt += len; in handle_ddp_data()
698 handle_ddp_close(struct toepcb *toep, struct tcpcb *tp, __be32 rcv_nxt) in handle_ddp_close() argument
709 len = be32toh(rcv_nxt) - tp->rcv_nxt; in handle_ddp_close()
710 tp->rcv_nxt += len; in handle_ddp_close()
796 handle_ddp_data(toep, cpl->ddp_report, cpl->rcv_nxt, 0); in do_rx_ddp_complete()
Dt4_cpl_io.c162 FLOWC_PARAM(RCVNXT, tp->rcv_nxt); in send_flowc_wr()
168 tp ? tp->snd_nxt : 0, tp ? tp->rcv_nxt : 0); in send_flowc_wr()
404 tp->last_ack_sent = tp->rcv_nxt; in make_established()
1238 tp->rcv_nxt++; /* FIN */ in do_peer_close()
1246 handle_ddp_close(toep, tp, cpl->rcv_nxt); in do_peer_close()
1251 KASSERT(tp->rcv_nxt == be32toh(cpl->rcv_nxt), in do_peer_close()
1252 ("%s: rcv_nxt mismatch: %u %u", __func__, tp->rcv_nxt, in do_peer_close()
1253 be32toh(cpl->rcv_nxt))); in do_peer_close()
1565 if (__predict_false(tp->rcv_nxt != be32toh(cpl->seq))) in do_rx_data()
1566 ddp_placed = be32toh(cpl->seq) - tp->rcv_nxt; in do_rx_data()
[all …]
Dt4_tls.c1492 __func__, tid, pdu_length, len, be32toh(cpl->seq), tp->rcv_nxt); in do_rx_tls_cmp()
1495 tp->rcv_nxt += pdu_length; in do_rx_tls_cmp()
1626 tp->rcv_nxt += len; in do_rx_data_tls()
/freebsd-12-stable/sys/ofed/drivers/infiniband/ulp/sdp/
Dsdp.h409 #define rcv_nxt(ssk) atomic_read(&(ssk->rcv_nxt)) macro
410 atomic_t rcv_nxt; member
Dsdp_rx.c210 SDP_SKB_CB(mb)->seq = rcv_nxt(ssk); in sdp_sock_queue_rcv_mb()
234 atomic_add(mb->len, &ssk->rcv_nxt); in sdp_sock_queue_rcv_mb()
240 atomic_add(mb->m_pkthdr.len, &ssk->rcv_nxt); in sdp_sock_queue_rcv_mb()
Dsdp_proc.c146 rx_queue = rcv_nxt(sdp_sk(sk)) - sdp_sk(sk)->copied_seq; in sdp_seq_show()
Dsdp_cma.c255 if (rcv_nxt(ssk)) in sdp_disconnected_handler()
Dsdp_zcopy.c603 atomic_add(copied, &ssk->rcv_nxt); in sdp_rdma_to_iovec()
/freebsd-12-stable/sbin/ipf/ipsend/
Dsock.c305 ti->ti_ack = tcb.rcv_nxt; in do_socket()
/freebsd-12-stable/sys/dev/cxgbe/cxgbei/
Dcxgbei.c393 MPASS(icp->icp_seq == tp->rcv_nxt); in do_rx_iscsi_ddp()
395 tp->rcv_nxt += pdu_len; in do_rx_iscsi_ddp()
/freebsd-12-stable/usr.sbin/trpt/
Dtrpt.c422 (u_long)tp->rcv_nxt, (u_long)tp->rcv_wnd, in tcp_trace()
/freebsd-12-stable/cddl/lib/libdtrace/
Dtcp.d234 tcps_rnxt = p == NULL ? 0 : p->rcv_nxt;
/freebsd-12-stable/sys/dev/cxgb/common/
Dcxgb_t3_cpl.h771 __be32 rcv_nxt; member
828 __be32 rcv_nxt; member

12