port number

Author: Watson1978

test/fluent/plugin/test_in_otlp.rb

@@ -7,18 +7,20 @@
 
 class Fluent::Plugin::OtlpInputTest < Test::Unit::TestCase
   def config
-    <<~CONFIG
+    <<~"CONFIG"
       tag otlp.test
       <http>
         bind 127.0.0.1
-        port 14318
+        port #{@port}
       </http>
     CONFIG
   end
 
   def setup
     Fluent::Test.setup
 
+    @port = unused_tcp_port
+
     # Enable mock_process_clock for freezing Fluent::EventTime
     Timecop.mock_process_clock = true
     Timecop.freeze(Time.parse("2025-01-01 00:00:00 UTC"))
@@ -38,7 +40,7 @@ def test_configure
     d = create_driver
     assert_equal "otlp.test", d.instance.tag
     assert_equal "127.0.0.1", d.instance.http_config.bind
-    assert_equal 14318, d.instance.http_config.port
+    assert_equal @port, d.instance.http_config.port
   end
 
   data("metrics" => {
@@ -163,7 +165,7 @@ def config
         tag otlp.test
         <http>
           bind 127.0.0.1
-          port 14318
+          port #{@port}
         </http>
         <transport tls>
           ca_path "#{File.expand_path(File.dirname(__FILE__) + '/../resources/certs/ca.crt')}"
@@ -205,7 +207,7 @@ def compress(data)
 
   def post_https_json(path, json, headers: {})
     headers = headers.merge({ "Content-Type" => "application/json" })
-    post(path, json, endpoint: "https://127.0.0.1:14318", headers: headers, options: https_option)
+    post(path, json, endpoint: "https://127.0.0.1:#{@port}", headers: headers, options: https_option)
   end
 
   def post_json(path, json, headers: {}, options: {})
@@ -215,15 +217,15 @@ def post_json(path, json, headers: {}, options: {})
 
   def post_https_protobuf(path, binary, headers: {}, options: {})
     headers = headers.merge({ "Content-Type" => "application/x-protobuf" })
-    post(path, binary, endpoint: "https://127.0.0.1:14318", headers: headers, options: options)
+    post(path, binary, endpoint: "https://127.0.0.1:#{@port}", headers: headers, options: options)
   end
 
   def post_protobuf(path, binary, headers: {}, options: {})
     headers = headers.merge({ "Content-Type" => "application/x-protobuf" })
     post(path, binary, headers: headers, options: options)
   end
 
-  def post(path, body, endpoint: "http://127.0.0.1:14318", headers: {}, options: {})
+  def post(path, body, endpoint: "http://127.0.0.1:#{@port}", headers: {}, options: {})
     connection = Excon.new("#{endpoint}#{path}", body: body, headers: headers, **options)
     connection.post
   end

test/fluent/plugin/test_out_otlp.rb

@@ -14,15 +14,15 @@ class Fluent::Plugin::OtlpOutputTest < Test::Unit::TestCase
   DEFAULT_LOGGER = ::WEBrick::Log.new($stdout, ::WEBrick::BasicLog::FATAL)
 
   def config
-    <<~CONFIG
+    <<~"CONFIG"
       <http>
-        endpoint "http://127.0.0.1:24318"
+        endpoint "http://127.0.0.1:#{@port}"
       </http>
     CONFIG
   end
 
   def server_config
-    config = { BindAddress: "127.0.0.1", Port: "24318" }
+    config = { BindAddress: "127.0.0.1", Port: @port }
     # Suppress webrick logs
     config[:Logger] = DEFAULT_LOGGER
     config[:AccessLog] = []
@@ -63,6 +63,8 @@ def run_http_server
   def setup
     Fluent::Test.setup
 
+    @port = unused_tcp_port
+
     @@server_request = nil
     @@server_response_code = 200
     @@http_server_thread = Thread.new do
@@ -71,8 +73,6 @@ def setup
   end
 
   def teardown
-    p "!" * 80
-    p @@http_server_thread
     @@http_server_thread.kill
     @@http_server_thread = nil
   end
@@ -83,7 +83,7 @@ def create_driver(conf = config)
 
   def test_configure
     d = create_driver
-    assert_equal "http://127.0.0.1:24318", d.instance.http_config.endpoint
+    assert_equal "http://127.0.0.1:#{@port}", d.instance.http_config.endpoint
   end
 
   def test_send_logs
@@ -133,7 +133,7 @@ def test_send_compressed_message
 
     d = create_driver(%[
       <http>
-        endpoint "http://127.0.0.1:24318"
+        endpoint "http://127.0.0.1:#{@port}"
         compress gzip
       </http>
     ])
@@ -157,7 +157,7 @@ def test_unrecoverable_error
       d.feed(event)
     end
 
-    assert_match(%r{got unrecoverable error response from 'http://127.0.0.1:24318/v1/logs', response code is 500},
+    assert_match(%r{got unrecoverable error response from 'http://127.0.0.1:#{@port}/v1/logs', response code is 500},
                  d.instance.log.out.logs.join)
 
     d.instance_shutdown
@@ -169,15 +169,15 @@ def test_error_with_disabled_unrecoverable
 
     d = create_driver(%[
       <http>
-        endpoint "http://127.0.0.1:24318"
+        endpoint "http://127.0.0.1:#{@port}"
         error_response_as_unrecoverable false
       </http>
     ])
     d.run(default_tag: "otlp.test", shutdown: false) do
       d.feed(event)
     end
 
-    assert_match(%r{got error response from 'http://127.0.0.1:24318/v1/logs', response code is 500},
+    assert_match(%r{got error response from 'http://127.0.0.1:#{@port}/v1/logs', response code is 500},
                  d.instance.log.out.logs.join)
 
     d.instance_shutdown
@@ -192,7 +192,7 @@ def test_write_with_retryable_response
 
     d = create_driver(%[
       <http>
-        endpoint "http://127.0.0.1:24318"
+        endpoint "http://127.0.0.1:#{@port}"
         retryable_response_codes [503]
       </http>
     ])
@@ -211,7 +211,7 @@ def test_write_with_retryable_response
   sub_test_case "HTTPS" do
     def server_config
       config = super
-      config[:Port] = "24318"
+      config[:Port] = "#{@port}"
       # WEBrick supports self-generated self-signed certificate
       config[:SSLEnable] = true
       config[:SSLCertName] = [["CN", WEBrick::Utils.getservername]]
@@ -221,7 +221,7 @@ def server_config
     def config
       <<~"CONFIG"
         <http>
-          endpoint "https://127.0.0.1:24318"
+          endpoint "https://127.0.0.1:#{@port}"
         </http>
         <transport tls>
           cert_path "#{File.expand_path(File.dirname(__FILE__) + '/../resources/certs/ca.crt')}"

test/helper.rb

@@ -33,3 +33,19 @@ module ProtocolBuffers
     INVALID = "invalid"
   end
 end
+
+def unused_tcp_port(num = 1)
+  ports = []
+  sockets = []
+  num.times do
+    s = TCPServer.open(0)
+    sockets << s
+    ports << s.addr[1]
+  end
+  sockets.each(&:close)
+  if num == 1
+    return ports.first
+  else
+    return *ports
+  end
+end