Class SslConnection.DecryptedEndPoint

    • Field Detail

      • _incompleteWriteCallback

        private final Callback _incompleteWriteCallback
      • _failure

        private java.lang.Throwable _failure
    • Constructor Detail

      • DecryptedEndPoint

        public DecryptedEndPoint()
    • Method Detail

      • isOpen

        public boolean isOpen()
        Description copied from class: IdleTimeout
        This abstract method should be called to check if idle timeouts should still be checked.
        Specified by:
        isOpen in interface EndPoint
        Overrides:
        isOpen in class AbstractEndPoint
        Returns:
        True if the entity monitored should still be checked for idle timeouts
      • getLocalAddress

        public java.net.InetSocketAddress getLocalAddress()
        Returns:
        The local Inet address to which this EndPoint is bound, or null if this EndPoint does not represent a network connection.
      • getRemoteAddress

        public java.net.InetSocketAddress getRemoteAddress()
        Returns:
        The remote Inet address to which this EndPoint is bound, or null if this EndPoint does not represent a network connection.
      • onFillable

        protected void onFillable()
      • onFillableFail

        protected void onFillableFail​(java.lang.Throwable failure)
      • fill

        public int fill​(java.nio.ByteBuffer buffer)
                 throws java.io.IOException
        Description copied from interface: EndPoint
        Fill the passed buffer with data from this endpoint. The bytes are appended to any data already in the buffer by writing from the buffers limit up to it's capacity. The limit is updated to include the filled bytes.
        Parameters:
        buffer - The buffer to fill. The position and limit are modified during the fill. After the operation, the position is unchanged and the limit is increased to reflect the new data filled.
        Returns:
        an int value indicating the number of bytes filled or -1 if EOF is read or the input is shutdown.
        Throws:
        java.io.IOException - if the endpoint is closed.
      • handshakeSucceeded

        private void handshakeSucceeded()
                                 throws javax.net.ssl.SSLException
        Throws:
        javax.net.ssl.SSLException
      • handshakeFailed

        private java.lang.Throwable handshakeFailed​(java.lang.Throwable failure)
      • terminateInput

        private void terminateInput()
      • closeInbound

        private java.lang.Throwable closeInbound()
                                          throws javax.net.ssl.SSLException
        Throws:
        javax.net.ssl.SSLException
      • flush

        public boolean flush​(java.nio.ByteBuffer... appOuts)
                      throws java.io.IOException
        Description copied from interface: EndPoint
        Flush data from the passed header/buffer to this endpoint. As many bytes as can be consumed are taken from the header/buffer position up until the buffer limit. The header/buffers position is updated to indicate how many bytes have been consumed.
        Parameters:
        appOuts - the buffers to flush
        Returns:
        True IFF all the buffers have been consumed and the endpoint has flushed the data to its destination (ie is not buffering any data).
        Throws:
        java.io.IOException - If the endpoint is closed or output is shutdown.
      • closeOutbound

        private void closeOutbound()
      • ensureFillInterested

        private void ensureFillInterested()
      • isOutboundDone

        private boolean isOutboundDone()
      • getTransport

        public java.lang.Object getTransport()
        Returns:
        The underlying transport object (socket, channel, etc.)
      • isInboundDone

        private boolean isInboundDone()
      • notifyHandshakeSucceeded

        private void notifyHandshakeSucceeded​(javax.net.ssl.SSLEngine sslEngine)
                                       throws javax.net.ssl.SSLException
        Throws:
        javax.net.ssl.SSLException
      • notifyHandshakeFailed

        private void notifyHandshakeFailed​(javax.net.ssl.SSLEngine sslEngine,
                                           java.lang.Throwable failure)
      • isRenegotiating

        private boolean isRenegotiating()
      • allowRenegotiate

        private boolean allowRenegotiate()
      • isTLS13

        private boolean isTLS13()
      • handleException

        private java.lang.Throwable handleException​(java.lang.Throwable x,
                                                    java.lang.String context)
      • rethrow

        private void rethrow​(java.lang.Throwable x)
                      throws java.io.IOException
        Throws:
        java.io.IOException