scottk/wlan-cloud-lib-cppkafka
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git synced 2025-11-01 02:57:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixed spacing issues

Browse Source
This commit is contained in:
demin80
2019-01-07 14:42:32 -05:00
parent 97229ebfd9
commit 00370c981d
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -682,7 +682,7 @@ bool BufferedProducer<BufferType, Allocator>::flush(std::chrono::milliseconds ti
std::swap(messages_, flush_queue); std::swap(messages_, flush_queue);
} }
auto remaining = timeout; auto remaining = timeout;
auto start_time = std::chrono::high_resolution_clock::now(); auto start_time = std::chrono::high_resolution_clock::now();
do { do {
if (!hi_pri_flush_queue.empty()) { if (!hi_pri_flush_queue.empty()) {
sync_produce(hi_pri_flush_queue.front()); sync_produce(hi_pri_flush_queue.front());
@@ -824,7 +824,7 @@ void BufferedProducer<BufferType, Allocator>::do_add_message(BuilderType&& build
else { else {
async_flush(); async_flush();
} }
} }
} }
template <typename BufferType, typename Allocator> template <typename BufferType, typename Allocator>