Function timer_create_sigev_thread

src/plugin/timer/timer_create.cpp:81–142

}

LIB_PRIVATE
int
timer_create_sigev_thread(clockid_t clock_id,
                          struct sigevent *evp,
                          timer_t *timerid,
                          struct sigevent *sevOut)
{
  /* If the user wants notification via a thread we need to handle
     this special.  */
  JASSERT(evp == NULL || evp->sigev_notify == SIGEV_THREAD);

  /* Create the helper thread.  */
  pthread_once(&helper_once, start_helper_thread);
  sem_wait(&helper_notification);
  if (helper_tid == 0) {
    /* No resources to start the helper thread.  */
    errno = EAGAIN;
    return -1;
  }

  struct timer *newp;
  newp = (struct timer *)JALLOC_MALLOC(sizeof(struct timer));
  if (newp == NULL) {
    return -1;
  }

  /* Copy the thread parameters the user provided.  */
  newp->sival = evp->sigev_value;
  newp->thrfunc = evp->sigev_notify_function;
  newp->sigev_notify = SIGEV_THREAD;

  /* We cannot simply copy the thread attributes since the
     implementation might keep internal information for
     each instance.  */
  (void)pthread_attr_init(&newp->attr);

  // TODO: Copy attributes from evp->sigev_notify_attributes to newp->attr.

  /* In any case set the detach flag.  */
  (void)pthread_attr_setdetachstate(&newp->attr, PTHREAD_CREATE_DETACHED);

  /* Create the event structure for the kernel timer.  */
  sevOut->sigev_value.sival_ptr = newp;
  sevOut->sigev_signo = SIGTIMER;
  sevOut->sigev_notify = SIGEV_SIGNAL | SIGEV_THREAD_ID;
  sevOut->_sigev_un._tid = helper_tid;

  /* Create the timer.  */
  int res = _real_timer_create(clock_id, sevOut, timerid);
  if (res == 0) {
    /* Add to the queue of active timers with thread delivery.  */
    DmtcpMutexLock(&active_timer_sigev_thread_lock);
    newp->next = active_timer_sigev_thread;
    active_timer_sigev_thread = newp;
    DmtcpMutexUnlock(&active_timer_sigev_thread_lock);
    return 0;
  }