X-Git-Url: http://plrg.eecs.uci.edu/git/?p=c11tester.git;a=blobdiff_plain;f=libthreads.cc;h=4d61e536c9c4e44d603616d92d205ce0f193a7e5;hp=73a948cc4a493a7fa4b3c1bea65af8653c6ebc17;hb=7742256df627848c1c375f979f5369a45c92057b;hpb=3cade2fadc95d3dcbc37f5e6c4da4b8e9b559c23 diff --git a/libthreads.cc b/libthreads.cc index 73a948cc..4d61e536 100644 --- a/libthreads.cc +++ b/libthreads.cc @@ -1,6 +1,8 @@ -#include "libthreads.h" -#include "common.h" #include "threads.h" +#include "common.h" +#include "threads-model.h" +#include "action.h" + /* global "model" object */ #include "model.h" @@ -8,28 +10,25 @@ /* * 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; - DBG(); - ret = model->add_thread(new Thread(t, start_routine, arg)); - DEBUG("create thread %d\n", id_to_int(thrd_to_id(*t))); - return ret; + struct thread_params params = { start_routine, arg }; + /* seq_cst is just a 'don't care' parameter */ + model->switch_thread(new ModelAction(THREAD_CREATE, std::memory_order_seq_cst, t, (uint64_t)¶ms)); + 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) - ret = model->switch_to_master(NULL); - return ret; + Thread *th = t.priv; + model->switch_thread(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 model->switch_to_master(new ModelAction(THREAD_YIELD, memory_order_seq_cst, NULL, VALUE_NONE)); + model->switch_thread(new ModelAction(THREAD_YIELD, std::memory_order_seq_cst, thread_current(), VALUE_NONE)); } thrd_t thrd_current(void)