diff options
author | Markus Grüneis <gimpf@gimpf.org> | 2014-10-19 18:03:18 +0200 |
---|---|---|
committer | Markus Grüneis <gimpf@gimpf.org> | 2014-10-19 18:03:18 +0200 |
commit | 3c7c6f2d9a49e136a8a6fb3f4e517fde2bb2a837 (patch) | |
tree | 1049c9bcfe13ddbc64a94ba966cfc9da6c2f96a1 /src/hub | |
parent | hub: use goji for new s5srvWeb (diff) |
hub: fix s5srv data appender
- this time, really start the appendActor
- use a buffered channel for the appending
Diffstat (limited to 'src/hub')
-rw-r--r-- | src/hub/src/spreadspace.org/sfive/s5srv.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/hub/src/spreadspace.org/sfive/s5srv.go b/src/hub/src/spreadspace.org/sfive/s5srv.go index 7eab0eb..a734ec1 100644 --- a/src/hub/src/spreadspace.org/sfive/s5srv.go +++ b/src/hub/src/spreadspace.org/sfive/s5srv.go @@ -41,6 +41,7 @@ func NewServer(dbPath string) (server *StatsSinkServer, err error) { server.quit = make(chan bool) server.done = make(chan bool) - server.appendData = make(chan StatisticsData) + server.appendData = make(chan StatisticsData, 100) + go server.appendActor() return } |