fix stalling db closing in case there is exp backoff for connectin ac…

…tive
drpcorg · Nov 22, 2024 · 2102e0b · 2102e0b
1 parent 5f651fb
commit 2102e0b
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/protocol/net.go b/protocol/net.go
@@ -236,7 +236,11 @@ func (n *Net) KeepConnecting(ctx context.Context, name string, addrs []string) {
 		if err != nil {
 			n.log.Error("net: couldn't connect", "name", name, "err", err)
 
-			time.Sleep(connBackoff)
+			select {
+			case <-time.After(connBackoff):
+			case <-ctx.Done():
+				break
+			}
 			connBackoff = min(MAX_RETRY_PERIOD, connBackoff*2)
 
 			continue