test_supervisor: add test case when loaded all files with @include

Signed-off-by: Shizuo Fujita <fujita@clear-code.com>

Author: Watson1978

test/test_supervisor.rb

@@ -1267,6 +1267,68 @@ def test_stop_parallel_old_supervisor_after_delay
       $log.out.reset if $log&.out&.respond_to?(:reset)
     end
 
+    test "do not load additional configuration when loaded all files with @include" do
+      write_config("#{@config_include_dir}/forward.conf", <<~EOF)
+        <match test>
+          @type forward
+          <server>
+            host 127.0.0.1
+            port 24224
+          </server>
+        </match>
+      EOF
+      write_config("#{@config_include_dir}/obsolete_plugins.conf", <<~EOF)
+        <source>
+          @type obsolete_plugins
+        </source>
+      EOF
+
+      write_config("#{@tmp_dir}/fluent.conf", <<~EOF)
+        <system>
+          config_include_dir #{@config_include_dir}
+        </system>
+
+        <match sample.*>
+          @type file
+        </match>
+
+        @include #{@config_include_dir}/*.conf
+      EOF
+
+      supervisor = Fluent::Supervisor.new({ config_path: "#{@tmp_dir}/fluent.conf" })
+      stub(supervisor).setup_global_logger { create_debug_dummy_logger }
+
+      supervisor.configure(supervisor: true)
+      elements = supervisor.instance_variable_get(:@conf).elements
+      assert_equal(4, elements.size)
+
+      assert_equal('system', elements[0].name)
+      assert_equal(@config_include_dir, elements[0]['config_include_dir'])
+
+      assert_equal('match', elements[1].name)
+      assert_equal('file', elements[1]['@type'])
+
+      assert_equal('match', elements[2].name)
+      assert_equal('forward', elements[2]['@type'])
+
+      assert_equal('source', elements[3].name)
+      assert_equal('obsolete_plugins', elements[3]['@type'])
+
+      # no additional load, all files were skipped
+      skipped_files = %W[
+        #{@config_include_dir}/forward.conf
+        #{@config_include_dir}/obsolete_plugins.conf
+      ]
+
+      logs_line = $log.out.logs.join
+      skipped_files.each do |path|
+        assert { logs_line.include?("skip auto loading, it was already loaded path=\"#{path}\"") }
+      end
+      assert_not_match(/loading additional configuration file/, logs_line)
+    ensure
+      $log.out.reset if $log&.out&.respond_to?(:reset)
+    end
+
     test "can load partial config loaded config_include_dir feature by even if already loaded" do
       write_config("#{@config_include_dir}/system.conf", <<~EOF)
         <system>