in_tail: Fix the error when 'tag *' is configured. fix #1512

fluent · Aug 16, 2017 · 3a1a1e8 · 3a1a1e8
1 parent c7e94e8
commit 3a1a1e8
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 0 deletions.
diff --git a/lib/fluent/plugin/in_tail.rb b/lib/fluent/plugin/in_tail.rb
@@ -130,6 +130,7 @@ def configure(conf)
     def configure_tag
       if @tag.index('*')
         @tag_prefix, @tag_suffix = @tag.split('*')
+        @tag_prefix ||= ''
         @tag_suffix ||= ''
       else
         @tag_prefix = nil

diff --git a/test/plugin/test_in_tail.rb b/test/plugin/test_in_tail.rb
@@ -972,6 +972,20 @@ def test_tag
       plugin.receive_lines(['foo', 'bar'], DummyWatcher.new('foo.bar.log'))
     end
 
+    def test_tag_with_only_star
+      config = config_element("", "", {
+                                "tag" => "*",
+                                "path" => "test/plugin/*/%Y/%m/%Y%m%d-%H%M%S.log,test/plugin/data/log/**/*.log",
+                                "format" => "none",
+                                "read_from_head" => true
+                              })
+      d = create_driver(config, false)
+      d.run {}
+      plugin = d.instance
+      mock(plugin.router).emit_stream('foo.bar.log', anything).once
+      plugin.receive_lines(['foo', 'bar'], DummyWatcher.new('foo.bar.log'))
+    end
+
     def test_tag_prefix
       config = config_element("", "", {
                                 "tag" => "pre.*",