/freebsd-10-stable/sys/netinet/ |
H A D | tcp_seq.h | 59 (tp)->rcv_adv = (tp)->rcv_nxt = (tp)->irs + 1
|
H A D | tcp_reass.c | 205 if ((th->th_seq != tp->rcv_nxt || !TCPS_HAVEESTABLISHED(tp->t_state)) && 229 if (th->th_seq != tp->rcv_nxt || !TCPS_HAVEESTABLISHED(tp->t_state)) { 335 * Present data to user, advancing rcv_nxt through 341 if (!q || q->tqe_th->th_seq != tp->rcv_nxt) 345 tp->rcv_nxt += q->tqe_len; 357 } while (q && q->tqe_th->th_seq == tp->rcv_nxt);
|
H A D | tcp_timewait.c | 292 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt)) 293 tw->last_win = (tp->rcv_adv - tp->rcv_nxt) >> tp->rcv_scale; 310 tw->rcv_nxt = tp->rcv_nxt; 387 if (SEQ_GT(new_iss, tw->snd_nxt) && SEQ_GT(new_irs, tw->rcv_nxt)) 457 if ((thflags & TH_SYN) && SEQ_GT(th->th_seq, tw->rcv_nxt)) { 473 if (seq + 1 == tw->rcv_nxt) 481 th->th_seq != tw->rcv_nxt || th->th_ack != tw->snd_nxt) 618 th->th_ack = htonl(tw->rcv_nxt);
|
H A D | tcp_output.c | 642 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt)) { 643 oldwin = (tp->rcv_adv - tp->rcv_nxt); 1185 th->th_ack = htonl(tp->rcv_nxt); 1198 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt) && 1199 recwin < (long)(tp->rcv_adv - tp->rcv_nxt)) 1200 recwin = (long)(tp->rcv_adv - tp->rcv_nxt); 1587 if (recwin >= 0 && SEQ_GT(tp->rcv_nxt + recwin, tp->rcv_adv)) 1588 tp->rcv_adv = tp->rcv_nxt + recwin; 1589 tp->last_ack_sent = tp->rcv_nxt;
|
H A D | tcp_input.c | 1716 th->th_seq == tp->rcv_nxt && 1858 tp->rcv_nxt += tlen; 1866 * rcv_nxt. 1868 tp->rcv_up = tp->rcv_nxt; 1916 tp->rcv_wnd = imax(win, (int)(tp->rcv_adv - tp->rcv_nxt)); 1961 * initialize tp->rcv_nxt and tp->irs 2108 * receive window. If segment begins before rcv_nxt, 2119 * we should test against last_ack_sent instead of rcv_nxt. 2169 !(SEQ_GEQ(th->th_seq, tp->rcv_nxt - 1) && 2170 SEQ_LEQ(th->th_seq, tp->rcv_nxt [all...] |
H A D | tcp_debug.c | 218 (u_long)tp->rcv_nxt, tp->rcv_wnd, (u_long)tp->rcv_up,
|
H A D | tcp_sack.c | 186 if (SEQ_GEQ(start, end) || SEQ_LEQ(start, tp->rcv_nxt)) { 214 if (SEQ_GT(head_blk.start, tp->rcv_nxt)) {
|
H A D | tcp_var.h | 133 tcp_seq rcv_nxt; /* receive next */ member in struct:tcpcb 377 tcp_seq rcv_nxt; member in struct:tcptw
|
H A D | tcp_usrreq.c | 1359 ti->tcpi_rcv_nxt = tp->rcv_nxt; 2106 db_printf("iss: 0x%08x irs: 0x%08x rcv_nxt: 0x%08x\n", 2107 tp->iss, tp->irs, tp->rcv_nxt);
|
H A D | tcp_timer.c | 401 tp->rcv_nxt, tp->snd_una - 1, 0);
|
/freebsd-10-stable/sys/dev/cxgbe/tom/ |
H A D | t4_cpl_io.c | 152 flowc->mnemval[5].val = htobe32(ftxp->rcv_nxt); 159 "%s: tid %u, mss %u, sndbuf %u, snd_nxt 0x%x, rcv_nxt 0x%x", 161 ftxp->rcv_nxt); 321 tp->last_ack_sent = tp->rcv_nxt; 349 ftxp.rcv_nxt = tp->rcv_nxt; 1119 tp->rcv_nxt++; /* FIN */ 1125 handle_ddp_close(toep, tp, sb, cpl->rcv_nxt); 1130 KASSERT(tp->rcv_nxt == be32toh(cpl->rcv_nxt), [all...] |
H A D | t4_ddp.c | 140 tp->rcv_nxt += n; 332 handle_ddp_data(struct toepcb *toep, __be32 ddp_report, __be32 rcv_nxt, int len) argument 360 __func__, toep->tid, be32toh(rcv_nxt), len, inp->inp_flags); 368 * For RX_DDP_COMPLETE, len will be zero and rcv_nxt is the 371 * comparing the new and old values of rcv_nxt. 376 * for this DDP buffer. rcv_nxt is the sequence number of the 379 len += be32toh(rcv_nxt) - tp->rcv_nxt; 380 tp->rcv_nxt += len; 435 __be32 rcv_nxt) 434 handle_ddp_close(struct toepcb *toep, struct tcpcb *tp, struct sockbuf *sb, __be32 rcv_nxt) argument [all...] |
H A D | t4_tom.h | 166 uint32_t rcv_nxt; member in struct:flowc_tx_params
|
/freebsd-10-stable/sys/ofed/drivers/infiniband/ulp/sdp/ |
H A D | sdp_rx.c | 209 SDP_SKB_CB(mb)->seq = rcv_nxt(ssk); 233 atomic_add(mb->len, &ssk->rcv_nxt); 239 atomic_add(mb->m_pkthdr.len, &ssk->rcv_nxt);
|
H A D | sdp.h | 411 #define rcv_nxt(ssk) atomic_read(&(ssk->rcv_nxt)) macro 412 atomic_t rcv_nxt; member in struct:sdp_sock
|
H A D | sdp_cma.c | 254 if (rcv_nxt(ssk))
|
H A D | sdp_proc.c | 145 rx_queue = rcv_nxt(sdp_sk(sk)) - sdp_sk(sk)->copied_seq;
|
H A D | sdp_zcopy.c | 601 atomic_add(copied, &ssk->rcv_nxt);
|
/freebsd-10-stable/cddl/lib/libdtrace/ |
H A D | tcp.d | 192 tcps_rnxt = p == NULL ? 0 : p->rcv_nxt;
|
/freebsd-10-stable/sys/dev/cxgb/ulp/tom/ |
H A D | cxgb_cpl_io.c | 1151 if (__predict_false(tp->rcv_nxt != be32toh(hdr->seq))) { 1153 "%s: unexpected seq# %x for TID %u, rcv_nxt %x\n", 1154 __func__, be32toh(hdr->seq), toep->tp_tid, tp->rcv_nxt); 1157 tp->rcv_nxt += m->m_pkthdr.len; 1236 tp->rcv_nxt++; 1591 tp->last_ack_sent = tp->rcv_nxt;
|
/freebsd-10-stable/contrib/ipfilter/ipsend/ |
H A D | sock.c | 449 ti->ti_ack = tcb.rcv_nxt;
|
H A D | iptests.c | 1139 ti.ti_ack = tcb.rcv_nxt;
|
/freebsd-10-stable/usr.sbin/trpt/ |
H A D | trpt.c | 418 (u_long)tp->rcv_nxt, tp->rcv_wnd,
|
/freebsd-10-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-10-stable/sys/dev/cxgbe/common/ |
H A D | t4_msg.h | 976 __be32 rcv_nxt; member in struct:cpl_close_con_rpl 1061 __be32 rcv_nxt; member in struct:cpl_peer_close 1687 __be32 rcv_nxt; member in struct:cpl_rx_ddp_complete
|