added type conversion to avoid signed-vs-unsigned-comparison warning

demin80 · demin80 · commit 5a34955fae09 · 2019-01-16T10:52:14.000-05:00
diff --git a/include/cppkafka/utils/buffered_producer.h b/include/cppkafka/utils/buffered_producer.h
@@ -811,7 +811,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
     // 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) {
             flush();
         }

Original file line number	Diff line number	Diff line change
`@@ -811,7 +811,7 @@ void BufferedProducer<BufferType, Allocator>::do_add_message(BuilderType&& build`
`811`	`811`
`812`	`812`	`// Flush the queues only if a regular message is added. Retry messages may be added`
`813`	`813`	`// from rdkafka callbacks, and flush/async_flush is a user-level call`
`814`		`- if (queue_kind == QueueKind::Regular && flush_action == FlushAction::DoFlush && (max_buffer_size_ >= 0) && (max_buffer_size_ <= get_buffer_size())) {`
	`814`	`+ if (queue_kind == QueueKind::Regular && flush_action == FlushAction::DoFlush && (max_buffer_size_ >= 0) && (max_buffer_size_ <= (ssize_t)get_buffer_size())) {`
`815`	`815`	`if (flush_method_ == FlushMethod::Sync) {`
`816`	`816`	`flush();`
`817`	`817`	`}`