YUKI Hiroshi
null+****@clear*****
Wed Apr 22 10:53:31 JST 2015
YUKI Hiroshi 2015-04-22 10:53:31 +0900 (Wed, 22 Apr 2015) New Revision: 7e84a83705d531fa618a4e7b04578f90919d2a3d https://github.com/droonga/droonga-engine/commit/7e84a83705d531fa618a4e7b04578f90919d2a3d Message: Remove needless "else" block Modified files: lib/droonga/forward_buffer.rb Modified: lib/droonga/forward_buffer.rb (+4 -4) =================================================================== --- lib/droonga/forward_buffer.rb 2015-04-22 10:29:00 +0900 (04c9f74) +++ lib/droonga/forward_buffer.rb 2015-04-22 10:53:31 +0900 (8c12184) @@ -73,6 +73,10 @@ module Droonga @process_messages_newer_than_timestamp logger.info("#{n_forwarded_messages} new messages forwarded. " + "The boundary is now cleared.") + # Don't clear the boundary while forwarding. + # Because buffered messages are not sorted by their "date", + # so older messages can appear after newer one. + # (ex. messages generated by Dispatcher) @process_messages_newer_than_timestamp = nil end @serf.reset_have_unprocessed_messages_for(@target) @@ -111,10 +115,6 @@ module Droonga :message_at => message_timestamp) if @process_messages_newer_than_timestamp >= message_timestamp buffered_message = nil - else - logger.info("New message is detected.") - # Don't clear the boundary for now, because older messages - # forwarded by the dispatcher can be still buffered. end end -------------- next part -------------- HTML����������������������������...Descargar
