Kouhei Sutou
null+****@clear*****
Fri Apr 11 18:45:09 JST 2014
Kouhei Sutou 2014-04-11 18:45:09 +0900 (Fri, 11 Apr 2014) New Revision: a9ae0ab8cb25ada9414a6e0d54024d91a82ec129 https://github.com/droonga/fluent-plugin-droonga/commit/a9ae0ab8cb25ada9414a6e0d54024d91a82ec129 Message: Reduce needless signals Modified files: lib/droonga/fluent_message_sender.rb Modified: lib/droonga/fluent_message_sender.rb (+6 -1) =================================================================== --- lib/droonga/fluent_message_sender.rb 2014-04-11 18:39:15 +0900 (7f94ecb) +++ lib/droonga/fluent_message_sender.rb 2014-04-11 18:45:09 +0900 (fa951b0) @@ -55,7 +55,10 @@ module Droonga packed_fluent_message = MessagePackPacker.pack(fluent_message) @write_mutex.synchronize do @buffer << packed_fluent_message - @writer.signal + unless @signaling + @signaling = true + @writer.signal + end end logger.trace("send: done") end @@ -107,9 +110,11 @@ module Droonga def start_writer @writer = Coolio::AsyncWatcher.new + @signaling = false on_signal = lambda do @write_mutex.synchronize do + @signaling = false connect unless connected? @buffer.each do |data| @socket.write(data) -------------- next part -------------- HTML����������������������������...Download