Kouhei Sutou
null+****@clear*****
Wed Oct 15 18:20:33 JST 2014
Kouhei Sutou 2014-10-15 18:20:33 +0900 (Wed, 15 Oct 2014) New Revision: e80400788e75b3d12adc621e20a92297af235e30 https://github.com/groonga/fluent-plugin-groonga/commit/e80400788e75b3d12adc621e20a92297af235e30 Message: in: use 10043 as the default port for gqtp Modified files: lib/fluent/plugin/in_groonga.rb Modified: lib/fluent/plugin/in_groonga.rb (+17 -2) =================================================================== --- lib/fluent/plugin/in_groonga.rb 2014-10-10 13:59:09 +0900 (8ff2be4) +++ lib/fluent/plugin/in_groonga.rb 2014-10-15 18:20:33 +0900 (361ab6d) @@ -77,9 +77,9 @@ module Fluent include DetachMultiProcessMixin config_param :bind, :string, :default => "0.0.0.0" - config_param :port, :integer, :default => 10041 + config_param :port, :integer, :default => nil config_param :real_host, :string - config_param :real_port, :integer, :default => 10041 + config_param :real_port, :integer, :default => nil DEFAULT_EMIT_COMMANDS = [ /\Atable_/, /\Acolumn_/, @@ -103,6 +103,13 @@ module Fluent end end + def configure(conf) + super + + @port ||= default_port + @real_port ||= default_port + end + def start listen_socket = TCPServer.new(@bind, @port) detach_multi_process do @@ -157,6 +164,10 @@ module Fluent class HTTPInput < BaseInput private + def default_port + 10041 + end + def handler_class Handler end @@ -206,6 +217,10 @@ module Fluent class GQTPInput < BaseInput private + def default_port + 10043 + end + def handler_class Handler end -------------- next part -------------- HTML����������������������������...Download
