public class SecureNio2Channel extends Nio2Channel
Modifier and Type | Field and Description |
---|---|
protected boolean |
closed |
protected boolean |
closing |
protected Nio2Endpoint |
endpoint |
protected java.nio.ByteBuffer |
netInBuffer |
protected java.nio.ByteBuffer |
netOutBuffer |
protected boolean |
sniComplete |
protected javax.net.ssl.SSLEngine |
sslEngine |
bufHandler, emptyBuf, sc, socket
Constructor and Description |
---|
SecureNio2Channel(SocketBufferHandler bufHandler,
Nio2Endpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Sends a SSL close message, will not physically close the connection here.
|
void |
close(boolean force)
Close the connection.
|
java.util.concurrent.Future<java.lang.Boolean> |
flush()
Flush the channel.
|
void |
free()
Free the channel memory
|
java.nio.ByteBuffer |
getEmptyBuf() |
javax.net.ssl.SSLEngine |
getSslEngine() |
int |
handshake()
Performs SSL handshake, non blocking, but performs NEED_TASK on the same
thread.
|
protected int |
handshakeInternal(boolean async) |
protected javax.net.ssl.SSLEngineResult |
handshakeUnwrap()
Perform handshake unwrap
|
protected javax.net.ssl.SSLEngineResult |
handshakeWrap()
Performs the WRAP function
|
boolean |
isClosing() |
boolean |
isHandshakeComplete() |
java.util.concurrent.Future<java.lang.Integer> |
read(java.nio.ByteBuffer dst)
Reads a sequence of bytes from this channel into the given buffer.
|
<A> void |
read(java.nio.ByteBuffer[] dsts,
int offset,
int length,
long timeout,
java.util.concurrent.TimeUnit unit,
A attachment,
java.nio.channels.CompletionHandler<java.lang.Long,? super A> handler) |
<A> void |
read(java.nio.ByteBuffer dst,
long timeout,
java.util.concurrent.TimeUnit unit,
A attachment,
java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler) |
void |
rehandshake()
Force a blocking handshake to take place for this key.
|
void |
reset(java.nio.channels.AsynchronousSocketChannel channel,
SocketWrapperBase<Nio2Channel> socket)
Reset the channel.
|
protected javax.net.ssl.SSLEngineResult.HandshakeStatus |
tasks()
Executes all the tasks needed on the same thread.
|
java.util.concurrent.Future<java.lang.Integer> |
write(java.nio.ByteBuffer src)
Writes a sequence of bytes to this channel from the given buffer.
|
<A> void |
write(java.nio.ByteBuffer[] srcs,
int offset,
int length,
long timeout,
java.util.concurrent.TimeUnit unit,
A attachment,
java.nio.channels.CompletionHandler<java.lang.Long,? super A> handler) |
<A> void |
write(java.nio.ByteBuffer src,
long timeout,
java.util.concurrent.TimeUnit unit,
A attachment,
java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler) |
getAppReadBufHandler, getBufHandler, getIOChannel, getSocket, isOpen, read, setAppReadBufHandler, toString, write
protected java.nio.ByteBuffer netInBuffer
protected java.nio.ByteBuffer netOutBuffer
protected javax.net.ssl.SSLEngine sslEngine
protected final Nio2Endpoint endpoint
protected boolean sniComplete
protected boolean closed
protected boolean closing
public SecureNio2Channel(SocketBufferHandler bufHandler, Nio2Endpoint endpoint)
public void reset(java.nio.channels.AsynchronousSocketChannel channel, SocketWrapperBase<Nio2Channel> socket) throws java.io.IOException
Nio2Channel
reset
in class Nio2Channel
channel
- The new async channel to associate with this NIO2 channelsocket
- The new socket to associate with this NIO2 channeljava.io.IOException
- If a problem was encountered resetting the channelpublic void free()
Nio2Channel
free
in class Nio2Channel
public java.util.concurrent.Future<java.lang.Boolean> flush()
flush
in class Nio2Channel
true
if the network buffer has been flushed out and
is empty else false
(as a future)public int handshake() throws java.io.IOException
The return for this operation is 0 if the handshake is complete and a positive value if it is not complete. In the event of a positive value coming back, the appropriate read/write will already have been called with an appropriate CompletionHandler.
handshake
in class Nio2Channel
java.io.IOException
- if an error occurs during the handshakeprotected int handshakeInternal(boolean async) throws java.io.IOException
java.io.IOException
public void rehandshake() throws java.io.IOException
java.io.IOException
- - if an IO exception occurs or if application or network buffers contain datajava.net.SocketTimeoutException
- - if a socket operation timed outprotected javax.net.ssl.SSLEngineResult.HandshakeStatus tasks()
protected javax.net.ssl.SSLEngineResult handshakeWrap() throws java.io.IOException
java.io.IOException
- An IO error occurredprotected javax.net.ssl.SSLEngineResult handshakeUnwrap() throws java.io.IOException
java.io.IOException
- An IO error occurredpublic void close() throws java.io.IOException
close();
while (isOpen() && !myTimeoutFunction()) Thread.sleep(25);
if ( isOpen() ) close(true); //forces a close if you timed out
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in interface java.nio.channels.AsynchronousChannel
close
in interface java.nio.channels.Channel
close
in class Nio2Channel
java.io.IOException
- if an I/O error occursjava.io.IOException
- if there is data on the outgoing network buffer and we are unable to flush itpublic void close(boolean force) throws java.io.IOException
Nio2Channel
close
in class Nio2Channel
force
- Should the underlying socket be forcibly closed?java.io.IOException
- If closing the secure channel fails.public java.util.concurrent.Future<java.lang.Integer> read(java.nio.ByteBuffer dst)
read
in interface java.nio.channels.AsynchronousByteChannel
read
in class Nio2Channel
dst
- The buffer into which bytes are to be transferredjava.lang.IllegalStateException
- if the handshake was not completedpublic java.util.concurrent.Future<java.lang.Integer> write(java.nio.ByteBuffer src)
write
in interface java.nio.channels.AsynchronousByteChannel
write
in class Nio2Channel
src
- The buffer from which bytes are to be retrievedpublic <A> void read(java.nio.ByteBuffer dst, long timeout, java.util.concurrent.TimeUnit unit, A attachment, java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler)
read
in class Nio2Channel
public <A> void read(java.nio.ByteBuffer[] dsts, int offset, int length, long timeout, java.util.concurrent.TimeUnit unit, A attachment, java.nio.channels.CompletionHandler<java.lang.Long,? super A> handler)
read
in class Nio2Channel
public <A> void write(java.nio.ByteBuffer src, long timeout, java.util.concurrent.TimeUnit unit, A attachment, java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler)
write
in class Nio2Channel
public <A> void write(java.nio.ByteBuffer[] srcs, int offset, int length, long timeout, java.util.concurrent.TimeUnit unit, A attachment, java.nio.channels.CompletionHandler<java.lang.Long,? super A> handler)
write
in class Nio2Channel
public boolean isHandshakeComplete()
isHandshakeComplete
in class Nio2Channel
public boolean isClosing()
isClosing
in class Nio2Channel
public javax.net.ssl.SSLEngine getSslEngine()
public java.nio.ByteBuffer getEmptyBuf()
Copyright © 2000-1970 Apache Software Foundation. All Rights Reserved.