Home Research Papers Posters Manuals Talks Download People Help Internal

libs/ck-libs/pose/gvt.h

Go to the documentation of this file.

#ifndef GVT_H
#define GVT_H
#include "gvt.decl.h"

#define OPTIMISTIC 0
#define CONSERVATIVE 1

extern CkGroupID ThePVT;  
extern CkGroupID TheGVT;

class SRtable;  // from srtable.h
class SRentry;  // from srtable.h

void POSE_sumGVTIterations(void *param, void *msg); 


class UpdateMsg : public CMessage_UpdateMsg {
public:

  POSE_TimeType optPVT;
  POSE_TimeType conPVT;
  POSE_TimeType maxSR;
  SRentry *SRs;
  int numEntries;
  int inactive;
  POSE_TimeType inactiveTime;
  int nextLB;
  int runGVTflag;
};

class GVTMsg : public CMessage_GVTMsg {
public:
  POSE_TimeType estGVT;
  int done;
};

class prioBcMsg : public CMessage_prioBcMsg {
public:
  int bc;
};


class PVT : public Group {
 private:
#if !CMK_TRACE_DISABLED
  localStat *localStats;
#endif
  POSE_TimeType optPVT;
  POSE_TimeType conPVT;
  POSE_TimeType estGVT;       
  POSE_TimeType repPVT;       
  int simdone;
  POSE_TimeType iterMin;

  int waitForFirst;
  SRtable *SendsAndRecvs;            
  pvtObjects objs;           
  int reportTo, reportsExpected, reportReduceTo, reportEnd;
  int gvtTurn;
  int specEventCount, eventCount;
  int startPhaseActive;
  double parStartTime;
  int parCheckpointInProgress;
  POSE_TimeType parLastCheckpointGVT;
  int parLBInProgress;
  POSE_TimeType parLastLBGVT;
  double parLastCheckpointTime;
  /* things which used to be member function statics */
  POSE_TimeType optGVT, conGVT;
  int rdone;
  SRentry *SRs;
#ifdef MEM_TEMPORAL
  TimePool *localTimePool;
#endif
  //  int debugBufferLoc, debugBufferWrapped, debugBufferDumped;
  //  char debugBuffer[NUM_PVT_DEBUG_BUFFER_LINES][PVT_DEBUG_BUFFER_LINE_LENGTH];

 public:
  PVT(void);
  PVT(CkMigrateMessage *msg) : Group(msg) { };
  void pup(PUP::er &p);
  ~PVT() { }
  void startPhase(prioBcMsg *m);             
  void startPhaseExp(prioBcMsg *m);             

  void setGVT(GVTMsg *m);            
  void beginCheckpoint(eventMsg *m);
  void resumeAfterCheckpoint(eventMsg *m);
  void beginLoadbalancing(eventMsg *m);
  void resumeAfterLB(eventMsg *m);
  void callAtSync();
  void doneLB();

  inline POSE_TimeType getGVT() { return estGVT; }    

  inline int getSpecEventCount() { return specEventCount; }    
  inline int getEventCount() { return eventCount; }    
  inline void incSpecEventCount() { specEventCount++; }    
  inline void incEventCount() { eventCount++; }
  inline void decEventCount() { eventCount--; }
  inline int done() { return simdone; }
  int objRegister(int arrIdx, POSE_TimeType safeTime, int sync, sim *myPtr);
  void objRemove(int pvtIdx);
  void objUpdate(POSE_TimeType timestamp, int sr); 
  void objUpdateOVT(int pvtIdx, POSE_TimeType safeTime, POSE_TimeType ovt);
  void reportReduce(UpdateMsg *);
  void addSR(SRentry **SRs, SRentry *e, POSE_TimeType og, int ne);
  inline int getNumObjs() { return objs.getNumObjs(); }
/*
  inline void dumpDebugBuffer() {
    int endLoc;
    if (!debugBufferDumped) {
      debugBufferDumped = 1;
      if (debugBufferLoc == 0) {
    endLoc = NUM_PVT_DEBUG_BUFFER_LINES - 1;
      } else {
    endLoc = debugBufferLoc - 1;
      }
      if (debugBufferWrapped) {
    int j = 0;
    for (int i = debugBufferLoc; i < NUM_PVT_DEBUG_BUFFER_LINES; i++) {
      CkPrintf("{%5d} %s", j, debugBuffer[i]);
      j++;
    }
    if (debugBufferLoc != 0) {
      for (int i = 0; i <= endLoc; i++) {
        CkPrintf("{%5d} %s", j, debugBuffer[i]);
        j++;
      }
    }
      } else {
    for (int i = 0; i <= endLoc; i++) {
      CkPrintf("{%5d} %s", i, debugBuffer[i]);
    }
      }
    }
  }
  inline void printDebug(char *str) {
    strcpy(debugBuffer[debugBufferLoc], str);
    debugBufferLoc++;
    if (debugBufferLoc >= NUM_PVT_DEBUG_BUFFER_LINES) {
      debugBufferLoc = 0;
      debugBufferWrapped = 1;
    }
  }
*/
};


class GVT : public Group { 
private:
#if !CMK_TRACE_DISABLED
  localStat *localStats;
#endif
  POSE_TimeType estGVT; 
  int inactive;
  POSE_TimeType inactiveTime;
  int nextLBstart; 
  POSE_TimeType lastEarliest;
  int lastSends;
  int lastRecvs;
  int reportsExpected;
  /* things which used to be member function static */
  POSE_TimeType optGVT, conGVT;
  int done;
  SRentry *SRs;
  int startOffset;
public:
  /* This count is contributed to a summation reduction upon
     simulation completion for printout during one of the POSE exit
     functions */
  int gvtIterationCount;

  GVT(void);
  GVT(CkMigrateMessage *msg) : Group(msg) { };
  void pup(PUP::er &p);
  inline int getGVTIterationCount() { return gvtIterationCount; }
  //Use this for Ccd calls
  //static void _runGVT(UpdateMsg *);
  inline void sumGVTIterationCounts() {
    contribute(sizeof(int), &gvtIterationCount, CkReduction::sum_int, CkCallback(POSE_sumGVTIterations, NULL));
  }

  void runGVT(UpdateMsg *);
  void computeGVT(UpdateMsg *); 
  void addSR(SRentry **SRs, SRentry *e, POSE_TimeType og, int ne);
};

#endif

---