YUKI Hiroshi
null+****@clear*****
Thu Apr 23 10:05:17 JST 2015
YUKI Hiroshi 2015-04-23 10:05:17 +0900 (Thu, 23 Apr 2015) New Revision: 3a6dad4db00d57552f0e28338f88eaab7a4c043c https://github.com/droonga/droonga-engine/commit/3a6dad4db00d57552f0e28338f88eaab7a4c043c Message: Output more trace logs around refreshing of connections Modified files: lib/droonga/cluster.rb lib/droonga/engine_node.rb lib/droonga/forwarder.rb Modified: lib/droonga/cluster.rb (+5 -1) =================================================================== --- lib/droonga/cluster.rb 2015-04-23 06:07:00 +0900 (1798547) +++ lib/droonga/cluster.rb 2015-04-23 10:05:17 +0900 (b70b812) @@ -100,11 +100,13 @@ module Droonga end def refresh_connection_for(name) + logger.trace("refresh_connection_for(#{name}): start") engine_nodes.each do |node| if node.name == name node.refresh_connection end end + logger.trace("refresh_connection_for(#{name}): done") end def reload @@ -118,7 +120,9 @@ module Droonga if @state == old_state logger.info("cluster state not changed") else - logger.info("cluster state changed", :state => @state) + logger.info("cluster state changed", + :before => old_state, + :after => @state) clear_cache engine_nodes.each(&:resume) on_change Modified: lib/droonga/engine_node.rb (+2 -0) =================================================================== --- lib/droonga/engine_node.rb 2015-04-23 06:07:00 +0900 (5553a47) +++ lib/droonga/engine_node.rb 2015-04-23 10:05:17 +0900 (28b0fcc) @@ -66,8 +66,10 @@ module Droonga end def refresh_connection + logger.trace("refresh_connection: start") shutdown sender # instantiate new sender + logger.trace("refresh_connection: done") end def forward(message, destination) Modified: lib/droonga/forwarder.rb (+4 -0) =================================================================== --- lib/droonga/forwarder.rb 2015-04-23 06:07:00 +0900 (bb915ba) +++ lib/droonga/forwarder.rb 2015-04-23 10:05:17 +0900 (03a32b2) @@ -62,6 +62,7 @@ module Droonga end def refresh_connection_for(name) + logger.trace("refresh_connection_for(#{name}): start") sender = @senders[name] if sender sender.shutdown @@ -72,10 +73,13 @@ module Droonga timer.detach @auto_close_timers.delete(name) end + logger.trace("refresh_connection_for(#{name}): done") end def refresh_all_connections + logger.trace("refresh_all_connections: start") clear_senders + logger.trace("refresh_all_connections: done") end private -------------- next part -------------- HTML����������������������������...ダウンロード
