Kouhei Sutou
null+****@clear*****
Fri Dec 20 15:58:48 JST 2013
Kouhei Sutou 2013-12-20 15:58:48 +0900 (Fri, 20 Dec 2013) New Revision: 34d25b13060924f44fae1f8eb85dd79471443353 https://github.com/droonga/fluent-plugin-droonga/commit/34d25b13060924f44fae1f8eb85dd79471443353 Message: Unindent Modified files: lib/droonga/collector.rb Modified: lib/droonga/collector.rb (+13 -13) =================================================================== --- lib/droonga/collector.rb 2013-12-20 15:58:29 +0900 (b0756d4) +++ lib/droonga/collector.rb 2013-12-20 15:58:48 +0900 (0cd7fa5) @@ -79,21 +79,21 @@ module Droonga process(command, message) return if task["n_of_inputs"] < n_of_expects #the task is done - result = task["values"] - post = component["post"] - @dispatcher.post(result, post) if post - component["descendants"].each do |name, indices| - message = { - "id" => @id, - "input" => name, - "value" => result[name] - } - indices.each do |index| - @components[index]["routes"].each do |route| - @dispatcher.dispatch(message, route) - end + result = task["values"] + post = component["post"] + @dispatcher.post(result, post) if post + component["descendants"].each do |name, indices| + message = { + "id" => @id, + "input" => name, + "value" => result[name] + } + indices.each do |index| + @components[index]["routes"].each do |route| + @dispatcher.dispatch(message, route) end end + end @n_dones += 1 @dispatcher.collectors.delete(@id) if @n_dones ==****@tasks***** end -------------- next part -------------- HTML����������������������������...Download