[Groonga-commit] droonga/droonga-engine at 6def76c [master] Remove codes to send messages for dead nodes.

Back to archive index

YUKI Hiroshi null+****@clear*****
Fri Jun 27 16:33:52 JST 2014


YUKI Hiroshi	2014-06-27 16:33:52 +0900 (Fri, 27 Jun 2014)

  New Revision: 6def76c0fe97bae6e925121510f8a6f48172c47d
  https://github.com/droonga/droonga-engine/commit/6def76c0fe97bae6e925121510f8a6f48172c47d

  Message:
    Remove codes to send messages for dead nodes.
    
    It should be re-introduced after 1.0.4.

  Modified files:
    lib/droonga/dispatcher.rb

  Modified: lib/droonga/dispatcher.rb (+0 -25)
===================================================================
--- lib/droonga/dispatcher.rb    2014-06-27 16:32:53 +0900 (69c7c59)
+++ lib/droonga/dispatcher.rb    2014-06-27 16:33:52 +0900 (fded5ca)
@@ -171,27 +171,10 @@ module Droonga
     def dispatch_steps(steps)
       id = @engine_state.generate_id
 
-      one_way_steps = []
-      one_way_destinations = []
-      have_dead_nodes = !@engine_state.dead_nodes.empty?
-
       destinations = []
       steps.each do |step|
         dataset =****@catal*****(step["dataset"])
         if dataset
-          if have_dead_nodes and write_step?(step)
-            routes = dataset.get_routes(step, @engine_state.dead_nodes)
-            unless routes.empty?
-              one_way_step = Marshal.load(Marshal.dump(step))
-              one_way_step["routes"] = routes
-              one_way_step.delete("post")
-              one_way_step.delete("outputs")
-              one_way_steps << one_way_step
-              one_way_destinations += routes.collect do |route|
-                farm_path(route)
-              end
-            end
-          end
           routes = dataset.get_routes(step, @engine_state.live_nodes)
           step["routes"] = routes
         else
@@ -206,14 +189,6 @@ module Droonga
       destinations.uniq.each do |destination|
         dispatch(dispatch_message, destination)
       end
-
-      unless one_way_steps.empty?
-        dispatch_message = { "id" => @engine_state.generate_id,
-                             "steps" => one_way_steps }
-        one_way_destinations.uniq.each do |destination|
-          dispatch(dispatch_message, destination)
-        end
-      end
     end
 
     def process_local_message(local_message)
-------------- next part --------------
HTML����������������������������...
Télécharger 



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