Skip to content
This repository was archived by the owner on Jan 24, 2025. It is now read-only.

Commit 3e2cb84

Browse files
committed
Shutdown the validator loops on scheduler shutdown
1 parent 600a856 commit 3e2cb84

File tree

1 file changed

+3
-0
lines changed
  • pkg/protocol/engine/congestioncontrol/scheduler/drr

1 file changed

+3
-0
lines changed

pkg/protocol/engine/congestioncontrol/scheduler/drr/scheduler.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -388,6 +388,9 @@ loop:
388388
for {
389389
select {
390390
// on close, exit the loop
391+
case <-s.shutdownSignal:
392+
break loop
393+
// on close, exit the loop
391394
case <-validatorQueue.shutdownSignal:
392395
break loop
393396
// when a block is pushed by this validator queue.

0 commit comments

Comments
 (0)