Revive close when raised error

Signed-off-by: Yuta Iwama <[email protected]>
fluent · Apr 26, 2019 · d3cb120 · d3cb120
1 parent 41d19a3
commit d3cb120
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/fluent/plugin/out_forward.rb b/lib/fluent/plugin/out_forward.rb
@@ -845,6 +845,8 @@ def send_data(tag, chunk)
         rescue
           if @keepalive
             @socket_cache.revoke
+          else
+            sock.close rescue nil
           end
           raise
         end