[Groonga-commit] droonga/droonga-engine at 5efa6ef [master] Output readable trace log for sessions

Back to archive index

YUKI Hiroshi null+****@clear*****
Wed Apr 1 20:23:19 JST 2015


YUKI Hiroshi	2015-04-01 20:23:19 +0900 (Wed, 01 Apr 2015)

  New Revision: 5efa6ef71eeeb7ea60e35d37a948fe66fea99073
  https://github.com/droonga/droonga-engine/commit/5efa6ef71eeeb7ea60e35d37a948fe66fea99073

  Message:
    Output readable trace log for sessions

  Modified files:
    lib/droonga/dispatcher.rb
    lib/droonga/session.rb

  Modified: lib/droonga/dispatcher.rb (+0 -2)
===================================================================
--- lib/droonga/dispatcher.rb    2015-04-01 20:13:57 +0900 (35d6cc2)
+++ lib/droonga/dispatcher.rb    2015-04-01 20:23:19 +0900 (21a6a4d)
@@ -163,7 +163,6 @@ module Droonga
       id = message["id"]
       session = @engine_state.find_session(id)
       if session
-        logger.trace("process_internal_message: session exists", :session => session)
         session.receive(message["input"], message["value"])
       else
         logger.trace("process_internal_message: no session")
@@ -173,7 +172,6 @@ module Droonga
           dataset = message["dataset"] || @message["dataset"]
           collector_runner = @collector_runners[dataset]
           session = session_planner.create_session(id, self, collector_runner)
-          logger.trace("process_internal_message: session created", :session => session)
           @engine_state.register_session(id, session)
         else
           logger.error("no steps error", :id => id, :message => message)

  Modified: lib/droonga/session.rb (+4 -0)
===================================================================
--- lib/droonga/session.rb    2015-04-01 20:13:57 +0900 (44cb710)
+++ lib/droonga/session.rb    2015-04-01 20:23:19 +0900 (115be6c)
@@ -34,11 +34,13 @@ module Droonga
 
     def start
       tasks = @inputs[nil] || []
+      logger.trace("start: no task!") if tasks.empty?
       tasks.each do |task|
         local_message = {
           "id"   => @id,
           "task" => task,
         }
+        logger.trace("start: dispatching local message", :message => local_message)
         @dispatcher.process_local_message(local_message)
         @n_dones += 1
       end
@@ -46,6 +48,8 @@ module Droonga
 
     def receive(name, value)
       tasks = @inputs[name]
+      logger.trace("receive: process response",
+                   :name => name, :value => value, :task => tasks)
       unless tasks
         #TODO: result arrived before its query
         return
-------------- next part --------------
HTML����������������������������...
다운로드 



More information about the Groonga-commit mailing list
Back to archive index