YUKI Hiroshi
null+****@clear*****
Thu Apr 23 23:25:15 JST 2015
YUKI Hiroshi 2015-04-23 23:25:15 +0900 (Thu, 23 Apr 2015) New Revision: c530784c2440da1b1156ef048d8b41dae4907696 https://github.com/droonga/droonga-engine/commit/c530784c2440da1b1156ef048d8b41dae4907696 Message: Save last processed message timestamp based on messages processed while "graceful stop" operations Modified files: lib/droonga/engine.rb Modified: lib/droonga/engine.rb (+5 -2) =================================================================== --- lib/droonga/engine.rb 2015-04-23 23:06:46 +0900 (13b4854) +++ lib/droonga/engine.rb 2015-04-23 23:25:15 +0900 (80fba7b) @@ -80,10 +80,13 @@ module Droonga on_finish = lambda do logger.trace("stop_gracefully: middle") @export_last_processed_message_timestamp_observer.stop - export_last_processed_message_timestamp @dispatcher.stop_gracefully do @state.shutdown yield + #XXX We must save last processed message timstamp + # based on forwarded/dispatched messages while + # "graceful stop" operations. + export_last_processed_message_timestamp logger.trace("stop_gracefully: done") end end @@ -100,10 +103,10 @@ module Droonga def stop_immediately logger.trace("stop_immediately: start") @export_last_processed_message_timestamp_observer.stop - export_last_processed_message_timestamp @dispatcher.stop_immediately @cluster.shutdown @state.shutdown + export_last_processed_message_timestamp logger.trace("stop_immediately: done") end -------------- next part -------------- HTML����������������������������...Download