YUKI Hiroshi
null+****@clear*****
Tue Apr 14 12:26:06 JST 2015
YUKI Hiroshi 2015-04-14 12:26:06 +0900 (Tue, 14 Apr 2015) New Revision: 4afb781808a8ab6b94ed236d2cf1101b163e2b1e https://github.com/droonga/droonga-engine/commit/4afb781808a8ab6b94ed236d2cf1101b163e2b1e Message: Count up number of processed messages correctly Modified files: lib/droonga/plugins/system/absorb_data.rb Modified: lib/droonga/plugins/system/absorb_data.rb (+2 -0) =================================================================== --- lib/droonga/plugins/system/absorb_data.rb 2015-04-14 12:21:41 +0900 (2c805dc) +++ lib/droonga/plugins/system/absorb_data.rb 2015-04-14 12:26:06 +0900 (9fe6a5a) @@ -61,6 +61,7 @@ module Droonga @start_time = Time.now begin + @n_processed_messages = 0 @total_n_source_records = nil get_total_n_source_records do |count| @total_n_source_records = count @@ -70,6 +71,7 @@ module Droonga @messenger.forward(message, "to" => my_node_name, "type" => message["type"]) + @n_processed_messages += 1 elapsed_seconds = (Time.now - @start_time).to_i if (elapsed_seconds % progress_interval_seconds).zero? and not @total_n_source_records.nil? -------------- next part -------------- HTML����������������������������...Download
