| /f-stack/freebsd/netinet/ |
| H A D | tcp_timewait.c | 303 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt) && in tcp_twstart() 304 recwin < (tp->rcv_adv - tp->rcv_nxt)) in tcp_twstart() 305 recwin = (tp->rcv_adv - tp->rcv_nxt); in tcp_twstart() 321 tw->rcv_nxt = tp->rcv_nxt; in tcp_twstart() 440 if ((thflags & TH_SYN) && SEQ_GT(th->th_seq, tw->rcv_nxt)) { in tcp_twcheck() 467 if (seq + 1 == tw->rcv_nxt) in tcp_twcheck() 475 th->th_seq != tw->rcv_nxt || th->th_ack != tw->snd_nxt) { in tcp_twcheck() 616 th->th_ack = htonl(tw->rcv_nxt); in tcp_twrespond()
|
| H A D | tcp_sack.c | 168 if (SEQ_LT(rcv_end, tp->rcv_nxt) || in tcp_update_dsack_list() 169 ((rcv_end == tp->rcv_nxt) && in tcp_update_dsack_list() 171 (tp->sackblks[0].end == tp->rcv_nxt))) { in tcp_update_dsack_list() 194 if (SEQ_GT(tp->rcv_nxt, end)) { in tcp_update_dsack_list() 226 if ((SEQ_LT(tp->rcv_nxt, mid_blk.end) && in tcp_update_dsack_list() 236 (SEQ_GT(tp->sackblks[j].start, tp->rcv_nxt)))) in tcp_update_dsack_list() 290 if (SEQ_GEQ(start, end) || SEQ_LEQ(start, tp->rcv_nxt)) { in tcp_update_sack_list() 406 if (SEQ_GEQ(start, end) || SEQ_LEQ(start, tp->rcv_nxt)) { in tcp_clean_dsack_blocks()
|
| H A D | tcp_reass.c | 555 KASSERT(SEQ_GEQ(th->th_seq, tp->rcv_nxt), in tcp_reass() 588 if ((th->th_seq != tp->rcv_nxt || !TCPS_HAVEESTABLISHED(tp->t_state)) && in tcp_reass() 728 if (SEQ_LT(th->th_seq, tp->rcv_nxt)) { in tcp_reass() 737 th->th_seq, tp->rcv_nxt, tp); in tcp_reass() 739 i = tp->rcv_nxt - th->th_seq; in tcp_reass() 951 if (th->th_seq == tp->rcv_nxt && TCPS_HAVEESTABLISHED(tp->t_state)) { in tcp_reass() 952 tp->rcv_nxt += *tlenp; in tcp_reass() 1051 KASSERT(q == NULL || SEQ_GEQ(q->tqe_start, tp->rcv_nxt), in tcp_reass() 1053 if (!q || q->tqe_start != tp->rcv_nxt) { in tcp_reass() 1061 tp->rcv_nxt += q->tqe_len; in tcp_reass() [all …]
|
| H A D | tcp_input.c | 1749 th->th_seq == tp->rcv_nxt && in tcp_do_segment() 1885 tp->rcv_nxt += tlen; in tcp_do_segment() 1904 tp->rcv_up = tp->rcv_nxt; in tcp_do_segment() 2191 tp->last_ack_sent = tp->rcv_nxt; in tcp_do_segment() 2214 tp->last_ack_sent = tp->rcv_nxt; in tcp_do_segment() 2262 todrop = tp->rcv_nxt - th->th_seq; in tcp_do_segment() 3088 tp->rcv_up = tp->rcv_nxt; in tcp_do_segment() 3106 tcp_seq save_rnxt = tp->rcv_nxt; in tcp_do_segment() 3121 if (th->th_seq == tp->rcv_nxt && in tcp_do_segment() 3129 tp->rcv_nxt += tlen; in tcp_do_segment() [all …]
|
| H A D | tcp_output.c | 671 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt)) { in tcp_output() 672 oldwin = (tp->rcv_adv - tp->rcv_nxt); in tcp_output() 1247 th->th_ack = htonl(tp->rcv_nxt); in tcp_output() 1264 if (SEQ_GT(tp->rcv_adv, tp->rcv_nxt) && in tcp_output() 1265 recwin < (tp->rcv_adv - tp->rcv_nxt)) in tcp_output() 1266 recwin = (tp->rcv_adv - tp->rcv_nxt); in tcp_output() 1689 if (SEQ_GT(tp->rcv_nxt + recwin, tp->rcv_adv)) in tcp_output() 1690 tp->rcv_adv = tp->rcv_nxt + recwin; in tcp_output() 1691 tp->last_ack_sent = tp->rcv_nxt; in tcp_output()
|
| H A D | tcp_seq.h | 69 (tp)->rcv_adv = (tp)->rcv_nxt = (tp)->irs + 1
|
| H A D | tcp_debug.c | 220 (u_long)tp->rcv_nxt, (u_long)tp->rcv_wnd, (u_long)tp->rcv_up, in tcp_trace()
|
| H A D | tcp_var.h | 161 tcp_seq rcv_nxt; /* receive next */ member 506 tcp_seq rcv_nxt; member
|
| H A D | tcp_timer.c | 479 tp->rcv_nxt, tp->snd_una - 1, 0); in tcp_timer_keep()
|
| H A D | tcp_usrreq.c | 1790 ti->tcpi_rcv_nxt = tp->rcv_nxt; in tcp_fill_info() 2985 tp->iss, tp->irs, tp->rcv_nxt); in db_print_tcpcb()
|
| H A D | tcp_log_buf.c | 1688 COPY_STAT(rcv_nxt); in tcp_log_event_()
|
| H A D | tcp_syncache.c | 1055 tp->last_ack_sent = tp->rcv_nxt; in syncache_socket()
|
| /f-stack/freebsd/netinet/tcp_stacks/ |
| H A D | rack_bbr_common.c | 520 todrop = tp->rcv_nxt - th->th_seq; in ctf_drop_checks() 580 todrop = (th->th_seq + tlen) - (tp->rcv_nxt + tp->rcv_wnd); in ctf_drop_checks() 592 if (tp->rcv_wnd == 0 && th->th_seq == tp->rcv_nxt) { in ctf_drop_checks() 683 (tp->rcv_nxt == th->th_seq) || in ctf_process_rst() 711 tp->rcv_nxt, tp->snd_nxt, TH_ACK); in ctf_process_rst() 712 tp->last_ack_sent = tp->rcv_nxt; in ctf_process_rst() 741 tcp_respond(tp, mtod(m, void *), th, m, tp->rcv_nxt, in ctf_challenge_ack() 743 tp->last_ack_sent = tp->rcv_nxt; in ctf_challenge_ack() 802 tp->rcv_wnd = imax(win, (int)(tp->rcv_adv - tp->rcv_nxt)); in ctf_calc_rwin()
|
| H A D | rack.c | 8602 tp->rcv_up = tp->rcv_nxt; in rack_process_data() 8618 tcp_seq save_rnxt = tp->rcv_nxt; in rack_process_data() 8633 if (th->th_seq == tp->rcv_nxt && in rack_process_data() 8652 tp->rcv_nxt += tlen; in rack_process_data() 8755 tp->rcv_nxt++; in rack_process_data() 8885 tp->rcv_nxt += tlen; in rack_do_fastnewdata() 8902 tp->rcv_up = tp->rcv_nxt; in rack_do_fastnewdata() 9806 tp->rcv_nxt = th->th_seq + *tlen; in rack_check_data_after_close() 13505 th->th_ack = htonl(tp->rcv_nxt); in rack_output() 14034 tp->rcv_adv = tp->rcv_nxt + recwin; in rack_output() [all …]
|
| H A D | bbr.c | 8282 tp->rcv_up = tp->rcv_nxt; in bbr_process_data() 8298 tcp_seq save_rnxt = tp->rcv_nxt; in bbr_process_data() 8313 if (th->th_seq == tp->rcv_nxt && in bbr_process_data() 8340 tp->rcv_nxt += tlen; in bbr_process_data() 8438 tp->rcv_nxt++; in bbr_process_data() 8566 tp->rcv_nxt += tlen; in bbr_do_fastnewdata() 8583 tp->rcv_up = tp->rcv_nxt; in bbr_do_fastnewdata() 9500 tp->rcv_nxt = th->th_seq + *tlen; in bbr_check_data_after_close() 13526 th->th_ack = htonl(tp->rcv_nxt); in bbr_output_wtime() 14150 tp->rcv_adv = tp->rcv_nxt + recwin; in bbr_output_wtime() [all …]
|
| /f-stack/tools/compat/include/netinet/ |
| H A D | tcp_seq.h | 69 (tp)->rcv_adv = (tp)->rcv_nxt = (tp)->irs + 1
|
| H A D | tcp_var.h | 161 tcp_seq rcv_nxt; /* receive next */ member 506 tcp_seq rcv_nxt; member
|