Searched refs:rcv_nxt (Results 1 - 25 of 27) sorted by relevance

12

/freebsd-9.3-release/sys/netinet/
H A Dtcp_timewait.c245 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt))
246 tw->last_win = (tp->rcv_adv - tp->rcv_nxt) >> tp->rcv_scale;
263 tw->rcv_nxt = tp->rcv_nxt;
340 if (SEQ_GT(new_iss, tw->snd_nxt) && SEQ_GT(new_irs, tw->rcv_nxt))
411 if ((thflags & TH_SYN) && SEQ_GT(th->th_seq, tw->rcv_nxt)) {
427 if (seq + 1 == tw->rcv_nxt)
435 th->th_seq != tw->rcv_nxt || th->th_ack != tw->snd_nxt)
573 th->th_ack = htonl(tw->rcv_nxt);
H A Dtcp_seq.h59 (tp)->rcv_adv = (tp)->rcv_nxt = (tp)->irs + 1
H A Dtcp_reass.c196 if ((th->th_seq != tp->rcv_nxt || !TCPS_HAVEESTABLISHED(tp->t_state)) &&
219 if (th->th_seq != tp->rcv_nxt || !TCPS_HAVEESTABLISHED(tp->t_state)) {
325 * Present data to user, advancing rcv_nxt through
331 if (!q || q->tqe_th->th_seq != tp->rcv_nxt)
335 tp->rcv_nxt += q->tqe_len;
347 } while (q && q->tqe_th->th_seq == tp->rcv_nxt);
H A Dtcp_output.c595 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt)) {
596 oldwin = (tp->rcv_adv - tp->rcv_nxt);
1021 th->th_ack = htonl(tp->rcv_nxt);
1034 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt) &&
1035 recwin < (long)(tp->rcv_adv - tp->rcv_nxt))
1036 recwin = (long)(tp->rcv_adv - tp->rcv_nxt);
1374 if (recwin >= 0 && SEQ_GT(tp->rcv_nxt + recwin, tp->rcv_adv))
1375 tp->rcv_adv = tp->rcv_nxt + recwin;
1376 tp->last_ack_sent = tp->rcv_nxt;
H A Dtcp_input.c1620 th->th_seq == tp->rcv_nxt &&
1762 tp->rcv_nxt += tlen;
1770 * rcv_nxt.
1772 tp->rcv_up = tp->rcv_nxt;
1872 tp->rcv_wnd = imax(win, (int)(tp->rcv_adv - tp->rcv_nxt));
1899 * initialize tp->rcv_nxt and tp->irs
2041 * receive window. If segment begins before rcv_nxt,
2052 * we should test against last_ack_sent instead of rcv_nxt.
2102 !(SEQ_GEQ(th->th_seq, tp->rcv_nxt - 1) &&
2103 SEQ_LEQ(th->th_seq, tp->rcv_nxt
[all...]
H A Dtcp_debug.c219 (u_long)tp->rcv_nxt, tp->rcv_wnd, (u_long)tp->rcv_up,
H A Dtcp_sack.c186 if (SEQ_GEQ(start, end) || SEQ_LEQ(start, tp->rcv_nxt)) {
214 if (SEQ_GT(head_blk.start, tp->rcv_nxt)) {
H A Dtcp_var.h128 tcp_seq rcv_nxt; /* receive next */ member in struct:tcpcb
345 tcp_seq rcv_nxt; member in struct:tcptw
H A Dtcp_timer.c362 tp->rcv_nxt, tp->snd_una - 1, 0);
H A Dtcp_usrreq.c1276 ti->tcpi_rcv_nxt = tp->rcv_nxt;
1969 db_printf("iss: 0x%08x irs: 0x%08x rcv_nxt: 0x%08x\n",
1970 tp->iss, tp->irs, tp->rcv_nxt);
/freebsd-9.3-release/sys/dev/cxgbe/tom/
H A Dt4_cpl_io.c118 flowc->mnemval[5].val = htobe32(ftxp->rcv_nxt);
271 tp->last_ack_sent = tp->rcv_nxt;
299 ftxp.rcv_nxt = tp->rcv_nxt;
855 tp->rcv_nxt++; /* FIN */
861 m = get_ddp_mbuf(be32toh(cpl->rcv_nxt) - tp->rcv_nxt);
862 tp->rcv_nxt = be32toh(cpl->rcv_nxt);
877 KASSERT(tp->rcv_nxt
[all...]
H A Dt4_ddp.c221 tp->rcv_nxt += n;
413 handle_ddp_data(struct toepcb *toep, __be32 ddp_report, __be32 rcv_nxt, int len) argument
441 __func__, toep->tid, be32toh(rcv_nxt), len, inp->inp_flags);
447 len += be32toh(rcv_nxt) - tp->rcv_nxt;
448 tp->rcv_nxt += len;
527 handle_ddp_data(toep, cpl->ddp_report, cpl->rcv_nxt, 0);
H A Dt4_tom.h140 uint32_t rcv_nxt; member in struct:flowc_tx_params
/freebsd-9.3-release/sys/ofed/drivers/infiniband/ulp/sdp/
H A Dsdp.h409 #define rcv_nxt(ssk) atomic_read(&(ssk->rcv_nxt)) macro
410 atomic_t rcv_nxt; member in struct:sdp_sock
H A Dsdp_rx.c209 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 Dsdp_cma.c254 if (rcv_nxt(ssk))
H A Dsdp_proc.c145 rx_queue = rcv_nxt(sdp_sk(sk)) - sdp_sk(sk)->copied_seq;
H A Dsdp_zcopy.c601 atomic_add(copied, &ssk->rcv_nxt);
/freebsd-9.3-release/sys/dev/cxgb/ulp/tom/
H A Dcxgb_cpl_io.c1152 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++;
1592 tp->last_ack_sent = tp->rcv_nxt;
/freebsd-9.3-release/contrib/ipfilter/ipsend/
H A Dsock.c453 ti->ti_ack = tcb.rcv_nxt;
H A Diptests.c1139 ti.ti_ack = tcb.rcv_nxt;
/freebsd-9.3-release/usr.sbin/trpt/
H A Dtrpt.c418 (u_long)tp->rcv_nxt, tp->rcv_wnd,
/freebsd-9.3-release/sys/dev/cxgb/common/
H A Dcxgb_t3_cpl.h770 __be32 rcv_nxt; member in struct:cpl_close_con_rpl
827 __be32 rcv_nxt; member in struct:cpl_peer_close
/freebsd-9.3-release/sys/dev/cxgbe/common/
H A Dt4_msg.h861 __be32 rcv_nxt; member in struct:cpl_close_con_rpl
918 __be32 rcv_nxt; member in struct:cpl_peer_close
1468 __be32 rcv_nxt; member in struct:cpl_rx_ddp_complete
/freebsd-9.3-release/sys/dev/cxgb/ulp/iw_cxgb/
H A Diw_cxgb_cm.c213 ep->rcv_seq = tp->rcv_nxt;

Completed in 309 milliseconds

12