X-Git-Url: http://plrg.eecs.uci.edu/git/?p=c11tester.git;a=blobdiff_plain;f=libthreads.cc;h=5ff106c8535982bd82835366a0444ce77c0f300e;hp=7dd043c317c715e0604b3cdecf61d210c6bf9742;hb=c369befe1aed16a6ddf9f4937b586c5104d5b92f;hpb=511dc79c4688c5a304e00d57dee1f7ebc84637a1 diff --git a/libthreads.cc b/libthreads.cc index 7dd043c3..5ff106c8 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", thrd_to_id(*t)); - return ret; + struct thread_params params = { start_routine, arg }; + /* seq_cst is just a 'don't care' parameter */ + model->switch_to_master(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_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 model->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)