diff --git a/lib/fluent/plugin/out_forward.rb b/lib/fluent/plugin/out_forward.rb index 058f8a02da..80383fe408 100644 --- 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