Переглянути джерело

fix: do not prematurely close channel

Signed-off-by: mudler <[email protected]>
mudler 1 рік тому
батько
коміт
d061067801
1 змінених файлів з 1 додано та 1 видалено
  1. 1 1
      pkg/discovery/dht.go

+ 1 - 1
pkg/discovery/dht.go

@@ -164,7 +164,7 @@ func (d *DHT) FindClosePeers(ll log.StandardLogger, onlyStaticRelays bool, stati
 			if !onlyStaticRelays {
 				closestPeers, err := d.GetClosestPeers(ctx, d.PeerID().String())
 				if err != nil {
-					close(peerChan)
+					ll.Debug("Error getting closest peers: ", err)
 				}
 
 				for _, p := range closestPeers {