Package org.jppf.node

Class AbstractNodeConnection<C>

java.lang.Object

org.jppf.node.AbstractNodeConnection<C>

Type Parameters:

C - the type of communication channel used by this connection.

All Implemented Interfaces:

NodeConnection<C>

Direct Known Subclasses:

AbstractClassLoaderConnection

public abstract class AbstractNodeConnection<C>
extends Object
implements NodeConnection<C>

Abstract impelementation of ClassLoaderConnection.

Author:

Laurent Cohen

Field Summary

Fields

Modifier and Type	Field	Description
protected C	channel	The channel used to communicate witht he driver.
protected final AtomicBoolean	initializing	Determines whether this connection is initializing.
protected final ReentrantLock	lock	Used to synchronize access to the communication channel from multiple threads.

Constructor Summary

Constructors

Constructor	Description
AbstractNodeConnection()

Method Summary

Modifier and Type	Method	Description
C	getChannel()	Get the communication channel for this connection.
void	reset()	Reset this connection.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jppf.node.NodeConnection

close, init

Field Details

channel

protected C channel

The channel used to communicate witht he driver.

lock

protected final ReentrantLock lock

Used to synchronize access to the communication channel from multiple threads.

initializing

protected final AtomicBoolean initializing

Determines whether this connection is initializing.

Constructor Details

AbstractNodeConnection

public AbstractNodeConnection()

Method Details

getChannel

public C getChannel()

Description copied from interface: NodeConnection

Get the communication channel for this connection.

Specified by:

getChannel in interface NodeConnection<C>

Returns:

an object representing the channel.

reset

public void reset()
           throws Exception

Description copied from interface: NodeConnection

Reset this connection.

Specified by:

reset in interface NodeConnection<C>

Throws:

Exception - if any error occurs.