YUKI Hiroshi
null+****@clear*****
Thu Sep 4 18:34:26 JST 2014
YUKI Hiroshi 2014-09-04 18:34:26 +0900 (Thu, 04 Sep 2014) New Revision: 7e67b47f9bad2fe7ac22228f2edf7f7089e657f3 https://github.com/long-long-float/droonga-engine/commit/7e67b47f9bad2fe7ac22228f2edf7f7089e657f3 Message: Output more logs for debugging of #11 in the trace level Modified files: lib/droonga/dispatcher.rb lib/droonga/engine.rb lib/droonga/fluent_message_receiver.rb Modified: lib/droonga/dispatcher.rb (+2 -0) =================================================================== --- lib/droonga/dispatcher.rb 2014-09-04 17:10:32 +0900 (e0db01b) +++ lib/droonga/dispatcher.rb 2014-09-04 18:34:26 +0900 (0203435) @@ -70,6 +70,7 @@ module Droonga end def shutdown + logger.trace("shutdown: start") @collector_runners.each_value do |collector_runner| collector_runner.shutdown end @@ -77,6 +78,7 @@ module Droonga adapter_runner.shutdown end @farm.shutdown + logger.trace("shutdown: done") end def process_message(message) Modified: lib/droonga/engine.rb (+5 -1) =================================================================== --- lib/droonga/engine.rb 2014-09-04 17:10:32 +0900 (879a62d) +++ lib/droonga/engine.rb 2014-09-04 18:34:26 +0900 (c47ebac) @@ -57,16 +57,18 @@ module Droonga logger.trace("stop_gracefully: start") @live_nodes_list_observer.stop on_finish = lambda do + logger.trace("stop_gracefully/on_finish: start") output_last_processed_timestamp @dispatcher.shutdown @state.shutdown - logger.trace("stop_gracefully/on_finish: start") yield logger.trace("stop_gracefully/on_finish: done") end if****@state*****_session? + logger.trace("stop_gracefully/having sessions") @state.on_finish = on_finish else + logger.trace("stop_gracefully/no session") on_finish.call end logger.trace("stop_gracefully: done") @@ -114,11 +116,13 @@ module Droonga end def output_last_processed_timestamp + logger.trace("output_last_processed_timestamp: start") path = Path.last_processed_timestamp FileUtils.mkdir_p(path.dirname.to_s) path.open("w") do |file| file.write(@last_processed_timestamp) end + logger.trace("output_last_processed_timestamp: done") end def effective_message?(message) Modified: lib/droonga/fluent_message_receiver.rb (+3 -0) =================================================================== --- lib/droonga/fluent_message_receiver.rb 2014-09-04 17:10:32 +0900 (bb23adc) +++ lib/droonga/fluent_message_receiver.rb 2014-09-04 18:34:26 +0900 (c54a6d3) @@ -43,6 +43,7 @@ module Droonga def stop_gracefully logger.trace("stop_gracefully: start") shutdown_heartbeat_receiver + logger.trace("stop_gracefully: middle") shutdown_server logger.trace("stop_gracefully: done") end @@ -88,7 +89,9 @@ module Droonga end def shutdown_server + logger.trace("shutdown_server: start") @server.close + logger.trace("shutdown_server: done") end def shutdown_clients -------------- next part -------------- HTML����������������������������... Descargar