diff options
Diffstat (limited to 'src/hub/src/spreadspace.org/sfive/s5srvForwardGraphite.go')
| -rw-r--r-- | src/hub/src/spreadspace.org/sfive/s5srvForwardGraphite.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/hub/src/spreadspace.org/sfive/s5srvForwardGraphite.go b/src/hub/src/spreadspace.org/sfive/s5srvForwardGraphite.go index 2972b91..90afb69 100644 --- a/src/hub/src/spreadspace.org/sfive/s5srvForwardGraphite.go +++ b/src/hub/src/spreadspace.org/sfive/s5srvForwardGraphite.go @@ -44,25 +44,25 @@ tryResync: for { client, err := graphite.NewGraphiteFromAddress(forwardHost) if err != nil { - s5l.Printf("fwd-graphite: connect returned err: %v", err) + s5l.Printf("srv|fwd-graphite: connecting failed: %v", err) time.Sleep(5 * time.Second) continue tryResync } lastID, err := srv.store.GetLastUpdateID() if err != nil { - s5l.Printf("fwd-graphite: lastupdate returned err: %v", err) + s5l.Printf("srv|fwd-graphite: fetching lastupdate failed: %v", err) client.Disconnect() time.Sleep(5 * time.Second) continue tryResync } - s5l.Printf("fwd-graphite: lastupdate: %d", lastID) + s5l.Printf("srv|fwd-graphite: new lastupdate: %d", lastID) nextBatch: for { updates, err := srv.store.GetUpdatesAfter(lastID, 5000) if err != nil { - s5l.Printf("fwd-graphite: failed reading updates: %v", err) + s5l.Printf("srv|fwd-graphite: reading updates failed: %v", err) time.Sleep(500 * time.Millisecond) continue nextBatch } @@ -85,13 +85,13 @@ tryResync: err = client.SendMetrics(metrics) if err != nil { - s5l.Printf("fwd-graphite: sending metrics failed: %v", err) + s5l.Printf("srv|fwd-graphite: sending metrics failed: %v", err) time.Sleep(1 * time.Second) continue tryResync } lastID = findMaxID(updates) - s5l.Printf("fwd-graphite: successfully forwarded %d updates, new lastid: %d", len(updates), lastID) + s5l.Printf("srv|fwd-graphite: successfully forwarded %d updates, new lastid: %d", len(updates), lastID) } } } |