Differential D29690 Diff 87598 sys/netinet/tcp_stacks/rack.c

Changeset View

Standalone View

sys/netinet/tcp_stacks/rack.c

This file is larger than 256 KB, so syntax highlighting is disabled by default.

Show First 20 Lines • Show All 8,338 Lines • ▼ Show 20 Lines	if ((sbused(&so->so_snd) == 0) &&
/*		/*
* We must be sure our fin		* We must be sure our fin
* was sent and acked (we can be		* was sent and acked (we can be
* in FIN_WAIT_1 without having		* in FIN_WAIT_1 without having
* sent the fin).		* sent the fin).
*/		*/
ourfinisacked = 1;		ourfinisacked = 1;
}		}
SOCKBUF_UNLOCK(&so->so_snd);		/* NB: sowwakeup_locked() does an implicit unlock. */
tp->t_flags \|= TF_WAKESOW;		sowwakeup_locked(so);
m_freem(mfree);		m_freem(mfree);
if (rack->r_ctl.rc_early_recovery == 0) {		if (rack->r_ctl.rc_early_recovery == 0) {
if (IN_RECOVERY(tp->t_flags)) {		if (IN_RECOVERY(tp->t_flags)) {
if (SEQ_LT(th->th_ack, tp->snd_recover) &&		if (SEQ_LT(th->th_ack, tp->snd_recover) &&
(SEQ_LT(th->th_ack, tp->snd_max))) {		(SEQ_LT(th->th_ack, tp->snd_max))) {
tcp_rack_partialack(tp, th);		tcp_rack_partialack(tp, th);
} else {		} else {
rack_post_recovery(tp, th);		rack_post_recovery(tp, th);
▲ Show 20 Lines • Show All 303 Lines • ▼ Show 20 Lines	#endif
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
appended =		appended =
#endif		#endif
sbappendstream_locked(&so->so_rcv, m, 0);		sbappendstream_locked(&so->so_rcv, m, 0);
SOCKBUF_UNLOCK(&so->so_rcv);
tp->t_flags \|= TF_WAKESOR;		tp->t_flags \|= TF_WAKESOR;
#ifdef NETFLIX_SB_LIMITS		#ifdef NETFLIX_SB_LIMITS
if (so->so_rcv.sb_shlim && appended != mcnt)		if (so->so_rcv.sb_shlim && appended != mcnt)
counter_fo_release(so->so_rcv.sb_shlim,		counter_fo_release(so->so_rcv.sb_shlim,
mcnt - appended);		mcnt - appended);
#endif		#endif
} else {		} else {
/*		/*
▲ Show 20 Lines • Show All 50 Lines • ▼ Show 20 Lines	#endif
}		}

/*		/*
* If FIN is received ACK the FIN and let the user know that the		* If FIN is received ACK the FIN and let the user know that the
* connection is closing.		* connection is closing.
*/		*/
if (thflags & TH_FIN) {		if (thflags & TH_FIN) {
if (TCPS_HAVERCVDFIN(tp->t_state) == 0) {		if (TCPS_HAVERCVDFIN(tp->t_state) == 0) {
socantrcvmore(so);		if (tp->t_flags & TF_WAKESOR) {
/* The socket upcall is handled by socantrcvmore. */		/* The socket upcall is handled by socantrcvmore. */
tp->t_flags &= ~TF_WAKESOR;		tp->t_flags &= ~TF_WAKESOR;
		socantrcvmore_locked(so);
		} else
		socantrcvmore(so);
/*		/*
* If connection is half-synchronized (ie NEEDSYN		* If connection is half-synchronized (ie NEEDSYN
* flag on) then delay ACK, so it may be piggybacked		* flag on) then delay ACK, so it may be piggybacked
* when SYN is sent. Otherwise, since we received a		* when SYN is sent. Otherwise, since we received a
* FIN then no more input can be expected, send ACK		* FIN then no more input can be expected, send ACK
* now.		* now.
*/		*/
if (tp->t_flags & TF_NEEDSYN) {		if (tp->t_flags & TF_NEEDSYN) {
▲ Show 20 Lines • Show All 175 Lines • ▼ Show 20 Lines	if (newsize)
so->so_rcv.sb_flags &= ~SB_AUTOSIZE;		so->so_rcv.sb_flags &= ~SB_AUTOSIZE;
m_adj(m, drop_hdrlen); /* delayed header drop */		m_adj(m, drop_hdrlen); /* delayed header drop */
#ifdef NETFLIX_SB_LIMITS		#ifdef NETFLIX_SB_LIMITS
appended =		appended =
#endif		#endif
sbappendstream_locked(&so->so_rcv, m, 0);		sbappendstream_locked(&so->so_rcv, m, 0);
ctf_calc_rwin(so, tp);		ctf_calc_rwin(so, tp);
}		}
SOCKBUF_UNLOCK(&so->so_rcv);
tp->t_flags \|= TF_WAKESOR;		tp->t_flags \|= TF_WAKESOR;
#ifdef NETFLIX_SB_LIMITS		#ifdef NETFLIX_SB_LIMITS
if (so->so_rcv.sb_shlim && mcnt != appended)		if (so->so_rcv.sb_shlim && mcnt != appended)
counter_fo_release(so->so_rcv.sb_shlim, mcnt - appended);		counter_fo_release(so->so_rcv.sb_shlim, mcnt - appended);
#endif		#endif
rack_handle_delayed_ack(tp, rack, tlen, 0);		rack_handle_delayed_ack(tp, rack, tlen, 0);
if (tp->snd_una == tp->snd_max)		if (tp->snd_una == tp->snd_max)
sack_filter_clear(&rack->r_ctl.rack_sf, tp->snd_una);		sack_filter_clear(&rack->r_ctl.rack_sf, tp->snd_una);
▲ Show 20 Lines • Show All 201 Lines • ▼ Show 20 Lines	if (tp->snd_una == tp->snd_max) {
if (rack->r_ctl.rc_went_idle_time == 0)		if (rack->r_ctl.rc_went_idle_time == 0)
rack->r_ctl.rc_went_idle_time = 1;		rack->r_ctl.rc_went_idle_time = 1;
rack_log_progress_event(rack, tp, 0, PROGRESS_CLEAR, __LINE__);		rack_log_progress_event(rack, tp, 0, PROGRESS_CLEAR, __LINE__);
if (sbavail(&tp->t_inpcb->inp_socket->so_snd) == 0)		if (sbavail(&tp->t_inpcb->inp_socket->so_snd) == 0)
tp->t_acktime = 0;		tp->t_acktime = 0;
rack_timer_cancel(tp, rack, rack->r_ctl.rc_rcvtime, __LINE__);		rack_timer_cancel(tp, rack, rack->r_ctl.rc_rcvtime, __LINE__);
}		}
/* Wake up the socket if we have room to write more */		/* Wake up the socket if we have room to write more */
tp->t_flags \|= TF_WAKESOW;		sowwakeup(so);
if (sbavail(&so->so_snd)) {		if (sbavail(&so->so_snd)) {
rack->r_wanted_output = 1;		rack->r_wanted_output = 1;
}		}
return (1);		return (1);
}		}

/*		/*
* Return value of 1, the TCB is unlocked and most		* Return value of 1, the TCB is unlocked and most
▲ Show 20 Lines • Show All 5,826 Lines • Show Last 20 Lines