Package org.jppf.server.nio.client

Class AsyncClientNioServer

java.lang.Object

java.lang.Thread

org.jppf.nio.NioServer

org.jppf.nio.StatelessNioServer<AsyncClientContext>

org.jppf.server.nio.client.AsyncClientNioServer

All Implemented Interfaces:

Runnable

public final class AsyncClientNioServer
extends org.jppf.nio.StatelessNioServer<AsyncClientContext>

The NIO server that handles asynchronous client connections, which can handle multiple jobs concurrently.

Author:

Laurent Cohen

Nested Class Summary

Nested classes/interfaces inherited from class org.jppf.nio.StatelessNioServer

org.jppf.nio.StatelessNioServer.ContextAction<C extends org.jppf.nio.AbstractNioContext>, org.jppf.nio.StatelessNioServer.ContextFilter<C extends org.jppf.nio.AbstractNioContext>, org.jppf.nio.StatelessNioServer.KeysetHandler<C extends org.jppf.nio.AbstractNioContext>

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class org.jppf.nio.StatelessNioServer

acceptHandler, messageReader, messageWriter, readHandler, writeHandler

Fields inherited from class org.jppf.nio.NioServer

attachment, configuration, identifier, requestShutdown, selecting, selector, selectTimeout, sslContext, sslHelper, stopped, sync, wakeUpAction

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
AsyncClientNioServer(JPPFDriver driver, int identifier, boolean useSSL)

Method Summary

Modifier and Type	Method	Description
void	accept(ServerSocketChannel serverSocketChannel, SocketChannel channel, org.jppf.nio.SSLHandler sslHandler, boolean ssl, boolean peer, Object... params)
void	closeConnection(AsyncClientContext context)	Close the specified channel.
AsyncClientContext	createNioContext(Object... params)
AsyncClientMessageHandler	getMessageHandler()
protected void	go(Set<SelectionKey> selectedKeys)
protected void	handleSelectionException(SelectionKey key, Exception e)
protected void	initNioHandlers()
protected void	initReaderAndWriter()
void	removeAllConnections()

Methods inherited from class org.jppf.nio.StatelessNioServer

doOperation, getAllContexts, handleRead, handleWrite, init, isKeyValid, performContextAction, registerChannel, run, toString, toString, updateInterestOps, updateInterestOpsNoWakeup

Methods inherited from class org.jppf.nio.NioServer

addServer, configurePeerSSL, configureSSLEngine, createSSLContext, doAccept, end, externalStopCondition, getConfiguration, getIdentifier, getSelector, isStopped, removeServer, setConfiguration, shutdown, wakeUpSelectorIfNeeded

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, yield

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncClientNioServer

public AsyncClientNioServer(JPPFDriver driver,
 int identifier,
 boolean useSSL)
                     throws Exception

Parameters:

driver - reference to the driver.

identifier - the channel identifier for channels handled by this server.

useSSL - determines whether an SSLContext should be created for this server.

Throws:

Exception - if any error occurs.

Method Details

initReaderAndWriter

protected void initReaderAndWriter()

Specified by:

initReaderAndWriter in class org.jppf.nio.StatelessNioServer<AsyncClientContext>

go

protected void go(Set<SelectionKey> selectedKeys)
           throws Exception

Overrides:

go in class org.jppf.nio.StatelessNioServer<AsyncClientContext>

Throws:

Exception

handleSelectionException

protected void handleSelectionException(SelectionKey key,
 Exception e)

Specified by:

handleSelectionException in class org.jppf.nio.StatelessNioServer<AsyncClientContext>

accept

public void accept(ServerSocketChannel serverSocketChannel,
 SocketChannel channel,
 org.jppf.nio.SSLHandler sslHandler,
 boolean ssl,
 boolean peer,
 Object... params)

Specified by:

accept in class org.jppf.nio.NioServer

createNioContext

public AsyncClientContext createNioContext(Object... params)

Specified by:

createNioContext in class org.jppf.nio.NioServer

closeConnection

public void closeConnection(AsyncClientContext context)

Close the specified channel.

Parameters:

context - the channel to close.

removeAllConnections

public void removeAllConnections()

Overrides:

removeAllConnections in class org.jppf.nio.NioServer

getMessageHandler

public AsyncClientMessageHandler getMessageHandler()

Returns:

the message handler for this server.

initNioHandlers

protected void initNioHandlers()

Overrides:

initNioHandlers in class org.jppf.nio.StatelessNioServer<AsyncClientContext>