YUKI Hiroshi
null+****@clear*****
Wed Aug 27 18:57:34 JST 2014
YUKI Hiroshi 2014-08-27 18:57:34 +0900 (Wed, 27 Aug 2014) New Revision: 693db53c2c87228cde7d021d9ffd25e270e0d8d3 https://github.com/long-long-float/droonga-engine/commit/693db53c2c87228cde7d021d9ffd25e270e0d8d3 Message: Align Modified files: bin/droonga-engine-join Modified: bin/droonga-engine-join (+7 -7) =================================================================== --- bin/droonga-engine-join 2014-08-27 18:45:49 +0900 (5f065f6) +++ bin/droonga-engine-join 2014-08-27 18:57:34 +0900 (d1ce7e8) @@ -67,20 +67,20 @@ end puts "Joining new replica to the cluster..." run_remote_command(joining_node, "join", - "node" => joining_node, - "type" => "replica", - "source" => source_node, - "port" => options[:port], + "node" => joining_node, + "type" => "replica", + "source" => source_node, + "port" => options[:port], "dataset" => options[:dataset], - "tag" => options[:tag], - "copy" => !options["no-copy"]) + "tag" => options[:tag], + "copy" => !options["no-copy"]) sleep(5) #TODO: wait for restarting of the joining node. this should be done more safely. while true sleep(3) response = run_remote_command(joining_node, "report_status", "node" => joining_node, - "key" => "absorbing") + "key" => "absorbing") absorbing = response["value"] break unless absorbing end -------------- next part -------------- HTML����������������������������...Download