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����������������������������...下载
