X-Git-Url: http://demsky.eecs.uci.edu/git/?a=blobdiff_plain;f=threads.cc;h=93160310466d6539d0863118c048e69ebbf7621d;hb=9b6c5d465f4a762dbe75baf2c293510ee6e9bd07;hp=23041b28b55db34d617b86b25e8f3c527810b918;hpb=bd3decdede241f9d7f9ac745d47518099b9b36b5;p=c11tester.git diff --git a/threads.cc b/threads.cc index 23041b28..93160310 100644 --- a/threads.cc +++ b/threads.cc @@ -61,13 +61,13 @@ Thread * thread_current(void) } void modelexit() { - model->switch_to_master(new ModelAction(THREAD_FINISH, std::memory_order_seq_cst, thread_current())); + model->switch_thread(new ModelAction(THREAD_FINISH, std::memory_order_seq_cst, thread_current())); } void initMainThread() { atexit(modelexit); Thread * curr_thread = thread_current(); - model->switch_to_master(new ModelAction(THREAD_START, std::memory_order_seq_cst, curr_thread)); + model->switch_thread(new ModelAction(THREAD_START, std::memory_order_seq_cst, curr_thread)); } /** @@ -80,7 +80,7 @@ void thread_startup() Thread * curr_thread = thread_current(); #ifndef TLS /* Add dummy "start" action, just to create a first clock vector */ - model->switch_to_master(new ModelAction(THREAD_START, std::memory_order_seq_cst, curr_thread)); + model->switch_thread(new ModelAction(THREAD_START, std::memory_order_seq_cst, curr_thread)); #endif /* Call the actual thread function */ @@ -93,7 +93,7 @@ void thread_startup() } #ifndef TLS /* Finish thread properly */ - model->switch_to_master(new ModelAction(THREAD_FINISH, std::memory_order_seq_cst, curr_thread)); + model->switch_thread(new ModelAction(THREAD_FINISH, std::memory_order_seq_cst, curr_thread)); #endif } @@ -212,7 +212,7 @@ void * helper_thread(void * ptr) { curr_thread->helpercontext.uc_stack.ss_sp = curr_thread->helper_stack; curr_thread->helpercontext.uc_stack.ss_size = STACK_SIZE; curr_thread->helpercontext.uc_stack.ss_flags = 0; - curr_thread->helpercontext.uc_link = model->get_system_context(); + curr_thread->helpercontext.uc_link = NULL; makecontext(&curr_thread->helpercontext, finalize_helper_thread, 0); model_swapcontext(&curr_thread->context, &curr_thread->helpercontext); @@ -235,7 +235,7 @@ void tlsdestructor(void *v) { return; } /* Finish thread properly */ - model->switch_to_master(new ModelAction(THREAD_FINISH, std::memory_order_seq_cst, thread_current())); + model->switch_thread(new ModelAction(THREAD_FINISH, std::memory_order_seq_cst, thread_current())); } #endif @@ -285,7 +285,7 @@ int Thread::create_context() context.uc_stack.ss_sp = stack; context.uc_stack.ss_size = STACK_SIZE; context.uc_stack.ss_flags = 0; - context.uc_link = model->get_system_context(); + context.uc_link = NULL; #ifdef TLS makecontext(&context, setup_context, 0); #else @@ -335,6 +335,9 @@ int Thread::swap(Thread *t, Thread *t2) { t->set_state(THREAD_READY); t2->set_state(THREAD_RUNNING); + if (t == t2) + return 0; + #ifdef TLS if (t2->tls != NULL) set_tls_addr((uintptr_t)t2->tls); @@ -342,12 +345,15 @@ int Thread::swap(Thread *t, Thread *t2) return model_swapcontext(&t->context, &t2->context); } -/** Terminate a thread and free its stack. */ +/** Terminate a thread. */ void Thread::complete() { ASSERT(!is_complete()); DEBUG("completed thread %d\n", id_to_int(get_id())); state = THREAD_COMPLETED; +} + +void Thread::freeResources() { if (stack) stack_free(stack); #ifdef TLS