YUKI Hiroshi
null+****@clear*****
Thu Apr 2 14:36:18 JST 2015
YUKI Hiroshi 2015-04-02 14:36:18 +0900 (Thu, 02 Apr 2015) New Revision: dcfd75186754e6fde0fc45f4b38622cb1f3c8510 https://github.com/droonga/droonga-engine/commit/dcfd75186754e6fde0fc45f4b38622cb1f3c8510 Message: Output more trace logs Modified files: lib/droonga/command/droonga_engine_service.rb lib/droonga/fluent_message_receiver.rb Modified: lib/droonga/command/droonga_engine_service.rb (+4 -0) =================================================================== --- lib/droonga/command/droonga_engine_service.rb 2015-04-02 12:13:58 +0900 (d0b4ff7) +++ lib/droonga/command/droonga_engine_service.rb 2015-04-02 14:36:18 +0900 (804f300) @@ -182,6 +182,8 @@ module Droonga end def on_message(tag, time, record) + logger.trace("on_message: start", :record => record) + prefix, type, *arguments = tag.split(/\./) if type.nil? or type.empty? or type == "message" message = record @@ -201,6 +203,8 @@ module Droonga end @engine.process(message) + + logger.trace("on_message: done") end def stop_gracefully Modified: lib/droonga/fluent_message_receiver.rb (+4 -0) =================================================================== --- lib/droonga/fluent_message_receiver.rb 2015-04-02 12:13:58 +0900 (ca2c012) +++ lib/droonga/fluent_message_receiver.rb 2015-04-02 14:36:18 +0900 (579d41c) @@ -81,7 +81,9 @@ module Droonga @clients = [] @server = create_server do |connection| client = Client.new(connection) do |tag, time, record| + logger.trace("Client: on_message: start") @on_message.call(tag, time, record) + logger.trace("Client: on_message: done") end client.on_close = lambda do @clients.delete(client) @@ -206,6 +208,7 @@ module Droonga private def feed(data) @unpacker.feed_each(data) do |object| + logger.trace("Client: feed_each: start", :object => object) tag = object[0] case object[1] when String # PackedForward message @@ -221,6 +224,7 @@ module Droonga entries.each do |time, record| @on_message.call(tag, time || Time.now.to_i, record) end + logger.trace("Client: feed_each: done") end end -------------- next part -------------- HTML����������������������������...ダウンロード
