Skip to content

Commit 140b897

Browse files
Merge branch 'testNewConfigsLogstash' into feature/RefactorClass
2 parents 0e9f300 + ffc4f88 commit 140b897

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

lib/logstash/outputs/kusto/custom_size_based_buffer.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ def <<(event)
4343
prepare_flush(force: true) # Flush when buffer is full
4444
sleep 0.1
4545
end
46-
46+
4747
@pending_mutex.synchronize do
4848
@buffer_state[:pending_items] << event
4949
@buffer_state[:pending_size] += event.bytesize
@@ -109,7 +109,7 @@ def prepare_flush(options = {})
109109
end
110110

111111
def perform_flush(events, file_path = nil)
112-
112+
113113
@flush_mutex.lock
114114

115115
begin

0 commit comments

Comments
 (0)