00001 #include "completion.h" 00002 00003 CompletionDetector::CompletionDetector() 00004 { 00005 __sdag_init(); 00006 init(); 00007 } 00008 00009 void CompletionDetector::init() { 00010 producers_total = 0; 00011 producers_done_local = producers_done_global = 0; 00012 produced = 0; 00013 consumed = 0; 00014 running = false; 00015 unconsumed = 1; // Nonsense value, for loop below 00016 } 00017 00018 void CompletionDetector::produce(int events_produced) { 00019 produced += events_produced; 00020 } 00021 00022 void CompletionDetector::consume(int events_consumed) { 00023 consumed += events_consumed; 00024 } 00025 00026 void CompletionDetector::done(int producers_done) { 00027 producers_done_local += producers_done; 00028 } 00029 00030 #include "completion.def.h"
1.5.5