Home Research Papers Posters Manuals Talks Download People Help Internal

libs/ck-libs/pose/event.C

Go to the documentation of this file.

#include "pose.h"

Event::Event() :   spawnedList(NULL),msg (NULL), commitBfr(NULL),cpData(NULL),
           serialCPdataSz(0), serialCPdata(NULL),
           next(NULL),prev(NULL), commitBfrLen(0), commitErr(0),
           done (0),   fnIdx(-1),  timestamp(POSE_UnsetTS),
           srt(0.0), svt (0)
{ 

}

Event::~Event() 
{                                   
  SpawnedEvent *tmp;
  //  double start=CmiWallTimer();
  delete msg;
  //double elapsed=CmiWallTimer()-start;
  //if (elapsed>50e-6)
  //CkPrintf("delete msg(%p) took %.6f\n", (void *)msg,elapsed);
  if (commitBfr) free(commitBfr);
  while (spawnedList) {  // purge list of spawned events
    tmp = spawnedList;
    spawnedList = spawnedList->next;
    delete tmp;
  }
  // NOTE: cpData and serialCPdata are deleted in evq::Commit
}

void Event::pup(PUP::er &p) 
{
  int msgSize, spawn = 0;
  SpawnedEvent *tmp = NULL;
  
  evID.pup(p); p(fnIdx); p(timestamp); p(done); p(commitBfrLen); p(commitErr);
  p(srt); p(ert); p(svt); p(evt);
  // commitBfr
  if (p.isUnpacking() && (commitBfrLen > 0)) { // unpack non-empty commitBfr
    commitBfr = new char[commitBfrLen];
    p(commitBfr, commitBfrLen);
  }
  else if (commitBfrLen > 0) // pack/size non-empty commitBfr
    p(commitBfr, commitBfrLen);
  else // unpack empty commitBfr
    commitBfr = NULL;
  
  // msg
  if (p.isUnpacking()) { // unpack msg
    p(msgSize); // unpack msgSize
    if (msgSize > 0) { // if nonzero, unpack msg
      msg = (eventMsg *)CmiAlloc(msgSize); // allocate space
      p((char *)msg, msgSize); // unpack into space
      msg = (eventMsg *)EnvToUsr((envelope *)msg); // reset msg pointer
    }
    else // empty message
      msg = NULL; // set msg to null
  }
  else { // pack msg
    if (msg != NULL) { // msg is not null
      msgSize = (UsrToEnv(msg))->getTotalsize(); // get msg size
      p(msgSize); // pack msg size
      p((char *)(UsrToEnv(msg)), msgSize); // pack from start of envelope
    }
    else { // msg is null
      msgSize = 0;                           
      p(msgSize); // pack size of zero
    }
  }
  
  // spawnedList
  if (p.isUnpacking()) { // unpack spawnedList
    p(spawn); // unpack spawn count
    if (spawn > 0) spawnedList = tmp = new SpawnedEvent();
    else spawnedList = NULL;
    while (spawn > 0) { // unpack each spawned event record
      tmp->pup(p);
      tmp->next = NULL;
      spawn--;
      if (spawn > 0) {
    tmp->next = new SpawnedEvent();
    tmp = tmp->next;
      }
    }
  }
  else { // pack/size spawnedList
    tmp = spawnedList;
    while (tmp != NULL) { // count the spawn
      spawn++;
      tmp = tmp->next;
    }
    p(spawn); // pack the spawn count
    tmp = spawnedList;
    while (tmp != NULL) { // pack each spawn
      tmp->pup(p);
      tmp = tmp->next;
    }
  }
  
  if (p.isUnpacking()) {
    cpData = NULL; // to be set later
    serialCPdata = NULL;
    serialCPdataSz = 0;
  }
}

void Event::sanitize()
{
  if ((fnIdx != -99) && (fnIdx != -100)) {
    evID.sanitize();   
    msg->sanitize();
    // check fnIdx... not clear how
    // check timestamp... not clear how
    CmiAssert((done == 0) || (done == 1) || (done == 2));
    CmiAssert((commitErr == 0) || (commitErr == 1));
    CmiAssert(((commitBfrLen == 0) && (commitBfr == NULL)) ||
          ((commitBfrLen > 0) && (commitBfr != NULL)));
    //CmiAssert(next->prev == this);
    //CmiAssert(prev->next == this);
  }
}

---