/freebsd-11-stable/sys/netinet/ |
H A D | tcp_timewait.c | 304 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt) && 305 recwin < (tp->rcv_adv - tp->rcv_nxt)) 306 recwin = (tp->rcv_adv - tp->rcv_nxt); 322 tw->rcv_nxt = tp->rcv_nxt; 439 if ((thflags & TH_SYN) && SEQ_GT(th->th_seq, tw->rcv_nxt)) { 465 if (seq + 1 == tw->rcv_nxt) 473 th->th_seq != tw->rcv_nxt || th->th_ack != tw->snd_nxt) { 615 th->th_ack = htonl(tw->rcv_nxt);
|
H A D | tcp_seq.h | 67 (tp)->rcv_adv = (tp)->rcv_nxt = (tp)->irs + 1
|
H A D | tcp_reass.c | 554 KASSERT(SEQ_GEQ(th->th_seq, tp->rcv_nxt), 570 * the rcv_nxt <-> rcv_wnd but thats 587 if ((th->th_seq != tp->rcv_nxt || !TCPS_HAVEESTABLISHED(tp->t_state)) && 727 if (SEQ_LT(th->th_seq, tp->rcv_nxt)) { 735 panic("th->th_seq:%u rcv_nxt:%u tp:%p not pre-trimmed", 736 th->th_seq, tp->rcv_nxt, tp); 738 i = tp->rcv_nxt - th->th_seq; 950 if (th->th_seq == tp->rcv_nxt && TCPS_HAVEESTABLISHED(tp->t_state)) { 951 tp->rcv_nxt += *tlenp; 1043 * Present data to user, advancing rcv_nxt throug [all...] |
H A D | tcp_sack.c | 169 if (SEQ_LT(rcv_end, tp->rcv_nxt) || 170 ((rcv_end == tp->rcv_nxt) && 172 (tp->sackblks[0].end == tp->rcv_nxt))) { 195 if (SEQ_GT(tp->rcv_nxt, end)) { 227 if ((SEQ_LT(tp->rcv_nxt, mid_blk.end) && 237 (SEQ_GT(tp->sackblks[j].start, tp->rcv_nxt)))) 274 /* retaining DSACK block below rcv_nxt (todrop) */ 291 if (SEQ_GEQ(start, end) || SEQ_LEQ(start, tp->rcv_nxt)) { 407 if (SEQ_GEQ(start, end) || SEQ_LEQ(start, tp->rcv_nxt)) {
|
H A D | tcp_output.c | 673 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt)) { 674 oldwin = (tp->rcv_adv - tp->rcv_nxt); 1210 th->th_ack = htonl(tp->rcv_nxt); 1223 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt) && 1224 recwin < (long)(tp->rcv_adv - tp->rcv_nxt)) 1225 recwin = (long)(tp->rcv_adv - tp->rcv_nxt); 1634 if (recwin >= 0 && SEQ_GT(tp->rcv_nxt + recwin, tp->rcv_adv)) 1635 tp->rcv_adv = tp->rcv_nxt + recwin; 1636 tp->last_ack_sent = tp->rcv_nxt;
|
H A D | tcp_debug.c | 218 (u_long)tp->rcv_nxt, tp->rcv_wnd, (u_long)tp->rcv_up,
|
H A D | tcp_input.c | 1777 th->th_seq == tp->rcv_nxt && 1919 tp->rcv_nxt += tlen; 1927 * rcv_nxt. 1929 tp->rcv_up = tp->rcv_nxt; 1978 tp->rcv_wnd = imax(win, (int)(tp->rcv_adv - tp->rcv_nxt)); 2022 * initialize tp->rcv_nxt and tp->irs 2161 * receive window. If segment begins before rcv_nxt, 2172 * test against last_ack_sent instead of rcv_nxt. 2212 tp->rcv_nxt, tp->snd_nxt, TH_ACK); 2213 tp->last_ack_sent = tp->rcv_nxt; [all...] |
H A D | tcp_var.h | 185 tcp_seq rcv_nxt; /* receive next */ member in struct:tcpcb 423 tcp_seq rcv_nxt; member in struct:tcptw
|
H A D | tcp_usrreq.c | 1404 ti->tcpi_rcv_nxt = tp->rcv_nxt; 2317 db_printf("iss: 0x%08x irs: 0x%08x rcv_nxt: 0x%08x\n", 2318 tp->iss, tp->irs, tp->rcv_nxt);
|
/freebsd-11-stable/usr.sbin/cxgbetool/ |
H A D | tcb_common.c | 275 unsigned rcv_nxt,unsigned rx_frag0_start_idx_raw) 290 tvp->val=(rcv_nxt+rx_frag0_start_idx_raw+fragx) & 0xFFFFFFFF; 292 tvp->val=(rcv_nxt - rawval) & 0xFFFFFFFF; 461 unsigned tx_max=0, rcv_nxt=0, rx_frag0_start_idx_raw=0; local 472 if (!got_rcv_nxt && tcb_strmatch_nc("rcv_nxt",tvp->name)) { 473 rcv_nxt=tvp->val; 496 decompress_val(tvp,ulp_type,tx_max,rcv_nxt,rx_frag0_start_idx_raw); 274 decompress_val(_TCBVAR *tvp,unsigned ulp_type,unsigned tx_max, unsigned rcv_nxt,unsigned rx_frag0_start_idx_raw) argument
|
/freebsd-11-stable/sys/netinet/tcp_stacks/ |
H A D | fastpath.c | 377 tp->rcv_nxt += tlen; 385 * rcv_nxt. 387 tp->rcv_up = tp->rcv_nxt; 469 tp->rcv_wnd = imax(win, (int)(tp->rcv_adv - tp->rcv_nxt)); 491 * initialize tp->rcv_nxt and tp->irs 629 * receive window. If segment begins before rcv_nxt, 640 * test against last_ack_sent instead of rcv_nxt. 679 tp->rcv_nxt, tp->snd_nxt, TH_ACK); 680 tp->last_ack_sent = tp->rcv_nxt; 704 tcp_respond(tp, mtod(m, void *), th, m, tp->rcv_nxt, [all...] |
/freebsd-11-stable/sys/dev/cxgbe/tom/ |
H A D | t4_ddp.c | 307 tp->rcv_nxt += n; 480 handle_ddp_data(struct toepcb *toep, __be32 ddp_report, __be32 rcv_nxt, int len) argument 514 __func__, toep->tid, be32toh(rcv_nxt), len, inp->inp_flags); 523 * For RX_DDP_COMPLETE, len will be zero and rcv_nxt is the 526 * comparing the new and old values of rcv_nxt. 531 * for this DDP buffer. rcv_nxt is the sequence number of the 534 len += be32toh(rcv_nxt) - tp->rcv_nxt; 535 tp->rcv_nxt += len; 702 handle_ddp_close(struct toepcb *toep, struct tcpcb *tp, __be32 rcv_nxt) argument [all...] |
H A D | t4_cpl_io.c | 172 FLOWC_PARAM(RCVNXT, ftxp->rcv_nxt); 177 "%s: tid %u, mss %u, sndbuf %u, snd_nxt 0x%x, rcv_nxt 0x%x", 179 ftxp->rcv_nxt); 416 tp->last_ack_sent = tp->rcv_nxt; 434 ftxp.rcv_nxt = tp->rcv_nxt; 1262 tp->rcv_nxt++; /* FIN */ 1269 handle_ddp_close(toep, tp, cpl->rcv_nxt); 1275 KASSERT(tp->rcv_nxt == be32toh(cpl->rcv_nxt), [all...] |
H A D | t4_tom.h | 213 uint32_t rcv_nxt; member in struct:flowc_tx_params
|
H A D | t4_tls.c | 1501 CTR6(KTR_CXGBE, "%s: tid %u PDU len %d len %d seq %u, rcv_nxt %u", 1502 __func__, tid, pdu_length, len, be32toh(cpl->seq), tp->rcv_nxt); 1505 tp->rcv_nxt += pdu_length;
|
/freebsd-11-stable/sys/ofed/drivers/infiniband/ulp/sdp/ |
H A D | sdp_rx.c | 210 SDP_SKB_CB(mb)->seq = rcv_nxt(ssk); 234 atomic_add(mb->len, &ssk->rcv_nxt); 240 atomic_add(mb->m_pkthdr.len, &ssk->rcv_nxt);
|
H A D | sdp.h | 409 #define rcv_nxt(ssk) atomic_read(&(ssk->rcv_nxt)) macro 410 atomic_t rcv_nxt; member in struct:sdp_sock
|
H A D | sdp_proc.c | 144 rx_queue = rcv_nxt(sdp_sk(sk)) - sdp_sk(sk)->copied_seq;
|
H A D | sdp_cma.c | 253 if (rcv_nxt(ssk))
|
/freebsd-11-stable/contrib/ipfilter/ipsend/ |
H A D | sock.c | 308 ti->ti_ack = tcb.rcv_nxt;
|
/freebsd-11-stable/sys/dev/cxgb/ulp/tom/ |
H A D | cxgb_cpl_io.c | 1152 if (__predict_false(tp->rcv_nxt != be32toh(hdr->seq))) { 1154 "%s: unexpected seq# %x for TID %u, rcv_nxt %x\n", 1155 __func__, be32toh(hdr->seq), toep->tp_tid, tp->rcv_nxt); 1158 tp->rcv_nxt += m->m_pkthdr.len; 1237 tp->rcv_nxt++; 1591 tp->last_ack_sent = tp->rcv_nxt;
|
/freebsd-11-stable/usr.sbin/trpt/ |
H A D | trpt.c | 420 (u_long)tp->rcv_nxt, tp->rcv_wnd,
|
/freebsd-11-stable/cddl/lib/libdtrace/ |
H A D | tcp.d | 208 tcps_rnxt = p == NULL ? 0 : p->rcv_nxt;
|
/freebsd-11-stable/sys/dev/cxgb/common/ |
H A D | cxgb_t3_cpl.h | 770 __be32 rcv_nxt; member in struct:cpl_close_con_rpl 827 __be32 rcv_nxt; member in struct:cpl_peer_close
|
/freebsd-11-stable/sys/dev/cxgbe/cxgbei/ |
H A D | cxgbei.c | 647 MPASS(icp->pdu_seq == tp->rcv_nxt); 649 tp->rcv_nxt += pdu_len;
|