diff options
| author | Christian Pointner <equinox@spreadspace.org> | 2017-05-10 23:45:54 +0200 |
|---|---|---|
| committer | Christian Pointner <equinox@spreadspace.org> | 2017-05-10 23:45:54 +0200 |
| commit | 17ac9bc0db65c4784e66ee8cedeed575a467a0b8 (patch) | |
| tree | 37c34ee55bf3ad0a44651e69de34447d879381d9 /src/hub | |
| parent | new protocol version with streamlined names for variables (diff) | |
improved log output for forwarder
Diffstat (limited to 'src/hub')
4 files changed, 4 insertions, 4 deletions
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) } } } |