From 9a3692039a7dccb3a5cf115c411dd05bb272ae18 Mon Sep 17 00:00:00 2001 From: YangKeao Date: Thu, 15 Dec 2022 10:57:16 +0800 Subject: [PATCH] initialize notifyStateCh in ttl job manager Signed-off-by: YangKeao --- ttl/ttlworker/job_manager.go | 1 + 1 file changed, 1 insertion(+) diff --git a/ttl/ttlworker/job_manager.go b/ttl/ttlworker/job_manager.go index f067522411da7..58c47d05efe4f 100644 --- a/ttl/ttlworker/job_manager.go +++ b/ttl/ttlworker/job_manager.go @@ -90,6 +90,7 @@ func NewJobManager(id string, sessPool sessionPool, store kv.Storage) (manager * manager.store = store manager.sessPool = sessPool manager.delCh = make(chan *ttlDeleteTask) + manager.notifyStateCh = make(chan interface{}, 1) manager.init(manager.jobLoop) manager.ctx = logutil.WithKeyValue(manager.ctx, "ttl-worker", "manager")