com.maverick.nio

Class SocketConnection

java.lang.Object

com.maverick.nio.SocketConnection

All Implemented Interfaces:

SelectionKeyAware, SelectorRegistrationListener, SocketHandler

Direct Known Subclasses:

SSLContextConnection, SSLSocketConnection

public class SocketConnection
extends Object
implements SocketHandler

This class implements a SocketHandler using a standard socket.

Author:

Lee David Painter

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	closed
protected Daemon	daemon
protected DaemonContext	daemonContext
protected SelectionKey	key
protected SocketAddress	localAddr
protected int	localPort
protected ProtocolEngine	protocolEngine
protected SocketAddress	remoteAddr
protected int	remotePort
protected SelectorThread	selectorThread
protected SocketChannel	socketChannel
protected ByteBuffer	socketDataIn
protected ByteBuffer	socketDataOut

Constructor Summary

Constructors

Constructor and Description
SocketConnection() Construct the socket.

Method Summary

Modifier and Type	Method and Description
void	closeConnection() Close this socket connection.
DaemonContext	getDaemonContext() Get the daemon process for this socket.
IdleStateManager	getIdleStates() Get the idle state manager.
int	getInterestedOps() Get the initial interested ops for this socket.
SocketAddress	getLocalAddress() Returns the local address to which the remote socket is connected.
int	getLocalPort() Returns the local port to which the remote socket is connected.
int	getPort() Returns the local port to which the remote socket is connected.
ProtocolEngine	getProtocolEngine() Get the protocol engine for this socket.
SocketAddress	getRemoteAddress() Returns the address of the remote socket.
SocketChannel	getSocketChannel() Get the SocketChannel for this socket.
SelectorThread	getThread() Get the selector thread for this connection
String	getUuid()
void	initialize(ProtocolEngine protocolEngine, Daemon daemon, SelectableChannel sc, SelectorThread selectorThread) Initialize the socket with the protocol engine and the daemon process.
protected boolean	isConnected() Is the socket still connected?
protected boolean	isDeferredConnectEvent()
boolean	isSelectorThread() Is the current thread this sockets SelectorThread?
boolean	processReadEvent() The selector is ready to be read.
boolean	processWriteEvent() The selector is ready to be written to.
void	registrationCompleted(SelectableChannel channel, SelectionKey key) The sockets channel has completed registration.
void	setSelectionKey(SelectionKey key)
void	setThread(SelectorThread thread) Set the selector thread for this connection
void	setWriteState(boolean wantsWrite) Sets the write state of the socket.

Methods inherited from class java.lang.Object

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

Field Detail

socketChannel

protected SocketChannel socketChannel

protocolEngine

protected ProtocolEngine protocolEngine

daemonContext

protected DaemonContext daemonContext

selectorThread

protected SelectorThread selectorThread

key

protected SelectionKey key

daemon

protected Daemon daemon

socketDataIn

protected ByteBuffer socketDataIn

socketDataOut

protected ByteBuffer socketDataOut

closed

protected boolean closed

remoteAddr

protected SocketAddress remoteAddr

localAddr

protected SocketAddress localAddr

localPort

protected int localPort

remotePort

protected int remotePort

Constructor Detail

SocketConnection

public SocketConnection()

Construct the socket.

Method Detail

getUuid

public String getUuid()

Specified by:

getUuid in interface SocketHandler

initialize

public void initialize(ProtocolEngine protocolEngine,
                       Daemon daemon,
                       SelectableChannel sc,
                       SelectorThread selectorThread)

Initialize the socket with the protocol engine and the daemon process.

Specified by:

initialize in interface SocketHandler

Parameters:

protocolEngine - ProtocolEngine

daemon - Daemon

isDeferredConnectEvent

protected boolean isDeferredConnectEvent()

registrationCompleted

public void registrationCompleted(SelectableChannel channel,
                                  SelectionKey key)

The sockets channel has completed registration.

Specified by:

registrationCompleted in interface SelectorRegistrationListener

Parameters:

channel - SelectableChannel

key - SelectionKey

selectorThread - SelectorThread

setSelectionKey

public void setSelectionKey(SelectionKey key)

Specified by:

setSelectionKey in interface SelectionKeyAware

closeConnection

public void closeConnection()

Close this socket connection.

getProtocolEngine

public ProtocolEngine getProtocolEngine()

Get the protocol engine for this socket.

Returns:

ProtocolEngine

getDaemonContext

public DaemonContext getDaemonContext()

Get the daemon process for this socket.

Returns:

DaemonContext

getLocalAddress

public SocketAddress getLocalAddress()

Returns the local address to which the remote socket is connected.

Returns:

getLocalPort

public int getLocalPort()

Returns the local port to which the remote socket is connected.

Returns:

getPort

public int getPort()

Returns the local port to which the remote socket is connected.

Returns:

getRemoteAddress

public SocketAddress getRemoteAddress()

Returns the address of the remote socket.

Returns:

getSocketChannel

public SocketChannel getSocketChannel()

Get the SocketChannel for this socket.

Returns:

SocketChannel

getIdleStates

public IdleStateManager getIdleStates()

Get the idle state manager.

Returns:

IdleStateManager

isSelectorThread

public boolean isSelectorThread()

Is the current thread this sockets SelectorThread?

Returns:

boolean

setWriteState

public void setWriteState(boolean wantsWrite)

Sets the write state of the socket.

Parameters:

wantsWrite - boolean

isConnected

protected boolean isConnected()

Is the socket still connected?

Returns:

boolean

getThread

public SelectorThread getThread()

Get the selector thread for this connection

Returns:

SelectorThread

getInterestedOps

public int getInterestedOps()

Get the initial interested ops for this socket.

Specified by:

getInterestedOps in interface SocketHandler

Returns:

int

processReadEvent

public boolean processReadEvent()

The selector is ready to be read.

Specified by:

processReadEvent in interface SocketHandler

Returns:

boolean

processWriteEvent

public boolean processWriteEvent()

The selector is ready to be written to.

Specified by:

processWriteEvent in interface SocketHandler

Returns:

boolean

setThread

public void setThread(SelectorThread thread)

Set the selector thread for this connection

Specified by:

setThread in interface SocketHandler

Parameters:

thread - SelectorThread