Class Any2AnyConnectionImpl<T>

java.lang.Object

org.jcsp.lang.AbstractConnectionImpl

org.jcsp.lang.Any2AnyConnectionImpl<T>

All Implemented Interfaces:

Any2AnyConnection<T>, ConnectionWithSharedAltingClient<T>, ConnectionWithSharedAltingServer<T>

class Any2AnyConnectionImpl<T>
extends AbstractConnectionImpl
implements Any2AnyConnection<T>

This class is an implementation of Any2AnyConnection. Each end is safe to be used by one thread at a time.

Nested Class Summary

Nested classes/interfaces inherited from class AbstractConnectionImpl

AbstractConnectionImpl.NonSingleRequestOpenMsg

Field Summary

Fields

Modifier and Type	Field	Description
private Any2OneChannel<T>	chanClientSynch
private One2OneChannel<T>	chanFromServer
private Any2OneChannel<T>	chanServerSynch
private One2OneChannel<T>	chanToServer

Fields inherited from class AbstractConnectionImpl

CLIENT_STATE_CLOSED, CLIENT_STATE_MADE_REQ, CLIENT_STATE_OPEN, nonSingleRequestMsg, SERVER_STATE_CLOSED, SERVER_STATE_OPEN, SERVER_STATE_RECEIVED

Constructor Summary

Constructors

Constructor	Description
Any2AnyConnectionImpl()	Initializes all the attributes to necessary values.

Method Summary

Modifier and Type	Method	Description
SharedAltingConnectionClient	client()	Returns a SharedAltingConnectionClient object for this connection.
SharedConnectionServer	server()	Returns a SharedConnectionServer object for this connection.

Methods inherited from class Object

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

Field Details

chanToServer

private One2OneChannel<T> chanToServer

chanFromServer

private One2OneChannel<T> chanFromServer

chanClientSynch

private Any2OneChannel<T> chanClientSynch

chanServerSynch

private Any2OneChannel<T> chanServerSynch

Constructor Details

Any2AnyConnectionImpl

public Any2AnyConnectionImpl()

Initializes all the attributes to necessary values. Channels are created using the static factory in the ChannelServer inteface. Constructor for One2OneConnectionImpl.

Method Details

client

public SharedAltingConnectionClient client()

Returns a SharedAltingConnectionClient object for this connection. This method can be called multiple times to return a new SharedAltingConnectionClient object each time. Any object created can only be used by one process at a time but the set of objects constructed can be used concurrently.

Specified by:

client in interface Any2AnyConnection<T>

Specified by:

client in interface ConnectionWithSharedAltingClient<T>

Returns:

a new SharedAltingConnectionClient object.

server

public SharedConnectionServer server()

Returns a SharedConnectionServer object for this connection. This method can be called multiple times to return a new SharedConnectionServer object each time. Any object created can only be used by one process at a time but the set of objects constructed can be used concurrently.

Specified by:

server in interface Any2AnyConnection<T>

Specified by:

server in interface ConnectionWithSharedAltingServer<T>

Returns:

a new SharedConnectionServer object.