add subnetstatus lock for handleAddOrUpdateSubnet (#2669)

kubeovn · Apr 19, 2023 · 5ad2baf · 5ad2baf
1 parent f314ab5
commit 5ad2baf
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/controller/subnet.go b/pkg/controller/subnet.go
@@ -473,6 +473,8 @@ func (c Controller) patchSubnetStatus(subnet *kubeovnv1.Subnet, reason string, e
 
 func (c *Controller) handleAddOrUpdateSubnet(key string) error {
 	var err error
+	c.subnetStatusKeyMutex.Lock(key)
+	defer c.subnetStatusKeyMutex.Unlock(key)
 
 	cachedSubnet, err := c.subnetsLister.Get(key)
 	if err != nil {