Package org.dellroad.stuff.net

Class TCPConnection

java.lang.Object

org.dellroad.stuff.net.ChannelConnection

org.dellroad.stuff.net.TCPConnection

All Implemented Interfaces:

SelectorSupport.IOHandler

public class TCPConnection
extends ChannelConnection

A TCP connection to be used with a ChannelNetwork. Locking

All access to this class must be with the associated TCPNetwork instance locked.

Field Summary

Fields inherited from class org.dellroad.stuff.net.ChannelConnection

inputChannel, inputSelectionKey, log, network, outputChannel, outputSelectionKey, peer

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TCPConnection(TCPNetwork network, String peer, SocketChannel channel)

Method Summary

Modifier and Type	Method	Description
SocketChannel	getSocketChannel()	Get the associated SocketChannel.
protected void	performHousekeeping()	Perform housekeeping.
void	serviceIO(SelectionKey key)	Handle ready I/O.
protected void	updateSelection()	Update selected keys.

Methods inherited from class org.dellroad.stuff.net.ChannelConnection

close, getIdleTime, getInputChannel, getOutputChannel, getPeer, output, restartIdleTimer, toString

Methods inherited from class java.lang.Object

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

Constructor Details

TCPConnection

protected TCPConnection(TCPNetwork network,
 String peer,
 SocketChannel channel)
                 throws IOException

Throws:

IOException

Method Details

getSocketChannel

public SocketChannel getSocketChannel()

Get the associated SocketChannel.

Returns:

the socket channel for this connection

updateSelection

protected void updateSelection()

Description copied from class: ChannelConnection

Update selected keys.

The implementation in ChannelConnection selects for read if the input queue is not full, and for write if the output queue is non-empty.

Overrides:

updateSelection in class ChannelConnection

serviceIO

public void serviceIO(SelectionKey key)
               throws IOException

Description copied from interface: SelectorSupport.IOHandler

Handle ready I/O.

Specified by:

serviceIO in interface SelectorSupport.IOHandler

Overrides:

serviceIO in class ChannelConnection

Parameters:

key - selection key

Throws:

IOException - if an I/O error occurs; this will result in close() being invoked

performHousekeeping

protected void performHousekeeping()
                            throws IOException

Description copied from class: ChannelConnection

Perform housekeeping. The implementation in ChannelConnection checks the max idle time.

Overrides:

performHousekeeping in class ChannelConnection

Throws:

IOException - if an I/O error occurs (this connection will be closed)