Kouhei Sutou
null+****@clear*****
Sun Mar 23 18:22:00 JST 2014
Kouhei Sutou 2014-03-23 18:22:00 +0900 (Sun, 23 Mar 2014) New Revision: 3dda29aa7df0f7fd88a5e77d9ba01b6926836d28 https://github.com/droonga/fluent-plugin-droonga/commit/3dda29aa7df0f7fd88a5e77d9ba01b6926836d28 Message: Remove needless loop dependency Modified files: lib/droonga/job_pusher.rb Modified: lib/droonga/job_pusher.rb (+2 -4) =================================================================== --- lib/droonga/job_pusher.rb 2014-03-23 18:20:18 +0900 (5264002) +++ lib/droonga/job_pusher.rb 2014-03-23 18:22:00 +0900 (8a9e4a2) @@ -32,7 +32,7 @@ module Droonga def start FileUtils.rm_f(@socket_path) @server = Coolio::UNIXServer.new(@socket_path) do |connection| - @job_queue.add_worker(WorkerConnection.new(@loop, connection)) + @job_queue.add_worker(WorkerConnection.new(connection)) end FileUtils.chmod(0600, @socket_path) @loop.attach(@server) @@ -110,8 +110,7 @@ module Droonga class WorkerConnection attr_writer :on_ready - def initialize(loop, connection) - @loop = loop + def initialize(connection) @connection = connection @ready = false @on_ready = nil @@ -125,7 +124,6 @@ module Droonga def write(job) @connection.write(job) @ready = false - @loop.break_current_loop end def close -------------- next part -------------- HTML����������������������������...Download