YUKI Hiroshi
null+****@clear*****
Tue Mar 31 17:33:31 JST 2015
YUKI Hiroshi 2015-03-31 17:33:31 +0900 (Tue, 31 Mar 2015) New Revision: 1521cc919e2bc3a03b289fd46335b163a72842c6 https://github.com/droonga/droonga-engine/commit/1521cc919e2bc3a03b289fd46335b163a72842c6 Message: Output more trace logs Modified files: lib/droonga/engine_node.rb lib/droonga/fluent_message_sender.rb Modified: lib/droonga/engine_node.rb (+4 -0) =================================================================== --- lib/droonga/engine_node.rb 2015-03-31 17:33:10 +0900 (5212f21) +++ lib/droonga/engine_node.rb 2015-03-31 17:33:31 +0900 (deaa4eb) @@ -24,6 +24,7 @@ module Droonga attr_reader :name def initialize(name, state, loop, params) + logger.trace("initialize: start") @name = name @state = state @sender_node_metadata = params[:metadata] @@ -34,6 +35,7 @@ module Droonga parsed_name[:port], :buffering => true) @sender.start + logger.trace("initialize: done") end def start @@ -90,7 +92,9 @@ module Droonga end def resume + logger.trace("resume: start") @sender.resume + logger.trace("resume: done") end private Modified: lib/droonga/fluent_message_sender.rb (+12 -4) =================================================================== --- lib/droonga/fluent_message_sender.rb 2015-03-31 17:33:10 +0900 (58a4b93) +++ lib/droonga/fluent_message_sender.rb 2015-03-31 17:33:31 +0900 (0cbc93a) @@ -52,13 +52,19 @@ module Droonga def send(tag, data) logger.trace("send: start") packed_fluent_message = create_packed_fluent_message(tag, data) - connect unless connected? + unless connected? + logger.trace("send: reconnect to #{@host}:#{@port}") + connect + end @socket.write(packed_fluent_message) logger.trace("send: done") end def resume - connect unless connected? + unless connected? + logger.trace("resume: reconnect to #{@host}:#{@port}") + connect + end end private @@ -80,6 +86,7 @@ module Droonga @socket = nil end on_close = lambda do + logger.trace("connection to #{@host}:#{@port} is closed by someone") @socket = nil end @@ -115,9 +122,10 @@ module Droonga def shutdown_socket return unless connected? unles****@socke*****? - @socket.close - logger.trace("shutdown_socket: socket watcher detached", + logger.trace("shutdown_socket: socket watcher detaching", :watcher => @socket) + @socket.close + logger.trace("shutdown_socket: socket watcher detached") end end -------------- next part -------------- HTML����������������������������...Download