summaryrefslogtreecommitdiffstats
path: root/sys/netinet/sctp_input.c
diff options
context:
space:
mode:
authorrwatson <rwatson@FreeBSD.org>2008-01-31 08:22:24 +0000
committerrwatson <rwatson@FreeBSD.org>2008-01-31 08:22:24 +0000
commitc57fa547596c416598879f29dc61157e959392bd (patch)
treea5b509ba53675bf270380aa0f227cfd9b595f023 /sys/netinet/sctp_input.c
parente57ce2b6e66969617ddf24cf15e2a24e11871b15 (diff)
downloadFreeBSD-src-c57fa547596c416598879f29dc61157e959392bd.zip
FreeBSD-src-c57fa547596c416598879f29dc61157e959392bd.tar.gz
Correct two problems relating to sorflush(), which is called to flush
read socket buffers in shutdown() and close(): - Call socantrcvmore() before sblock() to dislodge any threads that might be sleeping (potentially indefinitely) while holding sblock(), such as a thread blocked in recv(). - Flag the sblock() call as non-interruptible so that a signal delivered to the thread calling sorflush() doesn't cause sblock() to fail. The sblock() is required to ensure that all other socket consumer threads have, in fact, left, and do not enter, the socket buffer until we're done flushin it. To implement the latter, change the 'flags' argument to sblock() to accept two flags, SBL_WAIT and SBL_NOINTR, rather than one M_WAITOK flag. When SBL_NOINTR is set, it forces a non-interruptible sx acquisition, regardless of the setting of the disposition of SB_NOINTR on the socket buffer; without this change it would be possible for another thread to clear SB_NOINTR between when the socket buffer mutex is released and sblock() is invoked. Reviewed by: bz, kmacy Reported by: Jos Backus <jos at catnook dot com>
Diffstat (limited to 'sys/netinet/sctp_input.c')
-rw-r--r--sys/netinet/sctp_input.c3
1 files changed, 2 insertions, 1 deletions
diff --git a/sys/netinet/sctp_input.c b/sys/netinet/sctp_input.c
index ea7456f..5bad746 100644
--- a/sys/netinet/sctp_input.c
+++ b/sys/netinet/sctp_input.c
@@ -2509,7 +2509,8 @@ sctp_handle_cookie_echo(struct mbuf *m, int iphlen, int offset,
atomic_add_int(&(*stcb)->asoc.refcnt, 1);
SCTP_TCB_UNLOCK((*stcb));
- sctp_pull_off_control_to_new_inp((*inp_p), inp, *stcb, M_NOWAIT);
+ sctp_pull_off_control_to_new_inp((*inp_p), inp, *stcb,
+ 0);
SCTP_TCB_LOCK((*stcb));
atomic_subtract_int(&(*stcb)->asoc.refcnt, 1);
OpenPOWER on IntegriCloud