diff --git a/pkg/protocol/engine/congestioncontrol/scheduler/drr/scheduler.go b/pkg/protocol/engine/congestioncontrol/scheduler/drr/scheduler.go index 114451d66..37fd2dd2d 100644 --- a/pkg/protocol/engine/congestioncontrol/scheduler/drr/scheduler.go +++ b/pkg/protocol/engine/congestioncontrol/scheduler/drr/scheduler.go @@ -388,6 +388,9 @@ loop: for { select { // on close, exit the loop + case <-s.shutdownSignal: + break loop + // on close, exit the loop case <-validatorQueue.shutdownSignal: break loop // when a block is pushed by this validator queue.