scottk/wlan-cloud-lib-cppkafka
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git synced 2025-10-31 18:47:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixed bug with message leak in BufferedProducer::flush(timeout)

Browse Source
This commit is contained in:
accelerated
2018-12-14 16:08:57 -05:00
parent ab002fe119
commit 4a24971d3f
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
include/cppkafka/utils/buffered_producer.h
View File

@@ -581,6 +581,12 @@ bool BufferedProducer<BufferType, Allocator>::flush(std::chrono::milliseconds ti
remaining = timeout - std::chrono::duration_cast<std::chrono::milliseconds>
(std::chrono::high_resolution_clock::now() - start_time);
} while (!flush_queue.empty() && (remaining.count() > 0));
// Re-enqueue remaining messages in original order
if (!flush_queue.empty()) {
std::lock_guard<std::mutex> lock(mutex_);
messages_.insert(messages_.begin(), std::make_move_iterator(flush_queue.rbegin()), std::make_move_iterator(flush_queue.rend()))
}
}
else {
async_flush();