From bf2eb2eed3232cb9f3872d46c5e6bca8855840be Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Tue, 6 Jun 2017 09:24:31 -0700 Subject: Reconn times acquired atomically by socket under lock. --- src/core/socket.c | 11 +++++++++++ 1 file changed, 11 insertions(+) (limited to 'src/core/socket.c') 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) { -- cgit v1.2.3-70-g09d2