swarm: send notifications synchronously (#1562)

libp2p · Jun 24, 2022 · d4e0b6a · d4e0b6a
1 parent c4ef41f
commit d4e0b6a
Showing 1 changed file with 1 addition and 9 deletions.
diff --git a/p2p/net/swarm/swarm.go b/p2p/net/swarm/swarm.go
@@ -541,18 +541,10 @@ func (s *Swarm) Backoff() *DialBackoff {
 
 // notifyAll sends a signal to all Notifiees
 func (s *Swarm) notifyAll(notify func(network.Notifiee)) {
- var wg sync.WaitGroup
-
  s.notifs.RLock()
- wg.Add(len(s.notifs.m))
  for f := range s.notifs.m {
- go func(f network.Notifiee) {
- defer wg.Done()
- notify(f)
- }(f)
+ notify(f)
  }
-
- wg.Wait()
  s.notifs.RUnlock()
 }