YUKI Hiroshi
null+****@clear*****
Fri Nov 21 18:22:52 JST 2014
YUKI Hiroshi 2014-11-21 18:22:52 +0900 (Fri, 21 Nov 2014) New Revision: a62f866baef4d7914c451cd57be4d45518f19812 https://github.com/droonga/droonga-engine/commit/a62f866baef4d7914c451cd57be4d45518f19812 Message: Report progress only when data absorber is working Modified files: bin/droonga-engine-join Modified: bin/droonga-engine-join (+11 -9) =================================================================== --- bin/droonga-engine-join 2014-11-21 18:21:07 +0900 (8b25160) +++ bin/droonga-engine-join 2014-11-21 18:22:52 +0900 (461aa63) @@ -85,16 +85,18 @@ run_remote_command(joining_node, "join", "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") - absorbing = response["value"] - break unless absorbing +unless options["no-copy"] + while true + sleep(3) + response = run_remote_command(joining_node, "report_status", + "node" => joining_node, + "key" => "absorbing") + absorbing = response["value"] + break unless absorbing - progress = absorber.report_progress(start_time_in_seconds) - puts(progress) if progress + progress = absorber.report_progress(start_time_in_seconds) + puts(progress) if progress + end end response = run_remote_command(source_node, "report_status", -------------- next part -------------- HTML����������������������������...Download