diff options
author | peter <peter@FreeBSD.org> | 1998-05-31 18:42:49 +0000 |
---|---|---|
committer | peter <peter@FreeBSD.org> | 1998-05-31 18:42:49 +0000 |
commit | 10677f7b5c74e63360b808c734c4baee09455f8b (patch) | |
tree | 97d2eb85ab5a60c6d63470930d50e8de5e0b3098 /sys/netinet | |
parent | a4063ba4e26d0e7f8252f48af7e9b4fa5a86fea1 (diff) | |
download | FreeBSD-src-10677f7b5c74e63360b808c734c4baee09455f8b.zip FreeBSD-src-10677f7b5c74e63360b808c734c4baee09455f8b.tar.gz |
Let the sowwakeup macro decide when to call sowakeup rather than have
tcp "know" about it. A pending upcall would be missed, eg: used by NFS.
Obtained from: NetBSD
Diffstat (limited to 'sys/netinet')
-rw-r--r-- | sys/netinet/tcp_input.c | 8 | ||||
-rw-r--r-- | sys/netinet/tcp_reass.c | 8 |
2 files changed, 6 insertions, 10 deletions
diff --git a/sys/netinet/tcp_input.c b/sys/netinet/tcp_input.c index d33c29d..14b69b4 100644 --- a/sys/netinet/tcp_input.c +++ b/sys/netinet/tcp_input.c @@ -31,7 +31,7 @@ * SUCH DAMAGE. * * @(#)tcp_input.c 8.12 (Berkeley) 5/24/95 - * $Id: tcp_input.c,v 1.76 1998/05/18 17:07:58 guido Exp $ + * $Id: tcp_input.c,v 1.77 1998/05/18 17:11:24 guido Exp $ */ #include "opt_tcpdebug.h" @@ -538,8 +538,7 @@ findpcb: else if (tp->t_timer[TCPT_PERSIST] == 0) tp->t_timer[TCPT_REXMT] = tp->t_rxtcur; - if (so->so_snd.sb_flags & SB_NOTIFY) - sowwakeup(so); + sowwakeup(so); if (so->so_snd.sb_cc) (void) tcp_output(tp); return; @@ -1373,8 +1372,7 @@ process_ACK: tp->snd_wnd -= acked; ourfinisacked = 0; } - if (so->so_snd.sb_flags & SB_NOTIFY) - sowwakeup(so); + sowwakeup(so); tp->snd_una = ti->ti_ack; if (SEQ_LT(tp->snd_nxt, tp->snd_una)) tp->snd_nxt = tp->snd_una; diff --git a/sys/netinet/tcp_reass.c b/sys/netinet/tcp_reass.c index d33c29d..14b69b4 100644 --- a/sys/netinet/tcp_reass.c +++ b/sys/netinet/tcp_reass.c @@ -31,7 +31,7 @@ * SUCH DAMAGE. * * @(#)tcp_input.c 8.12 (Berkeley) 5/24/95 - * $Id: tcp_input.c,v 1.76 1998/05/18 17:07:58 guido Exp $ + * $Id: tcp_input.c,v 1.77 1998/05/18 17:11:24 guido Exp $ */ #include "opt_tcpdebug.h" @@ -538,8 +538,7 @@ findpcb: else if (tp->t_timer[TCPT_PERSIST] == 0) tp->t_timer[TCPT_REXMT] = tp->t_rxtcur; - if (so->so_snd.sb_flags & SB_NOTIFY) - sowwakeup(so); + sowwakeup(so); if (so->so_snd.sb_cc) (void) tcp_output(tp); return; @@ -1373,8 +1372,7 @@ process_ACK: tp->snd_wnd -= acked; ourfinisacked = 0; } - if (so->so_snd.sb_flags & SB_NOTIFY) - sowwakeup(so); + sowwakeup(so); tp->snd_una = ti->ti_ack; if (SEQ_LT(tp->snd_nxt, tp->snd_una)) tp->snd_nxt = tp->snd_una; |