github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 06:37:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

PERFORMANCE: Remove WriteBatch, it's 100% redundant

Browse source 
Fixes #8155
This commit is contained in:
Armin 2017-09-06 22:13:42 +02:00 • committed by Armin Braun
parent d82ba45d90
commit 340e879379
2 changed files with 3 additions and 47 deletions
Download patch file Download diff file Expand all files Collapse all files

23
logstash-core/lib/logstash/util/wrapped_acked_queue.rb
View file

@ -343,7 +343,7 @@ module LogStash; module Util
end
def get_new_batch
WriteBatch.new
[]
end
def push(event)
@ -363,26 +363,5 @@ module LogStash; module Util
end
end
end
class WriteBatch
def initialize
@events = []
end
def size
@events.size
end
def push(event)
@events.push(event)
end
alias_method(:<<, :push)
def each(&blk)
@events.each do |e|
blk.call(e)
end
end
end
end
end end

27
logstash-core/lib/logstash/util/wrapped_synchronous_queue.rb
View file

@ -247,7 +247,7 @@ module LogStash; module Util
end
def get_new_batch
WriteBatch.new
[]
end
def push(event)
@ -256,30 +256,7 @@ module LogStash; module Util
alias_method(:<<, :push)
def push_batch(batch)
LsQueueUtils.addAll(@queue, batch.events)
end
end
class WriteBatch
attr_reader :events
def initialize
@events = []
end
def size
@events.size
end
def push(event)
@events.push(event)
end
alias_method(:<<, :push)
def each(&blk)
@events.each do |e|
blk.call(e)
end
LsQueueUtils.addAll(@queue, batch)
end
end
end