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

emit new peer notification without holding the semaphore

Browse Source
This commit is contained in:
vyzo 2021-07-12 19:27:01 +03:00
parent ac4a401fd6
commit 861bb84b1e
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
notify.go
View File

@ -24,15 +24,13 @@ func (p *PubSubNotif) Connected(n network.Network, c network.Conn) {
select {
case <-p.newPeersSema:
defer func() {
p.newPeersSema <- struct{}{}
}()
case <-p.ctx.Done():
return
}
p.newPeersPend[c.RemotePeer()] = struct{}{}
p.newPeersSema <- struct{}{}
select {
case p.newPeers <- struct{}{}:
default:
@ -61,10 +59,6 @@ func (p *PubSubNotif) Initialize() {
select {
case <-p.newPeersSema:
defer func() {
p.newPeersSema <- struct{}{}
}()
case <-p.ctx.Done():
return
}
@ -76,6 +70,8 @@ func (p *PubSubNotif) Initialize() {
p.newPeersPend[pid] = struct{}{}
}
p.newPeersSema <- struct{}{}
select {
case p.newPeers <- struct{}{}:
default: