From 706938db11623ed5e50ff4169f573191300893fc Mon Sep 17 00:00:00 2001 From: kang Date: Tue, 15 Jun 2021 11:59:16 +0900 Subject: [PATCH] add else statement in poller.go sync --- pkg/queue/poller.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/queue/poller.go b/pkg/queue/poller.go index 9e54e1a3..41109b5a 100644 --- a/pkg/queue/poller.go +++ b/pkg/queue/poller.go @@ -68,8 +68,9 @@ func (p *Poller) Sync(stopCh <-chan struct{}) { for key, status := range threadStatus { if status == false { delete(p.threads, key) + } else { + p.threads[key] = status } - p.threads[key] = status } case <-stopCh: klog.V(1).Info("Stopping sync thread of poller gracefully.")