Method postCheckpoint

src/dmtcpworker.cpp:456–522

}

void
DmtcpWorker::postCheckpoint()
{
  // Send ckpt maps to coordinator.
  string workerPath("/worker/" + ProcessInfo::instance().upidStr());

  jalib::JAllocArena *arenas;
  int numArenas = 0;
  {
    jalib::JAlloc::getAllocArenas(&arenas, &numArenas);
    ostringstream o;
    for (int i = 0; i < numArenas; i++) {
      if (arenas[i].startAddr != NULL) {
        o << std::hex << (uint64_t) arenas[i].startAddr
          << "-" << (uint64_t) arenas[i].endAddr
          << " " << ((uint64_t)arenas[i].endAddr - (uint64_t)arenas[i].startAddr) << "\n";
      }
    }

    kvdb::set(workerPath, "ProcSelfMaps_JAllocArenas", o.str());
  }

#ifndef FORKED_CHECKPOINTING
  {
    kvdb::set(
      workerPath,
      "ProcSelfMaps_Ckpt",
      procSelfMaps->getData());
  }
#endif

  WorkerState::setCurrentState(WorkerState::CHECKPOINTED);

  // TODO: Merge this barrier with the previous `sendCkptFilename` msg.
  JTRACE("Waiting for Write-Ckpt barrier");
  CoordinatorAPI::waitForBarrier("DMT:WriteCkpt");

  // NOTE:  If FORKED_CHECKPOINTING, the grandchild may still be checkpointing.
  //        Grandchild process will do renaming and inform coordinator.
  if (getenv(ENV_VAR_FORKED_CKPT) == NULL) { 
    /* Now that temp checkpoint file is complete, rename it over old permanent
     * checkpoint file.  Uses rename() syscall, which doesn't change i-nodes.
     * So, gzip process can continue to write to file even after renaming.
     */
    JASSERT(rename(ProcessInfo::instance().getTempCkptFilename().c_str(),
                   ProcessInfo::instance().getCkptFilename().c_str()) == 0);
    CoordinatorAPI::sendCkptFilename();
  } else { // else FORKED CHECKPOINTING.  Write temp name; grandchild not done.
    string ckptFilename = ProcessInfo::instance().getCkptFilename();
    ProcessInfo::instance().setCkptFilename(
                       ProcessInfo::instance().getTempCkptFilename().c_str());
    CoordinatorAPI::sendCkptFilename();
    ProcessInfo::instance().setCkptFilename(ckptFilename.c_str());
  }

  if (exitAfterCkpt) {
    JTRACE("Asked to exit after checkpoint. Exiting!");
    _exit(0);