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

Merge pull request #157 from demin80/buffer-size-comparison-fix2

Browse Source 
added type conversion to avoid signed-vs-unsigned-comparison warning
This commit is contained in:
Matias Fontanini
2019-01-19 08:12:55 -08:00
committed by GitHub
parent fb4c5edc8e 755e9f10c2
commit efa4e95a18
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -708,6 +708,7 @@ bool BufferedProducer<BufferType, Allocator>::flush(std::chrono::milliseconds ti
}; };
re_enqueuer(retry_flush_queue, retry_messages_, retry_mutex_); re_enqueuer(retry_flush_queue, retry_messages_, retry_mutex_);
re_enqueuer(flush_queue, messages_, mutex_); re_enqueuer(flush_queue, messages_, mutex_);
return true;
} }
else { else {
async_flush(); async_flush();
@@ -811,7 +812,7 @@ void BufferedProducer<BufferType, Allocator>::do_add_message(BuilderType&& build
// Flush the queues only if a regular message is added. Retry messages may be added // Flush the queues only if a regular message is added. Retry messages may be added
// from rdkafka callbacks, and flush/async_flush is a user-level call // from rdkafka callbacks, and flush/async_flush is a user-level call
if (queue_kind == QueueKind::Regular && flush_action == FlushAction::DoFlush && (max_buffer_size_ >= 0) && (max_buffer_size_ <= get_buffer_size())) { if (queue_kind == QueueKind::Regular && flush_action == FlushAction::DoFlush && (max_buffer_size_ >= 0) && (max_buffer_size_ <= (ssize_t)get_buffer_size())) {
if (flush_method_ == FlushMethod::Sync) { if (flush_method_ == FlushMethod::Sync) {
flush(); flush();
} }