logos-messaging/go-libp2p-pubsub
1
0
Fork 0
mirror of https://github.com/logos-messaging/go-libp2p-pubsub.git synced 2026-01-23 06:53:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

don't spawn a goroutine for scheduling connections

Browse Source
This commit is contained in:
vyzo 2019-12-06 17:22:49 +02:00
parent 0dec90571b
commit ce1970d18d
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
gossipsub.go
View File

@ -420,16 +420,14 @@ func (gs *GossipSubRouter) pxConnect(peers []*pb.PeerInfo) {
return
}
// initiate connections, without blocking the event loop
go func() {
for _, ci := range toconnect {
select {
case gs.connect <- ci:
case <-gs.p.ctx.Done():
return
}
for _, ci := range toconnect {
select {
case gs.connect <- ci:
default:
log.Debugf("ignoring peer connection attempt; too many pending connections")
break
}
}()
}
}
func (gs *GossipSubRouter) connector() {