Rescue close if needed

Signed-off-by: Yuta Iwama <[email protected]>
fluent · Apr 26, 2019 · 41d19a3 · 41d19a3
1 parent 44cb301
commit 41d19a3
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/lib/fluent/plugin/out_forward.rb b/lib/fluent/plugin/out_forward.rb
@@ -589,12 +589,12 @@ def revoke(key = Thread.current.object_id)
         def clear
           @mutex.synchronize do
             @inactive_socks.values.each do |s|
-              s.sock.close
+              s.sock.close rescue nil
             end
             @inactive_socks.clear
 
             @active_socks.values.each do |s|
-              s.sock.close
+              s.sock.close rescue nil
             end
             @active_socks.clear
           end
@@ -606,7 +606,7 @@ def purge_obsolete_socks
               # 0 means sockets stored in this class received all acks
               if @inactive_socks[k].ref <= 0
                 s = @inactive_socks.delete(k)
-                s.sock.close
+                s.sock.close  rescue nil
                 @log.debug("purged obsolete socket #{s.sock}")
               end
             end