123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955 |
- #include <features.h>
- #include <errno.h>
- #include <sched.h>
- #include <stddef.h>
- #include <stdio.h>
- #include <stdlib.h>
- #include <string.h>
- #include <unistd.h>
- #include <sys/poll.h> /* for poll */
- #include <sys/mman.h> /* for mmap */
- #include <sys/param.h>
- #include <sys/time.h>
- #include <sys/wait.h> /* for waitpid macros */
- #include "pthread.h"
- #include "internals.h"
- #include "spinlock.h"
- #include "restart.h"
- #include "semaphore.h"
- #include "debug.h"
- #ifndef THREAD_STACK_OFFSET
- #define THREAD_STACK_OFFSET 0
- #endif
- #include <sys/syscall.h>
- #ifndef __NR_poll
- # define USE_SELECT
- #endif
- #ifndef MAP_FIXED_NOREPLACE
- #define MAP_FIXED_NOREPLACE 0
- #endif
- struct pthread_handle_struct __pthread_handles[PTHREAD_THREADS_MAX] =
- { { __LOCK_INITIALIZER, &__pthread_initial_thread, 0},
- { __LOCK_INITIALIZER, &__pthread_manager_thread, 0}, };
- const int __linuxthreads_pthread_threads_max = PTHREAD_THREADS_MAX;
- int __pthread_nonstandard_stacks;
- volatile int __pthread_handles_num = 2;
- volatile int __pthread_threads_debug;
- volatile td_thr_events_t __pthread_threads_events;
- volatile pthread_descr __pthread_last_event;
- static __inline__ pthread_descr thread_segment(int seg)
- {
- return (pthread_descr)(THREAD_STACK_START_ADDRESS - (seg - 1) * STACK_SIZE)
- - 1;
- }
- static volatile int terminated_children = 0;
- static int main_thread_exiting = 0;
- static pthread_t pthread_threads_counter = 0;
- static int pthread_handle_create(pthread_t *thread, const pthread_attr_t *attr,
- void * (*start_routine)(void *), void *arg,
- sigset_t *mask, int father_pid,
- int report_events,
- td_thr_events_t *event_maskp);
- static void pthread_handle_free(pthread_t th_id);
- static void pthread_handle_exit(pthread_descr issuing_thread, int exitcode) attribute_noreturn;
- static void pthread_reap_children(void);
- static void pthread_kill_all_threads(int sig, int main_thread_also);
- int attribute_noreturn __pthread_manager(void *arg)
- {
- int reqfd = (int) (long int) arg;
- #ifdef USE_SELECT
- struct timeval tv;
- fd_set fd;
- #else
- struct pollfd ufd;
- #endif
- sigset_t manager_mask;
- int n;
- struct pthread_request request;
-
- #ifdef INIT_THREAD_SELF
- INIT_THREAD_SELF(&__pthread_manager_thread, 1);
- #endif
-
- __pthread_manager_thread.p_errnop = &__pthread_manager_thread.p_errno;
- __pthread_manager_thread.p_h_errnop = &__pthread_manager_thread.p_h_errno;
- #ifdef __UCLIBC_HAS_XLOCALE__
-
- __pthread_manager_thread.locale = __global_locale;
- #endif
-
- __sigfillset(&manager_mask);
- sigdelset(&manager_mask, __pthread_sig_cancel);
- sigdelset(&manager_mask, SIGTRAP);
- if (__pthread_threads_debug && __pthread_sig_debug > 0)
- sigdelset(&manager_mask, __pthread_sig_debug);
- sigprocmask(SIG_SETMASK, &manager_mask, NULL);
-
- __pthread_manager_adjust_prio(__pthread_main_thread->p_priority);
-
- n = TEMP_FAILURE_RETRY(read(reqfd, (char *)&request,
- sizeof(request)));
- #ifndef USE_SELECT
- ufd.fd = reqfd;
- ufd.events = POLLIN;
- #endif
-
- while(1) {
- #ifdef USE_SELECT
- tv.tv_sec = 2;
- tv.tv_usec = 0;
- FD_ZERO (&fd);
- FD_SET (reqfd, &fd);
- n = select (reqfd + 1, &fd, NULL, NULL, &tv);
- #else
- PDEBUG("before poll\n");
- n = poll(&ufd, 1, 2000);
- PDEBUG("after poll\n");
- #endif
-
- if (getppid() == 1) {
- pthread_kill_all_threads(SIGKILL, 0);
- _exit(0);
- }
-
- if (terminated_children) {
- terminated_children = 0;
- pthread_reap_children();
- }
-
- #ifdef USE_SELECT
- if (n == 1)
- #else
- if (n == 1 && (ufd.revents & POLLIN))
- #endif
- {
- PDEBUG("before read\n");
- n = read(reqfd, (char *)&request, sizeof(request));
- PDEBUG("after read, n=%d\n", n);
- switch(request.req_kind) {
- case REQ_CREATE:
- PDEBUG("got REQ_CREATE\n");
- request.req_thread->p_retcode =
- pthread_handle_create((pthread_t *) &request.req_thread->p_retval,
- request.req_args.create.attr,
- request.req_args.create.fn,
- request.req_args.create.arg,
- &request.req_args.create.mask,
- request.req_thread->p_pid,
- request.req_thread->p_report_events,
- &request.req_thread->p_eventbuf.eventmask);
- PDEBUG("restarting %p\n", request.req_thread);
- restart(request.req_thread);
- break;
- case REQ_FREE:
- PDEBUG("got REQ_FREE\n");
- pthread_handle_free(request.req_args.free.thread_id);
- break;
- case REQ_PROCESS_EXIT:
- PDEBUG("got REQ_PROCESS_EXIT from %p, exit code = %d\n",
- request.req_thread, request.req_args.exit.code);
- pthread_handle_exit(request.req_thread,
- request.req_args.exit.code);
- break;
- case REQ_MAIN_THREAD_EXIT:
- PDEBUG("got REQ_MAIN_THREAD_EXIT\n");
- main_thread_exiting = 1;
-
- pthread_reap_children();
- if (__pthread_main_thread->p_nextlive == __pthread_main_thread) {
- restart(__pthread_main_thread);
-
- }
- break;
- case REQ_POST:
- PDEBUG("got REQ_POST\n");
- sem_post(request.req_args.post);
- break;
- case REQ_DEBUG:
- PDEBUG("got REQ_DEBUG\n");
-
- if (__pthread_threads_debug && __pthread_sig_debug > 0) {
- PDEBUG("about to call raise(__pthread_sig_debug)\n");
- raise(__pthread_sig_debug);
- }
- case REQ_KICK:
-
- break;
- }
- }
- }
- }
- int attribute_noreturn __pthread_manager_event(void *arg)
- {
-
- #ifdef INIT_THREAD_SELF
- INIT_THREAD_SELF(&__pthread_manager_thread, 1);
- #endif
-
- __pthread_lock (THREAD_GETMEM((&__pthread_manager_thread), p_lock), NULL);
-
- __pthread_unlock (THREAD_GETMEM((&__pthread_manager_thread), p_lock));
- __pthread_manager(arg);
- }
- static int
- attribute_noreturn
- pthread_start_thread(void *arg)
- {
- pthread_descr self = (pthread_descr) arg;
- struct pthread_request request;
- void * outcome;
-
- #ifdef INIT_THREAD_SELF
- INIT_THREAD_SELF(self, self->p_nr);
- #endif
- PDEBUG("\n");
-
- THREAD_SETMEM(self, p_pid, getpid());
-
- sigprocmask(SIG_SETMASK, &self->p_start_args.mask, NULL);
-
- if (THREAD_GETMEM(self, p_start_args.schedpolicy) >= 0)
-
- sched_setscheduler(THREAD_GETMEM(self, p_pid),
- THREAD_GETMEM(self, p_start_args.schedpolicy),
- &self->p_start_args.schedparam);
- else if (__pthread_manager_thread.p_priority > 0)
-
- {
- struct sched_param default_params;
- default_params.sched_priority = 0;
- sched_setscheduler(THREAD_GETMEM(self, p_pid),
- SCHED_OTHER, &default_params);
- }
-
- if (__pthread_threads_debug && __pthread_sig_debug > 0) {
- request.req_thread = self;
- request.req_kind = REQ_DEBUG;
- TEMP_FAILURE_RETRY(write(__pthread_manager_request,
- (char *) &request, sizeof(request)));
- suspend(self);
- }
-
- outcome = self->p_start_args.start_routine(THREAD_GETMEM(self,
- p_start_args.arg));
-
- __pthread_do_exit(outcome, CURRENT_STACK_FRAME);
- }
- static int
- attribute_noreturn
- pthread_start_thread_event(void *arg)
- {
- pthread_descr self = (pthread_descr) arg;
- #ifdef INIT_THREAD_SELF
- INIT_THREAD_SELF(self, self->p_nr);
- #endif
-
- THREAD_SETMEM(self, p_pid, getpid());
-
- __pthread_lock (THREAD_GETMEM(self, p_lock), NULL);
-
- __pthread_unlock (THREAD_GETMEM(self, p_lock));
-
- pthread_start_thread (arg);
- }
- static int pthread_allocate_stack(const pthread_attr_t *attr,
- pthread_descr default_new_thread,
- int pagesize,
- pthread_descr * out_new_thread,
- char ** out_new_thread_bottom,
- char ** out_guardaddr,
- size_t * out_guardsize)
- {
- pthread_descr new_thread;
- char * new_thread_bottom;
- char * guardaddr;
- size_t stacksize, guardsize;
- if (attr != NULL && attr->__stackaddr_set)
- {
-
- new_thread = (pthread_descr) ((long)(attr->__stackaddr) & -sizeof(void *)) - 1;
- new_thread_bottom = (char *) attr->__stackaddr - attr->__stacksize;
- guardaddr = NULL;
- guardsize = 0;
- __pthread_nonstandard_stacks = 1;
- #ifndef __ARCH_USE_MMU__
-
- NOMMU_INITIAL_THREAD_BOUNDS((char *) new_thread, (char *) new_thread_bottom);
- PDEBUG("initial stack: bos=%p, tos=%p\n", __pthread_initial_thread_bos,
- __pthread_initial_thread_tos);
- #endif
- }
- else
- {
- #ifdef __ARCH_USE_MMU__
- stacksize = STACK_SIZE - pagesize;
- if (attr != NULL)
- stacksize = MIN(stacksize, roundup(attr->__stacksize, pagesize));
-
- new_thread = default_new_thread;
- new_thread_bottom = (char *) (new_thread + 1) - stacksize;
- void * new_stack_addr = NULL;
- new_stack_addr = mmap((caddr_t)((char *)(new_thread + 1) - INITIAL_STACK_SIZE),
- INITIAL_STACK_SIZE, PROT_READ | PROT_WRITE | PROT_EXEC,
- MAP_PRIVATE | MAP_ANONYMOUS | MAP_FIXED_NOREPLACE | MAP_GROWSDOWN,
- -1, 0);
- if (new_stack_addr == MAP_FAILED){
-
- return -1;
- } else if ( new_stack_addr != (caddr_t)((char *)(new_thread + 1) - INITIAL_STACK_SIZE)) {
-
- munmap(new_stack_addr, INITIAL_STACK_SIZE);
- return -2;
- }
-
- if (stacksize == (size_t) (STACK_SIZE - pagesize))
- {
-
- guardaddr = NULL;
- guardsize = 0;
- }
- else
- {
-
- guardsize = attr->__guardsize;
- guardaddr = (void *)new_thread_bottom - guardsize;
- if (mmap((caddr_t) guardaddr, guardsize, 0, MAP_FIXED, -1, 0)
- == MAP_FAILED)
- {
-
- guardaddr = NULL;
- guardsize = 0;
- }
- }
- #else
-
- stacksize = INITIAL_STACK_SIZE;
-
- if (attr != NULL)
- {
- stacksize = attr->__stacksize;
- }
-
- if ((new_thread_bottom = malloc(stacksize)) == NULL)
- {
-
- return -1 ;
- }
- PDEBUG("malloced chunk: base=%p, size=0x%04x\n", new_thread_bottom, stacksize);
-
- new_thread = ((pthread_descr) ((long)(new_thread_bottom + stacksize) & -sizeof(void*))) - 1;
- guardaddr = NULL;
- guardsize = 0;
- PDEBUG("thread stack: bos=%p, tos=%p\n", new_thread_bottom, new_thread);
-
- NOMMU_INITIAL_THREAD_BOUNDS((char *) new_thread, (char *) new_thread_bottom);
- PDEBUG("initial stack: bos=%p, tos=%p\n", __pthread_initial_thread_bos,
- __pthread_initial_thread_tos);
-
- __pthread_nonstandard_stacks = 1;
- #endif
- }
-
- memset (new_thread, '\0', sizeof (*new_thread));
- *out_new_thread = new_thread;
- *out_new_thread_bottom = new_thread_bottom;
- *out_guardaddr = guardaddr;
- *out_guardsize = guardsize;
- return 0;
- }
- static int pthread_handle_create(pthread_t *thread, const pthread_attr_t *attr,
- void * (*start_routine)(void *), void *arg,
- sigset_t * mask, int father_pid,
- int report_events,
- td_thr_events_t *event_maskp)
- {
- size_t sseg;
- int pid;
- pthread_descr new_thread;
- char * new_thread_bottom;
- char * new_thread_top;
- pthread_t new_thread_id;
- char *guardaddr = NULL;
- size_t guardsize = 0;
- int pagesize = getpagesize();
- int saved_errno = 0;
-
- if (attr != NULL && attr->__schedpolicy != SCHED_OTHER && geteuid () != 0)
- return EPERM;
-
- for (sseg = 2; ; sseg++)
- {
- if (sseg >= PTHREAD_THREADS_MAX)
- return EAGAIN;
- if (__pthread_handles[sseg].h_descr != NULL)
- continue;
- int res = pthread_allocate_stack(attr, thread_segment(sseg), pagesize,
- &new_thread, &new_thread_bottom,
- &guardaddr, &guardsize);
- if ( res == 0)
- break;
- #ifndef __ARCH_USE_MMU__
- else
-
- return EAGAIN;
- #else
- else if (res == -2)
-
- return EAGAIN;
- #endif
- }
- __pthread_handles_num++;
-
- pthread_threads_counter += PTHREAD_THREADS_MAX;
- new_thread_id = sseg + pthread_threads_counter;
-
- new_thread->p_tid = new_thread_id;
- new_thread->p_lock = &(__pthread_handles[sseg].h_lock);
- new_thread->p_cancelstate = PTHREAD_CANCEL_ENABLE;
- new_thread->p_canceltype = PTHREAD_CANCEL_DEFERRED;
- new_thread->p_errnop = &new_thread->p_errno;
- new_thread->p_h_errnop = &new_thread->p_h_errno;
- #ifdef __UCLIBC_HAS_XLOCALE__
-
- new_thread->locale = __global_locale;
- #endif
- new_thread->p_guardaddr = guardaddr;
- new_thread->p_guardsize = guardsize;
- new_thread->p_self = new_thread;
- new_thread->p_nr = sseg;
-
- __pthread_init_lock(&__pthread_handles[sseg].h_lock);
- __pthread_handles[sseg].h_descr = new_thread;
- __pthread_handles[sseg].h_bottom = new_thread_bottom;
-
- new_thread->p_start_args.schedpolicy = -1;
- if (attr != NULL) {
- new_thread->p_detached = attr->__detachstate;
- new_thread->p_userstack = attr->__stackaddr_set;
- switch(attr->__inheritsched) {
- case PTHREAD_EXPLICIT_SCHED:
- new_thread->p_start_args.schedpolicy = attr->__schedpolicy;
- memcpy (&new_thread->p_start_args.schedparam, &attr->__schedparam,
- sizeof (struct sched_param));
- break;
- case PTHREAD_INHERIT_SCHED:
- new_thread->p_start_args.schedpolicy = sched_getscheduler(father_pid);
- sched_getparam(father_pid, &new_thread->p_start_args.schedparam);
- break;
- }
- new_thread->p_priority =
- new_thread->p_start_args.schedparam.sched_priority;
- }
-
- new_thread->p_start_args.start_routine = start_routine;
- new_thread->p_start_args.arg = arg;
- new_thread->p_start_args.mask = *mask;
-
- __pthread_manager_adjust_prio(new_thread->p_priority);
-
- pid = 0;
- new_thread_top = ((char *)new_thread - THREAD_STACK_OFFSET);
-
-
- new_thread->p_prevlive = __pthread_main_thread;
- new_thread->p_nextlive = __pthread_main_thread->p_nextlive;
- __pthread_main_thread->p_nextlive->p_prevlive = new_thread;
- __pthread_main_thread->p_nextlive = new_thread;
-
- if (report_events)
- {
-
- int idx = __td_eventword (TD_CREATE);
- uint32_t m = __td_eventmask (TD_CREATE);
- if ((m & (__pthread_threads_events.event_bits[idx]
- | event_maskp->event_bits[idx])) != 0)
- {
-
- __pthread_lock(new_thread->p_lock, NULL);
-
- #ifdef __ia64__
- pid = __clone2(pthread_start_thread_event, new_thread_top,
- new_thread_top - new_thread_bottom,
- CLONE_VM | CLONE_FS | CLONE_FILES | CLONE_SIGHAND |
- __pthread_sig_cancel, new_thread);
- #else
- pid = clone(pthread_start_thread_event, new_thread_top,
- CLONE_VM | CLONE_FS | CLONE_FILES | CLONE_SIGHAND |
- __pthread_sig_cancel, new_thread);
- #endif
- saved_errno = errno;
- if (pid != -1)
- {
-
- new_thread->p_eventbuf.eventdata = new_thread;
- new_thread->p_eventbuf.eventnum = TD_CREATE;
- __pthread_last_event = new_thread;
-
- new_thread->p_pid = pid;
-
- __linuxthreads_create_event ();
-
- __pthread_unlock(new_thread->p_lock);
- }
- }
- }
- if (pid == 0)
- {
- PDEBUG("cloning new_thread = %p\n", new_thread);
- #ifdef __ia64__
- pid = __clone2(pthread_start_thread, new_thread_top,
- new_thread_top - new_thread_bottom,
- CLONE_VM | CLONE_FS | CLONE_FILES | CLONE_SIGHAND |
- __pthread_sig_cancel, new_thread);
- #else
- pid = clone(pthread_start_thread, new_thread_top,
- CLONE_VM | CLONE_FS | CLONE_FILES | CLONE_SIGHAND |
- __pthread_sig_cancel, new_thread);
- #endif
- saved_errno = errno;
- }
-
- if (pid == -1) {
-
- new_thread->p_nextlive->p_prevlive = new_thread->p_prevlive;
- new_thread->p_prevlive->p_nextlive = new_thread->p_nextlive;
-
-
- if (attr == NULL || !attr->__stackaddr_set)
- {
- #ifdef __ARCH_USE_MMU__
- if (new_thread->p_guardsize != 0)
- munmap(new_thread->p_guardaddr, new_thread->p_guardsize);
- munmap((caddr_t)((char *)(new_thread+1) - INITIAL_STACK_SIZE),
- INITIAL_STACK_SIZE);
- #else
- free(new_thread_bottom);
- #endif
- }
- __pthread_handles[sseg].h_descr = NULL;
- __pthread_handles[sseg].h_bottom = NULL;
- __pthread_handles_num--;
- return saved_errno;
- }
- PDEBUG("new thread pid = %d\n", pid);
- #if 0
-
-
- new_thread->p_prevlive = __pthread_main_thread;
- new_thread->p_nextlive = __pthread_main_thread->p_nextlive;
- __pthread_main_thread->p_nextlive->p_prevlive = new_thread;
- __pthread_main_thread->p_nextlive = new_thread;
-
- #endif
-
- new_thread->p_pid = pid;
-
- *thread = new_thread_id;
- return 0;
- }
- static void pthread_free(pthread_descr th)
- {
- pthread_handle handle;
- pthread_readlock_info *iter, *next;
- #ifndef __ARCH_USE_MMU__
- char *h_bottom_save;
- #endif
-
- handle = thread_handle(th->p_tid);
- __pthread_lock(&handle->h_lock, NULL);
- #ifndef __ARCH_USE_MMU__
- h_bottom_save = handle->h_bottom;
- #endif
- handle->h_descr = NULL;
- handle->h_bottom = (char *)(-1L);
- __pthread_unlock(&handle->h_lock);
- #ifdef FREE_THREAD_SELF
- FREE_THREAD_SELF(th, th->p_nr);
- #endif
-
- __pthread_handles_num--;
-
- for (iter = th->p_readlock_list; iter != NULL; iter = next)
- {
- next = iter->pr_next;
- free(iter);
- }
- for (iter = th->p_readlock_free; iter != NULL; iter = next)
- {
- next = iter->pr_next;
- free(iter);
- }
-
- if (th == &__pthread_initial_thread) return;
- if (!th->p_userstack)
- {
- #ifdef __ARCH_USE_MMU__
-
- if (th->p_guardsize != 0)
- munmap(th->p_guardaddr, th->p_guardsize);
- munmap((caddr_t) ((char *)(th+1) - STACK_SIZE), STACK_SIZE);
- #else
-
- free(h_bottom_save);
- #endif
- }
- }
- static void pthread_exited(pid_t pid)
- {
- pthread_descr th;
- int detached;
-
- for (th = __pthread_main_thread->p_nextlive;
- th != __pthread_main_thread;
- th = th->p_nextlive) {
- if (th->p_pid == pid) {
-
- th->p_nextlive->p_prevlive = th->p_prevlive;
- th->p_prevlive->p_nextlive = th->p_nextlive;
-
- __pthread_lock(th->p_lock, NULL);
- th->p_exited = 1;
-
- if (th->p_report_events)
- {
-
- int idx = __td_eventword (TD_REAP);
- uint32_t mask = __td_eventmask (TD_REAP);
- if ((mask & (__pthread_threads_events.event_bits[idx]
- | th->p_eventbuf.eventmask.event_bits[idx])) != 0)
- {
-
- th->p_eventbuf.eventnum = TD_REAP;
- th->p_eventbuf.eventdata = th;
- __pthread_last_event = th;
-
- __linuxthreads_reap_event();
- }
- }
- detached = th->p_detached;
- __pthread_unlock(th->p_lock);
- if (detached)
- pthread_free(th);
- break;
- }
- }
-
- if (main_thread_exiting &&
- __pthread_main_thread->p_nextlive == __pthread_main_thread) {
- restart(__pthread_main_thread);
-
- }
- }
- static void pthread_reap_children(void)
- {
- pid_t pid;
- int status;
- PDEBUG("\n");
- while ((pid = waitpid(-1, &status, WNOHANG | __WCLONE)) > 0) {
- pthread_exited(pid);
- if (WIFSIGNALED(status)) {
-
- pthread_kill_all_threads(WTERMSIG(status), 1);
- _exit(0);
- }
- }
- }
- static void pthread_handle_free(pthread_t th_id)
- {
- pthread_handle handle = thread_handle(th_id);
- pthread_descr th;
- __pthread_lock(&handle->h_lock, NULL);
- if (invalid_handle(handle, th_id)) {
-
- __pthread_unlock(&handle->h_lock);
- return;
- }
- th = handle->h_descr;
- if (th->p_exited) {
- __pthread_unlock(&handle->h_lock);
- pthread_free(th);
- } else {
-
- th->p_detached = 1;
- __pthread_unlock(&handle->h_lock);
- }
- }
- static void pthread_kill_all_threads(int sig, int main_thread_also)
- {
- pthread_descr th;
- for (th = __pthread_main_thread->p_nextlive;
- th != __pthread_main_thread;
- th = th->p_nextlive) {
- kill(th->p_pid, sig);
- }
- if (main_thread_also) {
- kill(__pthread_main_thread->p_pid, sig);
- }
- }
- static void pthread_handle_exit(pthread_descr issuing_thread, int exitcode)
- {
- pthread_descr th;
- __pthread_exit_requested = 1;
- __pthread_exit_code = exitcode;
-
- for (th = issuing_thread->p_nextlive;
- th != issuing_thread;
- th = th->p_nextlive) {
- kill(th->p_pid, __pthread_sig_cancel);
- }
-
- for (th = issuing_thread->p_nextlive;
- th != issuing_thread;
- th = th->p_nextlive) {
- waitpid(th->p_pid, NULL, __WCLONE);
- }
- restart(issuing_thread);
- _exit(0);
- }
- void __pthread_manager_sighandler(int sig attribute_unused)
- {
- int kick_manager = terminated_children == 0 && main_thread_exiting;
- terminated_children = 1;
-
- if (kick_manager) {
- struct pthread_request request;
- request.req_thread = 0;
- request.req_kind = REQ_KICK;
- TEMP_FAILURE_RETRY(write(__pthread_manager_request,
- (char *) &request, sizeof(request)));
- }
- }
- void __pthread_manager_adjust_prio(int thread_prio)
- {
- struct sched_param param;
- if (thread_prio <= __pthread_manager_thread.p_priority) return;
- param.sched_priority =
- thread_prio < sched_get_priority_max(SCHED_FIFO)
- ? thread_prio + 1 : thread_prio;
- sched_setscheduler(__pthread_manager_thread.p_pid, SCHED_FIFO, ¶m);
- __pthread_manager_thread.p_priority = thread_prio;
- }
|