From 793065013faedfaff030641988657b33c4076df4 Mon Sep 17 00:00:00 2001 From: adioss Date: Fri, 3 Jun 2016 19:05:12 +0200 Subject: [PATCH 1/2] Reset backoffCount after correct ACK received --- libbeat/outputs/mode/single.go | 1 + 1 file changed, 1 insertion(+) diff --git a/libbeat/outputs/mode/single.go b/libbeat/outputs/mode/single.go index 4ecf454d2104..8d2b2d8478d8 100644 --- a/libbeat/outputs/mode/single.go +++ b/libbeat/outputs/mode/single.go @@ -141,6 +141,7 @@ func (s *SingleConnectionMode) publish( if resetFail { debug("reset fails") fails = 0 + backoffCount = 0 } if !guaranteed && (s.maxAttempts > 0 && fails == s.maxAttempts) { From 9c7dcc28c8f9bb25dbb78d38236b34c48694614c Mon Sep 17 00:00:00 2001 From: adioss Date: Mon, 6 Jun 2016 17:38:31 +0200 Subject: [PATCH 2/2] Reset backoffCount after send completed --- libbeat/outputs/mode/single.go | 1 + 1 file changed, 1 insertion(+) diff --git a/libbeat/outputs/mode/single.go b/libbeat/outputs/mode/single.go index 8d2b2d8478d8..a0cd1f3fde66 100644 --- a/libbeat/outputs/mode/single.go +++ b/libbeat/outputs/mode/single.go @@ -132,6 +132,7 @@ func (s *SingleConnectionMode) publish( goto sendFail } + backoffCount = 0 debug("send completed") outputs.SignalCompleted(signaler) return nil