diff --git a/pkg/utils/opsqueue.go b/pkg/utils/opsqueue.go index 01f9a12ff..30dbbe1ec 100644 --- a/pkg/utils/opsqueue.go +++ b/pkg/utils/opsqueue.go @@ -75,8 +75,12 @@ func (oq *OpsQueue) Enqueue(op func()) { oq.lock.Lock() defer oq.lock.Unlock() + if oq.isStopped { + return + } + oq.ops.PushBack(op) - if oq.ops.Len() == 1 && !oq.isStopped { + if oq.ops.Len() == 1 { select { case oq.wake <- struct{}{}: default: