Field Detail

• emptyBuf

  protected static ByteBuffer emptyBuf

• sc

  protected AsynchronousSocketChannel sc

• socket

  protected SocketWrapper<Nio2Channel> socket

• bufHandler

  protected SecureNio2Channel.ApplicationBufferHandler bufHandler

Constructor Detail

• Nio2Channel

  public Nio2Channel(SecureNio2Channel.ApplicationBufferHandler bufHandler)

Method Detail

• reset

  public void reset(AsynchronousSocketChannel channel,
           SocketWrapper<Nio2Channel> socket)
             throws IOException

  Reset the channel

  Throws:

  IOException - If a problem was encountered resetting the channel

• getSocket

  public SocketWrapper<Nio2Channel> getSocket()

• getBufferSize

  public int getBufferSize()

• close

  public void close()
             throws IOException

  Closes this channel.

  Specified by:

  close in interface Closeable

  Specified by:

  close in interface AutoCloseable

  Specified by:

  close in interface AsynchronousChannel

  Specified by:

  close in interface Channel

  Throws:

  IOException - If an I/O error occurs

• close

  public void close(boolean force)
             throws IOException

  Throws:

  IOException

• isOpen

  public boolean isOpen()

  Tells whether or not this channel is open.

  Specified by:

  isOpen in interface Channel

  Returns:

  true if, and only if, this channel is open

• getBufHandler

  public SecureNio2Channel.ApplicationBufferHandler getBufHandler()

• getIOChannel

  public AsynchronousSocketChannel getIOChannel()

• isClosing

  public boolean isClosing()

• isHandshakeComplete

  public boolean isHandshakeComplete()

• handshake

  public int handshake()
                throws IOException

  Performs SSL handshake hence is a no-op for the non-secure implementation.

  Returns:

  Always returns zero

  Throws:

  IOException

• toString

  public String toString()

  Overrides:

  toString in class Object

• read

  public Future<Integer> read(ByteBuffer dst)

  Specified by:

  read in interface AsynchronousByteChannel

• read

  public <A> void read(ByteBuffer dst,
              A attachment,
              CompletionHandler<Integer,? super A> handler)

  Specified by:

  read in interface AsynchronousByteChannel

• read

  public <A> void read(ByteBuffer dst,
              long timeout,
              TimeUnit unit,
              A attachment,
              CompletionHandler<Integer,? super A> handler)

• write

  public Future<Integer> write(ByteBuffer src)

  Specified by:

  write in interface AsynchronousByteChannel

• write

  public <A> void write(ByteBuffer src,
               A attachment,
               CompletionHandler<Integer,? super A> handler)

  Specified by:

  write in interface AsynchronousByteChannel

• write

  public <A> void write(ByteBuffer src,
               long timeout,
               TimeUnit unit,
               A attachment,
               CompletionHandler<Integer,? super A> handler)

• write

  public <A> void write(ByteBuffer[] srcs,
               int offset,
               int length,
               long timeout,
               TimeUnit unit,
               A attachment,
               CompletionHandler<Long,? super A> handler)

• flush

  public Future<Boolean> flush()