Merge pull request #4785 from strahe/fix/fast-connect-bootstrappers

async connect to bootstrappers
filecoin-project · Nov 10, 2020 · 1df7318 · 1df7318
2 parents 3ec25cb + e340996
commit 1df7318
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/lib/peermgr/peermgr.go b/lib/peermgr/peermgr.go
@@ -191,11 +191,17 @@ func (pmgr *PeerMgr) doExpand(ctx context.Context) {
 		}
 
 		log.Info("connecting to bootstrap peers")
+		wg := sync.WaitGroup{}
 		for _, bsp := range pmgr.bootstrappers {
-			if err := pmgr.h.Connect(ctx, bsp); err != nil {
-				log.Warnf("failed to connect to bootstrap peer: %s", err)
-			}
+			wg.Add(1)
+			go func(bsp peer.AddrInfo) {
+				defer wg.Done()
+				if err := pmgr.h.Connect(ctx, bsp); err != nil {
+					log.Warnf("failed to connect to bootstrap peer: %s", err)
+				}
+			}(bsp)
 		}
+		wg.Wait()
 		return
 	}