From 46717b48a221958bb7a822a69871638e14c9d786 Mon Sep 17 00:00:00 2001 From: vilyapilya <13.veter@gmail.com> Date: Tue, 21 Jan 2020 16:36:13 -0800 Subject: [PATCH 1/2] fix the bug --- lib/logdna/client.rb | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/logdna/client.rb b/lib/logdna/client.rb index 29290af..d58ebe0 100755 --- a/lib/logdna/client.rb +++ b/lib/logdna/client.rb @@ -49,7 +49,7 @@ def schedule_flush sleep(@exception_flag ? @retry_timeout : @flush_interval) flush if @flush_scheduled } - thread = Thread.new { start_timer } + thread = Thread.new { start_timer.call } thread.join end @@ -63,7 +63,7 @@ def write_to_buffer(msg, opts) @lock.unlock flush if @flush_limit <= @buffer_byte_size - schedule_flush unless @flush_scheduled + schedule_flush else @side_message_lock.synchronize do @side_messages.push(process_message(msg, opts)) From 28d743bc57dbad295cb5842f91f79fbb48c7b186 Mon Sep 17 00:00:00 2001 From: vilyapilya <13.veter@gmail.com> Date: Thu, 23 Jan 2020 13:45:14 -0800 Subject: [PATCH 2/2] enclose into if else --- lib/logdna/client.rb | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/lib/logdna/client.rb b/lib/logdna/client.rb index d58ebe0..cb0748a 100755 --- a/lib/logdna/client.rb +++ b/lib/logdna/client.rb @@ -62,8 +62,11 @@ def write_to_buffer(msg, opts) @flush_scheduled = true @lock.unlock - flush if @flush_limit <= @buffer_byte_size - schedule_flush + if @flush_limit <= @buffer_byte_size + flush + else + schedule_flush + end else @side_message_lock.synchronize do @side_messages.push(process_message(msg, opts))