YUKI Hiroshi
null+****@clear*****
Tue Apr 14 11:50:49 JST 2015
YUKI Hiroshi 2015-04-14 11:50:49 +0900 (Tue, 14 Apr 2015) New Revision: f1cd9ff670612aa1463fe99b616d0c381d8c06ea https://github.com/droonga/droonga-engine/commit/f1cd9ff670612aa1463fe99b616d0c381d8c06ea Message: Send dumped messages to the current dataset correctly Modified files: lib/droonga/plugins/system/absorb_data.rb Modified: lib/droonga/plugins/system/absorb_data.rb (+5 -0) =================================================================== --- lib/droonga/plugins/system/absorb_data.rb 2015-04-14 11:50:16 +0900 (d76a35a) +++ lib/droonga/plugins/system/absorb_data.rb 2015-04-14 11:50:49 +0900 (05b5541) @@ -63,6 +63,7 @@ module Droonga begin @total_n_source_records = count_total_n_source_records dumper_error_message = dumper.run do |message| + message["dataset"] = current_dataset @messenger.forward(message, "to" => my_node_name, "type" => message["type"]) @@ -141,6 +142,10 @@ module Droonga ENV["DROONGA_ENGINE_NAME"] end + def current_dataset + @request.dataset + end + def prepare_progress_interval_seconds interval_seconds =****@reque*****["progressIntervalSeconds"] || DEFAULT_PROGRESS_INTERVAL_SECONDS -------------- next part -------------- HTML����������������������������...Download