Package org.jcsp.net

Class NetChannelInputProcess

java.lang.Object

org.jcsp.net.NetChannelInputProcess

All Implemented Interfaces:

CSProcess

class NetChannelInputProcess
extends Object
implements CSProcess

A process for network input (RX).

This is a package-private implementation class.

Field Summary

Fields

Modifier and Type	Field	Description
private ChannelMessage.Ack	ackA
private ChannelMessage.Ack	ackB
private Alternative	alt
private ChannelID	channelID	Our channel ID.
private long	channelIndex	Our channel index.
private AltingChannelInput	fromNetIn	The channel we use for recieving from the demuxes.
private SharedChannelOutput	fromNetOut
private String	name	The name of this channel.
private RejectableChannel	out	The channel used for output.
private boolean	sendAckA
private Any2OneChannel	stopChannel

Constructor Summary

Constructors

Constructor	Description
NetChannelInputProcess(String label, RejectableChannel out)	Constructor which takes a label to assign to the channel's VCN and a ChannelOutput object on which to output any data received from over the network.

Method Summary

Modifier and Type	Method	Description
(package private) void	breakChannel()
(package private) long	getChannelIndex()
private Object	readFromNetChannel()	Reads a message from the network communications channel.
void	run()	Handle this link.

Methods inherited from class java.lang.Object

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

Field Details

channelIndex

private long channelIndex

Our channel index.

channelID

private ChannelID channelID

Our channel ID.

name

private String name

The name of this channel.

fromNetIn

private AltingChannelInput fromNetIn

The channel we use for recieving from the demuxes.

fromNetOut

private SharedChannelOutput fromNetOut

out

private RejectableChannel out

The channel used for output.

stopChannel

private Any2OneChannel stopChannel

alt

private Alternative alt

ackA

private transient ChannelMessage.Ack ackA

ackB

private transient ChannelMessage.Ack ackB

sendAckA

private transient boolean sendAckA

Constructor Details

NetChannelInputProcess

NetChannelInputProcess(String label,
 RejectableChannel out)

Constructor which takes a label to assign to the channel's VCN and a ChannelOutput object on which to output any data received from over the network.

Parameters:

label - the label to assign to the VCN. If this is null then no label will be assigned.

out - the ChannelOutput object on which to forward any data received from over the network.

Method Details

breakChannel

void breakChannel()

getChannelIndex

long getChannelIndex()

readFromNetChannel

private Object readFromNetChannel()

Reads a message from the network communications channel. Acknowledges and ignores LinkLost messages.

Returns:

The first Message read from the network.

run

public void run()

Handle this link. Gets data and sends acknowlegements. Runs forever.

Specified by:

run in interface CSProcess