[Groonga-commit] droonga/droonga-engine at 273f7f8 [master] Wait for more while after catalog.json is modified

Back to archive index

YUKI Hiroshi null+****@clear*****
Wed Jul 23 18:07:49 JST 2014


YUKI Hiroshi	2014-07-23 18:07:49 +0900 (Wed, 23 Jul 2014)

  New Revision: 273f7f8d56ee23a9be1fc067337ce3500abcf5ae
  https://github.com/droonga/droonga-engine/commit/273f7f8d56ee23a9be1fc067337ce3500abcf5ae

  Message:
    Wait for more while after catalog.json is modified

  Modified files:
    bin/droonga-engine-join
    lib/droonga/command/serf_event_handler.rb

  Modified: bin/droonga-engine-join (+1 -0)
===================================================================
--- bin/droonga-engine-join    2014-07-23 17:15:42 +0900 (b996e4c)
+++ bin/droonga-engine-join    2014-07-23 18:07:49 +0900 (4b7fde1)
@@ -142,6 +142,7 @@ run_remote_command(options.joining_node, "join",
                    "source" => options.source_node,
 #                   "fetch_port" => publish_port,
                    "copy"   => options.copy)
+sleep(5) #TODO: wait for restarting of the joining node. this should be done more safely.
 
 while true
   sleep(3)

  Modified: lib/droonga/command/serf_event_handler.rb (+1 -1)
===================================================================
--- lib/droonga/command/serf_event_handler.rb    2014-07-23 17:15:42 +0900 (42db0c0)
+++ lib/droonga/command/serf_event_handler.rb    2014-07-23 18:07:49 +0900 (0ddf2e0)
@@ -164,7 +164,7 @@ module Droonga
           modify_catalog do |modifier|
             modifier.datasets[dataset_name].replicas.hosts = [host]
           end
-          sleep(1) # wait for restart
+          sleep(5) #TODO: wait for restart. this should be done more safely, to avoid starting of absorbing with old catalog.json.
 
           save_status(:absorbing, true)
           DataAbsorber.absorb(:dataset          => dataset_name,
-------------- next part --------------
HTML����������������������������...
Download 



More information about the Groonga-commit mailing list
Back to archive index