public class IOPortEvent extends java.lang.Object implements DebugEvent
In Kepler the provenance recorder and the activity monitor use these events to save intermediate results / show status of the workflow. In the future these events could be used for "smart" reruns or a fault tolerance mechanism.
| Modifier and Type | Field and Description |
|---|---|
static int |
ALLCHANNELS
The token was broadcast on all channels.
|
static int |
GET_BEGIN
An event corresponding with the beginning of a token being received.
|
static int |
GET_END
An event corresponding with the ending of a token being received.
|
static int |
SEND
Deprecated.
Use SEND_BEGIN or SEND_END instead.
|
static int |
SEND_BEGIN
An event corresponding with the beginning of a token being sent.
|
static int |
SEND_END
An event corresponding with the ending of a token being sent.
|
static int |
SINGLETOKEN
A single token related event in getVectorLength().
|
| Constructor and Description |
|---|
IOPortEvent(IOPort port,
int event,
int channel,
boolean outside,
Token token)
Create a new port event with the given parameters.
|
IOPortEvent(IOPort port,
int event,
int channel,
boolean outside,
Token[] tokens,
int vectorLength)
Create a new port event with the given parameters.
|
IOPortEvent(IOPort port,
IOPort receiverPort,
boolean isBegin,
int channel,
boolean outside,
Token token)
Create a new port event with the given parameters.
|
| Modifier and Type | Method and Description |
|---|---|
int |
getChannel()
Return the channel on which the token was sent or received.
|
int |
getEventType()
Return the type of event.
|
boolean |
getOutsideFlag()
Return the flag indicating that the event related to the port's outside
activity (true) or to its inside activity.
|
IOPort |
getPort()
Return the port where the event occurred.
|
IOPort |
getReceiverPort()
Return the receiver's port if this event represents a token put directly
into a receiver instead of transferred via IOPort send or sendInside.
|
NamedObj |
getSource()
Return the port that caused this event.
|
Token |
getToken()
Return the token that was sent or received by the IOPort.
|
Token[] |
getTokenArray()
Return the array of tokens that the IOPort sent or received.
|
int |
getVectorLength()
Return the number of tokens in the array sent by the IOPort.
|
java.lang.String |
toString()
Return a string representation of this event.
|
@Deprecated public static final int SEND
public static final int SEND_BEGIN
public static final int GET_BEGIN
public static final int GET_END
public static final int SEND_END
public static final int ALLCHANNELS
public static final int SINGLETOKEN
public IOPortEvent(IOPort port, int event, int channel, boolean outside, Token[] tokens, int vectorLength)
port - The IOPort where the event occurred.event - The type of event.channel - Channel the token was sent/received on. Use
IOPortEvent.ALLCHANNELS to indicate a broadcast event.outside - True if the event is related the port's outside
activity, false if the event is related to the port's inside
activity.tokens - The token array used for the send/receive.vectorLength - The number of tokens sent/received.public IOPortEvent(IOPort port, int event, int channel, boolean outside, Token token)
port - The IOPort where the event occurredevent - The type of event.channel - Channel the token was sent/received on. Use
IOPortEvent.ALLCHANNELS to indicate a broadcast event.outside - True if the event is related the port's outside
activity, false if the event is related to the port's inside
activity.token - The token that was sent/received.public IOPortEvent(IOPort port, IOPort receiverPort, boolean isBegin, int channel, boolean outside, Token token)
port - The IOPort where the event occurredreceiverPort - The IOPort of the receiver.isBegin - True if this event is the start.channel - Channel the token was transferred on.outside - True if the event is related the port's outside
activity, false if the event is related to the port's inside
activity.token - The token that was transferred.public NamedObj getSource()
getSource in interface DebugEventpublic int getChannel()
public IOPort getReceiverPort()
public int getEventType()
public boolean getOutsideFlag()
public IOPort getPort()
public Token getToken()
public Token[] getTokenArray()
public int getVectorLength()
public java.lang.String toString()
toString in interface DebugEventtoString in class java.lang.Object