
#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 | ( | ) |
Definition at line 3 of file completion.C.
References init().

| void CompletionDetector::produce | ( | int | events_produced = 1 |
) |
Definition at line 17 of file completion.C.
References produced.
Referenced by ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::broadcast(), MeshStreamer< dtype >::broadcast(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::insertData(), and MeshStreamer< dtype >::insertData().

| void CompletionDetector::consume | ( | int | events_consumed = 1 |
) |
Definition at line 21 of file completion.C.
References consumed.
Referenced by ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::localBroadcast(), GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::localDeliver(), ArrayMeshStreamer< dtype, itype, ClientType, RouterType, EntryMethod >::localDeliver(), GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::localDeliver(), GroupChunkMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::receiveAtDestination(), and GroupMeshStreamer< dtype, ClientType, RouterType, EntryMethod >::receiveAtDestination().

| void CompletionDetector::done | ( | int | producers_done = 1 |
) |
Definition at line 25 of file completion.C.
References producers_done_local.
Referenced by MeshStreamer< dtype >::done().

| void CompletionDetector::init | ( | void | ) | [private] |
Definition at line 8 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