Navigation Menu

Skip to content

Commit

Permalink
Output more trace logs around refreshing of connections
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Apr 23, 2015
1 parent 103d889 commit 3a6dad4
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 1 deletion.
6 changes: 5 additions & 1 deletion lib/droonga/cluster.rb
Expand Up @@ -100,11 +100,13 @@ def shutdown
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
Expand All @@ -118,7 +120,9 @@ def reload
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
Expand Down
2 changes: 2 additions & 0 deletions lib/droonga/engine_node.rb
Expand Up @@ -66,8 +66,10 @@ def shutdown
end

def refresh_connection
logger.trace("refresh_connection: start")
shutdown
sender # instantiate new sender
logger.trace("refresh_connection: done")
end

def forward(message, destination)
Expand Down
4 changes: 4 additions & 0 deletions lib/droonga/forwarder.rb
Expand Up @@ -62,6 +62,7 @@ def forward(message, destination)
end

def refresh_connection_for(name)
logger.trace("refresh_connection_for(#{name}): start")
sender = @senders[name]
if sender
sender.shutdown
Expand All @@ -72,10 +73,13 @@ def refresh_connection_for(name)
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
Expand Down

0 comments on commit 3a6dad4

Please sign in to comment.