X-Git-Url: http://git.sourceforge.jp/view?a=blobdiff_plain;f=boehm-gc%2Fsolaris_threads.c;h=b599c5816ad2462cf06a16150a9a2f7207a05fbf;hb=5cbbcbc9cfece5949c8ed4ec796706e7cd3364d2;hp=11b0e0375f6c85bde7e9c74190f24ae4c9075494;hpb=fa4ee1f113cb5cb7452551cdd2a608656c06a45c;p=pf3gnuchains%2Fgcc-fork.git diff --git a/boehm-gc/solaris_threads.c b/boehm-gc/solaris_threads.c index 11b0e0375f6..b599c5816ad 100644 --- a/boehm-gc/solaris_threads.c +++ b/boehm-gc/solaris_threads.c @@ -16,9 +16,9 @@ */ /* Boehm, September 14, 1994 4:44 pm PDT */ -# if defined(GC_SOLARIS_THREADS) +#include "private/gc_priv.h" -# include "private/gc_priv.h" +# if defined(GC_SOLARIS_THREADS) || defined(GC_SOLARIS_PTHREADS) # include "private/solaris_threads.h" # include # include @@ -37,6 +37,10 @@ # include # include +#ifdef HANDLE_FORK + --> Not yet supported. Try porting the code from linux_threads.c. +#endif + /* * This is the default size of the LWP arrays. If there are more LWPs * than this when a stop-the-world GC happens, set_max_lwps will be @@ -361,7 +365,7 @@ static void restart_all_lwps() sizeof (prgregset_t)) != 0) { int j; - for(j = 0; j < NGREG; j++) + for(j = 0; j < NPRGREG; j++) { GC_printf3("%i: %x -> %x\n", j, GC_lwp_registers[i][j], @@ -414,7 +418,6 @@ GC_bool GC_thr_initialized = FALSE; size_t GC_min_stack_sz; -size_t GC_page_sz; /* * stack_head is stored at the top of free stacks @@ -456,7 +459,7 @@ ptr_t GC_stack_alloc(size_t * stack_size) GC_stack_free_lists[index] = GC_stack_free_lists[index]->next; } else { #ifdef MMAP_STACKS - base = (ptr_t)mmap(0, search_sz + GC_page_sz, + base = (ptr_t)mmap(0, search_sz + GC_page_size, PROT_READ|PROT_WRITE, MAP_PRIVATE |MAP_NORESERVE, GC_zfd, 0); if (base == (ptr_t)-1) @@ -465,27 +468,27 @@ ptr_t GC_stack_alloc(size_t * stack_size) return NULL; } - mprotect(base, GC_page_sz, PROT_NONE); - /* Should this use divHBLKSZ(search_sz + GC_page_sz) ? -- cf */ + mprotect(base, GC_page_size, PROT_NONE); + /* Should this use divHBLKSZ(search_sz + GC_page_size) ? -- cf */ GC_is_fresh((struct hblk *)base, divHBLKSZ(search_sz)); - base += GC_page_sz; + base += GC_page_size; #else - base = (ptr_t) GC_scratch_alloc(search_sz + 2*GC_page_sz); + base = (ptr_t) GC_scratch_alloc(search_sz + 2*GC_page_size); if (base == NULL) { *stack_size = 0; return NULL; } - base = (ptr_t)(((word)base + GC_page_sz) & ~(GC_page_sz - 1)); + base = (ptr_t)(((word)base + GC_page_size) & ~(GC_page_size - 1)); /* Protect hottest page to detect overflow. */ # ifdef SOLARIS23_MPROTECT_BUG_FIXED - mprotect(base, GC_page_sz, PROT_NONE); + mprotect(base, GC_page_size, PROT_NONE); # endif GC_is_fresh((struct hblk *)base, divHBLKSZ(search_sz)); - base += GC_page_sz; + base += GC_page_size; #endif } *stack_size = search_sz; @@ -665,8 +668,8 @@ void GC_my_stack_limits() /* original thread */ /* Empirically, what should be the stack page with lowest */ /* address is actually inaccessible. */ - stack_size = GC_get_orig_stack_size() - GC_page_sz; - stack = GC_stackbottom - stack_size + GC_page_sz; + stack_size = GC_get_orig_stack_size() - GC_page_size; + stack = GC_stackbottom - stack_size + GC_page_size; } else { stack = me -> stack; } @@ -704,7 +707,7 @@ void GC_push_all_stacks() top = p -> stack + p -> stack_size; } else { /* The original stack. */ - bottom = GC_stackbottom - GC_get_orig_stack_size() + GC_page_sz; + bottom = GC_stackbottom - GC_get_orig_stack_size() + GC_page_size; top = GC_stackbottom; } if ((word)sp > (word)bottom && (word)sp < (word)top) bottom = sp; @@ -783,13 +786,13 @@ void GC_thr_init(void) { GC_thread t; thread_t tid; + int ret; if (GC_thr_initialized) return; GC_thr_initialized = TRUE; GC_min_stack_sz = ((thr_min_stack() + 32*1024 + HBLKSIZE-1) & ~(HBLKSIZE - 1)); - GC_page_sz = sysconf(_SC_PAGESIZE); #ifdef MMAP_STACKS GC_zfd = open("/dev/zero", O_RDONLY); if (GC_zfd == -1) @@ -801,9 +804,11 @@ void GC_thr_init(void) t = GC_new_thread(thr_self()); t -> stack_size = 0; t -> flags = DETACHED | CLIENT_OWNS_STACK; - if (thr_create(0 /* stack */, 0 /* stack_size */, GC_thr_daemon, - 0 /* arg */, THR_DETACHED | THR_DAEMON, - &tid /* thread_id */) != 0) { + ret = thr_create(0 /* stack */, 0 /* stack_size */, GC_thr_daemon, + 0 /* arg */, THR_DETACHED | THR_DAEMON, + &tid /* thread_id */); + if (ret != 0) { + GC_err_printf1("Thr_create returned %ld\n", ret); ABORT("Cant fork daemon"); } thr_setprio(tid, 126); @@ -823,7 +828,7 @@ int GC_thr_suspend(thread_t target_thread) if (result == 0) { t = GC_lookup_thread(target_thread); if (t == 0) ABORT("thread unknown to GC"); - t -> flags |= SUSPENDED; + t -> flags |= SUSPNDED; } UNLOCK(); return(result); @@ -839,7 +844,7 @@ int GC_thr_continue(thread_t target_thread) if (result == 0) { t = GC_lookup_thread(target_thread); if (t == 0) ABORT("thread unknown to GC"); - t -> flags &= ~SUSPENDED; + t -> flags &= ~SUSPNDED; } UNLOCK(); return(result); @@ -911,10 +916,7 @@ GC_thr_create(void *stack_base, size_t stack_size, void * stack = stack_base; LOCK(); - if (!GC_thr_initialized) - { - GC_thr_init(); - } + if (!GC_is_initialized) GC_init_inner(); GC_multithreaded++; if (stack == 0) { if (stack_size == 0) stack_size = 1024*1024; @@ -928,7 +930,7 @@ GC_thr_create(void *stack_base, size_t stack_size, my_flags |= CLIENT_OWNS_STACK; } if (flags & THR_DETACHED) my_flags |= DETACHED; - if (flags & THR_SUSPENDED) my_flags |= SUSPENDED; + if (flags & THR_SUSPENDED) my_flags |= SUSPNDED; result = thr_create(stack, stack_size, start_routine, arg, flags & ~THR_DETACHED, &my_new_thread); if (result == 0) {