hub: Add retry to DB append in case of error.

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