
#include <completion.h>


Public Member Functions | |
| CompletionDetector () | |
| void | produce (int events_produced=1) |
| void | consume (int events_consumed=1) |
| void | done (int producers_done=1) |
Private Member Functions | |
| void | init () |
Private Attributes | |
| int | produced |
| int | consumed |
| int | unconsumed |
| int | producers_total |
| int | producers_done_local |
| int | producers_done_global |
| int | prio |
| bool | running |
Definition at line 6 of file completion.h.
| CompletionDetector::CompletionDetector | ( | ) |
| void CompletionDetector::produce | ( | int | events_produced = 1 |
) |
Definition at line 18 of file completion.C.
References produced.
Referenced by ArrayMeshStreamer< dtype, itype >::insertData().
| void CompletionDetector::consume | ( | int | events_consumed = 1 |
) |
Definition at line 22 of file completion.C.
References consumed.
Referenced by ArrayMeshStreamer< dtype, itype >::localDeliver(), GroupMeshStreamer< dtype >::receiveAtDestination(), and MeshStreamerArrayClient< dtype >::receiveRedeliveredItem().
| void CompletionDetector::done | ( | int | producers_done = 1 |
) |
Definition at line 26 of file completion.C.
References producers_done_local.
Referenced by MeshStreamer< ArrayDataItem< dtype, itype > >::done().
| void CompletionDetector::init | ( | void | ) | [private] |
Definition at line 9 of file completion.C.
References consumed, produced, producers_done_global, producers_done_local, producers_total, running, and unconsumed.
Referenced by CompletionDetector().
int CompletionDetector::produced [private] |
int CompletionDetector::consumed [private] |
int CompletionDetector::unconsumed [private] |
int CompletionDetector::producers_total [private] |
int CompletionDetector::producers_done_local [private] |
int CompletionDetector::producers_done_global [private] |
int CompletionDetector::prio [private] |
Definition at line 20 of file completion.h.
bool CompletionDetector::running [private] |
1.5.5