YUKI Hiroshi
null+****@clear*****
Wed Apr 22 10:27:21 JST 2015
YUKI Hiroshi 2015-04-22 10:27:21 +0900 (Wed, 22 Apr 2015) New Revision: 6b5f6254add087bca5ac88ed8be38d6dd7a194e8 https://github.com/droonga/droonga-engine/commit/6b5f6254add087bca5ac88ed8be38d6dd7a194e8 Message: Do only one thing at one line Modified files: lib/droonga/forward_buffer.rb Modified: lib/droonga/forward_buffer.rb (+7 -4) =================================================================== --- lib/droonga/forward_buffer.rb 2015-04-22 10:18:15 +0900 (83b52ed) +++ lib/droonga/forward_buffer.rb 2015-04-22 10:27:21 +0900 (fd75d3a) @@ -64,12 +64,15 @@ module Droonga def start_forward logger.trace("start_forward: start") - forwarded = false + n_forwarded_messages = 0 Pathname.glob("#{@data_directory}/*#{SUFFIX}").collect do |buffered_message_path| - forwarded = forward(buffered_message_path) || forwarded + forwarded = forward(buffered_message_path) + n_forwarded_messages += 1 if forwarded end - if @process_messages_newer_than_timestamp and forwarded - logger.info("New message is detected and forwarded. The boundary is now cleared.") + if n_forwarded_messages > 0 and + @process_messages_newer_than_timestamp + logger.info("#{n_forwarded_messages} new messages forwarded. " + + "The boundary is now cleared.") @process_messages_newer_than_timestamp = nil end @serf.reset_have_unprocessed_messages_for(@target) -------------- next part -------------- HTML����������������������������...다운로드
