YUKI Hiroshi
null+****@clear*****
Wed Jul 23 13:02:06 JST 2014
YUKI Hiroshi 2014-07-23 13:02:06 +0900 (Wed, 23 Jul 2014) New Revision: dcfea693ffdaa9eac1d98f389737ccad96d6ff47 https://github.com/droonga/droonga-engine/commit/dcfea693ffdaa9eac1d98f389737ccad96d6ff47 Message: Output number of processed dump messages Modified files: lib/droonga/command/serf_event_handler.rb Modified: lib/droonga/command/serf_event_handler.rb (+10 -2) =================================================================== --- lib/droonga/command/serf_event_handler.rb 2014-07-23 12:44:06 +0900 (b55f90f) +++ lib/droonga/command/serf_event_handler.rb 2014-07-23 13:02:06 +0900 (4d29e98) @@ -149,11 +149,15 @@ module Droonga end sleep(1) # wait for restart + count = 0 DataAbsorber.absorb(:dataset => dataset_name, :source_host => source_host, :destination_host => host, :port => port, - :tag => tag) + :tag => tag) do |dump| + count += 1 + end + puts "#{count} dump messages are successfully processed." sleep(1) end @@ -298,11 +302,15 @@ module Droonga puts "port = #{port}" puts "tag = #{tag}" + count = 0 DataAbsorber.absorb(:dataset => dataset_name, :source_host => source, :destination_host => host, :port => port, - :tag => tag) + :tag => tag) do |dump| + count += 1 + end + puts "#{count} dump messages are successfully processed." end def live_nodes -------------- next part -------------- HTML����������������������������...Download