aboutsummaryrefslogtreecommitdiff
path: root/src/core/socket.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/core/socket.c')
-rw-r--r--src/core/socket.c11
1 files changed, 11 insertions, 0 deletions
diff --git a/src/core/socket.c b/src/core/socket.c
index d091d126..ae399d73 100644
--- a/src/core/socket.c
+++ b/src/core/socket.c
@@ -792,6 +792,17 @@ nni_sock_rcvmaxsz(nni_sock *sock)
}
+void
+nni_sock_reconntimes(nni_sock *sock, nni_duration *rcur, nni_duration *rmax)
+{
+ // These two values are linked, so get them atomically.
+ nni_mtx_lock(&sock->s_mx);
+ *rcur = sock->s_reconn;
+ *rmax = sock->s_reconnmax ? sock->s_reconnmax : sock->s_reconn;
+ nni_mtx_unlock(&sock->s_mx);
+}
+
+
int
nni_sock_dial(nni_sock *sock, const char *addr, nni_ep **epp, int flags)
{