diff options
| -rw-r--r-- | src/hub/src/spreadspace.org/sfive/s5srv.go | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/hub/src/spreadspace.org/sfive/s5srv.go b/src/hub/src/spreadspace.org/sfive/s5srv.go index b643047..e296fd2 100644 --- a/src/hub/src/spreadspace.org/sfive/s5srv.go +++ b/src/hub/src/spreadspace.org/sfive/s5srv.go @@ -50,6 +50,7 @@ type appendManyToken struct { type Server struct { store Store + numWorker int anonymization AnonymizationAlgo quit chan bool done *sync.WaitGroup @@ -142,11 +143,12 @@ func NewServer(dbPath string, readOnly, anonymize bool, anonKeyfile string) (srv s5l.Printf("using IP address anonymization: %s", srv.anonymization) } + srv.numWorker = runtime.NumCPU() srv.quit = make(chan bool) srv.done = &sync.WaitGroup{} - srv.appendChan = make(chan appendToken, 32) - srv.appendManyChan = make(chan appendManyToken, 32) - for i := 0; i < runtime.NumCPU(); i = i + 1 { + srv.appendChan = make(chan appendToken, srv.numWorker) + srv.appendManyChan = make(chan appendManyToken, srv.numWorker) + for i := 0; i < srv.numWorker; i = i + 1 { srv.done.Add(1) go func(idx int) { defer srv.done.Done() |