Page MenuHomeFreeBSD
Differential D24902 Diff 76044 head/sys/netinet/tcp_stacks/bbr.c

Changeset View

Standalone View

View Options

head/sys/netinet/tcp_stacks/bbr.c

  • This file is larger than 256 KB, so syntax highlighting is disabled by default.
Show First 20 Lines • Show All 8,409 Lines • ▼ Show 20 Lines#endif
bbr->bbr_segs_rcvd += max(1, nsegs); bbr->bbr_segs_rcvd += max(1, nsegs);
tp->t_flags |= TF_DELACK; tp->t_flags |= TF_DELACK;
bbr_timer_cancel(bbr, __LINE__, bbr->r_ctl.rc_rcvtime); bbr_timer_cancel(bbr, __LINE__, bbr->r_ctl.rc_rcvtime);
} else { } else {
bbr->r_wanted_output = 1; bbr->r_wanted_output = 1;
tp->t_flags |= TF_ACKNOW; tp->t_flags |= TF_ACKNOW;
} }
tp->rcv_nxt += tlen; tp->rcv_nxt += tlen;
if (tlen &&
((tp->t_flags2 & TF2_FBYTES_COMPLETE) == 0) &&
(tp->t_fbyte_in == 0)) {
tp->t_fbyte_in = ticks;
if (tp->t_fbyte_in == 0)
tp->t_fbyte_in = 1;
if (tp->t_fbyte_out && tp->t_fbyte_in)
tp->t_flags2 |= TF2_FBYTES_COMPLETE;
}
thflags = th->th_flags & TH_FIN; thflags = th->th_flags & TH_FIN;
KMOD_TCPSTAT_ADD(tcps_rcvpack, (int)nsegs); KMOD_TCPSTAT_ADD(tcps_rcvpack, (int)nsegs);
KMOD_TCPSTAT_ADD(tcps_rcvbyte, tlen); KMOD_TCPSTAT_ADD(tcps_rcvbyte, tlen);
SOCKBUF_LOCK(&so->so_rcv); SOCKBUF_LOCK(&so->so_rcv);
if (so->so_rcv.sb_state & SBS_CANTRCVMORE) if (so->so_rcv.sb_state & SBS_CANTRCVMORE)
m_freem(m); m_freem(m);
else else
#ifdef NETFLIX_SB_LIMITS #ifdef NETFLIX_SB_LIMITS
▲ Show 20 Lines • Show All 200 Lines • ▼ Show 20 Lines if (so->so_rcv.sb_shlim) {
} }
} }
#endif #endif
/* Clean receiver SACK report if present */ /* Clean receiver SACK report if present */
if (tp->rcv_numsacks) if (tp->rcv_numsacks)
tcp_clean_sackreport(tp); tcp_clean_sackreport(tp);
KMOD_TCPSTAT_INC(tcps_preddat); KMOD_TCPSTAT_INC(tcps_preddat);
tp->rcv_nxt += tlen; tp->rcv_nxt += tlen;
if (tlen &&
((tp->t_flags2 & TF2_FBYTES_COMPLETE) == 0) &&
(tp->t_fbyte_in == 0)) {
tp->t_fbyte_in = ticks;
if (tp->t_fbyte_in == 0)
tp->t_fbyte_in = 1;
if (tp->t_fbyte_out && tp->t_fbyte_in)
tp->t_flags2 |= TF2_FBYTES_COMPLETE;
}
/* /*
* Pull snd_wl1 up to prevent seq wrap relative to th_seq. * Pull snd_wl1 up to prevent seq wrap relative to th_seq.
*/ */
tp->snd_wl1 = th->th_seq; tp->snd_wl1 = th->th_seq;
/* /*
* Pull rcv_up up to prevent seq wrap relative to rcv_nxt. * Pull rcv_up up to prevent seq wrap relative to rcv_nxt.
*/ */
tp->rcv_up = tp->rcv_nxt; tp->rcv_up = tp->rcv_nxt;
▲ Show 20 Lines • Show All 6,451 Lines • Show Last 20 Lines