fork of https://github.com/sourcegraph/zoekt
all: Use GOMAXPROCS instead of NumCPU
Now that GOMAXPROCS is set to match Linux CPU quota, it makes more sense to
limit concurrency based on NumCPU than GOMAXPROCS. Additionally, this allows
users to tune the amount of concurrency Zoekt uses via the GOMAXPROCS
environment variable if needs be. Ran
gofmt -w -r 'runtime.NumCPU() -> runtime.GOMAXPROCS(0)' .
Change-Id: I11e6ee63cbc8ea8da2cecc22a7e614dc6eebb4be
author
Keegan Carruthers-Smith
date
(Jul 12, 2019, 8:40 PM +0200)
commit
3f0a8f07
3f0a8f078efe0316ba092982cebcb7df874301a1
parent
22eb58c2
22eb58c2c7d286c0e742575ec9eb3bb5556825d7
+5
-5
+1
-1
cmd/zoekt-indexserver/main.go
+1
-1
cmd/zoekt-indexserver/main.go
+3
-3
shards/shards.go
+3
-3
shards/shards.go
···
59
59
// NewDirectorySearcher returns a searcher instance that loads all
60
60
// shards corresponding to a glob into memory.
61
61
func NewDirectorySearcher(dir string) (zoekt.Searcher, error) {
62
-
ss := newShardedSearcher(int64(runtime.NumCPU()))
62
+
ss := newShardedSearcher(int64(runtime.GOMAXPROCS(0)))
63
63
tl := &throttledLoader{
64
64
ss: ss,
65
-
throttle: make(chan struct{}, runtime.NumCPU()),
65
+
throttle: make(chan struct{}, runtime.GOMAXPROCS(0)),
66
66
}
67
67
_, err := NewDirectoryWatcher(dir, tl)
68
68
if err != nil {
···
163
163
feeder <- s
164
164
}
165
165
close(feeder)
166
-
for i := 0; i < runtime.NumCPU(); i++ {
166
+
for i := 0; i < runtime.GOMAXPROCS(0); i++ {
167
167
go func() {
168
168
for s := range feeder {
169
169
searchOneShard(childCtx, s, q, opts, all)