chore: update pex initial backoff (#3266)

Signed-off-by: Jim Ma <[email protected]>
dragonflyoss · May 14, 2024 · dc4540d · dc4540d
1 parent 7c69d5d
commit dc4540d
Showing 1 changed file with 19 additions and 6 deletions.
diff --git a/client/daemon/pex/peer_exchange.go b/client/daemon/pex/peer_exchange.go
@@ -224,17 +224,30 @@ func (p *peerExchange) Serve(localMember *MemberMeta) error {
 	go p.memberManager.broadcastInBackground()
 	go p.reSyncMember()
 
-	for {
-		if err := p.serve(); err == nil {
-			break
-		}
-	}
+	p.serve()
 
 	<-p.stopCh
 	return nil
 }
 
-func (p *peerExchange) serve() error {
+func (p *peerExchange) serve() {
+	for {
+		err := p.listAndJoin()
+		if err == nil {
+			return
+		}
+
+		select {
+		case <-p.stopCh:
+			return
+		default:
+		}
+
+		time.Sleep(p.config.initialRetryInterval)
+	}
+}
+
+func (p *peerExchange) listAndJoin() error {
 	var (
 		members []*InitialMember
 		err     error