Blame sysdeps/unix/sysv/linux/timer_create.c

Packit Service 82fcde
/* Copyright (C) 2003-2018 Free Software Foundation, Inc.
Packit Service 82fcde
   This file is part of the GNU C Library.
Packit Service 82fcde
   Contributed by Ulrich Drepper <drepper@redhat.com>, 2003.
Packit Service 82fcde
Packit Service 82fcde
   The GNU C Library is free software; you can redistribute it and/or
Packit Service 82fcde
   modify it under the terms of the GNU Lesser General Public License as
Packit Service 82fcde
   published by the Free Software Foundation; either version 2.1 of the
Packit Service 82fcde
   License, or (at your option) any later version.
Packit Service 82fcde
Packit Service 82fcde
   The GNU C Library is distributed in the hope that it will be useful,
Packit Service 82fcde
   but WITHOUT ANY WARRANTY; without even the implied warranty of
Packit Service 82fcde
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
Packit Service 82fcde
   Lesser General Public License for more details.
Packit Service 82fcde
Packit Service 82fcde
   You should have received a copy of the GNU Lesser General Public
Packit Service 82fcde
   License along with the GNU C Library; see the file COPYING.LIB.  If
Packit Service 82fcde
   not, see <http://www.gnu.org/licenses/>.  */
Packit Service 82fcde
Packit Service 82fcde
#include <errno.h>
Packit Service 82fcde
#include <pthread.h>
Packit Service 82fcde
#include <signal.h>
Packit Service 82fcde
#include <stdlib.h>
Packit Service 82fcde
#include <string.h>
Packit Service 82fcde
#include <time.h>
Packit Service 82fcde
#include <sysdep.h>
Packit Service 82fcde
#include <internaltypes.h>
Packit Service 82fcde
#include <nptl/pthreadP.h>
Packit Service 82fcde
#include "kernel-posix-timers.h"
Packit Service 82fcde
#include "kernel-posix-cpu-timers.h"
Packit Service 82fcde
Packit Service 82fcde
Packit Service 82fcde
#ifdef timer_create_alias
Packit Service 82fcde
# define timer_create timer_create_alias
Packit Service 82fcde
#endif
Packit Service 82fcde
Packit Service 82fcde
Packit Service 82fcde
int
Packit Service 82fcde
timer_create (clockid_t clock_id, struct sigevent *evp, timer_t *timerid)
Packit Service 82fcde
{
Packit Service 82fcde
#undef timer_create
Packit Service 82fcde
  {
Packit Service 82fcde
    clockid_t syscall_clockid = (clock_id == CLOCK_PROCESS_CPUTIME_ID
Packit Service 82fcde
				 ? MAKE_PROCESS_CPUCLOCK (0, CPUCLOCK_SCHED)
Packit Service 82fcde
				 : clock_id == CLOCK_THREAD_CPUTIME_ID
Packit Service 82fcde
				 ? MAKE_THREAD_CPUCLOCK (0, CPUCLOCK_SCHED)
Packit Service 82fcde
				 : clock_id);
Packit Service 82fcde
Packit Service 82fcde
    /* If the user wants notification via a thread we need to handle
Packit Service 82fcde
       this special.  */
Packit Service 82fcde
    if (evp == NULL
Packit Service 82fcde
	|| __builtin_expect (evp->sigev_notify != SIGEV_THREAD, 1))
Packit Service 82fcde
      {
Packit Service 82fcde
	struct sigevent local_evp;
Packit Service 82fcde
Packit Service 82fcde
	/* We avoid allocating too much memory by basically
Packit Service 82fcde
	   using struct timer as a derived class with the
Packit Service 82fcde
	   first two elements being in the superclass.  We only
Packit Service 82fcde
	   need these two elements here.  */
Packit Service 82fcde
	struct timer *newp = (struct timer *) malloc (offsetof (struct timer,
Packit Service 82fcde
								thrfunc));
Packit Service 82fcde
	if (newp == NULL)
Packit Service 82fcde
	  /* No more memory.  */
Packit Service 82fcde
	  return -1;
Packit Service 82fcde
Packit Service 82fcde
	if (evp == NULL)
Packit Service 82fcde
	  {
Packit Service 82fcde
	    /* The kernel has to pass up the timer ID which is a
Packit Service 82fcde
	       userlevel object.  Therefore we cannot leave it up to
Packit Service 82fcde
	       the kernel to determine it.  */
Packit Service 82fcde
	    local_evp.sigev_notify = SIGEV_SIGNAL;
Packit Service 82fcde
	    local_evp.sigev_signo = SIGALRM;
Packit Service 82fcde
	    local_evp.sigev_value.sival_ptr = newp;
Packit Service 82fcde
Packit Service 82fcde
	    evp = &local_evp;
Packit Service 82fcde
	  }
Packit Service 82fcde
Packit Service 82fcde
	kernel_timer_t ktimerid;
Packit Service 82fcde
	int retval = INLINE_SYSCALL (timer_create, 3, syscall_clockid, evp,
Packit Service 82fcde
				     &ktimerid);
Packit Service 82fcde
Packit Service 82fcde
	if (retval != -1)
Packit Service 82fcde
	  {
Packit Service 82fcde
	    newp->sigev_notify = (evp != NULL
Packit Service 82fcde
				  ? evp->sigev_notify : SIGEV_SIGNAL);
Packit Service 82fcde
	    newp->ktimerid = ktimerid;
Packit Service 82fcde
Packit Service 82fcde
	    *timerid = (timer_t) newp;
Packit Service 82fcde
	  }
Packit Service 82fcde
	else
Packit Service 82fcde
	  {
Packit Service 82fcde
	    /* Cannot allocate the timer, fail.  */
Packit Service 82fcde
	    free (newp);
Packit Service 82fcde
	    retval = -1;
Packit Service 82fcde
	  }
Packit Service 82fcde
Packit Service 82fcde
	return retval;
Packit Service 82fcde
      }
Packit Service 82fcde
    else
Packit Service 82fcde
      {
Packit Service 82fcde
	/* Create the helper thread.  */
Packit Service 82fcde
	pthread_once (&__helper_once, __start_helper_thread);
Packit Service 82fcde
	if (__helper_tid == 0)
Packit Service 82fcde
	  {
Packit Service 82fcde
	    /* No resources to start the helper thread.  */
Packit Service 82fcde
	    __set_errno (EAGAIN);
Packit Service 82fcde
	    return -1;
Packit Service 82fcde
	  }
Packit Service 82fcde
Packit Service 82fcde
	struct timer *newp;
Packit Service 82fcde
	newp = (struct timer *) malloc (sizeof (struct timer));
Packit Service 82fcde
	if (newp == NULL)
Packit Service 82fcde
	  return -1;
Packit Service 82fcde
Packit Service 82fcde
	/* Copy the thread parameters the user provided.  */
Packit Service 82fcde
	newp->sival = evp->sigev_value;
Packit Service 82fcde
	newp->thrfunc = evp->sigev_notify_function;
Packit Service 82fcde
	newp->sigev_notify = SIGEV_THREAD;
Packit Service 82fcde
Packit Service 82fcde
	/* We cannot simply copy the thread attributes since the
Packit Service 82fcde
	   implementation might keep internal information for
Packit Service 82fcde
	   each instance.  */
Packit Service 82fcde
	(void) pthread_attr_init (&newp->attr);
Packit Service 82fcde
	if (evp->sigev_notify_attributes != NULL)
Packit Service 82fcde
	  {
Packit Service 82fcde
	    struct pthread_attr *nattr;
Packit Service 82fcde
	    struct pthread_attr *oattr;
Packit Service 82fcde
Packit Service 82fcde
	    nattr = (struct pthread_attr *) &newp->attr;
Packit Service 82fcde
	    oattr = (struct pthread_attr *) evp->sigev_notify_attributes;
Packit Service 82fcde
Packit Service 82fcde
	    nattr->schedparam = oattr->schedparam;
Packit Service 82fcde
	    nattr->schedpolicy = oattr->schedpolicy;
Packit Service 82fcde
	    nattr->flags = oattr->flags;
Packit Service 82fcde
	    nattr->guardsize = oattr->guardsize;
Packit Service 82fcde
	    nattr->stackaddr = oattr->stackaddr;
Packit Service 82fcde
	    nattr->stacksize = oattr->stacksize;
Packit Service 82fcde
	  }
Packit Service 82fcde
Packit Service 82fcde
	/* In any case set the detach flag.  */
Packit Service 82fcde
	(void) pthread_attr_setdetachstate (&newp->attr,
Packit Service 82fcde
					    PTHREAD_CREATE_DETACHED);
Packit Service 82fcde
Packit Service 82fcde
	/* Create the event structure for the kernel timer.  */
Packit Service 82fcde
	struct sigevent sev =
Packit Service 82fcde
	  { .sigev_value.sival_ptr = newp,
Packit Service 82fcde
	    .sigev_signo = SIGTIMER,
Packit Service 82fcde
	    .sigev_notify = SIGEV_SIGNAL | SIGEV_THREAD_ID,
Packit Service 82fcde
	    ._sigev_un = { ._pad = { [0] = __helper_tid } } };
Packit Service 82fcde
Packit Service 82fcde
	/* Create the timer.  */
Packit Service 82fcde
	INTERNAL_SYSCALL_DECL (err);
Packit Service 82fcde
	int res;
Packit Service 82fcde
	res = INTERNAL_SYSCALL (timer_create, err, 3,
Packit Service 82fcde
				syscall_clockid, &sev, &newp->ktimerid);
Packit Service 82fcde
	if (! INTERNAL_SYSCALL_ERROR_P (res, err))
Packit Service 82fcde
	  {
Packit Service 82fcde
	    /* Add to the queue of active timers with thread
Packit Service 82fcde
	       delivery.  */
Packit Service 82fcde
	    pthread_mutex_lock (&__active_timer_sigev_thread_lock);
Packit Service 82fcde
	    newp->next = __active_timer_sigev_thread;
Packit Service 82fcde
	    __active_timer_sigev_thread = newp;
Packit Service 82fcde
	    pthread_mutex_unlock (&__active_timer_sigev_thread_lock);
Packit Service 82fcde
Packit Service 82fcde
	    *timerid = (timer_t) newp;
Packit Service 82fcde
	    return 0;
Packit Service 82fcde
	  }
Packit Service 82fcde
Packit Service 82fcde
	/* Free the resources.  */
Packit Service 82fcde
	free (newp);
Packit Service 82fcde
Packit Service 82fcde
	__set_errno (INTERNAL_SYSCALL_ERRNO (res, err));
Packit Service 82fcde
Packit Service 82fcde
	return -1;
Packit Service 82fcde
      }
Packit Service 82fcde
  }
Packit Service 82fcde
}