Method wrapperExecutionLockLock

src/threadsync.cpp:159–182

}

void
ThreadSync::wrapperExecutionLockLock()
{
  int saved_errno = errno;

  // The process is still initializing. We don't need to acquire lock.
  if (WorkerState::currentState() == WorkerState::UNKNOWN) {
    return;
  }

  Thread *thread = dmtcp_get_current_thread();

  if (thread->wrapperLockCount == 0) {
    // If we don't have a lock, acquire it now.
    if (DmtcpRWLockRdLock(&_wrapperExecutionLock) != 0) {
      fprintf(stderr, "ERROR %d at %s:%d %s: Failed to acquire lock\n",
              errno, __FILE__, __LINE__, __PRETTY_FUNCTION__);
      _exit(DMTCP_FAIL_RC);
    }
  }
  thread->wrapperLockCount++;

  errno = saved_errno;
}

void
ThreadSync::wrapperExecutionLockLockForNewThread(Thread *thread)