summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorVitaliy Makkoveev <mvs@cvs.openbsd.org>2021-11-11 16:35:10 +0000
committerVitaliy Makkoveev <mvs@cvs.openbsd.org>2021-11-11 16:35:10 +0000
commitb04b967eb1fce72cc51236e2b8ec570732b70aa4 (patch)
tree27aec543b22fb8c0daf9e05b4c5d620fcede8032
parentc3f6d772de1e9ab8fb030bfc7b85dd121da3d984 (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.c26
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);