YUKI Hiroshi
null+****@clear*****
Tue Apr 7 17:19:42 JST 2015
YUKI Hiroshi 2015-04-07 17:19:42 +0900 (Tue, 07 Apr 2015) New Revision: 929cc0dad39829e5083f0671f2b55a4b86e00837 https://github.com/droonga/droonga-engine/commit/929cc0dad39829e5083f0671f2b55a4b86e00837 Message: Start to forward buffered messages when EngineNode is resumed Modified files: lib/droonga/engine_node.rb Modified: lib/droonga/engine_node.rb (+9 -9) =================================================================== --- lib/droonga/engine_node.rb 2015-04-07 16:17:49 +0900 (5b2c69e) +++ lib/droonga/engine_node.rb 2015-04-07 17:19:42 +0900 (7c6b625) @@ -47,15 +47,7 @@ module Droonga def start logger.trace("start: start") - @sender.resume - unles****@buffe*****? - if really_writable? - logger.info("Target becomes writable. Start to forwarding.") - @buffer.start_forward - else - logger.info("Target is still unwritable.") - end - end + resume logger.trace("start: done") end @@ -135,6 +127,14 @@ module Droonga def resume logger.trace("resume: start") @sender.resume + unles****@buffe*****? + if really_writable? + logger.info("Target becomes writable. Start to forwarding.") + @buffer.start_forward + else + logger.info("Target is still unwritable.") + end + end logger.trace("resume: done") end -------------- next part -------------- HTML����������������������������...下载