ch.dermitza.securenio.test.variablebyte

Class MultiSocketClient

java.lang.Object

ch.dermitza.securenio.AbstractSelector

ch.dermitza.securenio.test.variablebyte.MultiSocketClient

All Implemented Interfaces:

HandshakeListener, TaskListener, TimeoutListener, java.lang.Runnable

public class MultiSocketClient
extends AbstractSelector

A client implementation with multiple sockets, used for testing.

Since:

0.19

Field Summary

Fields inherited from class ch.dermitza.securenio.AbstractSelector

address, cipherSuits, container, context, isClient, logger, needClientAuth, pendingData, port, protocols, selector, singleThreaded, taskWorker, toWorker, usingSSL

Constructor Summary

Constructors

Constructor and Description
MultiSocketClient(java.net.InetAddress address, int port, AbstractPacketWorker packetWorker, boolean usingSSL, boolean needClientAuth, int socketNo) Create a TCPClient instance

Method Summary

Methods

Modifier and Type	Method and Description
protected void	accept(java.nio.channels.SelectionKey key) As this is the client implementation, it is NOT allowed to call this method which is only useful for server implementations.
protected void	connect(java.nio.channels.SelectionKey key) Finish the connection to the server.
boolean	handshakesFinished()
protected void	initConnection() Initialize a client connection.
void	invalidateSession(SocketIF socket) Invalidate the SSL/TLS session (if any) on the underlying SocketIF.
boolean	isConnected() Returns whether or not this client is connected, if and only if it is running (returns false otherwise).
void	send(PacketIF packet) Send an PacketIF over the this client's SocketIF.

Methods inherited from class ch.dermitza.securenio.AbstractSelector

addListener, closeSocket, handshakeComplete, isRunning, read, removeListener, run, send, setRunning, setupEngine, setupSSL, taskComplete, timeoutExpired, write

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiSocketClient

public MultiSocketClient(java.net.InetAddress address,
                 int port,
                 AbstractPacketWorker packetWorker,
                 boolean usingSSL,
                 boolean needClientAuth,
                 int socketNo)

Create a TCPClient instance

Parameters:

address - The address to connect to

port - The port to connect to

packetWorker - The instance of packet worker to use

usingSSL - Whether we are using SSL/TLS

needClientAuth - Whether this client should also authenticate with the server.

socketNo - the number of sockets this client will have

Method Detail

send

public void send(PacketIF packet)

Send an PacketIF over the this client's SocketIF. Since the client only has one socket, no socket parameter is necessary.

Parameters:

packet - The PacketIF to send through the associated SocketIF.

See Also:

AbstractSelector.send(ch.dermitza.securenio.socket.SocketIF, java.nio.ByteBuffer)

invalidateSession

public void invalidateSession(SocketIF socket)

Invalidate the SSL/TLS session (if any) on the underlying SocketIF. As this client implementation only has a single socket, no parameter is needed.

Overrides:

invalidateSession in class AbstractSelector

Parameters:

socket - The socket whose underlying SSLSession should be invalidates

See Also:

AbstractSelector.invalidateSession(SocketIF)

handshakesFinished

public boolean handshakesFinished()

initConnection

protected void initConnection()
                       throws java.io.IOException

Initialize a client connection. This method initializes a SocketChannel, configures it to non-blocking, and registers it with the underlying Selector instance with an OP_CONNECT SelectionKey. If this client implementation is using SSL/TLS, it also sets up the SSLEngine, to be used.

Specified by:

initConnection in class AbstractSelector

Throws:

java.io.IOException - Propagates all underlying IOExceptions as thrown, to be handled by the application layer.

See Also:

AbstractSelector.run()

accept

protected void accept(java.nio.channels.SelectionKey key)

As this is the client implementation, it is NOT allowed to call this method which is only useful for server implementations. This implementation will throw a NoSuchMethodError if it is called and do nothing else.

Specified by:

accept in class AbstractSelector

Parameters:

key - The selection key with the underlying SocketChannel to be accepted

See Also:

AbstractSelector.run()

connect

protected void connect(java.nio.channels.SelectionKey key)

Finish the connection to the server. This method also instantiates an SSLEngine handshake if the underlying SocketIF is a secure socket. Finally, after the connection has been established, the socket is registered to the underlying Selector, with a SelectionKey of OP_READ, signalling it is ready to read data.

Specified by:

connect in class AbstractSelector

Parameters:

key - The selection key with the underlying SocketChannel that needs a connection finalization.

isConnected

public boolean isConnected()

Returns whether or not this client is connected, if and only if it is running (returns false otherwise).

Returns:

whether or not this client is connected, if and only if it is running (returns false otherwise)