YUKI Hiroshi
null+****@clear*****
Fri Apr 10 18:28:20 JST 2015
YUKI Hiroshi 2015-04-10 18:28:20 +0900 (Fri, 10 Apr 2015) New Revision: 3842ee8afd1e00bfac48849ccd265b7fb14d5304 https://github.com/droonga/droonga-engine/commit/3842ee8afd1e00bfac48849ccd265b7fb14d5304 Message: Fix indent Modified files: lib/droonga/plugins/system/absorb_data.rb Modified: lib/droonga/plugins/system/absorb_data.rb (+8 -9) =================================================================== --- lib/droonga/plugins/system/absorb_data.rb 2015-04-10 18:27:40 +0900 (14ce71f) +++ lib/droonga/plugins/system/absorb_data.rb 2015-04-10 18:28:20 +0900 (a6a953a) @@ -63,16 +63,15 @@ module Droonga begin @total_n_source_records = count_total_n_source_records - @n_processed_messages = 0 - dumper_error_message = dumper.run do |message| - @messenger.forward(message, - "to" => my_node_name, - "type" => message["type"]) - @n_processed_messages += 1 + @n_processed_messages = 0 + dumper_error_message = dumper.run do |message| + @messenger.forward(message, + "to" => my_node_name, + "type" => message["type"]) + @n_processed_messages += 1 + report_progress + end report_progress - end - - report_progress rescue Exception => exception dumper_error_message = exception.to_s end -------------- next part -------------- HTML����������������������������...Download
