Skip to content

Commit

Permalink
ttl: initialize notifyStateCh in ttl job manager (#39956)
Browse files Browse the repository at this point in the history
close #39955
  • Loading branch information
YangKeao authored Dec 15, 2022
1 parent c26a6b5 commit 51f0658
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions ttl/ttlworker/job_manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand Down

0 comments on commit 51f0658

Please sign in to comment.