X-Git-Url: http://nsz.repo.hu/git/?a=blobdiff_plain;f=src%2Finternal%2Fpthread_impl.h;h=508b40b5939241fcb6192d82d5100695186e7b06;hb=8f11e6127fe93093f81a52b15bb1537edc3fc8af;hp=3b4ad94d61f60191b7b420565ecd7e9fef7c6c0b;hpb=526e64f54d729947b35fd39129bc86cbc0b5f098;p=musl diff --git a/src/internal/pthread_impl.h b/src/internal/pthread_impl.h index 3b4ad94d..508b40b5 100644 --- a/src/internal/pthread_impl.h +++ b/src/internal/pthread_impl.h @@ -5,6 +5,7 @@ #include #include #include +#include #include "libc.h" #include "syscall.h" #include "atomic.h" @@ -16,21 +17,24 @@ struct pthread { /* Part 1 -- these fields may be external or * internal (accessed via asm) ABI. Do not change. */ struct pthread *self; - void **dtv, *unused1, *unused2; + uintptr_t *dtv; + struct pthread *prev, *next; /* non-ABI */ uintptr_t sysinfo; uintptr_t canary, canary2; - pid_t tid, pid; /* Part 2 -- implementation details, non-ABI. */ - int tsd_used, errno_val; - volatile int cancel, canceldisable, cancelasync; - int detached; + int tid; + int errno_val; + volatile int detach_state; + volatile int cancel; + volatile unsigned char canceldisable, cancelasync; + unsigned char tsd_used:1; + unsigned char dlerror_flag:1; unsigned char *map_base; size_t map_size; void *stack; size_t stack_size; - void *start_arg; - void *(*start)(void *); + size_t guard_size; void *result; struct __ptcb *cancelbuf; void **tsd; @@ -39,23 +43,22 @@ struct pthread { long off; volatile void *volatile pending; } robust_list; - int unblock_cancel; volatile int timer_id; locale_t locale; - volatile int join_futex; volatile int killlock[1]; - volatile int exitlock[1]; - volatile int startlock[2]; - unsigned long sigmask[_NSIG/8/sizeof(long)]; char *dlerror_buf; - int dlerror_flag; void *stdio_locks; - size_t guard_size; /* Part 3 -- the positions of these fields relative to * the end of the structure is external and internal ABI. */ uintptr_t canary_at_end; - void **dtv_copy; + uintptr_t *dtv_copy; +}; + +enum { + DT_EXITING = 0, + DT_JOINABLE, + DT_DETACHED, }; struct __timer { @@ -121,22 +124,35 @@ struct __timer { ((sigset_t *)(const unsigned long [_NSIG/8/sizeof(long)]){ \ 0x80000000 }) -pthread_t __pthread_self_init(void); - -int __clone(int (*)(void *), void *, int, void *, ...); -int __set_thread_area(void *); -int __libc_sigaction(int, const struct sigaction *, struct sigaction *); -int __libc_sigprocmask(int, const sigset_t *, sigset_t *); -void __lock(volatile int *); -void __unmapself(void *, size_t); - -void __vm_wait(void); -void __vm_lock(void); -void __vm_unlock(void); - -int __timedwait(volatile int *, int, clockid_t, const struct timespec *, int); -int __timedwait_cp(volatile int *, int, clockid_t, const struct timespec *, int); -void __wait(volatile int *, volatile int *, int, int); +void *__tls_get_addr(tls_mod_off_t *); +hidden void *__tls_get_new(tls_mod_off_t *); +hidden int __init_tp(void *); +hidden void *__copy_tls(unsigned char *); +hidden void __reset_tls(); + +hidden void __dl_thread_cleanup(void); +hidden void __testcancel(); +hidden void __do_cleanup_push(struct __ptcb *); +hidden void __do_cleanup_pop(struct __ptcb *); +hidden void __pthread_tsd_run_dtors(); + +hidden void __pthread_key_delete_synccall(void (*)(void *), void *); +hidden int __pthread_key_delete_impl(pthread_key_t); + +extern hidden volatile int __block_new_threads; +extern hidden volatile size_t __pthread_tsd_size; +extern hidden void *__pthread_tsd_main[]; +extern hidden volatile int __aio_fut; +extern hidden volatile int __eintr_valid_flag; + +hidden int __clone(int (*)(void *), void *, int, void *, ...); +hidden int __set_thread_area(void *); +hidden int __libc_sigaction(int, const struct sigaction *, struct sigaction *); +hidden void __unmapself(void *, size_t); + +hidden int __timedwait(volatile int *, int, clockid_t, const struct timespec *, int); +hidden int __timedwait_cp(volatile int *, int, clockid_t, const struct timespec *, int); +hidden void __wait(volatile int *, volatile int *, int, int); static inline void __wake(volatile void *addr, int cnt, int priv) { if (priv) priv = FUTEX_PRIVATE; @@ -147,20 +163,28 @@ static inline void __wake(volatile void *addr, int cnt, int priv) static inline void __futexwait(volatile void *addr, int val, int priv) { if (priv) priv = FUTEX_PRIVATE; - __syscall(SYS_futex, addr, FUTEX_WAIT|priv, val) != -ENOSYS || - __syscall(SYS_futex, addr, FUTEX_WAIT, val); + __syscall(SYS_futex, addr, FUTEX_WAIT|priv, val, 0) != -ENOSYS || + __syscall(SYS_futex, addr, FUTEX_WAIT, val, 0); } -void __acquire_ptc(void); -void __release_ptc(void); -void __inhibit_ptc(void); +hidden void __acquire_ptc(void); +hidden void __release_ptc(void); +hidden void __inhibit_ptc(void); + +hidden void __tl_lock(void); +hidden void __tl_unlock(void); +hidden void __tl_sync(pthread_t); + +extern hidden volatile int __thread_list_lock; + +extern hidden unsigned __default_stacksize; +extern hidden unsigned __default_guardsize; -void __block_all_sigs(void *); -void __block_app_sigs(void *); -void __restore_sigs(void *); +#define DEFAULT_STACK_SIZE 131072 +#define DEFAULT_GUARD_SIZE 8192 -#define DEFAULT_STACK_SIZE 81920 -#define DEFAULT_GUARD_SIZE 4096 +#define DEFAULT_STACK_MAX (8<<20) +#define DEFAULT_GUARD_MAX (1<<20) #define __ATTRP_C11_THREAD ((void*)(uintptr_t)-1)