Merge pull request #654 from private-forks/fix_close_race

[FIXED] Missing connection status check causing unexpected delay during connection close
nats-io · May 15, 2023 · 8c02dcc · 8c02dcc
2 parents 7f6910e + 5bc5156
commit 8c02dcc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/conn.c b/src/conn.c
@@ -1581,15 +1581,15 @@ _doReconnect(void *arg)
                 natsConn_Unlock(nc);
                 sleepTime = crd(nc, wlf, crdClosure);
                 natsConn_Lock(nc);
-                if (natsConn_isClosed(nc))
-                    break;
             }
             else
             {
                 sleepTime = nc->opts->reconnectWait;
                 if (jitter > 0)
                     sleepTime += rand() % jitter;
             }
+            if (natsConn_isClosed(nc))
+                break;
             natsCondition_TimedWait(nc->reconnectCond, nc->mu, sleepTime);
         }
         else