Package org.jppf.server.nio.classloader.node

Class AsyncNodeClassNioServer

java.lang.Object

java.lang.Thread

org.jppf.nio.NioServer

org.jppf.nio.StatelessNioServer<AsyncNodeClassContext>

org.jppf.server.nio.classloader.node.AsyncNodeClassNioServer

All Implemented Interfaces:

Runnable

public final class AsyncNodeClassNioServer
extends org.jppf.nio.StatelessNioServer<AsyncNodeClassContext>

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

Modifier and Type	Field	Description
protected final Map<String,AsyncNodeClassContext>	nodeConnections	Mapping of channels to their uuid.

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
AsyncNodeClassNioServer(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	addNodeConnection(String uuid, AsyncNodeClassContext channel)	Put the specified uuid / channel pair into the uuid map.
void	closeConnection(AsyncNodeClassContext context)	Close the specified channel.
void	connectionFailed(AsyncNodeClassContext channel)	Called when the node failed to respond to a heartbeat message.
AsyncNodeClassContext	createNioContext(Object... params)
List<AsyncNodeClassContext>	getAllNodeConnections()
AsyncNodeClassMessageHandler	getMessageHandler()
AsyncNodeClassContext	getNodeConnection(String uuid)	Get a channel from its uuid.
org.jppf.classloader.ResourceProvider	getResourceProvider()	Get the resource provider for this server.
protected void	handleSelectionException(SelectionKey key, Exception e)
protected void	initNioHandlers()
protected void	initReaderAndWriter()
void	removeAllConnections()	Close and remove all connections accepted by this server.
org.jppf.classloader.AsyncLocalNodeClassloaderContext	removeNodeConnection(String uuid)	Remove the specified uuid entry from the uuid map.

Methods inherited from class org.jppf.nio.StatelessNioServer

doOperation, getAllContexts, go, 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

Field Details

nodeConnections

protected final Map<String,AsyncNodeClassContext> nodeConnections

Mapping of channels to their uuid.

Constructor Details

AsyncNodeClassNioServer

public AsyncNodeClassNioServer(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<AsyncNodeClassContext>

handleSelectionException

protected void handleSelectionException(SelectionKey key,
 Exception e)

Specified by:

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

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 AsyncNodeClassContext createNioContext(Object... params)

Specified by:

createNioContext in class org.jppf.nio.NioServer

closeConnection

public void closeConnection(AsyncNodeClassContext context)

Close the specified channel.

Parameters:

context - the channel to close.

getNodeConnection

public AsyncNodeClassContext getNodeConnection(String uuid)

Get a channel from its uuid.

Parameters:

uuid - the uuid key to look up in the the map.

Returns:

channel the corresponding channel.

addNodeConnection

public void addNodeConnection(String uuid,
 AsyncNodeClassContext channel)

Put the specified uuid / channel pair into the uuid map.

Parameters:

uuid - the uuid key to add to the map.

channel - the corresponding channel.

removeNodeConnection

public org.jppf.classloader.AsyncLocalNodeClassloaderContext removeNodeConnection(String uuid)

Remove the specified uuid entry from the uuid map.

Parameters:

uuid - the uuid key to remove from the map.

Returns:

channel the corresponding channel.

connectionFailed

public void connectionFailed(AsyncNodeClassContext channel)

Called when the node failed to respond to a heartbeat message.

Parameters:

channel - the channel to close.

removeAllConnections

public void removeAllConnections()

Close and remove all connections accepted by this server.

Overrides:

removeAllConnections in class org.jppf.nio.NioServer

See Also:

• NioServer.removeAllConnections()

getAllNodeConnections

public List<AsyncNodeClassContext> getAllNodeConnections()

Returns:

the list of all current connections.

getResourceProvider

public org.jppf.classloader.ResourceProvider getResourceProvider()

Get the resource provider for this server.

Returns:

a ResourceProvider instance.

getMessageHandler

public AsyncNodeClassMessageHandler getMessageHandler()

Returns:

the message handler for this server.

initNioHandlers

protected void initNioHandlers()

Overrides:

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