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.c228 SEQ_GT(th->th_seq, tp->rcv_nxt)) { in tcp_twcheck()
285 if (seq + 1 == tp->rcv_nxt) in tcp_twcheck()
293 th->th_seq != tp->rcv_nxt || th->th_ack != tp->snd_nxt) { in tcp_twcheck()
295 tcp_respond(tp, mtod(m, void *), th, m, tp->rcv_nxt, in tcp_twcheck()
H A Dtcp_reass.c546 KASSERT(SEQ_GEQ(th->th_seq, tp->rcv_nxt), in tcp_reass()
592 if ((th->th_seq != tp->rcv_nxt || !TCPS_HAVEESTABLISHED(tp->t_state)) && in tcp_reass()
732 if (SEQ_LT(th->th_seq, tp->rcv_nxt)) { in tcp_reass()
741 th->th_seq, tp->rcv_nxt, tp); in tcp_reass()
743 i = tp->rcv_nxt - th->th_seq; in tcp_reass()
955 if (th->th_seq == tp->rcv_nxt && TCPS_HAVEESTABLISHED(tp->t_state)) { in tcp_reass()
956 tp->rcv_nxt += *tlenp; in tcp_reass()
1053 KASSERT(q == NULL || SEQ_GEQ(q->tqe_start, tp->rcv_nxt), in tcp_reass()
1055 if (!q || q->tqe_start != tp->rcv_nxt) { in tcp_reass()
1063 tp->rcv_nxt += q->tqe_len; in tcp_reass()
[all …]
H A Dtcp_sack.c166 if (SEQ_LEQ(tp->sackblks[0].end, tp->rcv_nxt)) in tcp_dsack_block_exists()
186 if (SEQ_LT(rcv_end, tp->rcv_nxt) || in tcp_update_dsack_list()
187 ((rcv_end == tp->rcv_nxt) && in tcp_update_dsack_list()
189 (tp->sackblks[0].end == tp->rcv_nxt))) { in tcp_update_dsack_list()
212 if (SEQ_GT(tp->rcv_nxt, end)) { in tcp_update_dsack_list()
244 if ((SEQ_LT(tp->rcv_nxt, mid_blk.end) && in tcp_update_dsack_list()
254 (SEQ_GT(tp->sackblks[j].start, tp->rcv_nxt)))) in tcp_update_dsack_list()
308 if (SEQ_GEQ(start, end) || SEQ_LEQ(start, tp->rcv_nxt)) { in tcp_update_sack_list()
424 if (SEQ_GEQ(start, end) || SEQ_LEQ(start, tp->rcv_nxt)) { in tcp_clean_dsack_blocks()
H A Dtcp_output.c670 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt)) { in tcp_default_output()
671 oldwin = (tp->rcv_adv - tp->rcv_nxt); in tcp_default_output()
1267 th->th_ack = htonl(tp->rcv_nxt); in tcp_default_output()
1283 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt) && in tcp_default_output()
1284 recwin < (tp->rcv_adv - tp->rcv_nxt)) in tcp_default_output()
1285 recwin = (tp->rcv_adv - tp->rcv_nxt); in tcp_default_output()
1744 if (SEQ_GT(tp->rcv_nxt + recwin, tp->rcv_adv)) in tcp_default_output()
1745 tp->rcv_adv = tp->rcv_nxt + recwin; in tcp_default_output()
1746 tp->last_ack_sent = tp->rcv_nxt; in tcp_default_output()
H A Dtcp_input.c1759 th->th_seq == tp->rcv_nxt && in tcp_do_segment()
1910 tp->rcv_nxt += tlen; in tcp_do_segment()
1929 tp->rcv_up = tp->rcv_nxt; in tcp_do_segment()
1973 tp->rcv_wnd = imax(win, (int)(tp->rcv_adv - tp->rcv_nxt)); in tcp_do_segment()
2274 todrop = tp->rcv_nxt - th->th_seq; in tcp_do_segment()
2359 todrop = (th->th_seq + tlen) - (tp->rcv_nxt + tp->rcv_wnd); in tcp_do_segment()
2371 if (tp->rcv_wnd == 0 && th->th_seq == tp->rcv_nxt) { in tcp_do_segment()
3182 (tp->rcv_up - tp->rcv_nxt) - 1; in tcp_do_segment()
3206 if (SEQ_GT(tp->rcv_nxt, tp->rcv_up)) in tcp_do_segment()
3207 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.c273 unsigned rcv_nxt,unsigned rx_frag0_start_idx_raw) in decompress_val() argument
288 tvp->val=(rcv_nxt+rx_frag0_start_idx_raw+fragx) & 0xFFFFFFFF; in decompress_val()
290 tvp->val=(rcv_nxt - rawval) & 0xFFFFFFFF; in decompress_val()
459 unsigned tx_max=0, rcv_nxt=0, rx_frag0_start_idx_raw=0; in parse_tcb() local
471 rcv_nxt=tvp->val; in parse_tcb()
494 decompress_val(tvp,ulp_type,tx_max,rcv_nxt,rx_frag0_start_idx_raw); in parse_tcb()
/freebsd/sys/netinet/tcp_stacks/
H A Drack_bbr_common.c557 todrop = tp->rcv_nxt - th->th_seq; in ctf_drop_checks()
618 todrop = (th->th_seq + tlen) - (tp->rcv_nxt + tp->rcv_wnd); in ctf_drop_checks()
630 if (tp->rcv_wnd == 0 && th->th_seq == tp->rcv_nxt) { in ctf_drop_checks()
722 (tp->rcv_nxt == th->th_seq)) { in ctf_process_rst()
777 tcp_respond(tp, mtod(m, void *), th, m, tp->rcv_nxt, in ctf_challenge_ack()
779 tp->last_ack_sent = tp->rcv_nxt; in ctf_challenge_ack()
864 tp->rcv_wnd = imax(win, (int)(tp->rcv_adv - tp->rcv_nxt)); in ctf_calc_rwin()
H A Dbbr.c4781 tp->rcv_nxt, tp->snd_una - 1, 0); in bbr_timeout_persist()
4837 tp->rcv_nxt, tp->snd_una - 1, 0); in bbr_timeout_keepalive()
8209 tp->rcv_up = tp->rcv_nxt; in bbr_process_data()
8224 tcp_seq save_rnxt = tp->rcv_nxt; in bbr_process_data()
8239 if (th->th_seq == tp->rcv_nxt && in bbr_process_data()
8266 tp->rcv_nxt += tlen; in bbr_process_data()
8322 } else if ((tlen > 0) && SEQ_GT(tp->rcv_nxt, save_rnxt)) { in bbr_process_data()
8372 tp->rcv_nxt++; in bbr_process_data()
8489 tp->rcv_nxt += tlen; in bbr_do_fastnewdata()
8506 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, inp->inp_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, inp->inp_flags); in handle_ddp_data_rcvbuf()
910 len += be32toh(rcv_nxt) - tp->rcv_nxt; in handle_ddp_data_rcvbuf()
911 tp->rcv_nxt += len; in handle_ddp_data_rcvbuf()
973 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.c137 FLOWC_PARAM(RCVNXT, tp->rcv_nxt); in send_flowc_wr()
143 tp ? tp->snd_nxt : 0, tp ? tp->rcv_nxt : 0); in send_flowc_wr()
376 tp->last_ack_sent = tp->rcv_nxt; in make_established()
1359 handle_ddp_close(toep, tp, cpl->rcv_nxt); in do_peer_close()
1374 KASSERT(tp->rcv_nxt + 1 == be32toh(cpl->rcv_nxt), in do_peer_close()
1375 ("%s: rcv_nxt mismatch: %u %u", __func__, tp->rcv_nxt, in do_peer_close()
1376 be32toh(cpl->rcv_nxt))); in do_peer_close()
1379 tp->rcv_nxt = be32toh(cpl->rcv_nxt); in do_peer_close()
1694 if (__predict_false(tp->rcv_nxt != be32toh(cpl->seq))) in do_rx_data()
1695 ddp_placed = be32toh(cpl->seq) - tp->rcv_nxt; in do_rx_data()
[all …]
H A Dt4_tls.c832 CTR6(KTR_CXGBE, "%s: tid %u PDU len %d len %d seq %u, rcv_nxt %u", in do_rx_tls_cmp()
833 __func__, tid, pdu_length, len, be32toh(cpl->seq), tp->rcv_nxt); in do_rx_tls_cmp()
836 tp->rcv_nxt += pdu_length; in do_rx_tls_cmp()
1010 tp->rcv_nxt += len; in do_rx_data_tls()
/freebsd/sys/dev/irdma/
H A Dirdma_cm.c396 cm_node->tcp_cntxt.loc_ack_num = cm_node->tcp_cntxt.rcv_nxt; in irdma_form_ah_cm_frame()
583 cm_node->tcp_cntxt.loc_ack_num = cm_node->tcp_cntxt.rcv_nxt; in irdma_form_uda_cm_frame()
2315 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2322 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2329 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2339 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2347 cm_node->tcp_cntxt.rcv_nxt++; in irdma_handle_fin_pkt()
2501 u32 rcv_nxt = cm_node->tcp_cntxt.rcv_nxt; in irdma_check_seq() local
2509 !between(seq, rcv_nxt, (rcv_nxt + rcv_wnd))) in irdma_check_seq()
2575 cm_node->tcp_cntxt.rcv_nxt = inc_sequence + 1; in irdma_handle_syn_pkt()
[all …]
H A Dirdma_puda.c1517 pfpdu->rcv_nxt = seqnum + fpdu_len; in irdma_ieq_handle_partial()
1618 pfpdu->rcv_nxt = buf->seqnum + len; in irdma_ieq_process_buf()
1625 pfpdu->rcv_nxt = buf->seqnum; in irdma_ieq_process_buf()
1656 if (buf->seqnum != pfpdu->rcv_nxt) { in irdma_ieq_process_fpdus()
1738 pfpdu->rcv_nxt = fps; in irdma_ieq_handle_exception()
1750 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.h358 u32 rcv_nxt; member
939 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()
681 tp->rcv_nxt = icp->icp_seq + pdu_len; in do_rx_iscsi_cmp()
773 tp->rcv_nxt = icp->icp_seq + pdu_len; in do_rx_iscsi_cmp()
/freebsd/sbin/ipf/ipsend/
H A Dsock.c301 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