doc: Add serial to list of ci file reserved words
[charm.git] / src / ck-perf / trace-projectionsBOC.h
index c91d2e0a4b1552d0f2d1b1e6fb972dc5dab7bb0e..fd63e0b80a20589608d3cd91fccf84393afec0f5 100644 (file)
@@ -3,6 +3,8 @@
 #include "trace-common.h"
 #include "ckcallback-ccs.h"
 
 #include "trace-common.h"
 #include "ckcallback-ccs.h"
 
+#include <set>
+
 #ifndef PROJ_ANALYSIS
 // NOTE: Needed to handle the automatically-generated method so 
 //   trace-projections would build correctly while ignoring any of the 
 #ifndef PROJ_ANALYSIS
 // NOTE: Needed to handle the automatically-generated method so 
 //   trace-projections would build correctly while ignoring any of the 
@@ -129,6 +131,7 @@ class KMeansBOC : public CBase_KMeansBOC {
 class TraceProjectionsBOC : public CBase_TraceProjectionsBOC {
  private:
   bool findOutliers;
 class TraceProjectionsBOC : public CBase_TraceProjectionsBOC {
  private:
   bool findOutliers;
+  bool findStartTime;
 
   int parModulesRemaining;
 
 
   int parModulesRemaining;
 
@@ -136,11 +139,15 @@ class TraceProjectionsBOC : public CBase_TraceProjectionsBOC {
   double endTime;
   double analysisStartTime;
   int endPe;                          // end PE which calls CkExit()
   double endTime;
   double analysisStartTime;
   int endPe;                          // end PE which calls CkExit()
+  std::set<int> list;
+  int          flush_count;
  public:
  public:
- TraceProjectionsBOC(bool _findOutliers) : findOutliers(_findOutliers), parModulesRemaining(0), endPe(-1) {};
- TraceProjectionsBOC(CkMigrateMessage *m):CBase_TraceProjectionsBOC(m), parModulesRemaining(0), endPe(-1) {};
+ TraceProjectionsBOC(bool _findOutliers, bool _findStartTime) : findOutliers(_findOutliers), findStartTime(_findStartTime), parModulesRemaining(0), endPe(-1), flush_count(0) {};
+ TraceProjectionsBOC(CkMigrateMessage *m):CBase_TraceProjectionsBOC(m), parModulesRemaining(0), endPe(-1), flush_count(0) {};
 
   void traceProjectionsParallelShutdown(int);
 
   void traceProjectionsParallelShutdown(int);
+  void startTimeAnalysis();
+  void startTimeDone(CkReductionMsg *);
   void startEndTimeAnalysis();
   void endTimeDone(CkReductionMsg *);
   void kMeansDone(CkReductionMsg *);
   void startEndTimeAnalysis();
   void endTimeDone(CkReductionMsg *);
   void kMeansDone(CkReductionMsg *);
@@ -151,5 +158,8 @@ class TraceProjectionsBOC : public CBase_TraceProjectionsBOC {
   void closeParallelShutdown(CkReductionMsg *);
 
   void ccsOutlierRequest(CkCcsRequestMsg *);
   void closeParallelShutdown(CkReductionMsg *);
 
   void ccsOutlierRequest(CkCcsRequestMsg *);
+
+  void flush_warning(int pe);
+  void print_warning();
 };
 #endif
 };
 #endif