fix race for hasPeerCh pointer read

walldiss · Oct 10, 2023 · be29fb7 · be29fb7
1 parent 00b32a8
commit be29fb7
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/share/p2p/peers/pool.go b/share/p2p/peers/pool.go
@@ -89,8 +89,11 @@ func (p *pool) next(ctx context.Context) <-chan peer.ID {
 				return
 			}
 
+			p.m.RLock()
+			hasPeerCh := p.hasPeerCh
+			p.m.RUnlock()
 			select {
-			case <-p.hasPeerCh:
+			case <-hasPeerCh:
 			case <-ctx.Done():
 				return
 			}