Navigation Menu

Skip to content

Commit

Permalink
Don't destroy forwarder by refreshing
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Apr 22, 2015
1 parent 9f3b557 commit 2061761
Showing 1 changed file with 13 additions and 10 deletions.
23 changes: 13 additions & 10 deletions lib/droonga/forwarder.rb
Expand Up @@ -47,14 +47,7 @@ def start
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

Expand Down Expand Up @@ -82,8 +75,7 @@ def refresh_connection_for(name)
end

def refresh_all_connections
shutdown
start
clear_senders
end

private
Expand Down Expand Up @@ -176,6 +168,17 @@ def set_auto_close_timer(host, port, params)
@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
Expand Down

0 comments on commit 2061761

Please sign in to comment.