Change logic to reset messages acked count on buffered producer

mfontanini · mfontanini · commit 5e84da245804 · 2017-04-23T14:55:33.000-07:00
diff --git a/include/cppkafka/utils/buffered_producer.h b/include/cppkafka/utils/buffered_producer.h
@@ -169,7 +169,6 @@ void BufferedProducer<BufferType>::flush() {
 
 template <typename BufferType>
 void BufferedProducer<BufferType>::wait_for_acks() {
-    messages_acked_ = 0;
     while (messages_acked_ < expected_acks_) {
         try {
             producer_.flush();
@@ -185,6 +184,7 @@ void BufferedProducer<BufferType>::wait_for_acks() {
         }
     }
     expected_acks_ = 0;
+    messages_acked_ = 0;
 }
 
 template <typename BufferType>

Original file line number	Diff line number	Diff line change
`@@ -169,7 +169,6 @@ void BufferedProducer<BufferType>::flush() {`
`169`	`169`
`170`	`170`	`template <typename BufferType>`
`171`	`171`	`void BufferedProducer<BufferType>::wait_for_acks() {`
`172`		`- messages_acked_ = 0;`
`173`	`172`	`while (messages_acked_ < expected_acks_) {`
`174`	`173`	`try {`
`175`	`174`	`producer_.flush();`
`@@ -185,6 +184,7 @@ void BufferedProducer<BufferType>::wait_for_acks() {`
`185`	`184`	`}`
`186`	`185`	`}`
`187`	`186`	`expected_acks_ = 0;`
	`187`	`+ messages_acked_ = 0;`
`188`	`188`	`}`
`189`	`189`
`190`	`190`	`template <typename BufferType>`