YUKI Hiroshi
null+****@clear*****
Mon Dec 22 17:37:55 JST 2014
YUKI Hiroshi 2014-12-22 17:37:55 +0900 (Mon, 22 Dec 2014) New Revision: 66bcfbdb67ae6eeef7a0b0495305e0851b5b2265 https://github.com/droonga/droonga-engine/commit/66bcfbdb67ae6eeef7a0b0495305e0851b5b2265 Message: Forward buffered messages on resume, if the node became writable Modified files: lib/droonga/buffered_forwarder.rb Modified: lib/droonga/buffered_forwarder.rb (+5 -0) =================================================================== --- lib/droonga/buffered_forwarder.rb 2014-12-22 17:37:38 +0900 (399934a) +++ lib/droonga/buffered_forwarder.rb 2014-12-22 17:37:55 +0900 (94a76a6) @@ -46,6 +46,11 @@ module Droonga def resume @forwarder.resume + @buffers.each do |node_name, buffer| + if writable_node?(node_name) + buffer.start_forward + end + end end def forward(message, destination) -------------- next part -------------- HTML����������������������������... Download