Package org.jcsp.net2

Class NetAltingConnectionServer

java.lang.Object

org.jcsp.lang.Guard

org.jcsp.lang.AltingConnectionServer

org.jcsp.net2.NetAltingConnectionServer

All Implemented Interfaces:

ConnectionServer, NetConnectionServer, Networked

public final class NetAltingConnectionServer
extends AltingConnectionServer
implements NetConnectionServer

Field Summary

Fields

Modifier and Type	Field	Description
private final ConnectionData	data
private final NetworkMessageFilter.FilterRx	inputFilter
private final NetworkMessage	lastRead
private final Link	linkConnectedTo
private final NetConnectionLocation	location
private final AltingChannelInput	openIn
private final NetworkMessageFilter.FilterTx	outputFilter
private final AltingChannelInput	requestIn

Fields inherited from interface org.jcsp.lang.ConnectionServer

FACTORY

Constructor Summary

Constructors

Modifier	Constructor	Description
private	NetAltingConnectionServer(AltingChannelInput openChan, AltingChannelInput requestChan, ConnectionData connData, NetworkMessageFilter.FilterRx filterRX, NetworkMessageFilter.FilterTx filterTX)

Method Summary

Modifier and Type	Method	Description
(package private) static NetAltingConnectionServer	create(int index, NetworkMessageFilter.FilterRx filterRX, NetworkMessageFilter.FilterTx filterTX)
(package private) static NetAltingConnectionServer	create(NetworkMessageFilter.FilterRx filterRX, NetworkMessageFilter.FilterTx filterTX)
void	destroy()	Destroys the Networked construct
NetLocation	getLocation()	Gets the networked location of the Networked construct
void	reply(Object data)	Sends some data back to the client after a request has been received but keeps the connection open.
void	reply(Object data, boolean close)	Sends some data back to the client after a request has been received.
void	replyAndClose(Object data)	Sends some data back to the client and closes the connection.
Object	request()	Receives a request from a client.

Methods inherited from class org.jcsp.lang.AltingConnectionServer

getAltingChannel, pending, setAltingChannel

Methods inherited from class org.jcsp.lang.Guard

schedule

Methods inherited from class java.lang.Object

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

Field Details

requestIn

private final AltingChannelInput requestIn

openIn

private final AltingChannelInput openIn

location

private final NetConnectionLocation location

inputFilter

private final NetworkMessageFilter.FilterRx inputFilter

outputFilter

private final NetworkMessageFilter.FilterTx outputFilter

data

private final ConnectionData data

lastRead

private final NetworkMessage lastRead

linkConnectedTo

private final Link linkConnectedTo

Constructor Details

NetAltingConnectionServer

private NetAltingConnectionServer(AltingChannelInput openChan,
 AltingChannelInput requestChan,
 ConnectionData connData,
 NetworkMessageFilter.FilterRx filterRX,
 NetworkMessageFilter.FilterTx filterTX)
                           throws JCSPNetworkException

Throws:

JCSPNetworkException

Method Details

create

static NetAltingConnectionServer create(int index,
 NetworkMessageFilter.FilterRx filterRX,
 NetworkMessageFilter.FilterTx filterTX)
                                 throws IllegalArgumentException

Throws:

IllegalArgumentException

create

static NetAltingConnectionServer create(NetworkMessageFilter.FilterRx filterRX,
 NetworkMessageFilter.FilterTx filterTX)

destroy

public void destroy()

Description copied from interface: Networked

Destroys the Networked construct

Specified by:

destroy in interface Networked

getLocation

public NetLocation getLocation()

Description copied from interface: Networked

Gets the networked location of the Networked construct

Specified by:

getLocation in interface Networked

Returns:

The location of the construct

reply

public void reply(Object data,
 boolean close)
           throws IllegalStateException

Description copied from interface: ConnectionServer

Sends some data back to the client after a request has been received. The boolean close parameter indicates whether the connection should be closed after this reply has been sent.

This method should not block.

Specified by:

reply in interface ConnectionServer

Parameters:

data - the data to send back to client.

close - boolean that should be true iff the connection should be dropped after the reply has been sent.

Throws:

IllegalStateException

reply

public void reply(Object data)
           throws IllegalStateException

Description copied from interface: ConnectionServer

Sends some data back to the client after a request has been received but keeps the connection open. After calling this method, the server should call recieve() to receive a further request.

A call to this method is equivalent to a call to reply(Object, boolean) with the boolean set to false.

Specified by:

reply in interface ConnectionServer

Parameters:

data - the data to send to the client.

Throws:

IllegalStateException

replyAndClose

public void replyAndClose(Object data)
                   throws IllegalStateException

Description copied from interface: ConnectionServer

Sends some data back to the client and closes the connection.

A call to this method is equivalent to a call to reply(Object, boolean) with the boolean set to true.

Specified by:

replyAndClose in interface ConnectionServer

Parameters:

data - the data to send back to client.

Throws:

IllegalStateException

request

public Object request()
               throws IllegalStateException

Description copied from interface: ConnectionServer

Receives a request from a client. This will block until the client calls its request(Object) method. Implementations may make this ALTable.

After this method has returned, the server should call one of the reply methods. Performing any external process synchronization between these method calls could be potentially hazardous and could lead to deadlock.

Specified by:

request in interface ConnectionServer

Returns:

the Object sent by the client.

Throws:

IllegalStateException