Uses of Interface
org.jppf.server.nio.ChannelWrapper

Packages that use ChannelWrapper

org.jppf.classloader	Support for socket-based communication with remote services.
org.jppf.server	Classes supporting the core functionality of the JPPF asynchronous comunication model.
org.jppf.server.debug	Classes providing server debug information via JMX.
org.jppf.server.job	Support for job management in the server.
org.jppf.server.nio	Classes supporting asynchronous communication through the NIO APIs.
org.jppf.server.nio.classloader	Support for socket-based communication with remote services.
org.jppf.server.nio.multiplexer	Classes supporting the multiplexing of TCP ports.
org.jppf.server.nio.multiplexer.generic	Classes supporting the multiplexing of TCP ports.
org.jppf.server.nio.nodeserver	Classes supporting the server node-side of the JPPF asynchronous comunication model.

Uses of ChannelWrapper in org.jppf.classloader

Classes in org.jppf.classloader that implement ChannelWrapper

class

LocalClassLoaderChannel Channel wrapper and I/O implementation for the class loader of an in-VM node.

Uses of ChannelWrapper in org.jppf.server

Methods in org.jppf.server that return types with arguments of type ChannelWrapper

Map<ChannelWrapper<?>,JPPFManagementInfo>

NodeInformationHandler.getNodeInformationMap() Get the mapping of channels to corresponding node information.

Methods in org.jppf.server with parameters of type ChannelWrapper

void	NodeInformationHandler.addNodeInformation(ChannelWrapper<?> channel, JPPFManagementInfo info) Add a node information object to the map of node information.
JPPFManagementInfo	NodeInformationHandler.getNodeInformation(ChannelWrapper<?> channel) Get the system information for the specified node.
void	NodeInformationHandler.removeNodeInformation(ChannelWrapper<?> channel) Remove a node information object from the map of node information.

Uses of ChannelWrapper in org.jppf.server.debug

Methods in org.jppf.server.debug with parameters of type ChannelWrapper

void	ServerDebug.addChannel(ChannelWrapper<?> channel, String serverName) Add a channel to those observed.
void	ServerDebug.removeChannel(ChannelWrapper<?> channel, String serverName) Remove a channel from those observed.

Uses of ChannelWrapper in org.jppf.server.job

Methods in org.jppf.server.job with parameters of type ChannelWrapper

void	JPPFJobManager.jobDispatched(BundleWrapper bundleWrapper, ChannelWrapper channel) Called when all or part of a job is dispatched to a node.
void	JPPFJobManager.jobReturned(BundleWrapper bundleWrapper, ChannelWrapper channel) Called when all or part of a job has returned from a node.

Constructors in org.jppf.server.job with parameters of type ChannelWrapper

ChannelBundlePair(ChannelWrapper<?> first, BundleWrapper second)
Initialize this object with the specified parameters.

JobEventTask(JPPFJobManager jobManager, JobEventType eventType, JPPFTaskBundle bundle, ChannelWrapper channel)
Initialize this job manager event task with the specified parameters.

Uses of ChannelWrapper in org.jppf.server.nio

Classes in org.jppf.server.nio that implement ChannelWrapper

class	AbstractChannelWrapper<S> Wraps a communication channel, no matter what the channel is.
class	AbstractLocalChannelWrapper<S,T extends AbstractNioContext> Channel wrapper and I/O implementation for the class loader of an in-VM node.
class	SelectionKeyWrapper Channel wrapper implementation for a SelectionKey.

Fields in org.jppf.server.nio declared as ChannelWrapper

ChannelWrapper<?>

StateTransitionManager.ChannelRegistrationAction.key The key resulting form the channel registration.

Methods in org.jppf.server.nio that return ChannelWrapper

ChannelWrapper<?>	NioContext.getChannel() Get the associated channel.
ChannelWrapper<?>	ChannelSelector.getChannel() Get the channel this selector is polling.
ChannelWrapper<?>	AbstractNioContext.getChannel() Get the associated channel.
ChannelWrapper<?>	LocalChannelSelector.getChannel() Get the channel this selector is polling.
ChannelWrapper<?>	StateTransitionManager.registerChannel(SocketChannel channel, int ops, NioContext context, StateTransitionManager.ChannelRegistrationAction action) Register a channel not opened through this server.

Methods in org.jppf.server.nio with parameters of type ChannelWrapper

void	NioContext.handleException(ChannelWrapper<?> channel) Handle the cleanup when an exception occurs on the channel.
abstract T	NioState.performTransition(ChannelWrapper<?> channel) Execute the action associated with this channel state.
abstract void	NioServer.postAccept(ChannelWrapper<?> key) Process a channel that was accepted by the server socket channel.
void	NioServer.postAccept(ChannelWrapper<?> key, ServerSocketChannel serverChannel) Process a channel that was accepted by the server socket channel.
boolean	NioContext.readMessage(ChannelWrapper<?> wrapper) Read data from a channel.
boolean	SimpleNioContext.readMessage(ChannelWrapper<?> wrapper) Read data from a channel.
void	NioContext.setChannel(ChannelWrapper<?> channel) Set the associated channel.
void	AbstractNioContext.setChannel(ChannelWrapper<?> channel) Set the associated channel.
void	StateTransitionManager.submitTransition(ChannelWrapper<?> key) Submit the next state transition for a specified channel.
void	StateTransitionManager.transitionChannel(ChannelWrapper<?> channel, T transition) Transition the specified channel to the specified state.
boolean	NioContext.writeMessage(ChannelWrapper<?> wrapper) Write data to a channel.
boolean	SimpleNioContext.writeMessage(ChannelWrapper<?> wrapper) Write data to a channel.

Constructors in org.jppf.server.nio with parameters of type ChannelWrapper

LocalChannelSelector(ChannelWrapper<?> channel)
Initialize this selector with the specified channel.

StateTransitionTask(ChannelWrapper<?> channel, NioServerFactory<S,T> factory)
Initialize this task with the specified key and factory.

Uses of ChannelWrapper in org.jppf.server.nio.classloader

Fields in org.jppf.server.nio.classloader declared as ChannelWrapper

protected ChannelWrapper<?>

ClassContext.currentRequest The request currently processed.

Fields in org.jppf.server.nio.classloader with type parameters of type ChannelWrapper

protected List<ChannelWrapper<?>>	ClassContext.pendingRequests The list of pending resource requests for a resource provider.
protected Map<String,List<ChannelWrapper<?>>>	ClassNioServer.providerConnections A mapping of the remote resource provider connections handled by this socket server, to their unique uuid.

Methods in org.jppf.server.nio.classloader that return ChannelWrapper

ChannelWrapper<?>

ClassContext.getCurrentRequest() Get the request currently processed.

Methods in org.jppf.server.nio.classloader that return types with arguments of type ChannelWrapper

List<ChannelWrapper<?>>	ClassContext.getPendingRequests() Get the list of pending resource requests for a resource provider.
List<ChannelWrapper<?>>	ClassNioServer.getProviderConnections(String uuid) Get all the provider connections for the specified client uuid.

Methods in org.jppf.server.nio.classloader with parameters of type ChannelWrapper

void	ClassNioServer.addProviderConnection(String uuid, ChannelWrapper<?> channel) Add a provider connection to the map of existing available providers.
void	ClassContext.addRequest(ChannelWrapper<?> request) Add a new pending request to this resource provider.
static void	ClassNioServer.closeConnection(ChannelWrapper<?> channel) Close the specified connection.
void	ClassContext.handleException(ChannelWrapper<?> channel) Handle the cleanup when an exception occurs on the channel.
void	ClassNioServer.initLocalChannel(ChannelWrapper<?> localChannel) Initialize the local channel connection.
void	ClassNioServer.postAccept(ChannelWrapper<?> wrapper) Process a channel that was accepted by the server socket channel.
boolean	LocalClassContext.readMessage(ChannelWrapper<?> wrapper) Read data from a channel.
void	ClassNioServer.removeProviderConnection(String uuid, ChannelWrapper channel) Add a provider connection to the map of existing available providers.
protected void	ClassContext.resetNodeState(ChannelWrapper<?> request, ClassNioServer server) Reset the state of the requesting node channel, after an error occurred on the provider which attempted to provide a response.
protected void	ClassContext.sendNullResponse(ChannelWrapper<?> request) Send a null response to a request node connection.
void	LocalClassContext.serializeResource(ChannelWrapper<?> wrapper) Serialize a resource wrapper to an array of bytes.
void	ClassContext.serializeResource(ChannelWrapper<?> wrapper) Serialize a resource wrapper to an array of bytes.
void	ClassContext.setCurrentRequest(ChannelWrapper<?> currentRequest) Set the request currently processed.
boolean	LocalClassContext.writeMessage(ChannelWrapper<?> wrapper) Write data to a channel.

Method parameters in org.jppf.server.nio.classloader with type arguments of type ChannelWrapper

void	ClassContext.setPendingRequests(List<ChannelWrapper<?>> pendingRequests) Set the list of pending resource requests for a resource provider.

Uses of ChannelWrapper in org.jppf.server.nio.multiplexer

Methods in org.jppf.server.nio.multiplexer that return ChannelWrapper

ChannelWrapper<?>

MultiplexerContext.getLinkedKey() Get the request currently processed.

Methods in org.jppf.server.nio.multiplexer with parameters of type ChannelWrapper

void	MultiplexerContext.handleException(ChannelWrapper<?> channel) Handle the cleanup when an exception occurs on the channel.
MultiplexerTransition	SendingState.performTransition(ChannelWrapper<?> wrapper) Execute the action associated with this channel state.
MultiplexerTransition	SendingOrReceivingState.performTransition(ChannelWrapper<?> wrapper) Execute the action associated with this channel state.
MultiplexerTransition	SendingMultiplexingInfoState.performTransition(ChannelWrapper<?> wrapper) Execute the action associated with this channel state.
MultiplexerTransition	ReceivingState.performTransition(ChannelWrapper<?> wrapper) Execute the action associated with this channel state.
MultiplexerTransition	IdleState.performTransition(ChannelWrapper<?> wrapper) Execute the action associated with this channel state.
MultiplexerTransition	IdentifyingInboundChannelState.performTransition(ChannelWrapper<?> wrapper) Execute the action associated with this channel state.
void	MultiplexerNioServer.postAccept(ChannelWrapper channel) Process a channel that was accepted by the server socket channel.
void	MultiplexerNioServer.postAccept(ChannelWrapper channel, ServerSocketChannel serverChannel) Process a channel that was accepted by the server socket channel.
void	MultiplexerContext.setLinkedKey(ChannelWrapper<?> key) Set the request currently processed.

Constructors in org.jppf.server.nio.multiplexer with parameters of type ChannelWrapper

MultiplexerChannelHandler(NioServer server, String host, int port, ChannelWrapper<?> initialKey)
Initialize the channel with the specified host and port.

OutboundChannelHandler(NioServer server, String host, int port, ChannelWrapper initialKey)
Initialize the channel with the specified host and port.

Uses of ChannelWrapper in org.jppf.server.nio.multiplexer.generic

Methods in org.jppf.server.nio.multiplexer.generic that return ChannelWrapper

ChannelWrapper

MultiplexerContext.getLinkedKey() Get the request currently processed.

Methods in org.jppf.server.nio.multiplexer.generic with parameters of type ChannelWrapper

void	MultiplexerContext.handleException(ChannelWrapper channel) Handle the cleanup when an exception occurs on the channel.
MultiplexerTransition	SendingState.performTransition(ChannelWrapper<?> wrapper) Execute the action associated with this channel state.
MultiplexerTransition	SendingOrReceivingState.performTransition(ChannelWrapper<?> wrapper) Execute the action associated with this channel state.
MultiplexerTransition	SendingMultiplexingInfoState.performTransition(ChannelWrapper<?> wrapper) Execute the action associated with this channel state.
MultiplexerTransition	ReceivingState.performTransition(ChannelWrapper<?> wrapper) Execute the action associated with this channel state.
MultiplexerTransition	IdleState.performTransition(ChannelWrapper<?> wrapper) Execute the action associated with this channel state.
MultiplexerTransition	IdentifyingInboundChannelState.performTransition(ChannelWrapper<?> wrapper) Execute the action associated with this channel state.
void	MultiplexerNioServer.postAccept(ChannelWrapper key) Process a channel that was accepted by the server socket channel.
void	MultiplexerNioServer.postAccept(ChannelWrapper key, ServerSocketChannel serverChannel) Process a channel that was accepted by the server socket channel.
ByteBuffer	MultiplexerContext.readMultiplexerMessage(ChannelWrapper<?> wrapper) Read data from a channel.
void	MultiplexerContext.setLinkedKey(ChannelWrapper key) Set the request currently processed.
boolean	MultiplexerContext.writeMultiplexerMessage(ChannelWrapper<?> wrapper) Write the current message to a channel.

Constructors in org.jppf.server.nio.multiplexer.generic with parameters of type ChannelWrapper

MultiplexerChannelHandler(NioServer server, String host, int port, ChannelWrapper initialKey)
Initialize the channel with the specified host and port.

OutboundChannelHandler(NioServer server, String host, int port, ChannelWrapper initialKey)
Initialize the channel with the specified host and port.

Uses of ChannelWrapper in org.jppf.server.nio.nodeserver

Classes in org.jppf.server.nio.nodeserver that implement ChannelWrapper

class

LocalNodeChannel Wrapper implementation for a local node's communication channel.

Methods in org.jppf.server.nio.nodeserver that return ChannelWrapper

ChannelWrapper<?>	NodeNioServer.removeIdleChannel(ChannelWrapper<?> channel) Remove a channel from the list of idle channels.
ChannelWrapper<?>	NodeNioServer.removeIdleChannel(int index) Remove the channel at the specified index from the list of idle channels.

Methods in org.jppf.server.nio.nodeserver that return types with arguments of type ChannelWrapper

List<ChannelWrapper<?>>

NodeNioServer.getIdleChannels() Get the list of currently idle channels.

Methods in org.jppf.server.nio.nodeserver with parameters of type ChannelWrapper

void	NodeNioServer.addIdleChannel(ChannelWrapper<?> channel) Add a channel to the list of idle channels.
static void	NodeNioServer.closeNode(ChannelWrapper<?> channel, AbstractNodeContext context) Close a connection to a node.
void	AbstractNodeContext.handleException(ChannelWrapper<?> channel) Handle the cleanup when an exception occurs on the channel.
void	NodeNioServer.initLocalChannel(ChannelWrapper<?> localChannel) Initialize the local channel connection.
void	NodeNioServer.postAccept(ChannelWrapper<?> channel) Process a channel that was accepted by the server socket channel.
boolean	LocalNodeMessage.read(ChannelWrapper<?> wrapper) Read data from the channel.
boolean	AbstractNodeMessage.read(ChannelWrapper<?> wrapper) Read data from the channel.
boolean	LocalNodeContext.readMessage(ChannelWrapper<?> channel) Read data from a channel.
boolean	AbstractNodeContext.readMessage(ChannelWrapper<?> channel) Read data from a channel.
protected boolean	RemoteNodeMessage.readNextObject(ChannelWrapper<?> wrapper) Read the next serializable object from the specified channel.
protected boolean	LocalNodeMessage.readNextObject(ChannelWrapper<?> wrapper) Read the next serializable object from the specified channel.
protected abstract boolean	AbstractNodeMessage.readNextObject(ChannelWrapper<?> wrapper) Read the next serializable object from the specified channel.
ChannelWrapper<?>	NodeNioServer.removeIdleChannel(ChannelWrapper<?> channel) Remove a channel from the list of idle channels.
void	AbstractNodeContext.serializeBundle(ChannelWrapper<?> wrapper) Serialize this context's bundle into a byte buffer.
void	LocalNodeContext.setNodeMessage(AbstractNodeMessage nodeMessage, ChannelWrapper<?> channel) Set the message wrapping the data sent or received over the socket channel.
void	AbstractNodeContext.setNodeMessage(AbstractNodeMessage nodeMessage, ChannelWrapper<?> channel) Set the message wrapping the data sent or received over the socket channel.
boolean	LocalNodeMessage.write(ChannelWrapper<?> wrapper) Read data from the channel.
boolean	AbstractNodeMessage.write(ChannelWrapper<?> wrapper) Read data from the channel.
boolean	LocalNodeContext.writeMessage(ChannelWrapper<?> channel) Write data to a channel.
boolean	AbstractNodeContext.writeMessage(ChannelWrapper<?> channel) Write data to a channel.
protected boolean	RemoteNodeMessage.writeNextObject(ChannelWrapper<?> wrapper) Write the next object to the specified channel.
protected boolean	LocalNodeMessage.writeNextObject(ChannelWrapper<?> wrapper) Write the next object to the specified channel.
protected abstract boolean	AbstractNodeMessage.writeNextObject(ChannelWrapper<?> wrapper) Write the next object to the specified channel.