Method postRestart

src/dmtcpworker.cpp:524–551

}

void
DmtcpWorker::postRestart(double ckptReadTime)
{
  JTRACE("begin postRestart()");
  WorkerState::setCurrentState(WorkerState::RESTARTING);

  JTRACE("Waiting for Restart barrier");
  CoordinatorAPI::waitForBarrier("DMT:Restart");

  PluginManager::eventHook(DMTCP_EVENT_RESTART);

  JTRACE("got resume message after restart");

  {
    // Send ckpt maps to coordinator.
    string workerPath("/worker/" + ProcessInfo::instance().upidStr());
    ProcSelfMaps procSelfMaps;
    kvdb::set(
      workerPath,
      "ProcSelfMaps_Rst",
      procSelfMaps.getData());
  }

  // Inform Coordinator of RUNNING state.
  WorkerState::setCurrentState(WorkerState::RUNNING);
  JTRACE("Informing coordinator of RUNNING status") (UniquePid::ThisProcess());
  CoordinatorAPI::sendMsgToCoordinator(DMT_WORKER_RESUMING);
}