X-Git-Url: http://repo.macrolet.net/gitweb/?a=blobdiff_plain;f=src%2Fruntime%2Fthread.h;h=37325b837b2a3f9ec23cb690df5220a65e6c71c1;hb=0b5119848b6b8713e473fa669356645747e11dbd;hp=870411c747a1222279eab92f332b4d68ee11f390;hpb=d8e682fdfb7e8ba067e15aea0f3d1f8d37ca9eb1;p=sbcl.git diff --git a/src/runtime/thread.h b/src/runtime/thread.h index 870411c..37325b8 100644 --- a/src/runtime/thread.h +++ b/src/runtime/thread.h @@ -1,4 +1,3 @@ - #if !defined(_INCLUDE_THREAD_H_) #define _INCLUDE_THREAD_H_ @@ -6,6 +5,7 @@ #include #include #include "sbcl.h" +#include "globals.h" #include "runtime.h" #include "os.h" #include "interrupt.h" @@ -18,23 +18,20 @@ struct alloc_region { }; #include "genesis/static-symbols.h" #include "genesis/thread.h" -#define STATE_RUNNING (make_fixnum(0)) -#define STATE_STOPPING (make_fixnum(1)) -#define STATE_STOPPED (make_fixnum(2)) +#define STATE_RUNNING (make_fixnum(1)) +#define STATE_SUSPENDED (make_fixnum(2)) #define STATE_DEAD (make_fixnum(3)) -#define STATE_STARTING (make_fixnum(4)) #define THREAD_SLOT_OFFSET_WORDS(c) \ (offsetof(struct thread,c)/(sizeof (struct thread *))) union per_thread_data { struct thread thread; - lispobj dynamic_values[1]; /* actually more like 4000 or so */ + lispobj dynamic_values[1]; /* actually more like 4000 or so */ }; -extern struct thread *all_threads; +extern struct thread * volatile all_threads; extern int dynamic_values_bytes; -extern struct thread *find_thread_by_os_thread(os_thread_t tid); #ifdef LISP_FEATURE_SB_THREAD #define for_each_thread(th) for(th=all_threads;th;th=th->next) @@ -46,50 +43,50 @@ extern struct thread *find_thread_by_os_thread(os_thread_t tid); static inline lispobj SymbolValue(u64 tagged_symbol_pointer, void *thread) { struct symbol *sym= (struct symbol *) - (pointer_sized_uint_t)(tagged_symbol_pointer-OTHER_POINTER_LOWTAG); + (pointer_sized_uint_t)(tagged_symbol_pointer-OTHER_POINTER_LOWTAG); #ifdef LISP_FEATURE_SB_THREAD if(thread && sym->tls_index) { - lispobj r= - ((union per_thread_data *)thread) - ->dynamic_values[fixnum_value(sym->tls_index)]; - if(r!=UNBOUND_MARKER_WIDETAG) return r; + lispobj r= + ((union per_thread_data *)thread) + ->dynamic_values[fixnum_value(sym->tls_index)]; + if(r!=NO_TLS_VALUE_MARKER_WIDETAG) return r; } #endif return sym->value; } static inline lispobj SymbolTlValue(u64 tagged_symbol_pointer, void *thread) { struct symbol *sym= (struct symbol *) - (pointer_sized_uint_t)(tagged_symbol_pointer-OTHER_POINTER_LOWTAG); + (pointer_sized_uint_t)(tagged_symbol_pointer-OTHER_POINTER_LOWTAG); #ifdef LISP_FEATURE_SB_THREAD return ((union per_thread_data *)thread) - ->dynamic_values[fixnum_value(sym->tls_index)]; + ->dynamic_values[fixnum_value(sym->tls_index)]; #else return sym->value; #endif } static inline void SetSymbolValue(u64 tagged_symbol_pointer,lispobj val, void *thread) { - struct symbol *sym= (struct symbol *) - (pointer_sized_uint_t)(tagged_symbol_pointer-OTHER_POINTER_LOWTAG); + struct symbol *sym= (struct symbol *) + (pointer_sized_uint_t)(tagged_symbol_pointer-OTHER_POINTER_LOWTAG); #ifdef LISP_FEATURE_SB_THREAD if(thread && sym->tls_index) { - lispobj *pr= &(((union per_thread_data *)thread) - ->dynamic_values[fixnum_value(sym->tls_index)]); - if(*pr!= UNBOUND_MARKER_WIDETAG) { - *pr=val; - return; - } + lispobj *pr= &(((union per_thread_data *)thread) + ->dynamic_values[fixnum_value(sym->tls_index)]); + if(*pr!=NO_TLS_VALUE_MARKER_WIDETAG) { + *pr=val; + return; + } } #endif sym->value = val; } static inline void SetTlSymbolValue(u64 tagged_symbol_pointer,lispobj val, void *thread) { #ifdef LISP_FEATURE_SB_THREAD - struct symbol *sym= (struct symbol *) - (pointer_sized_uint_t)(tagged_symbol_pointer-OTHER_POINTER_LOWTAG); + struct symbol *sym= (struct symbol *) + (pointer_sized_uint_t)(tagged_symbol_pointer-OTHER_POINTER_LOWTAG); ((union per_thread_data *)thread) - ->dynamic_values[fixnum_value(sym->tls_index)] - =val; + ->dynamic_values[fixnum_value(sym->tls_index)] + =val; #else SetSymbolValue(tagged_symbol_pointer,val,thread) ; #endif @@ -98,10 +95,10 @@ static inline void SetTlSymbolValue(u64 tagged_symbol_pointer,lispobj val, void static inline os_context_t *get_interrupt_context_for_thread(struct thread *th) { return th->interrupt_contexts - [fixnum_value(SymbolValue(FREE_INTERRUPT_CONTEXT_INDEX,th)-1)]; + [fixnum_value(SymbolValue(FREE_INTERRUPT_CONTEXT_INDEX,th)-1)]; } -/* This is clearly per-arch and possibly even per-OS code, but we can't +/* This is clearly per-arch and possibly even per-OS code, but we can't * put it somewhere sensible like x86-linux-os.c because it needs too * much stuff like struct thread and all_threads to be defined, which * usually aren't by that time. So, it's here instead. Sorry */ @@ -111,8 +108,8 @@ static inline struct thread *arch_os_get_current_thread() { #if defined(LISP_FEATURE_X86) register struct thread *me=0; if(all_threads) - __asm__ __volatile__ ("movl %%fs:%c1,%0" : "=r" (me) - : "i" (offsetof (struct thread,this))); + __asm__ __volatile__ ("movl %%fs:%c1,%0" : "=r" (me) + : "i" (offsetof (struct thread,this))); return me; #else return pthread_getspecific(specials);