X-Git-Url: http://plrg.eecs.uci.edu/git/?a=blobdiff_plain;f=threads.cc;h=6a9391f0302467097b415bf4b129eb1b90fffaa5;hb=99c0d85ef14259735fdd84cb7b3e578f64434314;hp=bdeea6a0e0c34c573df705d3874f8c81b8e8316b;hpb=a2b1ce7713d29dd465afc54660781aa04dc7db59;p=model-checker.git diff --git a/threads.cc b/threads.cc index bdeea6a..6a9391f 100644 --- a/threads.cc +++ b/threads.cc @@ -9,23 +9,32 @@ static void * stack_allocate(size_t size) { - return MYMALLOC(size); + return malloc(size); } static void stack_free(void *stack) { - MYFREE(stack); + free(stack); } Thread * thread_current(void) { + ASSERT(model); return model->scheduler->get_current_thread(); } -/* This method just gets around makecontext not being 64-bit clean */ - +/** + * Provides a startup wrapper for each thread, allowing some initial + * model-checking data to be recorded. This method also gets around makecontext + * not being 64-bit clean + */ void thread_startup() { Thread * curr_thread = thread_current(); + + /* Add dummy "start" action, just to create a first clock vector */ + model->switch_to_master(new ModelAction(THREAD_START, memory_order_seq_cst, curr_thread)); + + /* Call the actual thread function */ curr_thread->start_routine(curr_thread->arg); } @@ -68,19 +77,20 @@ void Thread::complete() } } -Thread::Thread(thrd_t *t, void (*func)(void *), void *a) { +Thread::Thread(thrd_t *t, void (*func)(void *), void *a) : + start_routine(func), + arg(a), + user_thread(t), + state(THREAD_CREATED), + last_action_val(VALUE_NONE) +{ int ret; - user_thread = t; - start_routine = func; - arg = a; - /* Initialize state */ ret = create_context(); if (ret) printf("Error in create_context\n"); - state = THREAD_CREATED; id = model->get_next_id(); *user_thread = id; parent = thread_current();