#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] |