fix: shutdown vpc workqueue

kubeovn · Nov 4, 2020 · 32c49c1 · 32c49c1
1 parent 67076d6
commit 32c49c1
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/pkg/controller/controller.go b/pkg/controller/controller.go
@@ -60,7 +60,6 @@ type Controller struct {
 	addOrUpdateSubnetQueue  workqueue.RateLimitingInterface
 	deleteSubnetQueue       workqueue.RateLimitingInterface
 	deleteRouteQueue        workqueue.RateLimitingInterface
-	checkVpcResourceQueue   workqueue.RateLimitingInterface
 	updateSubnetStatusQueue workqueue.RateLimitingInterface
 
 	ipsLister kubeovnlister.IPLister
@@ -348,7 +347,9 @@ func (c *Controller) shutdown() {
 	c.delVlanQueue.ShutDown()
 	c.updateVlanQueue.ShutDown()
 
-	c.checkVpcResourceQueue.ShutDown()
+	c.addOrUpdateVpcQueue.ShutDown()
+	c.updateVpcStatusQueue.ShutDown()
+	c.delVpcQueue.ShutDown()
 }
 
 func (c *Controller) startWorkers(stopCh <-chan struct{}) {