Home Research Papers Posters Manuals Talks Download People Help Internal

libs/ck-libs/pose/pvtobj.C

Go to the documentation of this file.

#include "pose.h"

void pvtObjectNode::sanitize() 
{
  if (present) {
    CmiAssert(ovt >= -1);
    CmiAssert(index >= 0);
    CmiAssert((sync == OPTIMISTIC) || (sync == CONSERVATIVE));
    CmiAssert((localObjPtr != NULL) && (localObjPtr->IsActive() < 2));
  }
}

pvtObjects::pvtObjects() 
{ 
  int i;
  numObjs = numSpaces = firstEmpty = stratIterCount = 0; 
  size = 100;
  if (!(objs = (pvtObjectNode *)malloc(100 * sizeof(pvtObjectNode)))) {
    CkPrintf("ERROR: pvtObjects::pvtObjects: OUT OF MEMORY!\n");
    CkExit();
  }
  for (i=0; i<size; i++) objs[i].set(POSE_UnsetTS, POSE_UnsetTS, false, 0, NULL);
}

int pvtObjects::Insert(int index, POSE_TimeType ovt, int sync, sim *myPtr)
{
  int idx;
  int i;
  if (numObjs < size) { // insert in empty space
    idx = firstEmpty;
    if (firstEmpty == numSpaces) // all spaces occupied up to end of list
      numSpaces++;  // use a previously unused space
    objs[idx].set(ovt, index, true, sync, myPtr);
    numObjs++;
    for (i=firstEmpty+1; i<size; i++)  // reset firstEmpty
      if (!objs[i].isPresent()) {
    firstEmpty = i;
    break;
      }
  }
  else { // no free spaces; expand objs
    firstEmpty = size;  // this is where firstEmpty will be after expansion
    size += 50;  // expand by 50
    if (!(objs = 
      (pvtObjectNode *)realloc(objs, size * sizeof(pvtObjectNode)))) {
      CkPrintf("ERROR: pvtObjects::Insert: OUT OF MEMORY!\n");
      CkExit();
    }
    for (i=firstEmpty; i<size; i++)  // initialize new slots to empty
      objs[i].set(POSE_UnsetTS, POSE_UnsetTS, false, 0, NULL);
    idx = firstEmpty;  // insert new object at firstEmpty
    objs[idx].set(ovt, index, true, sync, myPtr);
    numObjs++;
    numSpaces++;
    firstEmpty++;
  }   
  return idx;
}

void pvtObjects::callAtSync() {
  int i;
  for (i=0; i<numSpaces; i++)
    if (objs[i].isPresent()) {
      (objs[i].localObjPtr)->AtSync();
    }
}
void pvtObjects::Wake() {
  int i;
  for (i=0; i<numSpaces; i++)
    if (objs[i].isPresent()) (objs[i].localObjPtr)->Status();
}
void pvtObjects::Commit() {
  int i;
  for (i=0; i<numSpaces; i++)
    if (objs[i].isPresent()) (objs[i].localObjPtr)->Commit();
}
void pvtObjects::CheckpointCommit() {
  int i;
  for (i=0; i<numSpaces; i++)
    if (objs[i].isPresent()) (objs[i].localObjPtr)->CheckpointCommit();
}
void pvtObjects::StratCalcs() {
  // don't perform calculations every GVT iteration
  if (stratIterCount >= PVT_STRAT_CALC_PERIOD) {
    // calculate the average number of rollbacks per GVT iteration on
    // this PE (proportional to the fraction of posers on this PE) and
    // send to all strat objects
    long long totalRBs = 0LL;
    int poserCount = 0;
    for (int i = 0; i < numSpaces; i++) {
      if (objs[i].isPresent()) {
    totalRBs += (objs[i].localObjPtr)->basicStats[1];
    poserCount++;
      }
    }
    if (poserCount > 0) {
      GVT *localGVT = (GVT *)CkLocalBranch(TheGVT);
      // Each GVT iteration, a different GVT object computes the GVT and
      // increments its GVT iteration count, hence the need for the
      // number of PEs and the number of this PE to get the total GVT
      // iteration count.  GVT objects are cycled through, starting with 0.
      int gvtIterCount = localGVT->getGVTIterationCount() * CkNumPes() + CkMyPe();
      int avgRBsPerGVTIter = (int)((totalRBs * (long long)totalNumPosers) / ((long long)gvtIterCount * (long long)poserCount));
      for (int i = 0; i < numSpaces; i++) {
    // ensure each sim is present, and only update if using adapt5
    if (objs[i].isPresent() && (objs[i].localObjPtr->myStrat->STRAT_T == ADAPT5_T)) {
      ((adapt5 *)((objs[i].localObjPtr)->myStrat))->setAvgRBsPerGVTIter(avgRBsPerGVTIter);
    }
      }
    }
    stratIterCount = 0;
  } else {
    stratIterCount++;
  }
}

void pvtObjects::dump()
{
  int i;
  CkPrintf("numObjs=%d numSpaces=%d firstEmpty=%d size=%d\n", 
       numObjs, numSpaces, firstEmpty, size);
  for (i=0; i<numSpaces; i++) {
    CkPrintf("[%d] ", i);
    objs[i].dump();
    CkPrintf("\n");
  }
}

void pvtObjects::sanitize() 
{
  int i;
  CmiAssert(numObjs >= 0);
  CmiAssert(numSpaces >= 0);
  CmiAssert(size >= 0);
  CmiAssert(firstEmpty >= 0);
  CmiAssert(numObjs <= numSpaces);
  CmiAssert(numSpaces <= size);
  CmiAssert(firstEmpty < numSpaces);
  for (int i=0; i<numSpaces; i++) objs[i].sanitize();
}

---