fix(p2p): set connect timeout

celestiaorg · Mar 25, 2024 · 181faa3 · 181faa3
1 parent bdda26a
commit 181faa3
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/p2p/peer_tracker.go b/p2p/peer_tracker.go
@@ -109,6 +109,8 @@ func (p *peerTracker) bootstrap(ctx context.Context, trusted []libpeer.ID) error
 
 // connectToPeer attempts to connect to the given peer.
 func (p *peerTracker) connectToPeer(ctx context.Context, peer libpeer.ID) {
+	ctx, cancel := context.WithTimeout(ctx, time.Second*5)
+	defer cancel()
 	err := p.host.Connect(ctx, p.host.Peerstore().PeerInfo(peer))
 	if err != nil {
 		log.Debugw("failed to connect to peer", "id", peer.String(), "err", err)