diff options
author | Vitaliy Makkoveev <mvs@cvs.openbsd.org> | 2021-11-11 16:35:10 +0000 |
---|---|---|
committer | Vitaliy Makkoveev <mvs@cvs.openbsd.org> | 2021-11-11 16:35:10 +0000 |
commit | b04b967eb1fce72cc51236e2b8ec570732b70aa4 (patch) | |
tree | 27aec543b22fb8c0daf9e05b4c5d620fcede8032 | |
parent | c3f6d772de1e9ab8fb030bfc7b85dd121da3d984 (diff) |
Destroy protocol control block before perform `so_q0' and `so_q' queues
cleanup.
The dying socket is already unlinked from the file descriptor layer, but
still accessible from the stack or from the file system layer. We need to
unlink the socket to prevent concurrent connection when we unlocked dying
socket while we perform `so_q0' or `so_q' queues cleanup or while we
perform (*pr_detach)(). This unlocking will be appeared with the upcoming
fine grained locked sockets diffs.
ok bluhm@
-rw-r--r-- | sys/kern/uipc_socket.c | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/sys/kern/uipc_socket.c b/sys/kern/uipc_socket.c index 56d3098a6fd..6c0b47af006 100644 --- a/sys/kern/uipc_socket.c +++ b/sys/kern/uipc_socket.c @@ -1,4 +1,4 @@ -/* $OpenBSD: uipc_socket.c,v 1.268 2021/11/06 05:26:33 visa Exp $ */ +/* $OpenBSD: uipc_socket.c,v 1.269 2021/11/11 16:35:09 mvs Exp $ */ /* $NetBSD: uipc_socket.c,v 1.21 1996/02/04 02:17:52 christos Exp $ */ /* @@ -333,19 +333,9 @@ soclose(struct socket *so, int flags) s = solock(so); /* Revoke async IO early. There is a final revocation in sofree(). */ sigio_free(&so->so_sigio); - if (so->so_options & SO_ACCEPTCONN) { - while ((so2 = TAILQ_FIRST(&so->so_q0)) != NULL) { - (void) soqremque(so2, 0); - (void) soabort(so2); - } - while ((so2 = TAILQ_FIRST(&so->so_q)) != NULL) { - (void) soqremque(so2, 1); - (void) soabort(so2); - } - } - if (so->so_pcb == NULL) - goto discard; if (so->so_state & SS_ISCONNECTED) { + if (so->so_pcb == NULL) + goto discard; if ((so->so_state & SS_ISDISCONNECTING) == 0) { error = sodisconnect(so); if (error) @@ -372,6 +362,16 @@ drop: if (error == 0) error = error2; } + if (so->so_options & SO_ACCEPTCONN) { + while ((so2 = TAILQ_FIRST(&so->so_q0)) != NULL) { + (void) soqremque(so2, 0); + (void) soabort(so2); + } + while ((so2 = TAILQ_FIRST(&so->so_q)) != NULL) { + (void) soqremque(so2, 1); + (void) soabort(so2); + } + } discard: if (so->so_state & SS_NOFDREF) panic("soclose NOFDREF: so %p, so_type %d", so, so->so_type); |