summaryrefslogtreecommitdiff
path: root/src/hub
diff options
context:
space:
mode:
authorMarkus Grüneis <gimpf@gimpf.org>2014-10-19 18:03:18 +0200
committerMarkus Grüneis <gimpf@gimpf.org>2014-10-19 18:03:18 +0200
commit3c7c6f2d9a49e136a8a6fb3f4e517fde2bb2a837 (patch)
tree1049c9bcfe13ddbc64a94ba966cfc9da6c2f96a1 /src/hub
parenthub: 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.go3
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
}