YUKI Hiroshi
null+****@clear*****
Fri Apr 10 13:49:28 JST 2015
YUKI Hiroshi 2015-04-10 13:49:28 +0900 (Fri, 10 Apr 2015) New Revision: f6149caa9df861aa60b3ebd72eeb6f0d30a9ae84 https://github.com/droonga/droonga-engine/commit/f6149caa9df861aa60b3ebd72eeb6f0d30a9ae84 Message: Set "absorbing" tag for self Modified files: lib/droonga/plugins/system/absorb_data.rb Modified: lib/droonga/plugins/system/absorb_data.rb (+6 -0) =================================================================== --- lib/droonga/plugins/system/absorb_data.rb 2015-04-10 13:49:11 +0900 (efc2d9e) +++ lib/droonga/plugins/system/absorb_data.rb 2015-04-10 13:49:28 +0900 (01732a3) @@ -44,12 +44,18 @@ module Droonga raise MissingHostParameter.new unless message.include?("host") dumper = Drndump::Dumper.new(dumper_params(message)) + + serf = Serf.new(my_node_name) + serf.set_tag("absorbing", true) + error_message = dumper.run do |message| @messenger.forward(message, "to" => my_node_name, "type" => message["type"]) end + serf.set_tag("absorbing", true) + raise DumpFailed.new(error_message) if error_message true -------------- next part -------------- HTML����������������������������...ダウンロード
