Kouhei Sutou
null+****@clear*****
Fri Dec 20 15:33:51 JST 2013
Kouhei Sutou 2013-12-20 15:33:51 +0900 (Fri, 20 Dec 2013) New Revision: 0a41df980194df40cd19ae75d8aee37faa5585ec https://github.com/droonga/fluent-plugin-droonga/commit/0a41df980194df40cd19ae75d8aee37faa5585ec Message: Simplify Modified files: lib/droonga/collector.rb Modified: lib/droonga/collector.rb (+5 -8) =================================================================== --- lib/droonga/collector.rb 2013-12-20 15:32:44 +0900 (962c1c1) +++ lib/droonga/collector.rb 2013-12-20 15:33:51 +0900 (99160ea) @@ -40,12 +40,6 @@ module Droonga command = component["command"] n_of_expects = component["n_of_expects"] synchronous = nil - # TODO: check if asynchronous execution is available. - message = { - "task"=>task, - "name"=>nil, - "value"=>nil, - } descendants = {} component["descendants"].each do |name, indices| descendants[name] = indices.collect do |index| @@ -54,8 +48,11 @@ module Droonga end end end - message["descendants"] = descendants - message["id"] = @id + message = { + "id" => @id, + "task" => task, + "descendants" => descendants + } @dispatcher.deliver(@id, task["route"], message, command, synchronous) @n_dones += 1 @dispatcher.collectors.delete(@id) if @n_dones ==****@tasks***** -------------- next part -------------- HTML����������������������������...Download