raise activation channel capacity to 16

6 years ago · efdc140264
1 changed files with 1 additions and 1 deletions
--- a/p2p/protocol/identify/obsaddr.go
+++ b/p2p/protocol/identify/obsaddr.go
@ -67,7 +67,7 @@ func NewObservedAddrSet(ctx context.Context) *ObservedAddrSet {
 	oas := &ObservedAddrSet{
 		addrs: make(map[string][]*ObservedAddr),
 		ttl:   pstore.OwnObservedAddrTTL,
-		wch:   make(chan newObservation, 1),
+		wch:   make(chan newObservation, 16),
 	}
 	go oas.worker(ctx)
 	return oas