| /freebsd-9-stable/sys/netinet/ |
| D | tcp_timewait.c | 245 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt)) in tcp_twstart()
246 tw->last_win = (tp->rcv_adv - tp->rcv_nxt) >> tp->rcv_scale; in tcp_twstart()
263 tw->rcv_nxt = tp->rcv_nxt; in tcp_twstart()
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)) { in tcp_twcheck()
427 if (seq + 1 == tw->rcv_nxt) in tcp_twcheck()
435 th->th_seq != tw->rcv_nxt || th->th_ack != tw->snd_nxt) in tcp_twcheck()
573 th->th_ack = htonl(tw->rcv_nxt); in tcp_twrespond()
|
| D | tcp_reass.c | 196 if ((th->th_seq != tp->rcv_nxt || !TCPS_HAVEESTABLISHED(tp->t_state)) && in tcp_reass()
219 if (th->th_seq != tp->rcv_nxt || !TCPS_HAVEESTABLISHED(tp->t_state)) { in tcp_reass()
331 if (!q || q->tqe_th->th_seq != tp->rcv_nxt) in tcp_reass()
335 tp->rcv_nxt += q->tqe_len; in tcp_reass()
347 } while (q && q->tqe_th->th_seq == tp->rcv_nxt); in tcp_reass()
|
| D | tcp_output.c | 595 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt)) { in tcp_output()
596 oldwin = (tp->rcv_adv - tp->rcv_nxt); in tcp_output()
1115 th->th_ack = htonl(tp->rcv_nxt); in tcp_output()
1128 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt) && in tcp_output()
1129 recwin < (long)(tp->rcv_adv - tp->rcv_nxt)) in tcp_output()
1130 recwin = (long)(tp->rcv_adv - tp->rcv_nxt); in tcp_output()
1468 if (recwin >= 0 && SEQ_GT(tp->rcv_nxt + recwin, tp->rcv_adv)) in tcp_output()
1469 tp->rcv_adv = tp->rcv_nxt + recwin; in tcp_output()
1470 tp->last_ack_sent = tp->rcv_nxt; in tcp_output()
|
| D | tcp_input.c | 1623 th->th_seq == tp->rcv_nxt && in tcp_do_segment()
1765 tp->rcv_nxt += tlen; in tcp_do_segment()
1775 tp->rcv_up = tp->rcv_nxt; in tcp_do_segment()
1875 tp->rcv_wnd = imax(win, (int)(tp->rcv_adv - tp->rcv_nxt)); in tcp_do_segment()
2105 !(SEQ_GEQ(th->th_seq, tp->rcv_nxt - 1) && in tcp_do_segment()
2106 SEQ_LEQ(th->th_seq, tp->rcv_nxt + 1)) && in tcp_do_segment()
2185 todrop = tp->rcv_nxt - th->th_seq; in tcp_do_segment()
2259 todrop = (th->th_seq + tlen) - (tp->rcv_nxt + tp->rcv_wnd); in tcp_do_segment()
2271 if (tp->rcv_wnd == 0 && th->th_seq == tp->rcv_nxt) { in tcp_do_segment()
2859 (tp->rcv_up - tp->rcv_nxt) - 1; in tcp_do_segment()
[all …]
|
| D | tcp_seq.h | 59 (tp)->rcv_adv = (tp)->rcv_nxt = (tp)->irs + 1
|
| D | tcp_debug.c | 219 (u_long)tp->rcv_nxt, tp->rcv_wnd, (u_long)tp->rcv_up, in tcp_trace()
|
| D | tcp_sack.c | 186 if (SEQ_GEQ(start, end) || SEQ_LEQ(start, tp->rcv_nxt)) { in tcp_update_sack_list()
214 if (SEQ_GT(head_blk.start, tp->rcv_nxt)) { in tcp_update_sack_list()
|
| D | tcp_var.h | 128 tcp_seq rcv_nxt; /* receive next */ member
349 tcp_seq rcv_nxt; member
|
| D | tcp_timer.c | 362 tp->rcv_nxt, tp->snd_una - 1, 0); in tcp_timer_keep()
|
| D | tcp_usrreq.c | 1276 ti->tcpi_rcv_nxt = tp->rcv_nxt; in tcp_fill_info()
1970 tp->iss, tp->irs, tp->rcv_nxt); in db_print_tcpcb()
|
| D | tcp_syncache.c | 828 tp->last_ack_sent = tp->rcv_nxt; in syncache_socket()
|
| /freebsd-9-stable/sys/dev/cxgbe/tom/ |
| D | t4_cpl_io.c | 118 flowc->mnemval[5].val = htobe32(ftxp->rcv_nxt); in send_flowc_wr()
271 tp->last_ack_sent = tp->rcv_nxt; in make_established()
299 ftxp.rcv_nxt = tp->rcv_nxt; in make_established()
855 tp->rcv_nxt++; /* FIN */ in do_peer_close()
861 m = get_ddp_mbuf(be32toh(cpl->rcv_nxt) - tp->rcv_nxt); in do_peer_close()
862 tp->rcv_nxt = be32toh(cpl->rcv_nxt); in do_peer_close()
877 KASSERT(tp->rcv_nxt == be32toh(cpl->rcv_nxt), in do_peer_close()
878 ("%s: rcv_nxt mismatch: %u %u", __func__, tp->rcv_nxt, in do_peer_close()
879 be32toh(cpl->rcv_nxt))); in do_peer_close()
1181 if (__predict_false(tp->rcv_nxt != be32toh(cpl->seq))) in do_rx_data()
[all …]
|
| D | t4_ddp.c | 228 tp->rcv_nxt += n; in insert_ddp_data()
420 handle_ddp_data(struct toepcb *toep, __be32 ddp_report, __be32 rcv_nxt, int len) in handle_ddp_data() argument
448 __func__, toep->tid, be32toh(rcv_nxt), len, inp->inp_flags); in handle_ddp_data()
454 len += be32toh(rcv_nxt) - tp->rcv_nxt; in handle_ddp_data()
455 tp->rcv_nxt += len; in handle_ddp_data()
549 handle_ddp_data(toep, cpl->ddp_report, cpl->rcv_nxt, 0); in do_rx_ddp_complete()
|
| D | t4_tom.h | 140 uint32_t rcv_nxt; member
|
| /freebsd-9-stable/sys/ofed/drivers/infiniband/ulp/sdp/ |
| D | sdp.h | 409 #define rcv_nxt(ssk) atomic_read(&(ssk->rcv_nxt)) macro
410 atomic_t rcv_nxt; member
|
| D | sdp_rx.c | 209 SDP_SKB_CB(mb)->seq = rcv_nxt(ssk); in sdp_sock_queue_rcv_mb()
233 atomic_add(mb->len, &ssk->rcv_nxt); in sdp_sock_queue_rcv_mb()
239 atomic_add(mb->m_pkthdr.len, &ssk->rcv_nxt); in sdp_sock_queue_rcv_mb()
|
| D | sdp_cma.c | 254 if (rcv_nxt(ssk)) in sdp_disconnected_handler()
|
| D | sdp_proc.c | 145 rx_queue = rcv_nxt(sdp_sk(sk)) - sdp_sk(sk)->copied_seq; in sdp_seq_show()
|
| D | sdp_zcopy.c | 601 atomic_add(copied, &ssk->rcv_nxt); in sdp_rdma_to_iovec()
|
| /freebsd-9-stable/sys/dev/cxgb/ulp/tom/ |
| D | cxgb_cpl_io.c | 1152 if (__predict_false(tp->rcv_nxt != be32toh(hdr->seq))) { in do_rx_data()
1155 __func__, be32toh(hdr->seq), toep->tp_tid, tp->rcv_nxt); in do_rx_data()
1158 tp->rcv_nxt += m->m_pkthdr.len; in do_rx_data()
1237 tp->rcv_nxt++; in do_peer_close()
1592 tp->last_ack_sent = tp->rcv_nxt; in make_established()
|
| /freebsd-9-stable/contrib/ipfilter/ipsend/ |
| D | sock.c | 453 ti->ti_ack = tcb.rcv_nxt;
|
| D | iptests.c | 1139 ti.ti_ack = tcb.rcv_nxt;
|
| /freebsd-9-stable/usr.sbin/trpt/ |
| D | trpt.c | 418 (u_long)tp->rcv_nxt, tp->rcv_wnd, in tcp_trace()
|
| /freebsd-9-stable/sys/dev/cxgbe/common/ |
| D | t4_msg.h | 861 __be32 rcv_nxt; member
918 __be32 rcv_nxt; member
1468 __be32 rcv_nxt; member
|
| /freebsd-9-stable/sys/dev/cxgb/common/ |
| D | cxgb_t3_cpl.h | 770 __be32 rcv_nxt; member
827 __be32 rcv_nxt; member
|