pthread_impl.h 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167
  1. #ifndef _PTHREAD_IMPL_H
  2. #define _PTHREAD_IMPL_H
  3. #include <pthread.h>
  4. #include <signal.h>
  5. #include <errno.h>
  6. #include <limits.h>
  7. #include "libc.h"
  8. #include "syscall.h"
  9. #include "atomic.h"
  10. #include "futex.h"
  11. #define pthread __pthread
  12. struct pthread {
  13. /* Part 1 -- these fields may be external or
  14. * internal (accessed via asm) ABI. Do not change. */
  15. struct pthread *self;
  16. void **dtv, *unused1, *unused2;
  17. uintptr_t sysinfo;
  18. uintptr_t canary, canary2;
  19. pid_t tid, pid;
  20. /* Part 2 -- implementation details, non-ABI. */
  21. int tsd_used, errno_val;
  22. volatile int cancel, canceldisable, cancelasync;
  23. int detached;
  24. unsigned char *map_base;
  25. size_t map_size;
  26. void *stack;
  27. size_t stack_size;
  28. void *start_arg;
  29. void *(*start)(void *);
  30. void *result;
  31. struct __ptcb *cancelbuf;
  32. void **tsd;
  33. volatile int dead;
  34. struct {
  35. volatile void *volatile head;
  36. long off;
  37. volatile void *volatile pending;
  38. } robust_list;
  39. int unblock_cancel;
  40. volatile int timer_id;
  41. locale_t locale;
  42. volatile int killlock[1];
  43. volatile int exitlock[1];
  44. volatile int startlock[2];
  45. unsigned long sigmask[_NSIG/8/sizeof(long)];
  46. char *dlerror_buf;
  47. int dlerror_flag;
  48. void *stdio_locks;
  49. size_t guard_size;
  50. /* Part 3 -- the positions of these fields relative to
  51. * the end of the structure is external and internal ABI. */
  52. uintptr_t canary_at_end;
  53. void **dtv_copy;
  54. };
  55. struct __timer {
  56. int timerid;
  57. pthread_t thread;
  58. };
  59. #define __SU (sizeof(size_t)/sizeof(int))
  60. #define _a_stacksize __u.__s[0]
  61. #define _a_guardsize __u.__s[1]
  62. #define _a_stackaddr __u.__s[2]
  63. #define _a_detach __u.__i[3*__SU+0]
  64. #define _a_sched __u.__i[3*__SU+1]
  65. #define _a_policy __u.__i[3*__SU+2]
  66. #define _a_prio __u.__i[3*__SU+3]
  67. #define _m_type __u.__i[0]
  68. #define _m_lock __u.__vi[1]
  69. #define _m_waiters __u.__vi[2]
  70. #define _m_prev __u.__p[3]
  71. #define _m_next __u.__p[4]
  72. #define _m_count __u.__i[5]
  73. #define _c_shared __u.__p[0]
  74. #define _c_seq __u.__vi[2]
  75. #define _c_waiters __u.__vi[3]
  76. #define _c_clock __u.__i[4]
  77. #define _c_lock __u.__vi[8]
  78. #define _c_head __u.__p[1]
  79. #define _c_tail __u.__p[5]
  80. #define _rw_lock __u.__vi[0]
  81. #define _rw_waiters __u.__vi[1]
  82. #define _rw_shared __u.__i[2]
  83. #define _b_lock __u.__vi[0]
  84. #define _b_waiters __u.__vi[1]
  85. #define _b_limit __u.__i[2]
  86. #define _b_count __u.__vi[3]
  87. #define _b_waiters2 __u.__vi[4]
  88. #define _b_inst __u.__p[3]
  89. #include "pthread_arch.h"
  90. #ifndef CANARY
  91. #define CANARY canary
  92. #endif
  93. #ifndef DTP_OFFSET
  94. #define DTP_OFFSET 0
  95. #endif
  96. #ifndef tls_mod_off_t
  97. #define tls_mod_off_t size_t
  98. #endif
  99. #define SIGTIMER 32
  100. #define SIGCANCEL 33
  101. #define SIGSYNCCALL 34
  102. #define SIGALL_SET ((sigset_t *)(const unsigned long long [2]){ -1,-1 })
  103. #define SIGPT_SET \
  104. ((sigset_t *)(const unsigned long [_NSIG/8/sizeof(long)]){ \
  105. [sizeof(long)==4] = 3UL<<(32*(sizeof(long)>4)) })
  106. #define SIGTIMER_SET \
  107. ((sigset_t *)(const unsigned long [_NSIG/8/sizeof(long)]){ \
  108. 0x80000000 })
  109. pthread_t __pthread_self_init(void);
  110. int __clone(int (*)(void *), void *, int, void *, ...);
  111. int __set_thread_area(void *);
  112. int __libc_sigaction(int, const struct sigaction *, struct sigaction *);
  113. int __libc_sigprocmask(int, const sigset_t *, sigset_t *);
  114. void __lock(volatile int *);
  115. void __unmapself(void *, size_t);
  116. void __vm_wait(void);
  117. void __vm_lock(void);
  118. void __vm_unlock(void);
  119. int __timedwait(volatile int *, int, clockid_t, const struct timespec *, int);
  120. int __timedwait_cp(volatile int *, int, clockid_t, const struct timespec *, int);
  121. void __wait(volatile int *, volatile int *, int, int);
  122. static inline void __wake(volatile void *addr, int cnt, int priv)
  123. {
  124. if (priv) priv = FUTEX_PRIVATE;
  125. if (cnt<0) cnt = INT_MAX;
  126. __syscall(SYS_futex, addr, FUTEX_WAKE|priv, cnt) != -ENOSYS ||
  127. __syscall(SYS_futex, addr, FUTEX_WAKE, cnt);
  128. }
  129. static inline void __futexwait(volatile void *addr, int val, int priv)
  130. {
  131. if (priv) priv = FUTEX_PRIVATE;
  132. __syscall(SYS_futex, addr, FUTEX_WAIT|priv, val) != -ENOSYS ||
  133. __syscall(SYS_futex, addr, FUTEX_WAIT, val);
  134. }
  135. void __acquire_ptc(void);
  136. void __release_ptc(void);
  137. void __inhibit_ptc(void);
  138. void __block_all_sigs(void *);
  139. void __block_app_sigs(void *);
  140. void __restore_sigs(void *);
  141. #define DEFAULT_STACK_SIZE 81920
  142. #define DEFAULT_GUARD_SIZE 4096
  143. #define __ATTRP_C11_THREAD ((void*)(uintptr_t)-1)
  144. #endif