diff options
| author | Garrett D'Amore <garrett@damore.org> | 2024-12-09 22:27:55 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2024-12-09 23:03:42 -0800 |
| commit | 2ade67cf0bad8596838762d085664d87e91093ba (patch) | |
| tree | 87cddebb07ed7d8b8a8b9c61d8e813a476d87779 /src/sp/transport/ipc | |
| parent | 2e72f32c61e3c6227e654285890807b9ca8709cf (diff) | |
| download | nng-2ade67cf0bad8596838762d085664d87e91093ba.tar.gz nng-2ade67cf0bad8596838762d085664d87e91093ba.tar.bz2 nng-2ade67cf0bad8596838762d085664d87e91093ba.zip | |
windows ipc: significant refactor
This refactors a lot of the IPC code to hopefully address various
hangs on shutdown, etc. The problem is that named pipes are not
terrifically reliable when it comes to aborting ConnectNamedPipe.
Additionally there were some logic errors in some of our code that
left things rather brittle.
Ultimately this all needs to be replaced with UNIX domain sockets
which are superior in many ways.
Diffstat (limited to 'src/sp/transport/ipc')
| -rw-r--r-- | src/sp/transport/ipc/ipc_test.c | 8 |
1 files changed, 0 insertions, 8 deletions
diff --git a/src/sp/transport/ipc/ipc_test.c b/src/sp/transport/ipc/ipc_test.c index 51eb975d..509d8722 100644 --- a/src/sp/transport/ipc/ipc_test.c +++ b/src/sp/transport/ipc/ipc_test.c @@ -152,7 +152,6 @@ test_ipc_ping_pong(void) nng_socket s1; char *addr; - NUTS_ENABLE_LOG(NNG_LOG_INFO); NUTS_ADDR(addr, "ipc"); NUTS_OPEN(s0); NUTS_OPEN(s1); @@ -245,7 +244,6 @@ test_ipc_recv_max(void) size_t sz; char *addr; - NUTS_ENABLE_LOG(NNG_LOG_INFO); NUTS_ADDR(addr, "ipc"); NUTS_OPEN(s0); NUTS_PASS(nng_socket_set_ms(s0, NNG_OPT_RECVTIMEO, 100)); @@ -275,7 +273,6 @@ test_ipc_connect_refused(void) nng_dialer d; char *addr; - NUTS_ENABLE_LOG(NNG_LOG_INFO); NUTS_ADDR(addr, "ipc"); NUTS_OPEN(s0); NUTS_PASS(nng_socket_set_ms(s0, NNG_OPT_RECVTIMEO, 100)); @@ -292,7 +289,6 @@ test_ipc_connect_blocking(void) nng_stream_listener *l; char *addr; - NUTS_ENABLE_LOG(NNG_LOG_INFO); NUTS_ADDR(addr, "ipc"); NUTS_OPEN(s0); @@ -315,7 +311,6 @@ test_ipc_connect_blocking_accept(void) char *addr; nng_aio *aio; - NUTS_ENABLE_LOG(NNG_LOG_INFO); NUTS_ADDR(addr, "ipc"); NUTS_OPEN(s0); @@ -344,7 +339,6 @@ test_ipc_listen_accept_cancel(void) char *addr; nng_aio *aio; - NUTS_ENABLE_LOG(NNG_LOG_INFO); NUTS_ADDR(addr, "ipc"); NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); @@ -364,7 +358,6 @@ test_ipc_listen_duplicate(void) nng_socket s0; char *addr; - NUTS_ENABLE_LOG(NNG_LOG_INFO); NUTS_ADDR(addr, "ipc"); NUTS_OPEN(s0); @@ -384,7 +377,6 @@ test_ipc_listener_clean_stale(void) char *path; char renamed[256]; - NUTS_ENABLE_LOG(NNG_LOG_INFO); NUTS_ADDR(addr, "ipc"); NUTS_OPEN(s0); |