Modifier and Type | Method and Description |
---|---|
SocketIF |
ChangeRequest.getChannel()
Get the SocketIF associated with this ChangeRequest
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractSelector.closeSocket(SocketIF socket)
Closes the given
SocketIF . |
protected void |
TCPClient.closeSocket(SocketIF socket)
This method overrides the default
AbstractSelector.closeSocket(SocketIF) method, to also stop this
client from running, as this client implementation only has one
associated SocketIF . |
void |
AbstractSelector.handshakeComplete(SocketIF socket)
A handshake is completed on this socket, as such the socket is ready to
be used (reading and writing).
|
protected void |
AbstractSelector.invalidateSession(SocketIF socket)
Invalidate the
SSLSession associated with the
provided SocketIF . |
protected void |
AbstractSelector.send(SocketIF socket,
java.nio.ByteBuffer data)
Send an
ByteBuffer over the specified SocketIF . |
void |
TCPServer.send(SocketIF sc,
PacketIF packet)
|
void |
AbstractSelector.taskComplete(SocketIF socket)
A SSLEngine Task for a particular socket was completed by the TaskWorker.
|
void |
AbstractSelector.timeoutExpired(SocketIF socket)
The timeout on this socket has expired.
|
Constructor and Description |
---|
ChangeRequest(SocketIF sc,
int type,
int interestOps)
A ChangeRequest defines a request for some operation that needs to be
executed on the selector thread.
|
Modifier and Type | Method and Description |
---|---|
void |
PacketListener.paketArrived(SocketIF socket,
PacketIF packet)
This method is called from the
AbstractPacketWorker thread
once it has reassembled a complete PacketIF on a
SocketIF . |
Modifier and Type | Field and Description |
---|---|
protected java.util.HashMap<SocketIF,java.nio.ByteBuffer> |
AbstractPacketWorker.pendingData
Maps a SocketChannel to a list of ByteBuffer instances
|
protected java.util.ArrayDeque<SocketIF> |
AbstractPacketWorker.pendingSockets
Sockets that need to be operated upon (i.e.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractPacketWorker.addData(SocketIF socket,
java.nio.ByteBuffer data,
int count)
Queue data received from a
SocketIF for processing and
reconstruction. |
protected abstract void |
VariableLengthPacketWorker.assemblePacket(SocketIF socket,
short head,
byte[] data)
This method is called from the packet worker when a complete packet has
been received.
|
protected void |
AbstractPacketWorker.fireListeners(SocketIF socket,
PacketIF packet)
Once a
PacketIF has been completely reconstructed, registered
listeners are notified via this method. |
Modifier and Type | Class and Description |
---|---|
class |
PlainSocket
A plain socket implementation of
SocketIF . |
Modifier and Type | Method and Description |
---|---|
SocketIF |
SocketContainer.getSocket(java.nio.channels.SelectableChannel key)
Get the
SocketIF that is paired to the given
SelectableChannel key. |
SocketIF |
SocketContainer.removeSocket(java.nio.channels.SelectableChannel key)
Remove the
SocketIF that is paired to the given
SelectableChannel key. |
Modifier and Type | Method and Description |
---|---|
void |
SocketContainer.addSocket(java.nio.channels.SelectableChannel key,
SocketIF socket)
Associates the specified
SocketIF with the specified
SelectableChannel in this map. |
Modifier and Type | Class and Description |
---|---|
class |
SecureSocket
A secure socket implementation of
SocketIF . |
Modifier and Type | Method and Description |
---|---|
void |
HandshakeListener.handshakeComplete(SocketIF socket)
This method is called from the
SecureSocket once the
SSLEngine.getHandshakeStatus() is FINISHED. |
void |
TaskListener.taskComplete(SocketIF socket)
This method is called from the
TaskWorker thread once it has
finished processing all SSLEngine tasks associated
with a SecureSocket instance. |
Modifier and Type | Method and Description |
---|---|
void |
TimeoutListener.timeoutExpired(SocketIF socket)
This method is called from the
Timeout.expired()
method, notifying any Timeout Listeners that the Timeout has expired and
they should act upon it. |
Constructor and Description |
---|
TimeoutRunnable(TimeoutListener listener,
SocketIF socket,
long timeout)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
SocketIF |
Timeout.getSocket()
Get the
SocketIF this timeout is associated with |
Constructor and Description |
---|
Timeout(SocketIF socket,
TimeoutListener listener,
long timeout)
Create a new timeout for the
SocketIF given. |
Modifier and Type | Method and Description |
---|---|
void |
ClientListener.paketArrived(SocketIF socket,
PacketIF packet) |
void |
ServerTest.paketArrived(SocketIF channel,
PacketIF packet) |
Modifier and Type | Method and Description |
---|---|
protected void |
TestPacketWorker.assemblePacket(SocketIF socket,
short head,
byte[] data) |
void |
MultiSocketClient.invalidateSession(SocketIF socket)
Invalidate the SSL/TLS session (if any) on the underlying
SocketIF . |
void |
ClientListener.paketArrived(SocketIF socket,
PacketIF packet) |
void |
MultiSocketClientListener.paketArrived(SocketIF socket,
PacketIF packet) |
void |
ServerTest.paketArrived(SocketIF channel,
PacketIF packet) |