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

…2789-to-release-1.31

[release-1.31] chore: set GoMaxProcs as 2

pkg/azuredisk/azuredisk_option.go

@@ -64,6 +64,7 @@ type DriverOptions struct {
 	RemoveNotReadyTaint          bool
 	MaxConcurrentFormat          int64
 	ConcurrentFormatTimeout      int64
+	GoMaxProcs                   int64
 }
 
 func (o *DriverOptions) AddFlags() *flag.FlagSet {
@@ -109,6 +110,6 @@ func (o *DriverOptions) AddFlags() *flag.FlagSet {
 	fs.StringVar(&o.Endpoint, "endpoint", "unix://tmp/csi.sock", "CSI endpoint")
 	fs.Int64Var(&o.MaxConcurrentFormat, "max-concurrent-format", 2, "maximum number of concurrent format exec calls")
 	fs.Int64Var(&o.ConcurrentFormatTimeout, "concurrent-format-timeout", 300, "maximum time in seconds duration of a format operation before its concurrency token is released")
-
+	fs.Int64Var(&o.GoMaxProcs, "max-procs", 2, "maximum number of CPUs that can be executing simultaneously in golang runtime")
 	return fs
 }

pkg/azurediskplugin/main.go

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