Home
last modified time | relevance | path

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

12

/freebsd/sys/netinet/
H A Dtcp_timewait.c253 if (rfc6191 || SEQ_GT(th->th_seq, tp->rcv_nxt)) { in tcp_twcheck()
311 if (seq + 1 == tp->rcv_nxt) in tcp_twcheck()
319 th->th_seq != tp->rcv_nxt || th->th_ack != tp->snd_nxt) { in tcp_twcheck()
323 tcp_respond(tp, mtod(m, void *), th, m, tp->rcv_nxt, in tcp_twcheck()
H A Dtcp_reass.c545 KASSERT(SEQ_GEQ(th->th_seq, tp->rcv_nxt), in tcp_reass()
591 if ((th->th_seq != tp->rcv_nxt || !TCPS_HAVEESTABLISHED(tp->t_state)) && in tcp_reass()
731 if (SEQ_LT(th->th_seq, tp->rcv_nxt)) { in tcp_reass()
740 th->th_seq, tp->rcv_nxt, tp); in tcp_reass()
742 i = tp->rcv_nxt - th->th_seq; in tcp_reass()
954 if (th->th_seq == tp->rcv_nxt && TCPS_HAVEESTABLISHED(tp->t_state)) { in tcp_reass()
955 tp->rcv_nxt += *tlenp; in tcp_reass()
1052 KASSERT(q == NULL || SEQ_GEQ(q->tqe_start, tp->rcv_nxt), in tcp_reass()
1054 if (!q || q->tqe_start != tp->rcv_nxt) { in tcp_reass()
1062 tp->rcv_nxt += q->tqe_len; in tcp_reass()
[all …]
H A Dtcp_sack.c160 if (SEQ_LEQ(tp->sackblks[0].end, tp->rcv_nxt)) in tcp_dsack_block_exists()
180 if (SEQ_LT(rcv_end, tp->rcv_nxt) || in tcp_update_dsack_list()
181 ((rcv_end == tp->rcv_nxt) && in tcp_update_dsack_list()
183 (tp->sackblks[0].end == tp->rcv_nxt))) { in tcp_update_dsack_list()
206 if (SEQ_GT(tp->rcv_nxt, end)) { in tcp_update_dsack_list()
238 if ((SEQ_LT(tp->rcv_nxt, mid_blk.end) && in tcp_update_dsack_list()
248 (SEQ_GT(tp->sackblks[j].start, tp->rcv_nxt)))) in tcp_update_dsack_list()
302 if (SEQ_GEQ(start, end) || SEQ_LEQ(start, tp->rcv_nxt)) { in tcp_update_sack_list()
418 if (SEQ_GEQ(start, end) || SEQ_LEQ(start, tp->rcv_nxt)) { in tcp_clean_dsack_blocks()
H A Dtcp_output.c667 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt)) { in tcp_default_output()
668 oldwin = (tp->rcv_adv - tp->rcv_nxt); in tcp_default_output()
1264 th->th_ack = htonl(tp->rcv_nxt); in tcp_default_output()
1280 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt) && in tcp_default_output()
1281 recwin < (tp->rcv_adv - tp->rcv_nxt)) in tcp_default_output()
1282 recwin = (tp->rcv_adv - tp->rcv_nxt); in tcp_default_output()
1732 if (SEQ_GT(tp->rcv_nxt + recwin, tp->rcv_adv)) in tcp_default_output()
1733 tp->rcv_adv = tp->rcv_nxt + recwin; in tcp_default_output()
1734 tp->last_ack_sent = tp->rcv_nxt; in tcp_default_output()
H A Dtcp_input.c1719 th->th_seq == tp->rcv_nxt && in tcp_do_segment()
1870 tp->rcv_nxt += tlen; in tcp_do_segment()
1889 tp->rcv_up = tp->rcv_nxt; in tcp_do_segment()
1933 tp->rcv_wnd = imax(win, (int)(tp->rcv_adv - tp->rcv_nxt)); in tcp_do_segment()
2230 todrop = tp->rcv_nxt - th->th_seq; in tcp_do_segment()
2314 todrop = (th->th_seq + tlen) - (tp->rcv_nxt + tp->rcv_wnd); in tcp_do_segment()
2326 if (tp->rcv_wnd == 0 && th->th_seq == tp->rcv_nxt) { in tcp_do_segment()
3106 (tp->rcv_up - tp->rcv_nxt) - 1; in tcp_do_segment()
3130 if (SEQ_GT(tp->rcv_nxt, tp->rcv_up)) in tcp_do_segment()
3131 tp->rcv_up = tp->rcv_nxt; in tcp_do_segment()
[all …]
H A Dtcp_seq.h67 (tp)->rcv_adv = (tp)->rcv_nxt = (tp)->irs + 1
/freebsd/usr.sbin/cxgbetool/
H A Dtcb_common.c282 unsigned rcv_nxt,unsigned rx_frag0_start_idx_raw) in decompress_val()
297 tvp->val=(rcv_nxt+rx_frag0_start_idx_raw+fragx) & 0xFFFFFFFF; in decompress_val()
299 tvp->val=(rcv_nxt - rawval) & 0xFFFFFFFF; in decompress_val()
474 unsigned tx_max=0, rcv_nxt=0, rx_frag0_start_idx_raw=0; in parse_tcb()
485 if (!got_rcv_nxt && tcb_strmatch_nc("rcv_nxt",tvp->name)) { in parse_tcb()
486 rcv_nxt=tvp->val; in parse_tcb()
509 decompress_val(tvp,ulp_type,tx_max,rcv_nxt,rx_frag0_start_idx_raw); in parse_scb()
273 decompress_val(_TCBVAR * tvp,unsigned ulp_type,unsigned tx_max,unsigned rcv_nxt,unsigned rx_frag0_start_idx_raw) decompress_val() argument
459 unsigned tx_max=0, rcv_nxt=0, rx_frag0_start_idx_raw=0; parse_tcb() local
/freebsd/sys/netinet/tcp_stacks/
H A Drack_bbr_common.c553 todrop = tp->rcv_nxt - th->th_seq; in ctf_drop_checks()
614 todrop = (th->th_seq + tlen) - (tp->rcv_nxt + tp->rcv_wnd); in ctf_drop_checks()
626 if (tp->rcv_wnd == 0 && th->th_seq == tp->rcv_nxt) { in ctf_drop_checks()
718 (tp->rcv_nxt == th->th_seq)) { in ctf_process_rst()
772 tcp_respond(tp, mtod(m, void *), th, m, tp->rcv_nxt, in ctf_challenge_ack()
774 tp->last_ack_sent = tp->rcv_nxt; in ctf_challenge_ack()
859 tp->rcv_wnd = imax(win, (int)(tp->rcv_adv - tp->rcv_nxt)); in ctf_calc_rwin()
H A Dbbr.c4774 tp->rcv_nxt, tp->snd_una - 1, 0); in bbr_timeout_persist()
4830 tp->rcv_nxt, tp->snd_una - 1, 0); in bbr_timeout_keepalive()
8202 tp->rcv_up = tp->rcv_nxt; in bbr_process_data()
8217 tcp_seq save_rnxt = tp->rcv_nxt; in bbr_process_data()
8232 if (th->th_seq == tp->rcv_nxt && in bbr_process_data()
8259 tp->rcv_nxt += tlen; in bbr_process_data()
8315 } else if ((tlen > 0) && SEQ_GT(tp->rcv_nxt, save_rnxt)) { in bbr_process_data()
8365 tp->rcv_nxt++; in bbr_process_data()
8482 tp->rcv_nxt += tlen; in bbr_do_fastnewdata()
8499 tp->rcv_up = tp->rcv_nxt; in bbr_do_fastnewdata()
[all …]
/freebsd/sys/dev/cxgbe/tom/
H A Dt4_ddp.c480 tp->rcv_nxt += n; in insert_ddp_data()
638 handle_ddp_data_aio(struct toepcb *toep, __be32 ddp_report, __be32 rcv_nxt, in handle_ddp_data_aio() argument
673 __func__, toep->tid, be32toh(rcv_nxt), len, tp->t_flags); in handle_ddp_data_aio()
693 len += be32toh(rcv_nxt) - tp->rcv_nxt; in handle_ddp_data_aio()
694 tp->rcv_nxt += len; in handle_ddp_data_aio()
857 handle_ddp_data_rcvbuf(struct toepcb *toep, __be32 ddp_report, __be32 rcv_nxt, in handle_ddp_data_rcvbuf() argument
890 __func__, toep->tid, be32toh(rcv_nxt), len, tp->t_flags); in handle_ddp_data_rcvbuf()
908 len += be32toh(rcv_nxt) - tp->rcv_nxt; in handle_ddp_data_rcvbuf()
909 tp->rcv_nxt += len; in handle_ddp_data_rcvbuf()
971 handle_ddp_data(struct toepcb *toep, __be32 ddp_report, __be32 rcv_nxt, int len) in handle_ddp_data() argument
[all …]
H A Dt4_cpl_io.c139 FLOWC_PARAM(RCVNXT, tp->rcv_nxt); in send_flowc_wr()
145 tp ? tp->snd_nxt : 0, tp ? tp->rcv_nxt : 0); in send_flowc_wr()
382 tp->last_ack_sent = tp->rcv_nxt; in make_established()
1697 handle_ddp_close(toep, tp, cpl->rcv_nxt); in do_peer_close()
1713 KASSERT(tp->rcv_nxt + 1 == be32toh(cpl->rcv_nxt), in do_peer_close()
1714 ("%s: rcv_nxt mismatch: %u %u", __func__, tp->rcv_nxt, in do_peer_close()
1715 be32toh(cpl->rcv_nxt))); in do_peer_close()
1718 tp->rcv_nxt = be32toh(cpl->rcv_nxt); in do_peer_close()
2032 if (__predict_false(tp->rcv_nxt != be32toh(cpl->seq))) in do_rx_data()
2033 ddp_placed = be32toh(cpl->seq) - tp->rcv_nxt; in do_rx_data()
[all …]
H A Dt4_tls.c867 __func__, tid, pdu_length, len, be32toh(cpl->seq), tp->rcv_nxt); in do_rx_tls_cmp()
870 tp->rcv_nxt += pdu_length; in do_rx_tls_cmp()
1080 tp->rcv_nxt += len; in do_rx_data_tls()
/freebsd/sys/dev/irdma/
H A Dirdma_cm.c488 cm_node->tcp_cntxt.loc_ack_num = cm_node->tcp_cntxt.rcv_nxt; in irdma_form_ah_cm_frame()
675 cm_node->tcp_cntxt.loc_ack_num = cm_node->tcp_cntxt.rcv_nxt; in irdma_form_uda_cm_frame()
2438 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2445 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2454 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2464 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2472 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2626 u32 rcv_nxt = cm_node->tcp_cntxt.rcv_nxt; in irdma_check_seq() local
2634 !between(seq, rcv_nxt, (rcv_nxt + rcv_wnd))) in irdma_check_seq()
2700 cm_node->tcp_cntxt.rcv_nxt = inc_sequence + 1; in irdma_handle_syn_pkt()
[all …]
H A Dirdma_puda.c1534 pfpdu->rcv_nxt = seqnum + fpdu_len; in irdma_ieq_handle_partial()
1635 pfpdu->rcv_nxt = buf->seqnum + len; in irdma_ieq_process_buf()
1642 pfpdu->rcv_nxt = buf->seqnum; in irdma_ieq_process_buf()
1673 if (buf->seqnum != pfpdu->rcv_nxt) { in irdma_ieq_process_fpdus()
1755 pfpdu->rcv_nxt = fps; in irdma_ieq_handle_exception()
1767 if (!(rcv_wnd >= (buf->seqnum - pfpdu->rcv_nxt))) { in irdma_ieq_handle_exception()
H A Dirdma_cm.h258 u32 rcv_nxt; member
H A Dirdma_type.h359 u32 rcv_nxt; member
942 u32 rcv_nxt; member
/freebsd/sys/ofed/drivers/infiniband/ulp/sdp/
H A Dsdp.h367 #define rcv_nxt(ssk) atomic_read(&(ssk->rcv_nxt)) macro
368 atomic_t rcv_nxt; member
H A 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()
H A Dsdp_cma.c260 if (rcv_nxt(ssk)) in sdp_disconnected_handler()
H A Dsdp_proc.c146 rx_queue = rcv_nxt(sdp_sk(sk)) - sdp_sk(sk)->copied_seq; in sdp_seq_show()
H A Dsdp_zcopy.c603 atomic_add(copied, &ssk->rcv_nxt); in sdp_rdma_to_iovec()
/freebsd/sys/dev/cxgbe/cxgbei/
H A Dcxgbei.c517 MPASS(chip_id(sc) >= CHELSIO_T6 || icp->icp_seq == tp->rcv_nxt); in do_rx_iscsi_ddp()
518 tp->rcv_nxt = icp->icp_seq + pdu_len; in do_rx_iscsi_ddp()
680 tp->rcv_nxt = icp->icp_seq + pdu_len; in do_rx_iscsi_cmp()
772 tp->rcv_nxt = icp->icp_seq + pdu_len; in do_rx_iscsi_cmp()
/freebsd/sbin/ipf/ipsend/
H A Dsock.c300 ti->ti_ack = tcb.rcv_nxt; in do_socket()
/freebsd/cddl/lib/libdtrace/
H A Dtcp.d234 tcps_rnxt = p == NULL ? 0 : p->rcv_nxt;
/freebsd/sys/dev/cxgb/common/
H A Dcxgb_t3_cpl.h769 __be32 rcv_nxt; member
826 __be32 rcv_nxt; member

12