From 0b6be293df6105516304b51a0632b8cce04925b7 Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Sun, 8 Dec 2024 20:40:12 -0800 Subject: sockfd: implement endpoint stop functions --- src/sp/transport/socket/sockfd.c | 10 ++++++++++ 1 file changed, 10 insertions(+) (limited to 'src') diff --git a/src/sp/transport/socket/sockfd.c b/src/sp/transport/socket/sockfd.c index 3db76215..d066f837 100644 --- a/src/sp/transport/socket/sockfd.c +++ b/src/sp/transport/socket/sockfd.c @@ -621,6 +621,7 @@ sfd_tran_ep_close(void *arg) sfd_tran_ep *ep = arg; sfd_tran_pipe *p; + nni_aio_close(&ep->connaio); nni_mtx_lock(&ep->mtx); ep->closed = true; @@ -641,6 +642,14 @@ sfd_tran_ep_close(void *arg) nni_mtx_unlock(&ep->mtx); } +static void +sfd_tran_ep_stop(void *arg) +{ + sfd_tran_ep *ep = arg; + + nni_aio_stop(&ep->connaio); +} + static void sfd_tran_accept_cb(void *arg) { @@ -872,6 +881,7 @@ static nni_sp_listener_ops sfd_tran_listener_ops = { .l_bind = sfd_tran_ep_bind, .l_accept = sfd_tran_ep_accept, .l_close = sfd_tran_ep_close, + .l_stop = sfd_tran_ep_stop, .l_getopt = sfd_tran_listener_getopt, .l_setopt = sfd_tran_listener_setopt, }; -- cgit v1.2.3-70-g09d2