Navigation Menu

Skip to content

Commit

Permalink
Fix indent
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Apr 21, 2015
1 parent f80f225 commit 5e3a2a1
Showing 1 changed file with 25 additions and 25 deletions.
50 changes: 25 additions & 25 deletions bin/droonga-engine-join
Expand Up @@ -222,9 +222,9 @@ module Droonga
if absorber.source_node_suspendable?
puts("Changing role of the source node...")
source_node_serf.do_and_wait_restart do
source_node_serf.send_query("change_role",
"node" => source_node.to_s,
"role" => NodeRole::ABSORB_SOURCE)
source_node_serf.send_query("change_role",
"node" => source_node.to_s,
"role" => NodeRole::ABSORB_SOURCE)
end
end
@source_node_role_changed = true
Expand All @@ -233,9 +233,9 @@ module Droonga
def set_joining_node_role
puts("Changing role of the joining node...")
joining_node_serf.do_and_wait_restart do
joining_node_serf.send_query("change_role",
"node" => joining_node.to_s,
"role" => NodeRole::ABSORB_DESTINATION)
joining_node_serf.send_query("change_role",
"node" => joining_node.to_s,
"role" => NodeRole::ABSORB_DESTINATION)
end
@joining_node_role_changed = true
end
Expand All @@ -244,9 +244,9 @@ module Droonga
if absorber.source_node_suspendable?
puts("Restoring role of the source node...")
source_node_serf.do_and_wait_restart do
source_node_serf.send_query("change_role",
"node" => source_node.to_s,
"role" => NodeRole::SERVICE_PROVIDER)
source_node_serf.send_query("change_role",
"node" => source_node.to_s,
"role" => NodeRole::SERVICE_PROVIDER)
end
end
@source_node_role_changed = false
Expand All @@ -255,21 +255,21 @@ module Droonga
def reset_joining_node_role
puts("Restoring role of the joining node...")
joining_node_serf.do_and_wait_restart do
joining_node_serf.send_query("change_role",
"node" => joining_node.to_s,
"role" => NodeRole::SERVICE_PROVIDER)
joining_node_serf.send_query("change_role",
"node" => joining_node.to_s,
"role" => NodeRole::SERVICE_PROVIDER)
end
@joining_node_role_changed = false
end

def do_join
puts("Joining new replica to the cluster...")
joining_node_serf.do_and_wait_restart do
joining_node_serf.send_query("join",
"node" => joining_node.to_s,
"type" => "replica",
"source" => source_node.to_s,
"dataset" => dataset)
joining_node_serf.send_query("join",
"node" => joining_node.to_s,
"type" => "replica",
"source" => source_node.to_s,
"dataset" => dataset)
end
end

Expand Down Expand Up @@ -314,21 +314,21 @@ module Droonga
def register_to_existing_nodes
puts("Register new node to existing hosts in the cluster...")
source_node_serf.do_and_wait_restart do
source_node_serf.send_query("add_replicas",
"cluster_id" => source_cluster_id,
"dataset" => dataset,
"hosts" => [joining_node.host])
source_node_serf.send_query("add_replicas",
"cluster_id" => source_cluster_id,
"dataset" => dataset,
"hosts" => [joining_node.host])
end
@node_registered = true
end

def unregister_from_existing_nodes
puts("Unregister new node from existing hosts in the cluster...")
source_node_serf.do_and_wait_restart do
source_node_serf.send_query("remove_replicas",
"cluster_id" => source_cluster_id,
"dataset" => dataset,
"hosts" => [joining_node.host])
source_node_serf.send_query("remove_replicas",
"cluster_id" => source_cluster_id,
"dataset" => dataset,
"hosts" => [joining_node.host])
end
@node_registered = false
end
Expand Down

0 comments on commit 5e3a2a1

Please sign in to comment.