add peers async

vgonkivs · vgonkivs · commit 8ef32e8e30de · 2024-04-01T18:07:47.000+03:00
diff --git a/p2p/peer_tracker.go b/p2p/peer_tracker.go
@@ -67,7 +67,7 @@ func newPeerTracker(
 func (p *peerTracker) bootstrap(ctx context.Context, trusted []libpeer.ID) error {
 	// store peers that have been already connected
 	for _, c := range p.host.Network().Conns() {
-		p.connected(c.RemotePeer())
+		go p.connected(c.RemotePeer())
 	}
 
 	connectCtx, cancel := context.WithTimeout(context.Background(), time.Second*60)

Original file line number	Diff line number	Diff line change
`@@ -67,7 +67,7 @@ func newPeerTracker(`
`67`	`67`	`func (p *peerTracker) bootstrap(ctx context.Context, trusted []libpeer.ID) error {`
`68`	`68`	`// store peers that have been already connected`
`69`	`69`	`for _, c := range p.host.Network().Conns() {`
`70`		`- p.connected(c.RemotePeer())`
	`70`	`+ go p.connected(c.RemotePeer())`
`71`	`71`	`}`
`72`	`72`
`73`	`73`	`connectCtx, cancel := context.WithTimeout(context.Background(), time.Second*60)`