Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

only need max procs for running

pull/2147/head
Cory LaNou 2015-04-02 10:27:35 -05:00
parent e7866d3600
commit 8fa3571782
1 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
cmd/influxd/main.go
View File

@ -74,13 +74,11 @@ func main() {
case "": case "":
execRun(args) execRun(args)
case "backup": case "backup":
setGoMaxProcs()
cmd := NewBackupCommand() cmd := NewBackupCommand()
if err := cmd.Run(args[1:]...); err != nil { if err := cmd.Run(args[1:]...); err != nil {
log.Fatalf("backup: %s", err) log.Fatalf("backup: %s", err)
} }
case "restore": case "restore":
setGoMaxProcs()
cmd := NewRestoreCommand() cmd := NewRestoreCommand()
if err := cmd.Run(args[1:]...); err != nil { if err := cmd.Run(args[1:]...); err != nil {
log.Fatalf("restore: %s", err) log.Fatalf("restore: %s", err)
@ -96,12 +94,6 @@ func main() {
} }
} }
func setGoMaxProcs() {
// Set parallelism.
runtime.GOMAXPROCS(runtime.NumCPU())
log.Printf("GOMAXPROCS set to %d", runtime.GOMAXPROCS(0))
}
// execRun runs the "run" command. // execRun runs the "run" command.
func execRun(args []string) { func execRun(args []string) {
// Parse command flags. // Parse command flags.
@ -125,7 +117,9 @@ func execRun(args []string) {
fmt.Print(logo) fmt.Print(logo)
writePIDFile(*pidPath) writePIDFile(*pidPath)
setGoMaxProcs() // Set parallelism.
runtime.GOMAXPROCS(runtime.NumCPU())
log.Printf("GOMAXPROCS set to %d", runtime.GOMAXPROCS(0))
// Parse configuration file from disk. // Parse configuration file from disk.
config, err := parseConfig(*configPath, *hostname) config, err := parseConfig(*configPath, *hostname)