YUKI Hiroshi
null+****@clear*****
Fri Apr 10 18:00:06 JST 2015
YUKI Hiroshi 2015-04-10 18:00:06 +0900 (Fri, 10 Apr 2015) New Revision: 05d29d0088adf6b70f2f3999a899700ad736a7a4 https://github.com/droonga/droonga-engine/commit/05d29d0088adf6b70f2f3999a899700ad736a7a4 Message: Remove obsolete absorb_data remote command Modified files: lib/droonga/command/remote.rb lib/droonga/command/serf_event_handler.rb Modified: lib/droonga/command/remote.rb (+0 -48) =================================================================== --- lib/droonga/command/remote.rb 2015-04-10 17:58:53 +0900 (8a1111c) +++ lib/droonga/command/remote.rb 2015-04-10 18:00:06 +0900 (15a1e06) @@ -238,54 +238,6 @@ module Droonga end end - class AbsorbData < CrossNodeCommandBase - def process - return unless valid_params? - - log("start to absorb data from #{source_node}") - - if dataset.nil? or port.nil? or tag.nil? - generator = CatalogGenerator.new - generator.load(catalog) - - dataset_info = generator.dataset_for_host(source_host) - return unless dataset_info - - @dataset = dataset_info.name - @port = dataset_info.replicas.port - @tag = dataset_info.replicas.tag - end - - log("dataset = #{dataset}") - log("port = #{port}") - log("tag = #{tag}") - - @serf.set_tag("absorbing", true) - - log("start") - DataAbsorber.absorb(:dataset => dataset, - :source_host => source_host, - :destination_host => host, - :port => port, - :tag => tag, - :messages_per_second => messages_per_second, - :client => "droonga-send") - - @serf.delete_tag("absorbing") - log("done") - end - - private - def messages_per_second - @params["messages_per_second"] - end - - def valid_params? - not dataset.nil? and - not source_node.nil? - end - end - class ModifyReplicasBase < Base private def dataset Modified: lib/droonga/command/serf_event_handler.rb (+0 -2) =================================================================== --- lib/droonga/command/serf_event_handler.rb 2015-04-10 17:58:53 +0900 (f8dd914) +++ lib/droonga/command/serf_event_handler.rb 2015-04-10 18:00:06 +0900 (231f9dd) @@ -96,8 +96,6 @@ module Droonga Remote::AddReplicas when "remove_replicas" Remote::RemoveReplicas - when "absorb_data" - Remote::AbsorbData else nil end -------------- next part -------------- HTML����������������������������...다운로드
