Piro / YUKI Hiroshi
null+****@clear*****
Thu Apr 23 06:06:42 JST 2015
Piro / YUKI Hiroshi 2015-04-23 06:06:42 +0900 (Thu, 23 Apr 2015) New Revision: 206176103e5ce3f3d46e4bb67d1314117a5c5a59 https://github.com/droonga/droonga-engine/commit/206176103e5ce3f3d46e4bb67d1314117a5c5a59 Message: Don't destroy forwarder by refreshing Modified files: lib/droonga/forwarder.rb Modified: lib/droonga/forwarder.rb (+13 -10) =================================================================== --- lib/droonga/forwarder.rb 2015-04-23 04:22:07 +0900 (bdf33bf) +++ lib/droonga/forwarder.rb 2015-04-23 06:06:42 +0900 (bb915ba) @@ -47,14 +47,7 @@ module Droonga def shutdown logger.trace("shutdown: start") @shutting_down = true - @senders.each_value do |sender| - sender.shutdown - end - @senders = {} - @auto_close_timers.each_value do |timer| - timer.detach - end - @auto_close_timers = {} + clear_senders logger.trace("shutdown: done") end @@ -82,8 +75,7 @@ module Droonga end def refresh_all_connections - shutdown - start + clear_senders end private @@ -176,6 +168,17 @@ module Droonga @auto_close_timers[destination] = timer end + def clear_senders + @senders.each_value do |sender| + sender.shutdown + end + @senders = {} + @auto_close_timers.each_value do |timer| + timer.detach + end + @auto_close_timers = {} + end + def log_tag "[#{Process.ppid}] forwarder" end -------------- next part -------------- HTML����������������������������...Descargar
