Method waitForAllRestored

src/threadlist.cpp:699–749

* * Wait for all threads to finish restoring their context, then release them * all to continue on their way. * *****************************************************************************/

 *
 *****************************************************************************/
void
ThreadList::waitForAllRestored(Thread *thread)
{
  if (thread == ckptThread) {
    int i;
    for (i = 0; i < numUserThreads; i++) {
      sem_wait(&semNotifyCkptThread);
    }

    // Now that all threads have been created, restore the signal handler. We
    // need to do it before calling DmtcpWorker::postRestart() because that
    // routine will invoke restart hooks for all plugins. Some of the plugins
    // might perform tasks that could potentially generate a signal. For
    // example, the timer plugin may restore a timer which will fire right away,
    // and not having an appropriate signal handler could kill the process.
    SigInfo::restoreSigHandlers();

    JTRACE("before DmtcpWorker::postRestart()");

    DmtcpWorker::postRestart(thread->ckptReadTime);

    JTRACE("after DmtcpWorker::postRestart()");

    /* raise the signals which were pending for the entire process at the time
     * of checkpoint. It is assumed that if a signal is pending for all threads
     * including the ckpt-thread, then it was sent to the process as opposed to
     * sent to individual threads.
     */
    for (i = SIGRTMAX; i > 0; --i) {
      if (sigismember(&sigpending_global, i) == 1) {
        kill(getpid(), i);
      }
    }

    // if this was last of all, wake everyone up
    for (i = 0; i < numUserThreads; i++) {
      sem_post(&semWaitForCkptThreadSignal);
    }
  } else {
    sem_post(&semNotifyCkptThread);
    sem_wait(&semWaitForCkptThreadSignal);
  }

  PluginManager::eventHook(DMTCP_EVENT_THREAD_RESUME);

  Thread_RestoreSigState(thread);

  if (thread == motherofall) {
    DMTCP_RESTART_PAUSE_WHILE(restartPauseLevel == 7);
  }
}

/*****************************************************************************
 *