Merge pull request #2434 from luhn/dec_ref-bug

Fix dec_ref bug in out_forwarder plugin
fluent · Jun 3, 2019 · 068a004 · 068a004
2 parents 60e3a4c + 0bc9d16
commit 068a004
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/fluent/plugin/out_forward.rb b/lib/fluent/plugin/out_forward.rb
@@ -1084,10 +1084,10 @@ def connect(host = nil)
           begin
             yield(sock)
           rescue
-            @socket_cache.revoke(sock) if @keepalive
+            @socket_cache.revoke if @keepalive
             raise
           else
-            @socket_cache.dec_ref(sock) if @keepalive
+            @socket_cache.dec_ref if @keepalive
           ensure
             sock.close unless @keepalive
           end