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

release priority locks early when handling batches

Browse Source
This commit is contained in:
vyzo 2021-07-13 20:38:07 +03:00
parent e9e5a9913f
commit 3b98004eed
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pubsub.go
View File

@ -592,14 +592,15 @@ func (p *PubSub) processLoop(ctx context.Context) {
func (p *PubSub) handlePendingPeers() {
p.newPeersPrioLk.Lock()
defer p.newPeersPrioLk.Unlock()
if len(p.newPeersPend) == 0 {
p.newPeersPrioLk.Unlock()
return
}
newPeers := p.newPeersPend
p.newPeersPend = make(map[peer.ID]struct{})
p.newPeersPrioLk.Unlock()
for pid := range newPeers {
if p.host.Network().Connectedness(pid) != network.Connected {
@ -625,14 +626,15 @@ func (p *PubSub) handlePendingPeers() {
func (p *PubSub) handleDeadPeers() {
p.peerDeadPrioLk.Lock()
defer p.peerDeadPrioLk.Unlock()
if len(p.peerDeadPend) == 0 {
p.peerDeadPrioLk.Unlock()
return
}
deadPeers := p.peerDeadPend
p.peerDeadPend = make(map[peer.ID]struct{})
p.peerDeadPrioLk.Unlock()
for pid := range deadPeers {
ch, ok := p.peers[pid]