github
/
k3s
mirror of https://github.com/k3s-io/k3s
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Remove GOMAXPROCS() calls because they are unnecessary

pull/6/head
Lucas Käldström 2016-07-19 11:08:21 +03:00
parent 01925c810b
commit 88ea80b572
16 changed files with 3 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cmd/genswaggertypedocs/swagger_type_docs.go
View File

@ -20,7 +20,6 @@ import (
"fmt" "fmt"
"io" "io"
"os" "os"
"runtime"
kruntime "k8s.io/kubernetes/pkg/runtime" kruntime "k8s.io/kubernetes/pkg/runtime"
@ -35,7 +34,6 @@ var (
) )
func main() { func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
flag.Parse() flag.Parse()
if *typeSrc == "" { if *typeSrc == "" {

2
cmd/hyperkube/hyperkube.go
View File

@ -26,7 +26,6 @@ import (
"io/ioutil" "io/ioutil"
"os" "os"
"path" "path"
"runtime"
"k8s.io/kubernetes/pkg/util" "k8s.io/kubernetes/pkg/util"
utilflag "k8s.io/kubernetes/pkg/util/flag" 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. // RunToExit will run the hyperkube and then call os.Exit with an appropriate exit code.
func (hk *HyperKube) RunToExit(args []string) { func (hk *HyperKube) RunToExit(args []string) {
runtime.GOMAXPROCS(runtime.NumCPU())
err := hk.Run(args) err := hk.Run(args)
if err != nil { if err != nil {
fmt.Fprint(os.Stderr, err.Error()) fmt.Fprint(os.Stderr, err.Error())

2
cmd/kube-apiserver/apiserver.go
View File

@ -22,7 +22,6 @@ import (
"fmt" "fmt"
"math/rand" "math/rand"
"os" "os"
"runtime"
"time" "time"
"k8s.io/kubernetes/cmd/kube-apiserver/app" "k8s.io/kubernetes/cmd/kube-apiserver/app"
@ -35,7 +34,6 @@ import (
) )
func main() { func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
rand.Seed(time.Now().UTC().UnixNano()) rand.Seed(time.Now().UTC().UnixNano())
s := options.NewAPIServer() s := options.NewAPIServer()

2
cmd/kube-controller-manager/controller-manager.go
View File

@ -23,7 +23,6 @@ package main
import ( import (
"fmt" "fmt"
"os" "os"
"runtime"
"k8s.io/kubernetes/cmd/kube-controller-manager/app" "k8s.io/kubernetes/cmd/kube-controller-manager/app"
"k8s.io/kubernetes/cmd/kube-controller-manager/app/options" "k8s.io/kubernetes/cmd/kube-controller-manager/app/options"
@ -40,7 +39,6 @@ func init() {
} }
func main() { func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
s := options.NewCMServer() s := options.NewCMServer()
s.AddFlags(pflag.CommandLine) s.AddFlags(pflag.CommandLine)

5
cmd/kube-dns/app/options/options.go
View File

@ -22,10 +22,11 @@ import (
"os" "os"
"fmt" "fmt"
"github.com/spf13/pflag"
"k8s.io/kubernetes/pkg/util/validation"
_ "net/http/pprof" _ "net/http/pprof"
"strings" "strings"
"github.com/spf13/pflag"
"k8s.io/kubernetes/pkg/util/validation"
) )
type KubeDNSConfig struct { type KubeDNSConfig struct {

2
cmd/kube-proxy/proxy.go
View File

@ -19,7 +19,6 @@ package main
import ( import (
"fmt" "fmt"
"os" "os"
"runtime"
"k8s.io/kubernetes/cmd/kube-proxy/app" "k8s.io/kubernetes/cmd/kube-proxy/app"
"k8s.io/kubernetes/cmd/kube-proxy/app/options" "k8s.io/kubernetes/cmd/kube-proxy/app/options"
@ -36,7 +35,6 @@ func init() {
} }
func main() { func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
config := options.NewProxyConfig() config := options.NewProxyConfig()
config.AddFlags(pflag.CommandLine) config.AddFlags(pflag.CommandLine)

2
cmd/kubectl/kubectl.go
View File

@ -18,13 +18,11 @@ package main
import ( import (
"os" "os"
"runtime"
"k8s.io/kubernetes/cmd/kubectl/app" "k8s.io/kubernetes/cmd/kubectl/app"
) )
func main() { func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
if err := app.Run(); err != nil { if err := app.Run(); err != nil {
os.Exit(1) os.Exit(1)
} }

2
cmd/kubelet/kubelet.go
View File

@ -23,7 +23,6 @@ package main
import ( import (
"fmt" "fmt"
"os" "os"
"runtime"
"k8s.io/kubernetes/cmd/kubelet/app" "k8s.io/kubernetes/cmd/kubelet/app"
"k8s.io/kubernetes/cmd/kubelet/app/options" "k8s.io/kubernetes/cmd/kubelet/app/options"
@ -35,7 +34,6 @@ import (
) )
func main() { func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
s := options.NewKubeletServer() s := options.NewKubeletServer()
s.AddFlags(pflag.CommandLine) s.AddFlags(pflag.CommandLine)

2
cmd/kubemark/hollow-node.go
View File

@ -18,7 +18,6 @@ package main
import ( import (
"fmt" "fmt"
"runtime"
"k8s.io/kubernetes/pkg/api" "k8s.io/kubernetes/pkg/api"
"k8s.io/kubernetes/pkg/client/record" "k8s.io/kubernetes/pkg/client/record"
@ -83,7 +82,6 @@ func (c *HollowNodeConfig) createClientFromFile() (*client.Client, error) {
} }
func main() { func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
config := HollowNodeConfig{} config := HollowNodeConfig{}
config.addFlags(pflag.CommandLine) config.addFlags(pflag.CommandLine)

2
contrib/mesos/cmd/k8sm-controller-manager/main.go
View File

@ -19,7 +19,6 @@ package main
import ( import (
"fmt" "fmt"
"os" "os"
"runtime"
"k8s.io/kubernetes/pkg/healthz" "k8s.io/kubernetes/pkg/healthz"
"k8s.io/kubernetes/pkg/util" "k8s.io/kubernetes/pkg/util"
@ -36,7 +35,6 @@ func init() {
} }
func main() { func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
s := controllermanager.NewCMServer() s := controllermanager.NewCMServer()
s.AddFlags(pflag.CommandLine) s.AddFlags(pflag.CommandLine)

2
contrib/mesos/cmd/k8sm-executor/main.go
View File

@ -19,7 +19,6 @@ package main
import ( import (
"fmt" "fmt"
"os" "os"
"runtime"
"github.com/spf13/pflag" "github.com/spf13/pflag"
"k8s.io/kubernetes/contrib/mesos/pkg/executor/service" "k8s.io/kubernetes/contrib/mesos/pkg/executor/service"
@ -30,7 +29,6 @@ import (
) )
func main() { func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
s := service.NewKubeletExecutorServer() s := service.NewKubeletExecutorServer()
s.AddFlags(pflag.CommandLine) s.AddFlags(pflag.CommandLine)

2
contrib/mesos/cmd/k8sm-scheduler/main.go
View File

@ -19,7 +19,6 @@ package main
import ( import (
"fmt" "fmt"
"os" "os"
"runtime"
"github.com/spf13/pflag" "github.com/spf13/pflag"
"k8s.io/kubernetes/contrib/mesos/pkg/hyperkube" "k8s.io/kubernetes/contrib/mesos/pkg/hyperkube"
@ -30,7 +29,6 @@ import (
) )
func main() { func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
s := service.NewSchedulerServer() s := service.NewSchedulerServer()
s.AddStandaloneFlags(pflag.CommandLine) s.AddStandaloneFlags(pflag.CommandLine)

2
contrib/mesos/cmd/km/hyperkube.go
View File

@ -25,7 +25,6 @@ import (
"io/ioutil" "io/ioutil"
"os" "os"
"path" "path"
"runtime"
"k8s.io/kubernetes/pkg/util" "k8s.io/kubernetes/pkg/util"
"k8s.io/kubernetes/pkg/version/verflag" "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. // RunToExit will run the hyperkube and then call os.Exit with an appropriate exit code.
func (hk *HyperKube) RunToExit(args []string) { func (hk *HyperKube) RunToExit(args []string) {
runtime.GOMAXPROCS(runtime.NumCPU())
err := hk.Run(args) err := hk.Run(args)
if err != nil { if err != nil {
fmt.Fprint(os.Stderr, err.Error()) fmt.Fprint(os.Stderr, err.Error())

2
federation/cmd/federation-apiserver/apiserver.go
View File

@ -22,7 +22,6 @@ import (
"fmt" "fmt"
"math/rand" "math/rand"
"os" "os"
"runtime"
"time" "time"
"k8s.io/kubernetes/federation/cmd/federation-apiserver/app" "k8s.io/kubernetes/federation/cmd/federation-apiserver/app"
@ -35,7 +34,6 @@ import (
) )
func main() { func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
rand.Seed(time.Now().UTC().UnixNano()) rand.Seed(time.Now().UTC().UnixNano())
s := genericoptions.NewServerRunOptions() s := genericoptions.NewServerRunOptions()

2
federation/cmd/federation-controller-manager/controller-manager.go
View File

@ -19,7 +19,6 @@ package main
import ( import (
"fmt" "fmt"
"os" "os"
"runtime"
"github.com/spf13/pflag" "github.com/spf13/pflag"
"k8s.io/kubernetes/federation/cmd/federation-controller-manager/app" "k8s.io/kubernetes/federation/cmd/federation-controller-manager/app"
@ -35,7 +34,6 @@ func init() {
} }
func main() { func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
s := options.NewCMServer() s := options.NewCMServer()
s.AddFlags(pflag.CommandLine) s.AddFlags(pflag.CommandLine)

3
plugin/cmd/kube-scheduler/scheduler.go
View File

@ -17,8 +17,6 @@ limitations under the License.
package main package main
import ( import (
"runtime"
"k8s.io/kubernetes/pkg/healthz" "k8s.io/kubernetes/pkg/healthz"
"k8s.io/kubernetes/pkg/util" "k8s.io/kubernetes/pkg/util"
"k8s.io/kubernetes/pkg/util/flag" "k8s.io/kubernetes/pkg/util/flag"
@ -34,7 +32,6 @@ func init() {
} }
func main() { func main() {
runtime.GOMAXPROCS(runtime.NumCPU())
s := options.NewSchedulerServer() s := options.NewSchedulerServer()
s.AddFlags(pflag.CommandLine) s.AddFlags(pflag.CommandLine)