Merge pull request #135 from KangBK0120/fix-issue-134

add else statement in poller.go sync
practo · Jun 15, 2021 · da47e88 · da47e88
2 parents 507157c + 706938d
commit da47e88
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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.")