From 02352290f29d0ec4dd5a4db382d72d8699e640ee Mon Sep 17 00:00:00 2001
From: Tomy GUICHARD <tguichard@scaleway.com>
Date: Wed, 21 Aug 2024 12:30:52 +0200
Subject: [PATCH] feat: remove global attach/detach mutex

---
 pkg/driver/controller.go | 7 -------
 1 file changed, 7 deletions(-)

diff --git a/pkg/driver/controller.go b/pkg/driver/controller.go
index a686746..068b78f 100644
--- a/pkg/driver/controller.go
+++ b/pkg/driver/controller.go
@@ -3,7 +3,6 @@ package driver
 import (
 	"context"
 	"strconv"
-	"sync"
 
 	"github.com/container-storage-interface/spec/lib/go/csi"
 	"github.com/scaleway/scaleway-csi/pkg/scaleway"
@@ -61,8 +60,6 @@ var _ csi.ControllerServer = &controllerService{}
 type controllerService struct {
 	scaleway scaleway.Interface
 	config   *DriverConfig
-	// Global attach/detach mutex.
-	mux sync.Mutex
 	// Volume locks ensures we don't run parallel operations on volumes (e.g.
 	// detaching a volume and taking a snapshot).
 	locks namedlocker.Store
@@ -220,8 +217,6 @@ func (d *controllerService) ControllerPublishVolume(ctx context.Context, req *cs
 		return nil, status.Errorf(codes.ResourceExhausted, "max number of volumes reached for instance %s", nodeID)
 	}
 
-	d.mux.Lock()
-	defer d.mux.Unlock()
 	if err := d.scaleway.AttachVolume(ctx, nodeID, volumeID, volumeZone); err != nil {
 		return nil, status.Errorf(codes.Internal, "failed to attach volume to instance: %s", err)
 	}
@@ -273,8 +268,6 @@ func (d *controllerService) ControllerUnpublishVolume(ctx context.Context, req *
 		return nil, status.Errorf(code, "failed to get server where to unpublish volume: %s", err)
 	}
 
-	d.mux.Lock()
-	defer d.mux.Unlock()
 	if err := d.scaleway.DetachVolume(ctx, volumeID, volumeZone); err != nil {
 		return nil, status.Errorf(codes.Internal, "failed to detach volume: %s", err)
 	}