Navigation Menu

Skip to content

Commit

Permalink
Report more progress
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Jan 15, 2015
1 parent 00812b6 commit 8938aad
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions bin/droonga-engine-join
Expand Up @@ -148,10 +148,12 @@ class JoinCommand

def set_node_role
if absorber.source_node_suspendable?
puts("Changing role of the source node...")
run_remote_command(source_node, "change_role",
"node" => source_node,
"role" => Droonga::NodeMetadata::Role::ABSORB_SOURCE)
end
puts("Changing role of the joining node...")
run_remote_command(joining_node, "change_role",
"node" => joining_node,
"role" => Droonga::NodeMetadata::Role::ABSORB_DESTINATION)
Expand All @@ -160,10 +162,12 @@ class JoinCommand

def reset_node_role
if absorber.source_node_suspendable?
puts("Restoring role of the source node...")
run_remote_command(source_node, "change_role",
"node" => source_node,
"role" => nil)
end
puts("Restoring role of the joining node...")
run_remote_command(joining_node, "change_role",
"node" => joining_node,
"role" => nil)
Expand Down

0 comments on commit 8938aad

Please sign in to comment.