Reset backoff factor on partial ACK (#1819)

elastic · Jun 8, 2016 · f914870 · f914870
1 parent 070b7bc
commit f914870
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/CHANGELOG.asciidoc b/CHANGELOG.asciidoc
@@ -30,6 +30,7 @@ https://github.com/elastic/beats/compare/v5.0.0-alpha3...master[Check the HEAD d
 ==== Bugfixes
 
 *Affecting all Beats*
+- Reset backoff factor on partial ACK. {issue}1803[1803]
 
 *Metricbeat*
 

diff --git a/libbeat/outputs/mode/single/single.go b/libbeat/outputs/mode/single/single.go
@@ -143,13 +143,14 @@ func (s *Mode) publish(
 
 	sendFail:
 		logp.Info("send fail")
-		s.backoff.Wait()
 
 		fails++
 		if resetFail {
 			debugf("reset fails")
+			s.backoff.Reset()
 			fails = 0
 		}
+		s.backoff.Wait()
 
 		if !guaranteed && (s.maxAttempts > 0 && fails == s.maxAttempts) {
 			// max number of attempts reached