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 DebugEvent
public 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 DebugEvent
toString
in class java.lang.Object