Navigation Menu

Skip to content

Commit

Permalink
Wait until target node is completely restarted
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Apr 21, 2015
1 parent 1e7c429 commit be08561
Showing 1 changed file with 6 additions and 4 deletions.
10 changes: 6 additions & 4 deletions bin/droonga-engine-set-role
Expand Up @@ -71,15 +71,17 @@ module Droonga
"#{@options[:host]}:#{@options[:port]}/#{@options[:tag]}"
end

def run_remote_command(target, command, options)
serf = Serf.new(target, :verbose => @options[:verbose])
serf.send_query(command, options)
def target_node_serf
@target_node_serf ||= Serf.new(target_node,
:verbose => @options[:verbose])
end

def set_node_role
run_remote_command(target_node, "change_role",
target_node_serf.ensure_restarted do
target_node_serf.send_query("change_role",
"node" => target_node,
"role" => @options[:role])
end
end
end
end
Expand Down

0 comments on commit be08561

Please sign in to comment.