Class

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: INNER | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

com.newstep.solid.comm.tcp

Class TCPChannelAccessPoint

+--com.newstep.solid.comm.tcp.TCPChannelAccessPoint

All Implemented Interfaces:
IOHandler, ManagedExecutable

public class TCPChannelAccessPoint

Implements a TCP ChannelAccessPoint. On the server side it binds its
transport endpoint(selectable channel) to a particular transport address
(host and port)and creates TCP server Channels. On the client side creates a
TCP client channel and returns it to the caller

Kernel Association Association Link

to Class Multiplexor

Client navigability:

Supplier cardinality:

Supplier navigability:

Supplier visibility:

Kernel Association Association Link

Client navigability:

Supplier cardinality:

Supplier navigability:

Supplier visibility:

Generalization Generalization Link

Implementation Implementation Link

to Interface IOHandler

Field Summary
Multiplexor	mux
private int	bufferPoolSize
private ByteBufferPool	buffers
private int	bufferSize
private final static String	className
private boolean	inited
private boolean	keepAlive
private int	linger
private ConcurrentHashMap	listeners
private static Logger	logger
private Multiplexor	mux
private int	nrClients
private int	nrServers
private boolean	oobInline
private int	rcvBuf
private boolean	reuseAddr
private int	sndBuf
private int	tos

Constructor Summary
public void	TCPChannelAccessPoint(ChannelFactory channelFactory)

Method Summary
protected void	doShutdown()
protected void	doStart()
protected void	doStop()
public int	getBufferCapacity()
public Channel	getChannel(Address address)
public int	getInterestedOps()
private ServerSocketChannel	getListeningChannel(Address address)
public Multiplexor	getMux()
public int	getNrClientChannels()
public int	getNrServerChannels()
public void	init(CommConfig config)
public boolean	isListening(Address address)
public void	listen(Address address, ChannelAccessPointListener listener, Integer nrConn)
public void	onAccept(SelectionKey key)
public void	onClosed(SelectableChannel channel)
public void	onConnect()
public void	onDone()
public void	onRead(SelectionKey key)
public void	onWrite(SelectionKey key)
public Address	parseString(String string)
private void	setSocketOptions(Socket socket)
public void	stopListen(Address address)
public String	toString()

private int bufferPoolSize

private ByteBufferPool buffers

private int bufferSize

private final static String className

private boolean inited

private boolean keepAlive

private ConcurrentHashMap listeners

private static Logger logger

private Multiplexor mux

private int nrClients

private int nrServers

private boolean oobInline

private boolean reuseAddr

TCPChannelAccessPoint

public void TCPChannelAccessPoint (ChannelFactory channelFactory)

channelFactory
ChannelFactory

protected void doShutdown ()

Gracefully shuts down and propagates to the selector

protected void doStart ()

Starts the ChannelAccessPoint and the selector underneath

protected void doStop ()

Stops the ChannelAccessPoint and the selecytor underneath

public int getBufferCapacity ()

Return the buffers capacity

public Channel getChannel (Address address)

Returns a TCP channel that can be connected to the specified address

public int getInterestedOps ()

int the operations this IOHandler is interested in

private ServerSocketChannel getListeningChannel (Address address)

Returns the ChannelAccessPoint listener for a specified address

public Multiplexor getMux ()

Return the MUX processing this channel

public int getNrClientChannels ()

Returns the number of client channels this access point has created

public int getNrServerChannels ()

Return the number of server channels this access point has created

public void init (CommConfig config)

TCP channels configuration

public boolean isListening (Address address)

Checks if this channel access point is listening or not to a prticular
address

public void listen (Address address, ChannelAccessPointListener listener, Integer nrConn)

Starts listening for nrConn connections at the specified address. If
there's a listener provided it adds it to its list and on accept for a
new connection it notifies it. Only one listener is accepted per address
If nrConn is 0, there will be un unlimited number of accepted connection.
Otherwise there will only be nrConn connections accepted

address
Address
listener
ChannelAccessPointListener
nrConn
int

public void onAccept (SelectionKey key)

IOHandler interface. This is the only valid IO operation the TCP
ChannelAccess Point implements. It accepts the incoming connection
request and it creates a new TCP channel Then it registers the newly
created TCP Channel with the selector for READ operations. It also
notifies its listener that a new channel has been created.