X-Git-Url: http://nsz.repo.hu/git/?a=blobdiff_plain;f=src%2Fthread%2Fpthread_cancel.c;h=3d229223ed1b00f622c3319b7cfa327086f530d7;hb=8c4be3e2209d2a1d3874b8bc2b474668fcbbbac6;hp=fde090809c03b39e7226b8ac64701ca62e81231c;hpb=cbc02ba23cec16d7a821648ea8424546bc7f02dc;p=musl diff --git a/src/thread/pthread_cancel.c b/src/thread/pthread_cancel.c index fde09080..3d229223 100644 --- a/src/thread/pthread_cancel.c +++ b/src/thread/pthread_cancel.c @@ -1,15 +1,13 @@ +#define _GNU_SOURCE #include #include "pthread_impl.h" #include "syscall.h" #include "libc.h" -#ifdef SHARED -#define hidden __attribute__((__visibility__("hidden"))) -#else -#define hidden -#endif +__attribute__((__visibility__("hidden"))) +long __cancel(), __syscall_cp_asm(), __syscall_cp_c(); -hidden long __cancel() +long __cancel() { pthread_t self = __pthread_self(); if (self->canceldisable == PTHREAD_CANCEL_ENABLE || self->cancelasync) @@ -18,18 +16,10 @@ hidden long __cancel() return -ECANCELED; } -/* If __syscall_cp_asm has adjusted the stack pointer, it must provide a - * definition of __cp_cancel to undo those adjustments and call __cancel. - * Otherwise, __cancel provides a definition for __cp_cancel. */ - -hidden weak_alias(__cancel, __cp_cancel); - -hidden long __syscall_cp_asm(volatile void *, syscall_arg_t, syscall_arg_t, syscall_arg_t, syscall_arg_t, syscall_arg_t, syscall_arg_t, syscall_arg_t); -hidden long __syscall_cp_c(syscall_arg_t nr, syscall_arg_t u, syscall_arg_t v, syscall_arg_t w, syscall_arg_t x, syscall_arg_t y, syscall_arg_t z) @@ -55,20 +45,22 @@ static void _sigaddset(sigset_t *set, int sig) set->__bits[s/8/sizeof *set->__bits] |= 1UL<<(s&8*sizeof *set->__bits-1); } +__attribute__((__visibility__("hidden"))) +extern const char __cp_begin[1], __cp_end[1], __cp_cancel[1]; + static void cancel_handler(int sig, siginfo_t *si, void *ctx) { pthread_t self = __pthread_self(); ucontext_t *uc = ctx; - const char *ip = ((char **)&uc->uc_mcontext)[CANCEL_REG_IP]; - hidden extern const char __cp_begin[1], __cp_end[1]; + uintptr_t pc = uc->uc_mcontext.MC_PC; a_barrier(); if (!self->cancel || self->canceldisable == PTHREAD_CANCEL_DISABLE) return; _sigaddset(&uc->uc_sigmask, SIGCANCEL); - if (self->cancelasync || ip >= __cp_begin && ip < __cp_end) { - ((char **)&uc->uc_mcontext)[CANCEL_REG_IP] = (char *)__cp_cancel; + if (self->cancelasync || pc >= (uintptr_t)__cp_begin && pc < (uintptr_t)__cp_end) { + uc->uc_mcontext.MC_PC = (uintptr_t)__cp_cancel; return; } @@ -100,5 +92,6 @@ int pthread_cancel(pthread_t t) init = 1; } a_store(&t->cancel, 1); + if (t == pthread_self() && !t->cancelasync) return 0; return pthread_kill(t, SIGCANCEL); }