Repository: incubator-htrace
Updated Branches:
  refs/heads/master 35053cfc5 -> 8c82f6708


HTRACE-312. htraced: if GOMAXPROCS is left at 1, set it to the number of CPUs 
(Colin Patrick McCabe via iwasakims)


Project: http://git-wip-us.apache.org/repos/asf/incubator-htrace/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-htrace/commit/8c82f670
Tree: http://git-wip-us.apache.org/repos/asf/incubator-htrace/tree/8c82f670
Diff: http://git-wip-us.apache.org/repos/asf/incubator-htrace/diff/8c82f670

Branch: refs/heads/master
Commit: 8c82f67080463eb6ecaee87e05195f6f76db6fbe
Parents: 35053cf
Author: Masatake Iwasaki <[email protected]>
Authored: Thu Dec 3 17:26:42 2015 +0900
Committer: Masatake Iwasaki <[email protected]>
Committed: Thu Dec 3 17:26:42 2015 +0900

----------------------------------------------------------------------
 htrace-htraced/go/src/org/apache/htrace/htraced/htraced.go | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-htrace/blob/8c82f670/htrace-htraced/go/src/org/apache/htrace/htraced/htraced.go
----------------------------------------------------------------------
diff --git a/htrace-htraced/go/src/org/apache/htrace/htraced/htraced.go 
b/htrace-htraced/go/src/org/apache/htrace/htraced/htraced.go
index 5b0dfc6..fdd2745 100644
--- a/htrace-htraced/go/src/org/apache/htrace/htraced/htraced.go
+++ b/htrace-htraced/go/src/org/apache/htrace/htraced/htraced.go
@@ -92,7 +92,13 @@ func main() {
                lg.Infof(scanner.Text() + "\n")
        }
        common.InstallSignalHandlers(cnf)
-       lg.Infof("GOMAXPROCS=%d\n", runtime.GOMAXPROCS(0))
+       if runtime.GOMAXPROCS(0) == 1 {
+               ncpu := runtime.NumCPU()
+               runtime.GOMAXPROCS(ncpu)
+               lg.Infof("setting GOMAXPROCS=%d\n", ncpu)
+       } else {
+               lg.Infof("GOMAXPROCS=%d\n", runtime.GOMAXPROCS(0))
+       }
        lg.Infof("leveldb version=%d.%d\n",
                levigo.GetLevelDBMajorVersion(), 
levigo.GetLevelDBMinorVersion())
 

Reply via email to