diff options
| author | Garrett D'Amore <garrett@damore.org> | 2024-11-05 22:25:24 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2024-11-05 22:25:24 -0800 |
| commit | 85927b8d0d0a751e4c65849c392ef9d0e42a1bd7 (patch) | |
| tree | f2b97814bc6a72381766b655435917f664257298 /src/platform/posix/posix_ipcdial.c | |
| parent | b82e942b5915bb3b957e02b2ed1ff6de10e413af (diff) | |
| download | nng-85927b8d0d0a751e4c65849c392ef9d0e42a1bd7.tar.gz nng-85927b8d0d0a751e4c65849c392ef9d0e42a1bd7.tar.bz2 nng-85927b8d0d0a751e4c65849c392ef9d0e42a1bd7.zip | |
ipc: listener cancellation test
Diffstat (limited to 'src/platform/posix/posix_ipcdial.c')
| -rw-r--r-- | src/platform/posix/posix_ipcdial.c | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/platform/posix/posix_ipcdial.c b/src/platform/posix/posix_ipcdial.c index 6cbd7c17..81a8f1dc 100644 --- a/src/platform/posix/posix_ipcdial.c +++ b/src/platform/posix/posix_ipcdial.c @@ -80,7 +80,7 @@ static void ipc_dialer_cancel(nni_aio *aio, void *arg, int rv) { nni_ipc_dialer *d = arg; - nni_ipc_conn * c; + nni_ipc_conn *c; nni_mtx_lock(&d->mtx); if ((!nni_aio_list_active(aio)) || @@ -100,9 +100,9 @@ ipc_dialer_cancel(nni_aio *aio, void *arg, int rv) static void ipc_dialer_cb(nni_posix_pfd *pfd, unsigned ev, void *arg) { - nni_ipc_conn * c = arg; + nni_ipc_conn *c = arg; nni_ipc_dialer *d = c->dialer; - nni_aio * aio; + nni_aio *aio; int rv; nni_mtx_lock(&d->mtx); @@ -153,9 +153,9 @@ ipc_dialer_cb(nni_posix_pfd *pfd, unsigned ev, void *arg) void ipc_dialer_dial(void *arg, nni_aio *aio) { - ipc_dialer * d = arg; - nni_ipc_conn * c; - nni_posix_pfd * pfd = NULL; + ipc_dialer *d = arg; + nni_ipc_conn *c; + nni_posix_pfd *pfd = NULL; struct sockaddr_storage ss; size_t len; int fd; @@ -205,7 +205,7 @@ ipc_dialer_dial(void *arg, nni_aio *aio) goto error; } if (connect(fd, (void *) &ss, len) != 0) { - if (errno != EINPROGRESS) { + if (errno != EINPROGRESS && errno != EAGAIN) { if (errno == ENOENT) { // No socket present means nobody listening. rv = NNG_ECONNREFUSED; |