aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2018-08-14 18:08:36 +0500
committerGarrett D'Amore <garrett@damore.org>2018-08-14 18:08:36 +0500
commita1f485bba51c56305537f3308a777035ea7c514d (patch)
tree3daf4ce3f3981d2b4b2d62f5005c28c0b4dc5959
parent658fe8b446905158437f4698933a971c15d29e9e (diff)
downloadnng-a1f485bba51c56305537f3308a777035ea7c514d.tar.gz
nng-a1f485bba51c56305537f3308a777035ea7c514d.tar.bz2
nng-a1f485bba51c56305537f3308a777035ea7c514d.zip
fixes #652 dial has no timeout with UNIX domain sockets
-rw-r--r--src/transport/ipc/ipc.c5
1 files changed, 5 insertions, 0 deletions
diff --git a/src/transport/ipc/ipc.c b/src/transport/ipc/ipc.c
index 8141b588..5d0064e5 100644
--- a/src/transport/ipc/ipc.c
+++ b/src/transport/ipc/ipc.c
@@ -175,6 +175,11 @@ ipctran_pipe_init(ipctran_pipe **pipep, ipctran_ep *ep)
nni_atomic_flag_reset(&p->reaped);
nni_list_append(&ep->pipes, p);
+ // 5 seconds each for connection and negotiation; should be more than
+ // sufficient.
+ nni_aio_set_timeout(p->connaio, 5000);
+ nni_aio_set_timeout(p->negoaio, 5000);
+
p->proto = ep->proto;
p->rcvmax = ep->rcvmax;
p->sa = ep->sa;