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

All Implemented Interfaces:
Runnable

public class Multiplexor

The Multiplexor acts as IO processor and manages all IO operations requested
by the Channel. The IO operations are proccessed asynchronously. Usually
client applications does not require direct access to mutiplexor class, only
when multiple protocols would like to reuse the same multiplexor instance.
Each multiplexor instance instantiates one java.nio.channels.Selector
instance. Multiplexor represents a communications utility for providing
select functionality across multiple Channels and multiple
ChannelAccessPoints. Component implementations may configured to leverage the
Multiplexor construct in a manner most appropriate to the component's
communications requirements.

Field Summary
private LinkedList	cancelledChannels
private ReentrantLock	cancelledLock
private ConcurrentHashMap	channels
private final static String	className
private int	closed
private List	execCallbacks
private boolean	hasCancelled
private boolean	hasRegistred
private boolean	isShutDown
private boolean	isStopped
private static Logger	logger
private int	onAccept
private int	onConnect
private int	onRead
private int	onWrite
private int	registered
private Selector	selector
private Thread	selectorThread
private long	selectTimeOut
private ReentrantLock	shutDownLock
private int	updates

Constructor Summary
public void	Multiplexor()

Method Summary
private void	attemptShutdown()
public void	cancelHandler(SelectableChannel channel)
private void	doShutDown()
public synchronized boolean	isRunning()
private void	processCancelations()
private void	processRegistrations()
public synchronized void	registerHandler(SelectableChannel selectableChannel, IOHandler callback)
public void	run()
public void	setLogLevel(Level logLevel)
public synchronized void	shutDown(IOHandler handler)
public synchronized void	start()
public synchronized void	stop(IOHandler handler)
public String	toString()

private LinkedList cancelledChannels

private ReentrantLock cancelledLock

private ConcurrentHashMap channels

private final static String className

private List execCallbacks

private boolean hasCancelled

private boolean hasRegistred

private boolean isShutDown

private boolean isStopped

private static Logger logger

private int onAccept

private int onConnect

private int registered

private Selector selector

private Thread selectorThread

private long selectTimeOut

private ReentrantLock shutDownLock

public void Multiplexor ()

private void attemptShutdown ()

public void cancelHandler (SelectableChannel channel)

Cancel the key if exists and close the channel

channel
SelectableChannel

private void doShutDown ()

Shuts down the selector after it closes down all the channels.

public synchronized boolean isRunning ()

private void processCancelations ()

processRegistrations

private void processRegistrations ()

public synchronized void registerHandler (SelectableChannel selectableChannel, IOHandler callback)

Registers an IOHandler with the selector for the provided channel. The
interest operations are provided by the IOHandler. If the channel is
already it updates the interest operations.

The main work is done here. First we iterate through the list and
registers the new channels or just updates the interest operations. This
has to be done on the same thread as the select(). Then block on the
select. When there are ready keys available, call the appropiate IO
handler that processes them.

public void setLogLevel (Level logLevel)

public synchronized void shutDown (IOHandler handler)

Gracefully shuts down the selector

public synchronized void start ()

public synchronized void stop (IOHandler handler)

Stops the selector and cleans up

public String toString ()

Overview

Package