chore: provide a driver flag to print volume stats call with log level 2

Author: andyzhangx

pkg/azurefile/azurefile.go

@@ -202,6 +202,7 @@ type DriverOptions struct {
 	AppendNoShareSockOption                bool
 	SkipMatchingTagCacheExpireInMinutes    int
 	VolStatsCacheExpireInMinutes           int
+	PrintVolumeStatsCallLogs               bool
 }
 
 // Driver implements all interfaces of CSI drivers
@@ -222,6 +223,7 @@ type Driver struct {
 	kubeAPIQPS                             float64
 	kubeAPIBurst                           int
 	appendNoShareSockOption                bool
+	printVolumeStatsCallLogs               bool
 	fileClient                             *azureFileClient
 	mounter                                *mount.SafeFormatAndMount
 	// lock per volume attach (only for vhd disk feature)
@@ -272,6 +274,7 @@ func NewDriver(options *DriverOptions) *Driver {
 	driver.kubeAPIQPS = options.KubeAPIQPS
 	driver.kubeAPIBurst = options.KubeAPIBurst
 	driver.appendNoShareSockOption = options.AppendNoShareSockOption
+	driver.printVolumeStatsCallLogs = options.PrintVolumeStatsCallLogs
 	driver.volLockMap = newLockMap()
 	driver.subnetLockMap = newLockMap()
 	driver.volumeLocks = newVolumeLocks()

pkg/azurefile/nodeserver.go

@@ -468,7 +468,11 @@ func (d *Driver) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeS
 		return nil, status.Errorf(codes.Internal, "failed to stat file %s: %v", req.VolumePath, err)
 	}
 
-	klog.V(6).Infof("NodeGetVolumeStats: begin to get VolumeStats on volume %s path %s", req.VolumeId, req.VolumePath)
+	if d.printVolumeStatsCallLogs {
+		klog.V(2).Infof("NodeGetVolumeStats: begin to get VolumeStats on volume %s path %s", req.VolumeId, req.VolumePath)
+	} else {
+		klog.V(6).Infof("NodeGetVolumeStats: begin to get VolumeStats on volume %s path %s", req.VolumeId, req.VolumePath)
+	}
 
 	volumeMetrics, err := volume.NewMetricsStatFS(req.VolumePath).GetMetrics()
 	if err != nil {
@@ -518,7 +522,11 @@ func (d *Driver) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeS
 		},
 	}
 
-	klog.V(6).Infof("NodeGetVolumeStats: volume stats for volume %s path %s is %v", req.VolumeId, req.VolumePath, resp)
+	if d.printVolumeStatsCallLogs {
+		klog.V(2).Infof("NodeGetVolumeStats: volume stats for volume %s path %s is %v", req.VolumeId, req.VolumePath, resp)
+	} else {
+		klog.V(6).Infof("NodeGetVolumeStats: volume stats for volume %s path %s is %v", req.VolumeId, req.VolumePath, resp)
+	}
 	// cache the volume stats per volume
 	d.volStatsCache.Set(req.VolumeId, *resp)
 	if newVolID != "" {

pkg/azurefileplugin/main.go

@@ -58,6 +58,7 @@ var (
 	appendNoShareSockOption                = flag.Bool("append-nosharesock-option", true, "Whether appending nosharesock option to smb mount command")
 	skipMatchingTagCacheExpireInMinutes    = flag.Int("skip-matching-tag-cache-expire-in-minutes", 30, "The cache expire time in minutes for skipMatchingTagCache")
 	volStatsCacheExpireInMinutes           = flag.Int("vol-stats-cache-expire-in-minutes", 10, "The cache expire time in minutes for volume stats cache")
+	printVolumeStatsCallLogs               = flag.Bool("print-volume-stats-call-logs", false, "Whether to print volume statfs call logs with log level 2")
 )
 
 func main() {
@@ -101,6 +102,7 @@ func handle() {
 		AppendNoShareSockOption:                *appendNoShareSockOption,
 		SkipMatchingTagCacheExpireInMinutes:    *skipMatchingTagCacheExpireInMinutes,
 		VolStatsCacheExpireInMinutes:           *volStatsCacheExpireInMinutes,
+		PrintVolumeStatsCallLogs:               *printVolumeStatsCallLogs,
 	}
 	driver := azurefile.NewDriver(&driverOptions)
 	if driver == nil {