lib/fluent/plugin/output_node.rb in fluent-plugin-secure-forward-0.3.3 vs lib/fluent/plugin/output_node.rb in fluent-plugin-secure-forward-0.3.4
- old
+ new
@@ -332,12 +332,16 @@
rescue OpenSSL::SSL::SSLError
# to wait i/o restart
sleep socket_interval
rescue SystemCallError => e
log.warn "disconnected by Error", error_class: e.class, error: e, host: @host, port: @port
+ self.release!
+ self.detach!
break
rescue EOFError
log.warn "disconnected", host: @host, port: @port
+ self.release!
+ self.detach!
break
end
end
while @writing
break if @detach