nptl/sysdeps/unix/sysv/solaris2/kopensolaris-gnu/createthread.c

   1 /* Copyright (C) 2002, 2003, 2004, 2006, 2007, 2008
   2     Free Software Foundation, Inc.
   3    This file is part of the GNU C Library.
   4    Contributed by Ulrich Drepper <drepper@redhat.com>, 2002.
   5    OpenSolaris bits contributed by David Bartley
   6     <dtbartle@csclub.uwaterloo.ca>, 2008.
   7
   8    The GNU C Library is free software; you can redistribute it and/or
   9    modify it under the terms of the GNU Lesser General Public
  10    License as published by the Free Software Foundation; either
  11    version 2.1 of the License, or (at your option) any later version.
  12
  13    The GNU C Library is distributed in the hope that it will be useful,
  14    but WITHOUT ANY WARRANTY; without even the implied warranty of
  15    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  16    Lesser General Public License for more details.
  17
  18    You should have received a copy of the GNU Lesser General Public
  19    License along with the GNU C Library; if not, write to the Free
  20    Software Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
  21    02111-1307 USA.  */
  22
  23 #include <tls.h>
  24 #include <ucontext.h>
  25 #include <sys/segments.h>
  26 #include <sys/stack.h>
  27 #include <sys/stack.h>
  28 #include <sys/regset.h>
  29 #include <sys/segments.h>
  30 #include <inline-syscall.h>
  31 #include <sched_priv.h>
  32 #include <createthread_arch.c>
  33
  34 DECLARE_INLINE_SYSCALL (int, lwp_create, ucontext_t *ucp, int flags,
  35     pthread_t *new_lwp);
  36 DECLARE_INLINE_SYSCALL (int, lwp_continue, pthread_t lwpid);
  37 DECLARE_INLINE_SYSCALL (int, lwp_kill, pthread_t lwpid, int sig);
  38
  39 #ifndef TLS_MULTIPLE_THREADS_IN_TCB
  40 /* Pointer to the corresponding variable in libc.  */
  41 int *__libc_multiple_threads_ptr attribute_hidden;
  42 #endif
  43
  44 static int
  45 create_thread (struct pthread *pd, const struct pthread_attr *attr,
  46                STACK_VARIABLES_PARMS)
  47 {
  48 #ifdef TLS_TCB_AT_TP
  49   assert (pd->header.tcb != NULL);
  50 #endif
  51
  52   /* Do arch-specific creation.  */
  53   ucontext_t ctx = {0};
  54   int errval = create_thread_arch (&ctx, pd, attr, STACK_VARIABLES_ARGS);
  55   if (errval != 0)
  56     return errval;
  57
  58   /* One more thread.  We cannot have the thread do this itself, since it
  59      might exist but not have been scheduled yet by the time we've returned
  60      and need to check the value to behave correctly.  We must do it before
  61      creating the thread, in case it does get scheduled first and then
  62      might mistakenly think it was the only thread.  In the failure case,
  63      we momentarily store a false value; this doesn't matter because there
  64      is no kosher thing a signal handler interrupting us right here can do
  65      that cares whether the thread count is correct.  */
  66   atomic_increment (&__nptl_nthreads);
  67
  68   /* We set the thread to be initially suspended so that we can set
  69      scheduling magic.  */
  70   int lwp_flags =
  71       ((attr->flags & ATTR_FLAG_DAEMON) ? THR_DAEMON : 0) |
  72       ((attr->flags & ATTR_FLAG_DETACHSTATE) ? THR_DETACHED : 0);
  73   if (attr->flags & ATTR_FLAG_THR_CREATE == 0)
  74     lwp_flags |= THR_SUSPENDED;
  75   errval = INLINE_SYSCALL (lwp_create, 3, &ctx, lwp_flags, &pd->tid);
  76   if (errval == 0 && (attr->flags & ATTR_FLAG_THR_CREATE) == 0)
  77     {
  78       /* Set scheduling.  */
  79       if (attr->flags & (ATTR_FLAG_SCHED_SET | ATTR_FLAG_POLICY_SET))
  80         {
  81           int policy, priority;
  82           errval = __sched_getscheduler_id (P_LWPID, pd->tid,
  83             &policy, &priority);
  84           if (errval == 0)
  85             {
  86               if (attr->flags & ATTR_FLAG_SCHED_SET)
  87                 priority = attr->schedparam.__sched_priority;
  88               if (attr->flags & ATTR_FLAG_POLICY_SET)
  89                 policy = attr->schedpolicy;
  90
  91               errval = __sched_setscheduler_id (P_LWPID, pd->tid,
  92                 policy, priority);
  93             }
  94
  95           if (errval != 0)
  96             errval = EPERM;
  97         }
  98
  99       /* Resume thread if requested.  */
 100       if (errval == 0)
 101         {
 102           if (!(attr->flags & ATTR_FLAG_SUSPENDED))
 103             errval = INLINE_SYSCALL (lwp_continue, 1, pd->tid);
 104         }
 105
 106       /* Kill the thread if we didn't succeed above.  */
 107       if (errval != 0)
 108         INLINE_SYSCALL (lwp_kill, 2, pd->tid, SIGKILL);
 109     }
 110
 111   if (errval != 0)
 112     {
 113       atomic_decrement (&__nptl_nthreads); /* Oops, we lied for a second.  */
 114
 115       /* Failed.  If the thread is detached, remove the TCB here since
 116          the caller cannot do this.  The caller remembered the thread
 117          as detached and cannot reverify that it is not since it must
 118          not access the thread descriptor again.  */
 119       if (IS_DETACHED (pd))
 120         __deallocate_stack (pd);
 121     }
 122
 123   return errval;
 124 }