lib/logstash/inputs/tcp.rb in logstash-input-tcp-2.0.4 vs lib/logstash/inputs/tcp.rb in logstash-input-tcp-2.0.5
- old
+ new
@@ -155,9 +155,13 @@
end
rescue EOFError
@logger.debug? && @logger.debug("Connection closed", :client => socket.peer)
rescue Errno::ECONNRESET
@logger.debug? && @logger.debug("Connection reset by peer", :client => socket.peer)
+ rescue OpenSSL::SSL::SSLError => e
+ # Fixes issue #23
+ @logger.error("SSL Error", :exception => e, :backtrace => e.backtrace)
+ socket.close rescue nil
rescue => e
# if plugin is stopping, don't bother logging it as an error
!stop? && @logger.error("An error occurred. Closing connection", :client => socket.peer, :exception => e, :backtrace => e.backtrace)
ensure
# catch all rescue nil on close to discard any close errors or invalid socket