add signal forwarding for exiting requesters

erigontech · May 27, 2024 · 5673ac1 · 5673ac1
1 parent 3e31912
commit 5673ac1
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/webseed-peer.go b/webseed-peer.go
@@ -217,6 +217,12 @@ func (ws *webseedPeer) requester(i int) {
 				ws.updateRequestor.Stop()
 				ws.updateRequestor = nil
 			}
+
+			if i < ws.maxRequesters && ws.waiting >= ws.maxRequesters {
+				// we've been woken by a signal - if we are going to exit
+				// instead of processing we need to pass the signal on
+				ws.requesterCond.Signal()
+			}
 		} else {
 			// if there are more than one requests in the queue and we don't
 			// have all of the responders activated yet we need to