#include <QBox.h>
This object is passed to a QBox's runImpl() method and contains information specific to a particular invocation of the box, e.g., how many tuples to process.
Public Member Functions | |
QBoxInvocation () | |
unsigned int | getMaxTuplesToDequeue (unsigned int input_port) const |
Return the maximum tuples that should be dequeued on a particular input port. | |
bool | continueDequeueOn (QBox::DeqIterator deq, unsigned int input_port) const |
Should the caller continue to process tuples from a particular input? Guaranteed to return false if !deq.avail(). | |
unsigned long | ticks () const |
Public Attributes | |
unsigned int | _tuples_dequeued |
QBox * | _box |
vector< unsigned int > | _tuple_limit |
unsigned long | _end_time |
unsigned long | _last_ticks |
unsigned int | _next_tick |
Static Public Attributes | |
const int | CALLS_BETWEEN_TICK = 1 |
|
|
|
Should the caller continue to process tuples from a particular input? Guaranteed to return false if !deq.avail().
|
|
Return the maximum tuples that should be dequeued on a particular input port. Deprecated (use continueDequeueOn instead). |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|