Removed mutex from fake k8s

Author: kolluria

pkg/common/unittestcommon/types.go

@@ -50,8 +50,6 @@ type FakeK8SOrchestrator struct {
 	csiNodeTopologyInstances []interface{}
 	// PVCs for testing
 	pvcs []*v1.PersistentVolumeClaim
-	// RWMutex to synchronize access to 'pvcs' field from multiple callers
-	pvcsLock *sync.RWMutex
 }
 
 // volumeMigration holds mocked migrated volume information

pkg/common/unittestcommon/utils.go

@@ -544,12 +544,6 @@ func (c *FakeK8SOrchestrator) SetCSINodeTopologyInstances(instances []interface{
 }
 
 func (c *FakeK8SOrchestrator) ListPVCs(ctx context.Context, namespace string) []*v1.PersistentVolumeClaim {
-	if c.pvcsLock == nil {
-		c.pvcsLock = &sync.RWMutex{}
-	}
-	c.pvcsLock.RLock()
-	defer c.pvcsLock.RUnlock()
-
 	if namespace == "" {
 		// Return all PVCs
 		return c.pvcs
@@ -567,11 +561,6 @@ func (c *FakeK8SOrchestrator) ListPVCs(ctx context.Context, namespace string) []
 
 // SetPVCs sets the PVCs for testing
 func (c *FakeK8SOrchestrator) SetPVCs(pvcs []*v1.PersistentVolumeClaim) {
-	if c.pvcsLock == nil {
-		c.pvcsLock = &sync.RWMutex{}
-	}
-	c.pvcsLock.Lock()
-	defer c.pvcsLock.Unlock()
 	c.pvcs = pvcs
 }