YUKI Hiroshi
null+****@clear*****
Wed Jul 23 14:46:18 JST 2014
YUKI Hiroshi 2014-07-23 14:46:18 +0900 (Wed, 23 Jul 2014) New Revision: 4385140f0eaa446ca3bfdb74d2b1f72f8840c183 https://github.com/droonga/droonga-engine/commit/4385140f0eaa446ca3bfdb74d2b1f72f8840c183 Message: It is a part of dumps, not a dump Modified files: bin/droonga-engine-absorb-data lib/droonga/data_absorber.rb Modified: bin/droonga-engine-absorb-data (+1 -6) =================================================================== --- bin/droonga-engine-absorb-data 2014-07-23 14:38:46 +0900 (d15eb0e) +++ bin/droonga-engine-absorb-data 2014-07-23 14:46:18 +0900 (b9e9f7a) @@ -97,16 +97,11 @@ else puts "dataset = #{options.dataset}" puts "port = #{options.port}" puts "tag = #{options.tag}" - count = 0 Droonga::DataAbsorber.absorb(:dataset => options.dataset, :source_host => options.source_host, :destination_host => options.destination_host, :port => options.port, - :tag => options.tag) do |dump| - count += 1 - puts dump - end - puts "#{count} dump messages are successfully processed." + :tag => options.tag) end puts "Done." Modified: lib/droonga/data_absorber.rb (+3 -3) =================================================================== --- lib/droonga/data_absorber.rb 2014-07-23 14:38:46 +0900 (7ea3cfa) +++ lib/droonga/data_absorber.rb 2014-07-23 14:46:18 +0900 (36adf52) @@ -43,9 +43,9 @@ module Droonga dump_in.close Open3.popen3(*client_command_line, :pgroup => true) do |client_in, client_out, client_error, client_thread| client_out.close - dump_out.each do |dump| - yield dump if block_given? - client_in.puts(dump) + dump_out.each do |part| + yield part if block_given? + client_in.puts(part) end end end -------------- next part -------------- HTML����������������������������...Download