{@link TCPPacketReceiver} decomposes TCP packets containing PTIDES events.
* *
* This actor consumes one input token and creates a stream of output tokens, each with
* the timestamp specified as a part of the token.>/p?
*
* @author Ilge Akkaya
* @version $Id: TCPPacketReceiver.java 70402 2014-10-23 00:52:20Z cxh $
* @since Ptolemy II 10.0
* @Pt.ProposedRating
* @Pt.AcceptedRating
*/
public class TCPPacketReceiver extends InputDevice {
/** Construct a TCPPacketReceiver.
* @param container the container of the TCPPacketReceiver.
* @param name the name of the TCPPacketReceiver.
* @exception IllegalActionException If the TCPPacketReceiver cannot be constructed.
* @exception NameDuplicationException If there is a name collision.
*/
public TCPPacketReceiver(CompositeEntity container, String name)
throws IllegalActionException, NameDuplicationException {
super(container, name);
input = new TypedIOPort(this, "input", true, false);
output = new TypedIOPort(this, "output", false, true);
input.setTypeEquals(BaseType.RECORD);
//output.setTypeEquals(BaseType.DOUBLE);
}
///////////////////////////////////////////////////////////////////
//// ports and parameters ////
/** The input port, which is a record type. */
public TypedIOPort input;
/** The output port. */
public TypedIOPort output;
///////////////////////////////////////////////////////////////////
//// public methods ////
/** Decompose RecordToken into its components.
* @exception IllegalActionException If thrown by the super cass or
* if there are problems decomposing the record.
*/
@Override
public void fire() throws IllegalActionException {
super.fire();
Director director = getDirector();
if (director == null || !(director instanceof PtidesDirector)) {
throw new IllegalActionException(this, "Director expected to"
+ "be a Ptides director, but it's not.");
}
PtidesDirector ptidesDirector = (PtidesDirector) director;
// consume input
if (input.hasToken(0)) {
RecordToken fullTCPFrame = (RecordToken) input.get(0);
//RecordToken TCPHeader = (RecordToken) fullTCPFrame.get(TCPlabel);
RecordToken dataContent = (RecordToken) fullTCPFrame.get(tokens);
if (fullTCPFrame.labelSet().size() != 2) {
throw new IllegalActionException(
"the input record token has a size not equal to 2: "
+ "Here we assume the Record is of types: TCPHeader + tokens");
}
//if (record.get(payload).length == BaseType.RECORD)
// produce different events for each token within the record
//RecordToken payloadToken = (RecordToken)record.get(payload);
// make sure the TCPFrameTransmitter wraps the event labels with name "payloadLabels"
Iterator pLabels = dataContent.labelSet().iterator();
// send all the received tokens to the outputs according to their timestamps
while (pLabels.hasNext()) {
ptidesDirector.getModelTime();
ptidesDirector.getMicrostep();
String singleEventLabel = (String) pLabels.next();
//String singleEventLabel = Integer.toString(i);
RecordToken singleEventRecord = (RecordToken) dataContent
.get(singleEventLabel);
new Time(getDirector(),
((DoubleToken) singleEventRecord.get(timestamp))
.doubleValue());
((IntToken) singleEventRecord.get(microstep)).intValue();
if (output != null) {
// FIXME setTag not supported in Ptides director
//ptidesDirector.setTag(tokenTimestamp, tokenMicrostep);
output.send(0, singleEventRecord.get(payload));
}
//ptidesDirector.setTag(lastModelTime, lastMicrostep);
}
}
//ptidesDirector.setTag(lastModelTime, lastMicrostep);
}
/** Perform a check to see if this device is connected to a network
* port on the outside. If not, throw an exception. Also call
* preinitialize of the super class.
* @exception IllegalActionException If there are no outside source
* ports, or if any of the outside source ports is not a network
* port.
*/
@Override
public void preinitialize() throws IllegalActionException {
super.preinitialize();
boolean flag = false;
for (TypedIOPort input : inputPortList()) {
for (IOPort sourcePort : input.sourcePortList()) {
if (sourcePort.getContainer() == getContainer()) {
flag = true;
}
}
}
if (!flag) {
throw new IllegalActionException(
this,
"A NetworkReceiver must be connected to a port "
+ "on the outside, and that port should be a network port "
+ "(a port with the parameter networkPort).");
}
}
///////////////////////////////////////////////////////////////////
//// protected methods ////
/** Do not establish the usual default type constraints.
* @return null
*/
@Override
protected Set