From 155766e1bd291bd2a7dccf330b30993631a9303a Mon Sep 17 00:00:00 2001 From: Markus Grüneis Date: Fri, 24 Oct 2014 15:38:32 +0200 Subject: hub: Post all available updates at once in fwd. --- src/hub/src/spreadspace.org/sfive/s5srvForward.go | 38 +++++++++++------------ 1 file changed, 19 insertions(+), 19 deletions(-) (limited to 'src') diff --git a/src/hub/src/spreadspace.org/sfive/s5srvForward.go b/src/hub/src/spreadspace.org/sfive/s5srvForward.go index 475027a..4707dd5 100644 --- a/src/hub/src/spreadspace.org/sfive/s5srvForward.go +++ b/src/hub/src/spreadspace.org/sfive/s5srvForward.go @@ -69,28 +69,28 @@ tryResync: continue nextBatch } - for i := range updates { - data, err := json.Marshal(updates[i]) - if err != nil { - s5l.Panicf("fwd: encode failed: %v\n", err) - // TODO retry etc. - } - - _, err = client.Post(url, "application/json", bytes.NewBuffer(data)) - if err != nil { - s5l.Printf("fwd: post failed: %v\n", err) - continue tryResync - // TODO retry etc. - } - } - if len(updates) == 0 { time.Sleep(1 * time.Second) - } else { - lastId = findMaxId(updates) - s5tl.Printf("fwd: new lastid: %d", lastId) - time.Sleep(100 * time.Millisecond) + continue nextBatch } + + data, err := json.Marshal(StatisticsDataContainer{updates}) + + if err != nil { + s5l.Panicf("fwd: encode failed: %v\n", err) + } + + _, err = client.Post(url, "application/json", bytes.NewBuffer(data)) + if err != nil { + s5l.Printf("fwd: post failed: %v\n", err) + continue tryResync + // TODO retry etc. + } + // } + + lastId = findMaxId(updates) + s5tl.Printf("fwd: new lastid: %d", lastId) + time.Sleep(100 * time.Millisecond) } } } -- cgit v1.2.3