Fix dec_ref bug in out_forwarder plugin.

Fixes #2433 Signed-off-by: Theron Luhn <theron@luhn.com>
fluent · May 31, 2019 · 0bc9d16 · 0bc9d16
1 parent 71f223f
commit 0bc9d16
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