use it in windows host process

kubernetes-sigs · Nov 12, 2024 · 4ac69ae · 4ac69ae
1 parent 2e8cd4a
commit 4ac69ae
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/pkg/mounter/safe_mounter_windows.go b/pkg/mounter/safe_mounter_windows.go
@@ -415,10 +415,8 @@ func newCSIProxyMounter() (*csiProxyMounter, error) {
 func NewSafeMounter(enableWindowsHostProcess, useCSIProxyGAInterface bool, maxConcurrentFormat int, concurrentFormatTimeout time.Duration) (*mount.SafeFormatAndMount, error) {
 	if enableWindowsHostProcess {
 		klog.V(2).Infof("using windows host process mounter")
-		return &mount.SafeFormatAndMount{
-			Interface: NewWinMounter(),
-			Exec:      utilexec.New(),
-		}, nil
+		opt := mount.WithMaxConcurrentFormat(maxConcurrentFormat, concurrentFormatTimeout)
+		return mount.NewSafeFormatAndMount(NewWinMounter(), utilexec.New(), opt), nil
 	} else {
 		if useCSIProxyGAInterface {
 			csiProxyMounter, err := newCSIProxyMounter()