diff --git a/cmd/genswaggertypedocs/swagger_type_docs.go b/cmd/genswaggertypedocs/swagger_type_docs.go index 2725250b1a..0d3f8cbba2 100644 --- a/cmd/genswaggertypedocs/swagger_type_docs.go +++ b/cmd/genswaggertypedocs/swagger_type_docs.go @@ -20,7 +20,6 @@ import ( "fmt" "io" "os" - "runtime" kruntime "k8s.io/kubernetes/pkg/runtime" @@ -35,7 +34,6 @@ var ( ) func main() { - runtime.GOMAXPROCS(runtime.NumCPU()) flag.Parse() if *typeSrc == "" { diff --git a/cmd/hyperkube/hyperkube.go b/cmd/hyperkube/hyperkube.go index 45f1d6d44b..5501dacd01 100644 --- a/cmd/hyperkube/hyperkube.go +++ b/cmd/hyperkube/hyperkube.go @@ -26,7 +26,6 @@ import ( "io/ioutil" "os" "path" - "runtime" "k8s.io/kubernetes/pkg/util" utilflag "k8s.io/kubernetes/pkg/util/flag" @@ -188,7 +187,6 @@ func (hk *HyperKube) Run(args []string) error { // RunToExit will run the hyperkube and then call os.Exit with an appropriate exit code. func (hk *HyperKube) RunToExit(args []string) { - runtime.GOMAXPROCS(runtime.NumCPU()) err := hk.Run(args) if err != nil { fmt.Fprint(os.Stderr, err.Error()) diff --git a/cmd/kube-apiserver/apiserver.go b/cmd/kube-apiserver/apiserver.go index 646486d16a..b381ae9920 100644 --- a/cmd/kube-apiserver/apiserver.go +++ b/cmd/kube-apiserver/apiserver.go @@ -22,7 +22,6 @@ import ( "fmt" "math/rand" "os" - "runtime" "time" "k8s.io/kubernetes/cmd/kube-apiserver/app" @@ -35,7 +34,6 @@ import ( ) func main() { - runtime.GOMAXPROCS(runtime.NumCPU()) rand.Seed(time.Now().UTC().UnixNano()) s := options.NewAPIServer() diff --git a/cmd/kube-controller-manager/controller-manager.go b/cmd/kube-controller-manager/controller-manager.go index 6c1bc72daa..4caa7dd380 100644 --- a/cmd/kube-controller-manager/controller-manager.go +++ b/cmd/kube-controller-manager/controller-manager.go @@ -23,7 +23,6 @@ package main import ( "fmt" "os" - "runtime" "k8s.io/kubernetes/cmd/kube-controller-manager/app" "k8s.io/kubernetes/cmd/kube-controller-manager/app/options" @@ -40,7 +39,6 @@ func init() { } func main() { - runtime.GOMAXPROCS(runtime.NumCPU()) s := options.NewCMServer() s.AddFlags(pflag.CommandLine) diff --git a/cmd/kube-dns/app/options/options.go b/cmd/kube-dns/app/options/options.go index a5689952f2..3978b707a9 100644 --- a/cmd/kube-dns/app/options/options.go +++ b/cmd/kube-dns/app/options/options.go @@ -22,10 +22,11 @@ import ( "os" "fmt" - "github.com/spf13/pflag" - "k8s.io/kubernetes/pkg/util/validation" _ "net/http/pprof" "strings" + + "github.com/spf13/pflag" + "k8s.io/kubernetes/pkg/util/validation" ) type KubeDNSConfig struct { diff --git a/cmd/kube-proxy/proxy.go b/cmd/kube-proxy/proxy.go index 0137bb32e4..772a71fe48 100644 --- a/cmd/kube-proxy/proxy.go +++ b/cmd/kube-proxy/proxy.go @@ -19,7 +19,6 @@ package main import ( "fmt" "os" - "runtime" "k8s.io/kubernetes/cmd/kube-proxy/app" "k8s.io/kubernetes/cmd/kube-proxy/app/options" @@ -36,7 +35,6 @@ func init() { } func main() { - runtime.GOMAXPROCS(runtime.NumCPU()) config := options.NewProxyConfig() config.AddFlags(pflag.CommandLine) diff --git a/cmd/kubectl/kubectl.go b/cmd/kubectl/kubectl.go index cc7b11207c..3fce17f408 100644 --- a/cmd/kubectl/kubectl.go +++ b/cmd/kubectl/kubectl.go @@ -18,13 +18,11 @@ package main import ( "os" - "runtime" "k8s.io/kubernetes/cmd/kubectl/app" ) func main() { - runtime.GOMAXPROCS(runtime.NumCPU()) if err := app.Run(); err != nil { os.Exit(1) } diff --git a/cmd/kubelet/kubelet.go b/cmd/kubelet/kubelet.go index aa2356cfe5..dbd5dafa40 100644 --- a/cmd/kubelet/kubelet.go +++ b/cmd/kubelet/kubelet.go @@ -23,7 +23,6 @@ package main import ( "fmt" "os" - "runtime" "k8s.io/kubernetes/cmd/kubelet/app" "k8s.io/kubernetes/cmd/kubelet/app/options" @@ -35,7 +34,6 @@ import ( ) func main() { - runtime.GOMAXPROCS(runtime.NumCPU()) s := options.NewKubeletServer() s.AddFlags(pflag.CommandLine) diff --git a/cmd/kubemark/hollow-node.go b/cmd/kubemark/hollow-node.go index b5ca17d967..77ab67e952 100644 --- a/cmd/kubemark/hollow-node.go +++ b/cmd/kubemark/hollow-node.go @@ -18,7 +18,6 @@ package main import ( "fmt" - "runtime" "k8s.io/kubernetes/pkg/api" "k8s.io/kubernetes/pkg/client/record" @@ -83,7 +82,6 @@ func (c *HollowNodeConfig) createClientFromFile() (*client.Client, error) { } func main() { - runtime.GOMAXPROCS(runtime.NumCPU()) config := HollowNodeConfig{} config.addFlags(pflag.CommandLine) diff --git a/contrib/mesos/cmd/k8sm-controller-manager/main.go b/contrib/mesos/cmd/k8sm-controller-manager/main.go index 5437382320..9e7b7b18be 100644 --- a/contrib/mesos/cmd/k8sm-controller-manager/main.go +++ b/contrib/mesos/cmd/k8sm-controller-manager/main.go @@ -19,7 +19,6 @@ package main import ( "fmt" "os" - "runtime" "k8s.io/kubernetes/pkg/healthz" "k8s.io/kubernetes/pkg/util" @@ -36,7 +35,6 @@ func init() { } func main() { - runtime.GOMAXPROCS(runtime.NumCPU()) s := controllermanager.NewCMServer() s.AddFlags(pflag.CommandLine) diff --git a/contrib/mesos/cmd/k8sm-executor/main.go b/contrib/mesos/cmd/k8sm-executor/main.go index ed1a206ab9..4f706ce6ca 100644 --- a/contrib/mesos/cmd/k8sm-executor/main.go +++ b/contrib/mesos/cmd/k8sm-executor/main.go @@ -19,7 +19,6 @@ package main import ( "fmt" "os" - "runtime" "github.com/spf13/pflag" "k8s.io/kubernetes/contrib/mesos/pkg/executor/service" @@ -30,7 +29,6 @@ import ( ) func main() { - runtime.GOMAXPROCS(runtime.NumCPU()) s := service.NewKubeletExecutorServer() s.AddFlags(pflag.CommandLine) diff --git a/contrib/mesos/cmd/k8sm-scheduler/main.go b/contrib/mesos/cmd/k8sm-scheduler/main.go index 15bbc3218c..b685bafc59 100644 --- a/contrib/mesos/cmd/k8sm-scheduler/main.go +++ b/contrib/mesos/cmd/k8sm-scheduler/main.go @@ -19,7 +19,6 @@ package main import ( "fmt" "os" - "runtime" "github.com/spf13/pflag" "k8s.io/kubernetes/contrib/mesos/pkg/hyperkube" @@ -30,7 +29,6 @@ import ( ) func main() { - runtime.GOMAXPROCS(runtime.NumCPU()) s := service.NewSchedulerServer() s.AddStandaloneFlags(pflag.CommandLine) diff --git a/contrib/mesos/cmd/km/hyperkube.go b/contrib/mesos/cmd/km/hyperkube.go index 771d69899c..bb90278a25 100644 --- a/contrib/mesos/cmd/km/hyperkube.go +++ b/contrib/mesos/cmd/km/hyperkube.go @@ -25,7 +25,6 @@ import ( "io/ioutil" "os" "path" - "runtime" "k8s.io/kubernetes/pkg/util" "k8s.io/kubernetes/pkg/version/verflag" @@ -177,7 +176,6 @@ func (hk *HyperKube) Run(args []string) error { // RunToExit will run the hyperkube and then call os.Exit with an appropriate exit code. func (hk *HyperKube) RunToExit(args []string) { - runtime.GOMAXPROCS(runtime.NumCPU()) err := hk.Run(args) if err != nil { fmt.Fprint(os.Stderr, err.Error()) diff --git a/federation/cmd/federation-apiserver/apiserver.go b/federation/cmd/federation-apiserver/apiserver.go index 7f2deaebfa..7a65dca867 100644 --- a/federation/cmd/federation-apiserver/apiserver.go +++ b/federation/cmd/federation-apiserver/apiserver.go @@ -22,7 +22,6 @@ import ( "fmt" "math/rand" "os" - "runtime" "time" "k8s.io/kubernetes/federation/cmd/federation-apiserver/app" @@ -35,7 +34,6 @@ import ( ) func main() { - runtime.GOMAXPROCS(runtime.NumCPU()) rand.Seed(time.Now().UTC().UnixNano()) s := genericoptions.NewServerRunOptions() diff --git a/federation/cmd/federation-controller-manager/controller-manager.go b/federation/cmd/federation-controller-manager/controller-manager.go index 3e9becea55..bee83bebcb 100644 --- a/federation/cmd/federation-controller-manager/controller-manager.go +++ b/federation/cmd/federation-controller-manager/controller-manager.go @@ -19,7 +19,6 @@ package main import ( "fmt" "os" - "runtime" "github.com/spf13/pflag" "k8s.io/kubernetes/federation/cmd/federation-controller-manager/app" @@ -35,7 +34,6 @@ func init() { } func main() { - runtime.GOMAXPROCS(runtime.NumCPU()) s := options.NewCMServer() s.AddFlags(pflag.CommandLine) diff --git a/plugin/cmd/kube-scheduler/scheduler.go b/plugin/cmd/kube-scheduler/scheduler.go index 5d05a222d0..54ea65958b 100644 --- a/plugin/cmd/kube-scheduler/scheduler.go +++ b/plugin/cmd/kube-scheduler/scheduler.go @@ -17,8 +17,6 @@ limitations under the License. package main import ( - "runtime" - "k8s.io/kubernetes/pkg/healthz" "k8s.io/kubernetes/pkg/util" "k8s.io/kubernetes/pkg/util/flag" @@ -34,7 +32,6 @@ func init() { } func main() { - runtime.GOMAXPROCS(runtime.NumCPU()) s := options.NewSchedulerServer() s.AddFlags(pflag.CommandLine)