Package org.jppf.classloader

Class AsyncLocalClassLoaderConnection

java.lang.Object

org.jppf.node.AbstractNodeConnection<C>

org.jppf.classloader.AbstractClassLoaderConnection<AsyncLocalNodeClassloaderContext>

org.jppf.classloader.AsyncLocalClassLoaderConnection

All Implemented Interfaces:

ClassLoaderConnection<AsyncLocalNodeClassloaderContext>, NodeConnection<AsyncLocalNodeClassloaderContext>

public class AsyncLocalClassLoaderConnection
extends AbstractClassLoaderConnection<AsyncLocalNodeClassloaderContext>

Author:

Laurent Cohen

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.jppf.utils.concurrent.ThreadSynchronization	nodeLock	Object used to synchronize threads when reading/writing the node message.
protected final org.jppf.utils.concurrent.ThreadSynchronization	serverLock	Object used to synchronize threads when reading/writing the server message.

Fields inherited from class org.jppf.classloader.AbstractClassLoaderConnection

requestHandler, uuid

Fields inherited from class org.jppf.node.AbstractNodeConnection

channel, initializing, lock

Constructor Summary

Constructors

Constructor	Description
AsyncLocalClassLoaderConnection(String uuid, AsyncLocalNodeClassloaderContext channel)	Initialize this connection with the specified channel.

Method Summary

Modifier and Type	Method	Description
void	close()	Close this connection.
org.jppf.utils.concurrent.ThreadSynchronization	getNodeLock()	Get the object used to synchronize threads when reading/writing the node resource.
org.jppf.utils.concurrent.ThreadSynchronization	getServerLock()	Get the object used to synchronize threads when reading/writing the server resource.
void	init()	Initialize this connection.
String	toString()

Methods inherited from class org.jppf.classloader.AbstractClassLoaderConnection

getRequestHandler, loadResource, performCommonHandshake, reset, sendCloseChannelCommand

Methods inherited from class org.jppf.node.AbstractNodeConnection

getChannel

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jppf.node.NodeConnection

getChannel

Field Details

nodeLock

protected final org.jppf.utils.concurrent.ThreadSynchronization nodeLock

Object used to synchronize threads when reading/writing the node message.

serverLock

protected final org.jppf.utils.concurrent.ThreadSynchronization serverLock

Object used to synchronize threads when reading/writing the server message.

Constructor Details

AsyncLocalClassLoaderConnection

public AsyncLocalClassLoaderConnection(String uuid,
 AsyncLocalNodeClassloaderContext channel)

Initialize this connection with the specified channel.

Parameters:

uuid - this node's uuid.

channel - the communication channel with the driver.

Method Details

init

public void init()
          throws Exception

Description copied from interface: NodeConnection

Initialize this connection.

Throws:

Exception - if any error occurs.

close

public void close()

Description copied from interface: NodeConnection

Close this connection.

getNodeLock

public org.jppf.utils.concurrent.ThreadSynchronization getNodeLock()

Get the object used to synchronize threads when reading/writing the node resource.

Returns:

a ThreadSynchronization instance.

getServerLock

public org.jppf.utils.concurrent.ThreadSynchronization getServerLock()

Get the object used to synchronize threads when reading/writing the server resource.

Returns:

a ThreadSynchronization instance.

toString

public String toString()

Overrides:

toString in class AbstractClassLoaderConnection<AsyncLocalNodeClassloaderContext>