Kouhei Sutou
null+****@clear*****
Sun Mar 23 15:47:53 JST 2014
Kouhei Sutou 2014-03-23 15:47:53 +0900 (Sun, 23 Mar 2014) New Revision: 32e084600f854223c13bf8b476734eea4939733e https://github.com/droonga/fluent-plugin-droonga/commit/32e084600f854223c13bf8b476734eea4939733e Message: Simplify Modified files: lib/droonga/job_pusher.rb Modified: lib/droonga/job_pusher.rb (+5 -12) =================================================================== --- lib/droonga/job_pusher.rb 2014-03-23 15:31:42 +0900 (a48806b) +++ lib/droonga/job_pusher.rb 2014-03-23 15:47:53 +0900 (eca2efe) @@ -88,18 +88,11 @@ module Droonga def push(message) job = message.to_msgpack - @buffers << job - consume_buffers - end - - private - def consume_buffers - return if @ready_workers.empty? - until****@buffe*****? - while worker = @ready_workers.shift - worker.write(@buffers.shift) - return if****@buffe*****? - end + if****@buffe*****? and !@ready_workers.empty? + worker = @ready_workers.shift + worker.write(job) + else + @buffers << job end end end -------------- next part -------------- HTML����������������������������...Download