Package | Description |
---|---|
org.jcsp.lang |
This provides classes and interfaces corresponding to the fundamental
primitives of CSP.
|
org.jcsp.net |
This is main package for JCSP.NET.
|
org.jcsp.net.cns |
This package contains the files specifically for the
JCSP.NET Channel Name Service (CNS).
|
org.jcsp.net.dynamic |
Supports dynamic operations over the JCSP.NET infrastructure.
|
org.jcsp.net2 | |
org.jcsp.util.filter |
This defines filtering channels that can apply transformations to objects
as they are read and/or written.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
Any2OneChannelImpl<T>
This implements an any-to-one object channel,
safe for use by many writers and one reader.
|
(package private) class |
Any2OneImpl<T> |
(package private) class |
BufferedAny2OneChannel<T>
This implements an any-to-one object channel with user-definable buffering,
safe for use by many writers and one reader.
|
(package private) class |
PoisonableAny2OneChannelImpl<T> |
(package private) class |
PoisonableBufferedAny2OneChannel<T> |
Modifier and Type | Field and Description |
---|---|
private Any2OneChannel<T> |
Any2AnyConnectionImpl.chanClientSynch |
private Any2OneChannel<T> |
Any2AnyConnectionImpl.chanServerSynch |
private Any2OneChannel |
Any2OneConnectionImpl.chanSynch |
private Any2OneChannel<T> |
One2AnyConnectionImpl.chanSynch |
Modifier and Type | Method and Description |
---|---|
static <T> Any2OneChannel<T> |
Channel.any2one()
This constructs an Object carrying channel that
may be connected to any number of writer processes,
but only one reader at a time.
|
static <T> Any2OneChannel<T> |
Channel.any2one(ChannelDataStore<T> buffer)
This constructs an any-one Object channel with user chosen buffering size and policy.
|
static <T> Any2OneChannel<T> |
Channel.any2one(ChannelDataStore<T> buffer,
int immunity)
This constructs a buffered poisonable any-one Object channel.
|
static <T> Any2OneChannel<T> |
Channel.any2one(int immunity)
This constructs a poisonable any-one Object channel.
|
static <T> Any2OneChannel<T>[] |
Channel.any2oneArray(int size)
This constructs an array of any-one Object channels.
|
static <T> Any2OneChannel<T>[] |
Channel.any2oneArray(int size,
ChannelDataStore<T> buffer)
This constructs an array of buffered any-one Object channels.
|
static <T> Any2OneChannel<T>[] |
Channel.any2oneArray(int size,
ChannelDataStore<T> buffer,
int immunity)
This constructs an array of buffered poisonable any-one Object channels.
|
static <T> Any2OneChannel<T>[] |
Channel.any2oneArray(int size,
int immunity)
This constructs an array of poisonable any-one Object channels.
|
Any2OneChannel<T> |
StandardChannelFactory.createAny2One()
Constructs and returns an
Any2OneChannel object. |
Any2OneChannel<T> |
ChannelFactory.createAny2One()
Deprecated.
Creates a new
Any2One channel. |
static Any2OneChannel |
Channel.createAny2One()
Deprecated.
Use the
Channel.any2one() method instead. |
static Any2OneChannel |
Channel.createAny2One(ChannelDataStore buffer)
Deprecated.
Use the
Channel.any2one(ChannelDataStore) method instead. |
Any2OneChannel<T> |
StandardChannelFactory.createAny2One(ChannelDataStore<T> buffer)
Constructs and returns a
Any2OneChannel object which
uses the specified ChannelDataStore object as a buffer. |
Any2OneChannel<T> |
BufferedChannelFactory.createAny2One(ChannelDataStore<T> buffer)
Deprecated.
Creates a new
Any2One channel with the given buffering behaviour. |
Any2OneChannel<T>[] |
StandardChannelFactory.createAny2One(ChannelDataStore<T> buffer,
int n)
Constructs and returns an array of
Any2OneChannel objects
which use the specified ChannelDataStore object as a
buffer. |
Any2OneChannel<T>[] |
BufferedChannelArrayFactory.createAny2One(ChannelDataStore<T> buffer,
int n)
Deprecated.
Creates a populated array of
n Any2One channels with the specified
buffering behaviour. |
static Any2OneChannel[] |
Channel.createAny2One(ChannelDataStore buffer,
int n)
Deprecated.
Use the
Channel.any2oneArray(int,ChannelDataStore) method instead. |
Any2OneChannel<T>[] |
StandardChannelFactory.createAny2One(int n)
Constructs and returns an array of
Any2OneChannel
objects. |
Any2OneChannel<T>[] |
ChannelArrayFactory.createAny2One(int n)
Deprecated.
Creates a populated array of
n Any2One channels. |
static Any2OneChannel[] |
Channel.createAny2One(int n)
Deprecated.
Use the
Channel.any2oneArray(int) method instead. |
Modifier and Type | Method and Description |
---|---|
static <T> AltingChannelInput<T>[] |
Channel.getInputArray(Any2OneChannel<T>[] c)
This extracts the input-ends from the given channel array.
|
static <T> SharedChannelOutput<T>[] |
Channel.getOutputArray(Any2OneChannel<T>[] c)
This extracts the output-ends from the given channel array.
|
Modifier and Type | Field and Description |
---|---|
Any2OneChannel |
IndexManager.ChannelAndIndex.channel |
private Any2OneChannel |
LinkManager.checkForLink |
(package private) static Any2OneChannel |
One2NetChannel.failedLinks |
private Any2OneChannel |
LinkManager.getNodeIDChan |
private Any2OneChannel |
LinkManager.linkFailureChan |
private Any2OneChannel |
LinkManager.lostLinkChan |
private Any2OneChannel |
LinkManager.registerEventChannel |
private Any2OneChannel |
LinkManager.requestLink |
private Any2OneChannel |
NetChannelInputProcess.stopChannel |
private Any2OneChannel |
NetSharedAltingConnectionClient.synchChan |
private Any2OneChannel |
NetSharedConnectionServerImpl.synchChan |
Constructor and Description |
---|
ChannelAndIndex(Any2OneChannel channel,
long index) |
NetSharedAltingConnectionClient(Any2OneChannel synchChan,
NetAltingChannelInput fromServer,
NetChannelOutput openToServer,
NetChannelOutput reqToServer,
NetChannelOutput backToClient)
Constructor for NetSharedAltingConnectionClient.
|
NetSharedConnectionServerImpl(Any2OneChannel synchChan,
NetAltingChannelInput in)
Constructor for NetSharedConnectionServerImpl.
|
Modifier and Type | Field and Description |
---|---|
private Any2OneChannel |
CNSService.deregisterRequestChan |
private Any2OneChannel |
CNSService.leaseRequestChan |
private Any2OneChannel |
CNSService.registerRequestChan |
private Any2OneChannel |
CNSService.resolveRequestChan
Channels used to send requests to the service process
|
private Any2OneChannel |
CNS.stopChan |
private Any2OneChannel |
CNSService.stopChan |
Modifier and Type | Field and Description |
---|---|
private Any2OneChannel |
JFTP.classNotify
Child processes spawned to load classes from disk or from another node pass the loaded data on
this channel to the main process fror forwarding to the requesting clients.
|
private Any2OneChannel |
JFTP.classQueue
Child processes spawned to load classes from Java archives will create additional requests on
this channel to queue other files from the archive to be sent to a client.
|
private Any2OneChannel |
ClassManager.classRegChan
Used to pass requests to the main process thread from calls to the
registerClass
method. |
private Any2OneChannel |
ClassManager.classReqs
Used to pass requests to the main process thread from calls to the
getClass method. |
Modifier and Type | Field and Description |
---|---|
private Any2OneChannel |
Link.txChannel
The channel connected to the Link Tx process.
|
Modifier and Type | Interface and Description |
---|---|
interface |
FilteredAny2OneChannel
Interface for an Any2One channel that supports filtering operations at each end.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
FilteredAny2OneChannelImpl
This wraps up an Any2OneChannel object so that its
input and output ends are separate objects.
|
Modifier and Type | Method and Description |
---|---|
Any2OneChannel |
FilteredChannelFactory.createAny2One()
Creates a new Any2One channel with the filtering options set for this factory.
|
Any2OneChannel |
FilteredChannelFactory.createAny2One(ChannelDataStore buffer)
Creates a new Any2One channel with the filtering options set for this factory and the specified
data buffer.
|
Any2OneChannel[] |
FilteredChannelFactory.createAny2One(ChannelDataStore buffer,
int n)
Constructs and returns an array of
Any2OneChannel
objects with a given buffering behaviour. |
Any2OneChannel[] |
FilteredChannelFactory.createAny2One(int n)
Constructs and returns an array of
Any2OneChannel
objects. |
Constructor and Description |
---|
FilteredAny2OneChannelImpl(Any2OneChannel chan)
Constructs a new filtered channel over the top of an existing channel.
|