X-Git-Url: http://plrg.eecs.uci.edu/git/?a=blobdiff_plain;f=libthreads.cc;h=05cca8646a3daf69db7c2992e70e540c893dccf2;hb=d2cbbe4ce6d8f6e1aa23b8fe639ed58edf1789b7;hp=fd6259ad64d62474e0f7b7565cc72685e56288ad;hpb=62329036957e44d4fa85a5461766679916a03f74;p=cdsspec-compiler.git diff --git a/libthreads.cc b/libthreads.cc index fd6259a..05cca86 100644 --- a/libthreads.cc +++ b/libthreads.cc @@ -1,6 +1,6 @@ -#include "libthreads.h" +#include #include "common.h" -#include "threads_internal.h" +#include "threads-model.h" /* global "model" object */ #include "model.h" @@ -8,29 +8,29 @@ /* * User program API functions */ -int thrd_create(thrd_t *t, void (*start_routine)(), void *arg) +int thrd_create(thrd_t *t, thrd_start_t start_routine, void *arg) { - int ret; + Thread *thread; DBG(); - ret = model->add_thread(new Thread(t, start_routine, arg)); - DEBUG("create thread %d\n", thrd_to_id(*t)); - return ret; + thread = new Thread(t, start_routine, arg); + model->add_thread(thread); + DEBUG("create thread %d\n", id_to_int(thrd_to_id(*t))); + /* seq_cst is just a 'don't care' parameter */ + model->switch_to_master(new ModelAction(THREAD_CREATE, std::memory_order_seq_cst, thread, VALUE_NONE)); + return 0; } int thrd_join(thrd_t t) { - int ret = 0; Thread *th = model->get_thread(thrd_to_id(t)); - while (th->get_state() != THREAD_COMPLETED && !ret) - /* seq_cst is just a 'don't care' parameter */ - ret = thread_current()->switch_to_master(new ModelAction(THREAD_JOIN, memory_order_seq_cst, NULL, VALUE_NONE)); - return ret; + model->switch_to_master(new ModelAction(THREAD_JOIN, std::memory_order_seq_cst, th, id_to_int(thrd_to_id(t)))); + return 0; } -int thrd_yield(void) +/** A no-op, for now */ +void thrd_yield(void) { - /* seq_cst is just a 'don't care' parameter */ - return thread_current()->switch_to_master(new ModelAction(THREAD_YIELD, memory_order_seq_cst, NULL, VALUE_NONE)); + //model->switch_to_master(new ModelAction(THREAD_YIELD, std::memory_order_seq_cst, thread_current(), VALUE_NONE)); } thrd_t thrd_current(void)