Merge pull request #2315 from k8s-infra-cherrypick-robot/cherry-pick-…

…2314-to-release-1.31

[release-1.31] chore: set GoMaxProcs as 2

pkg/azurefile/azurefile_options.go

@@ -48,6 +48,7 @@ type DriverOptions struct {
 	PrintVolumeStatsCallLogs               bool
 	SasTokenExpirationMinutes              int
 	WaitForAzCopyTimeoutMinutes            int
+	GoMaxProcs                             int
 	KubeConfig                             string
 	Endpoint                               string
 }
@@ -87,6 +88,7 @@ func (o *DriverOptions) AddFlags() *flag.FlagSet {
 	fs.IntVar(&o.WaitForAzCopyTimeoutMinutes, "wait-for-azcopy-timeout-minutes", 19, "timeout in minutes for waiting for azcopy to finish")
 	fs.StringVar(&o.KubeConfig, "kubeconfig", "", "Absolute path to the kubeconfig file. Required only when running out of cluster.")
 	fs.StringVar(&o.Endpoint, "endpoint", "unix://tmp/csi.sock", "CSI endpoint")
+	fs.IntVar(&o.GoMaxProcs, "max-procs", 2, "maximum number of CPUs that can be executing simultaneously in golang runtime")
 
 	return fs
 }

pkg/azurefileplugin/main.go

@@ -23,6 +23,7 @@ import (
 	"net"
 	"net/http"
 	"os"
+	"runtime"
 	"strings"
 
 	"sigs.k8s.io/azurefile-csi-driver/pkg/azurefile"
@@ -61,6 +62,9 @@ func main() {
 }
 
 func handle() {
+	runtime.GOMAXPROCS(driverOptions.GoMaxProcs)
+	klog.Infof("Sys info: NumCPU: %v MAXPROC: %v", runtime.NumCPU(), runtime.GOMAXPROCS(0))
+
 	driver := azurefile.NewDriver(&driverOptions)
 	if driver == nil {
 		klog.Fatalln("Failed to initialize azurefile CSI Driver")