pair1: tweaks to aio shutdown

nanomsg · Dec 4, 2024 · a00a9fc · a00a9fc
1 parent 80d2283
commit a00a9fc
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/sp/protocol/pair1/pair.c b/src/sp/protocol/pair1/pair.c
@@ -199,8 +199,8 @@ pair1_pipe_stop(void *arg)
 	pair1_pipe *p = arg;
 	pair1_sock *s = p->pair;
 
-	nni_aio_stop(&p->aio_send);
-	nni_aio_stop(&p->aio_recv);
+	nni_aio_close(&p->aio_send);
+	nni_aio_close(&p->aio_recv);
 	nni_mtx_lock(&s->mtx);
 	if (s->p == p) {
 		s->p = NULL;
@@ -218,6 +218,8 @@ pair1_pipe_stop(void *arg)
 		}
 	}
 	nni_mtx_unlock(&s->mtx);
+	nni_aio_stop(&p->aio_send);
+	nni_aio_stop(&p->aio_recv);
 }
 
 static void