Kouhei Sutou
null+****@clear*****
Thu Jan 30 15:16:15 JST 2014
Kouhei Sutou 2014-01-30 15:16:15 +0900 (Thu, 30 Jan 2014) New Revision: 6be519c38d8d74e7ec635308514e9e0535503811 https://github.com/droonga/fluent-plugin-droonga/commit/6be519c38d8d74e7ec635308514e9e0535503811 Message: test: extract dependencies test for multiple outputs case Modified files: test/unit/plugin/distributor/test_search_planner.rb Modified: test/unit/plugin/distributor/test_search_planner.rb (+37 -4) =================================================================== --- test/unit/plugin/distributor/test_search_planner.rb 2014-01-30 15:15:00 +0900 (d50000d) +++ test/unit/plugin/distributor/test_search_planner.rb 2014-01-30 15:16:15 +0900 (50b5488) @@ -22,6 +22,10 @@ class DistributedSearchPlannerTest < Test::Unit::TestCase planner.messages end + def messages + @messages ||= plan(@request) + end + def broadcast_message(messages) messages.find do |message| message["type"] == "broadcast" @@ -75,6 +79,39 @@ class DistributedSearchPlannerTest < Test::Unit::TestCase } end + def test_dependencies + search_reduce_inputs = [ + "errors", + "query1", + "query2", + "query3", + ] + search_gather_inputs = [ + "errors_reduced", + "query1_reduced", + "query2_reduced", + "query3_reduced", + ] + assert_equal([ + { + "type" => "search_reduce", + "inputs" => search_reduce_inputs, + "outputs" => search_gather_inputs, + }, + { + "type" => "search_gather", + "inputs" => search_gather_inputs, + "outputs" => nil, + }, + { + "type" => "broadcast", + "inputs" => nil, + "outputs" => search_reduce_inputs, + }, + ], + dependencies(messages)) + end + def test_distribute expected_plan = [] @@ -1102,10 +1139,6 @@ class DistributedSearchPlannerTest < Test::Unit::TestCase } end - def messages - @messages ||= plan(@request) - end - def test_dependencies search_reduce_inputs = [ "errors", -------------- next part -------------- HTML����������������������������...Download