Package org.jppf.server.nio.heartbeat

Class HeartbeatNioServer

java.lang.Object

java.lang.Thread

org.jppf.nio.NioServer

org.jppf.nio.StatelessNioServer<org.jppf.server.nio.heartbeat.HeartbeatContext>

org.jppf.server.nio.heartbeat.HeartbeatNioServer

All Implemented Interfaces:

Runnable

public final class HeartbeatNioServer
extends org.jppf.nio.StatelessNioServer<org.jppf.server.nio.heartbeat.HeartbeatContext>

The NIO server that handles heartbeat connections.

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
HeartbeatNioServer(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)
org.jppf.server.nio.heartbeat.HeartbeatContext	createNioContext(Object... params)
org.jppf.server.nio.heartbeat.HeartbeatMessageHandler	getMessageHandler()
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, 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

Constructor Details

HeartbeatNioServer

public HeartbeatNioServer(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

handleSelectionException

protected void handleSelectionException(SelectionKey key,
 Exception e)

Specified by:

handleSelectionException in class org.jppf.nio.StatelessNioServer<org.jppf.server.nio.heartbeat.HeartbeatContext>

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 org.jppf.server.nio.heartbeat.HeartbeatContext createNioContext(Object... params)

Specified by:

createNioContext in class org.jppf.nio.NioServer

removeAllConnections

public void removeAllConnections()

Overrides:

removeAllConnections in class org.jppf.nio.NioServer

getMessageHandler

public org.jppf.server.nio.heartbeat.HeartbeatMessageHandler getMessageHandler()

Returns:

the message handler for this server.

initReaderAndWriter

protected void initReaderAndWriter()

Specified by:

initReaderAndWriter in class org.jppf.nio.StatelessNioServer<org.jppf.server.nio.heartbeat.HeartbeatContext>

initNioHandlers

protected void initNioHandlers()

Overrides:

initNioHandlers in class org.jppf.nio.StatelessNioServer<org.jppf.server.nio.heartbeat.HeartbeatContext>