[Groonga-commit] droonga/droonga-engine at 9b40a6e [master] Set tag while absorbing

Back to archive index

YUKI Hiroshi null+****@clear*****
Wed Jul 23 15:39:35 JST 2014


YUKI Hiroshi	2014-07-23 15:39:35 +0900 (Wed, 23 Jul 2014)

  New Revision: 9b40a6e0d02c1cb591f637fbfcb0da73cc57abcb
  https://github.com/droonga/droonga-engine/commit/9b40a6e0d02c1cb591f637fbfcb0da73cc57abcb

  Message:
    Set tag while absorbing

  Modified files:
    lib/droonga/command/serf_event_handler.rb

  Modified: lib/droonga/command/serf_event_handler.rb (+4 -0)
===================================================================
--- lib/droonga/command/serf_event_handler.rb    2014-07-23 15:38:56 +0900 (f3ea1f7)
+++ lib/droonga/command/serf_event_handler.rb    2014-07-23 15:39:35 +0900 (b8ef15d)
@@ -158,11 +158,13 @@ module Droonga
           end
           sleep(1) # wait for restart
 
+          Serf.set_tag("absorbing", "true")
           DataAbsorber.absorb(:dataset          => dataset_name,
                               :source_host      => source_host,
                               :destination_host => host,
                               :port             => port,
                               :tag              => tag)
+          Serf.delete_tag("absorbing")
           sleep(1)
         end
 
@@ -307,11 +309,13 @@ module Droonga
         log("port    = #{port}")
         log("tag     = #{tag}")
 
+        Serf.set_tag("absorbing", "true")
         DataAbsorber.absorb(:dataset          => dataset_name,
                             :source_host      => source,
                             :destination_host => host,
                             :port             => port,
                             :tag              => tag)
+        Serf.delete_tag("absorbing")
       end
 
       def live_nodes
-------------- next part --------------
HTML����������������������������...
Download 



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