more accurate back pressure

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()