src/runtime/thread.h

   1 #if !defined(_INCLUDE_THREAD_H_)
   2 #define _INCLUDE_THREAD_H_
   3
   4 #include <sys/types.h>
   5 #include <unistd.h>
   6 #include <stddef.h>
   7 #include "sbcl.h"
   8 #include "globals.h"
   9 #include "runtime.h"
  10 #include "os.h"
  11 #ifdef LISP_FEATURE_GENCGC
  12 #include "gencgc-alloc-region.h"
  13 #else
  14 struct alloc_region { };
  15 #endif
  16 #include "genesis/symbol.h"
  17 #include "genesis/static-symbols.h"
  18 #include "genesis/thread.h"
  19 #include "genesis/fdefn.h"
  20 #include "interrupt.h"
  21
  22 #define STATE_RUNNING (make_fixnum(1))
  23 #define STATE_SUSPENDED (make_fixnum(2))
  24 #define STATE_DEAD (make_fixnum(3))
  25
  26 #ifdef LISP_FEATURE_SB_THREAD
  27
  28 /* Only access thread state with blockables blocked. */
  29 static inline lispobj
  30 thread_state(struct thread *thread)
  31 {
  32     lispobj state;
  33     pthread_mutex_lock(thread->state_lock);
  34     state = thread->state;
  35     pthread_mutex_unlock(thread->state_lock);
  36     return state;
  37 }
  38
  39 static inline void
  40 set_thread_state(struct thread *thread, lispobj state)
  41 {
  42     pthread_mutex_lock(thread->state_lock);
  43     thread->state = state;
  44     pthread_cond_broadcast(thread->state_cond);
  45     pthread_mutex_unlock(thread->state_lock);
  46 }
  47
  48 static inline void
  49 wait_for_thread_state_change(struct thread *thread, lispobj state)
  50 {
  51     pthread_mutex_lock(thread->state_lock);
  52     while (thread->state == state)
  53         pthread_cond_wait(thread->state_cond, thread->state_lock);
  54     pthread_mutex_unlock(thread->state_lock);
  55 }
  56
  57 extern pthread_key_t lisp_thread;
  58 #endif
  59
  60 extern int kill_safely(os_thread_t os_thread, int signal);
  61
  62 #define THREAD_SLOT_OFFSET_WORDS(c) \
  63  (offsetof(struct thread,c)/(sizeof (struct thread *)))
  64
  65 union per_thread_data {
  66     struct thread thread;
  67     lispobj dynamic_values[1];  /* actually more like 4000 or so */
  68 };
  69
  70 extern struct thread *all_threads;
  71 extern int dynamic_values_bytes;
  72
  73 #if defined(LISP_FEATURE_DARWIN)
  74 #define CONTROL_STACK_ALIGNMENT_BYTES 8192 /* darwin wants page-aligned stacks */
  75 #define THREAD_ALIGNMENT_BYTES CONTROL_STACK_ALIGNMENT_BYTES
  76 #else
  77 #define THREAD_ALIGNMENT_BYTES BACKEND_PAGE_BYTES
  78 #define CONTROL_STACK_ALIGNMENT_BYTES 16
  79 #endif
  80
  81
  82 #ifdef LISP_FEATURE_SB_THREAD
  83 #define for_each_thread(th) for(th=all_threads;th;th=th->next)
  84 #else
  85 /* there's some possibility a SSC could notice this never actually
  86  * loops  */
  87 #define for_each_thread(th) for(th=all_threads;th;th=0)
  88 #endif
  89
  90 static inline lispobj *
  91 SymbolValueAddress(u64 tagged_symbol_pointer, void *thread)
  92 {
  93     struct symbol *sym= (struct symbol *)
  94         (pointer_sized_uint_t)(tagged_symbol_pointer-OTHER_POINTER_LOWTAG);
  95 #ifdef LISP_FEATURE_SB_THREAD
  96     if(thread && sym->tls_index) {
  97         lispobj *r = &(((union per_thread_data *)thread)
  98                        ->dynamic_values[fixnum_value(sym->tls_index)]);
  99         if((*r)!=NO_TLS_VALUE_MARKER_WIDETAG) return r;
 100     }
 101 #endif
 102     return &sym->value;
 103 }
 104
 105 static inline lispobj
 106 SymbolValue(u64 tagged_symbol_pointer, void *thread)
 107 {
 108     struct symbol *sym= (struct symbol *)
 109         (pointer_sized_uint_t)(tagged_symbol_pointer-OTHER_POINTER_LOWTAG);
 110 #ifdef LISP_FEATURE_SB_THREAD
 111     if(thread && sym->tls_index) {
 112         lispobj r=
 113             ((union per_thread_data *)thread)
 114             ->dynamic_values[fixnum_value(sym->tls_index)];
 115         if(r!=NO_TLS_VALUE_MARKER_WIDETAG) return r;
 116     }
 117 #endif
 118     return sym->value;
 119 }
 120
 121 static inline lispobj
 122 SymbolTlValue(u64 tagged_symbol_pointer, void *thread)
 123 {
 124     struct symbol *sym= (struct symbol *)
 125         (pointer_sized_uint_t)(tagged_symbol_pointer-OTHER_POINTER_LOWTAG);
 126 #ifdef LISP_FEATURE_SB_THREAD
 127     return ((union per_thread_data *)thread)
 128         ->dynamic_values[fixnum_value(sym->tls_index)];
 129 #else
 130     return sym->value;
 131 #endif
 132 }
 133
 134 static inline void
 135 SetSymbolValue(u64 tagged_symbol_pointer,lispobj val, void *thread)
 136 {
 137     struct symbol *sym= (struct symbol *)
 138         (pointer_sized_uint_t)(tagged_symbol_pointer-OTHER_POINTER_LOWTAG);
 139 #ifdef LISP_FEATURE_SB_THREAD
 140     if(thread && sym->tls_index) {
 141         lispobj *pr= &(((union per_thread_data *)thread)
 142                        ->dynamic_values[fixnum_value(sym->tls_index)]);
 143         if(*pr!=NO_TLS_VALUE_MARKER_WIDETAG) {
 144             *pr=val;
 145             return;
 146         }
 147     }
 148 #endif
 149     sym->value = val;
 150 }
 151
 152 static inline void
 153 SetTlSymbolValue(u64 tagged_symbol_pointer,lispobj val, void *thread)
 154 {
 155 #ifdef LISP_FEATURE_SB_THREAD
 156     struct symbol *sym= (struct symbol *)
 157         (pointer_sized_uint_t)(tagged_symbol_pointer-OTHER_POINTER_LOWTAG);
 158     ((union per_thread_data *)thread)
 159         ->dynamic_values[fixnum_value(sym->tls_index)]
 160         =val;
 161 #else
 162     SetSymbolValue(tagged_symbol_pointer,val,thread) ;
 163 #endif
 164 }
 165
 166 /* This only works for static symbols. */
 167 static inline lispobj
 168 StaticSymbolFunction(lispobj sym)
 169 {
 170     return ((struct fdefn *)native_pointer(SymbolValue(sym, 0)))->fun;
 171 }
 172
 173 #if defined(LISP_FEATURE_SB_THREAD) && defined(LISP_FEATURE_GCC_TLS)
 174 extern __thread struct thread *current_thread;
 175 #endif
 176
 177 /* This is clearly per-arch and possibly even per-OS code, but we can't
 178  * put it somewhere sensible like x86-linux-os.c because it needs too
 179  * much stuff like struct thread and all_threads to be defined, which
 180  * usually aren't by that time.  So, it's here instead.  Sorry */
 181
 182 static inline struct thread *arch_os_get_current_thread(void)
 183 {
 184 #if defined(LISP_FEATURE_SB_THREAD)
 185 #if defined(LISP_FEATURE_X86)
 186     register struct thread *me=0;
 187     if(all_threads) {
 188 #if defined(LISP_FEATURE_DARWIN) && defined(LISP_FEATURE_RESTORE_FS_SEGMENT_REGISTER_FROM_TLS)
 189         sel_t sel;
 190         struct thread *th = pthread_getspecific(specials);
 191         sel.index = th->tls_cookie;
 192         sel.rpl = USER_PRIV;
 193         sel.ti = SEL_LDT;
 194         __asm__ __volatile__ ("movw %w0, %%fs" : : "r"(sel));
 195 #elif defined(LISP_FEATURE_FREEBSD)
 196 #ifdef LISP_FEATURE_GCC_TLS
 197         struct thread *th = current_thread;
 198 #else
 199         struct thread *th = pthread_getspecific(specials);
 200 #endif
 201 #ifdef LISP_FEATURE_RESTORE_TLS_SEGMENT_REGISTER_FROM_TLS
 202         unsigned int sel = LSEL(th->tls_cookie, SEL_UPL);
 203         unsigned int fs = rfs();
 204
 205         /* Load FS only if it's necessary.  Modifying a selector
 206          * causes privilege checking and it takes long time. */
 207         if (fs != sel)
 208             load_fs(sel);
 209 #endif
 210         return th;
 211 #endif
 212         __asm__ __volatile__ ("movl %%fs:%c1,%0" : "=r" (me)
 213                  : "i" (offsetof (struct thread,this)));
 214     }
 215     return me;
 216 #else
 217 #ifdef LISP_FEATURE_GCC_TLS
 218     return current_thread;
 219 #else
 220     return pthread_getspecific(specials);
 221 #endif
 222 #endif /* x86 */
 223 #else
 224      return all_threads;
 225 #endif
 226 }
 227
 228 #if defined(LISP_FEATURE_MACH_EXCEPTION_HANDLER)
 229 #define THREAD_STRUCT_TO_EXCEPTION_PORT(th) ((mach_port_t) th)
 230 #define EXCEPTION_PORT_TO_THREAD_STRUCT(th) ((struct thread *) th)
 231 #endif
 232
 233 extern void create_initial_thread(lispobj);
 234
 235 #endif /* _INCLUDE_THREAD_H_ */