diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/hub/src/spreadspace.org/sfive/s5srv.go | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/src/hub/src/spreadspace.org/sfive/s5srv.go b/src/hub/src/spreadspace.org/sfive/s5srv.go index 59a6409..6647518 100644 --- a/src/hub/src/spreadspace.org/sfive/s5srv.go +++ b/src/hub/src/spreadspace.org/sfive/s5srv.go @@ -1,5 +1,7 @@ package sfive +import "time" + type appendManyToken struct { data []StatisticsData response chan bool @@ -20,7 +22,15 @@ func (self StatsSinkServer) appendActor() { case <-self.quit: return case value := <-self.appendData: - err := self.store.Append(value) + var err error + for tryNum := 0; tryNum < 5; tryNum++ { + err = self.store.Append(value) + if err != nil { + time.Sleep(1 * time.Second) + } else { + break + } + } if err != nil { s5l.Printf("failed to store data: %v\n", err) } |