Package org.elasticsearch.xpack.security.transport.nio

Class SSLChannelContext

java.lang.Object
org.elasticsearch.nio.ChannelContext<SocketChannel>
org.elasticsearch.nio.SocketChannelContext
org.elasticsearch.xpack.security.transport.nio.SSLChannelContext
public final class SSLChannelContext extends org.elasticsearch.nio.SocketChannelContext
Provides a TLS/SSL read/write layer over a channel. This context will use a SSLDriver to handshake with the peer channel. Once the handshake is complete, any data from the peer channel will be decrypted before being passed to the NioChannelHandler. Outbound data will be encrypted before being flushed to the channel.

  • Field Summary

    Fields inherited from class org.elasticsearch.nio.SocketChannelContext

    channel, channelBuffer, isClosing

    Fields inherited from class org.elasticsearch.nio.ChannelContext

    rawChannel

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    channelActive()
     
    void
    closeChannel()
     
    void
    closeFromSelector()
     
    void
    flushChannel()
     
    SSLEngine
    getSSLEngine()
     
    void
    queueWriteOperation(org.elasticsearch.nio.WriteOperation writeOperation)
     
    int
    read()
     
    boolean
    readyForFlush()
     
    boolean
    selectorShouldClose()
     

    Methods inherited from class org.elasticsearch.nio.SocketChannelContext

    addConnectListener, closeNow, connect, currentFlushOperationComplete, currentFlushOperationFailed, flushToChannel, getChannel, getPendingFlush, getSelector, handleReadBytes, isConnectComplete, readFromChannel, register, sendMessage, setCloseNow

    Methods inherited from class org.elasticsearch.nio.ChannelContext

    addCloseListener, getSelectionKey, handleException, isOpen, setSelectionKey

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • channelActive

      protected void channelActive() throws IOException
      Overrides:
      channelActive in class org.elasticsearch.nio.SocketChannelContext
      Throws:
      IOException

    • queueWriteOperation

      public void queueWriteOperation(org.elasticsearch.nio.WriteOperation writeOperation)
      Overrides:
      queueWriteOperation in class org.elasticsearch.nio.SocketChannelContext

    • flushChannel

      public void flushChannel() throws IOException
      Specified by:
      flushChannel in class org.elasticsearch.nio.SocketChannelContext
      Throws:
      IOException

    • readyForFlush

      public boolean readyForFlush()
      Overrides:
      readyForFlush in class org.elasticsearch.nio.SocketChannelContext

    • read

      public int read() throws IOException
      Specified by:
      read in class org.elasticsearch.nio.SocketChannelContext
      Throws:
      IOException

    • selectorShouldClose

      public boolean selectorShouldClose()
      Specified by:
      selectorShouldClose in class org.elasticsearch.nio.SocketChannelContext

    • closeChannel

      public void closeChannel()
      Specified by:
      closeChannel in class org.elasticsearch.nio.ChannelContext<SocketChannel>

    • closeFromSelector

      public void closeFromSelector() throws IOException
      Overrides:
      closeFromSelector in class org.elasticsearch.nio.SocketChannelContext
      Throws:
      IOException

    • getSSLEngine

      public SSLEngine getSSLEngine()