fix: add mount timeout in NFS EiT mount

fix

fix

Author: andyzhangx

pkg/azurefile-proxy/server/server.go

@@ -21,14 +21,18 @@ import (
 	"fmt"
 	"net"
 	"strings"
+	"time"
 
 	grpcprom "github.com/grpc-ecosystem/go-grpc-middleware/providers/prometheus"
 	"google.golang.org/grpc"
 	"k8s.io/klog/v2"
 	mount_utils "k8s.io/mount-utils"
 	mount_azurefile "sigs.k8s.io/azurefile-csi-driver/pkg/azurefile-proxy/pb"
+	volumehelper "sigs.k8s.io/azurefile-csi-driver/pkg/util"
 )
 
+const mountTimeoutInSec = 90
+
 type MountServer struct {
 	mount_azurefile.UnimplementedMountServiceServer
 
@@ -55,8 +59,14 @@ func (server *MountServer) MountAzureFile(_ context.Context,
 	sensitiveOptions := req.GetSensitiveOptions()
 	klog.V(2).Infof("received mount request: source: %s, target: %s, fstype: %s, options: %s", source, target, fstype, strings.Join(options, ","))
 
-	err = server.mounter.MountSensitive(source, target, fstype, options, sensitiveOptions)
-	if err != nil {
+	execFunc := func() error {
+		return server.mounter.MountSensitive(source, target, fstype, options, sensitiveOptions)
+	}
+	timeoutFunc := func() error {
+		return fmt.Errorf("mount operation timed out after 90 seconds: source=%s, target=%s", source, target)
+	}
+
+	if err = volumehelper.WaitUntilTimeout(mountTimeoutInSec*time.Second, execFunc, timeoutFunc); err != nil {
 		klog.Error("azurefile mount failed: with error:", err.Error())
 		return nil, fmt.Errorf("azurefile mount failed: %v", err)
 	}