From 17ac9bc0db65c4784e66ee8cedeed575a467a0b8 Mon Sep 17 00:00:00 2001 From: Christian Pointner Date: Wed, 10 May 2017 23:45:54 +0200 Subject: improved log output for forwarder --- src/hub/src/spreadspace.org/sfive/s5srvForward.go | 2 +- src/hub/src/spreadspace.org/sfive/s5srvForwardEs.go | 2 +- src/hub/src/spreadspace.org/sfive/s5srvForwardGraphite.go | 2 +- src/hub/src/spreadspace.org/sfive/s5srvForwardPiwik.go | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) (limited to 'src/hub') diff --git a/src/hub/src/spreadspace.org/sfive/s5srvForward.go b/src/hub/src/spreadspace.org/sfive/s5srvForward.go index bd16c78..2d70e32 100644 --- a/src/hub/src/spreadspace.org/sfive/s5srvForward.go +++ b/src/hub/src/spreadspace.org/sfive/s5srvForward.go @@ -146,7 +146,7 @@ tryResync: } lastId = findMaxId(updates) - s5l.Printf("fwd: new lastid: %d", lastId) + s5l.Printf("fwd: successfully forwarded %d updates, new lastid: %d", len(updates), lastId) } } } diff --git a/src/hub/src/spreadspace.org/sfive/s5srvForwardEs.go b/src/hub/src/spreadspace.org/sfive/s5srvForwardEs.go index 2794a24..a7931f2 100644 --- a/src/hub/src/spreadspace.org/sfive/s5srvForwardEs.go +++ b/src/hub/src/spreadspace.org/sfive/s5srvForwardEs.go @@ -154,7 +154,7 @@ tryResync: resp.Body.Close() // TODO: check result from elasticsearch lastId = findMaxId(updates) - s5l.Printf("fwd-es: new lastid: %d", lastId) + s5l.Printf("fwd-es: successfully forwarded %d updates, new lastid: %d", len(updates), lastId) } } } diff --git a/src/hub/src/spreadspace.org/sfive/s5srvForwardGraphite.go b/src/hub/src/spreadspace.org/sfive/s5srvForwardGraphite.go index 8665f4c..1b8e818 100644 --- a/src/hub/src/spreadspace.org/sfive/s5srvForwardGraphite.go +++ b/src/hub/src/spreadspace.org/sfive/s5srvForwardGraphite.go @@ -91,7 +91,7 @@ tryResync: } lastId = findMaxId(updates) - s5l.Printf("fwd-graphite: new lastid: %d", lastId) + s5l.Printf("fwd-graphite: successfully forwarded %d updates, new lastid: %d", len(updates), lastId) } } } diff --git a/src/hub/src/spreadspace.org/sfive/s5srvForwardPiwik.go b/src/hub/src/spreadspace.org/sfive/s5srvForwardPiwik.go index ff6d985..017e2ea 100644 --- a/src/hub/src/spreadspace.org/sfive/s5srvForwardPiwik.go +++ b/src/hub/src/spreadspace.org/sfive/s5srvForwardPiwik.go @@ -126,7 +126,7 @@ tryResync: resp.Body.Close() // TODO: check result from Piwik lastId = findMaxId(updates) - s5l.Printf("fwd-piwik: new lastid: %d", lastId) + s5l.Printf("fwd-piwik: successfully forwarded %d updates, new lastid: %d", len(updates), lastId) } } } -- cgit v1.2.3