X-Git-Url: http://plrg.eecs.uci.edu/git/?p=model-checker.git;a=blobdiff_plain;f=schedule.cc;h=7a703abab8cc7e229f7218c85add8580c7f3ad53;hp=5c93381b99763344d3fce9548a39955c041c6d79;hb=928115156b5d083b02ab934e2b291781af16cc0f;hpb=c6fb6d40ad44767d31cb682d3d4e32c7bbb4b6d3 diff --git a/schedule.cc b/schedule.cc index 5c93381..7a703ab 100644 --- a/schedule.cc +++ b/schedule.cc @@ -1,3 +1,6 @@ +#include +#include + #include "threads.h" #include "schedule.h" #include "common.h" @@ -16,9 +19,11 @@ void Scheduler::set_enabled(Thread *t, bool enabled_status) { int threadid=id_to_int(t->get_id()); if (threadid>=enabled_len) { bool * new_enabled=(bool *)malloc(sizeof(bool)*(threadid+1)); - memcpy(new_enabled, is_enabled, enabled_len*sizeof(bool)); memset(&new_enabled[enabled_len], 0, (threadid+1-enabled_len)*sizeof(bool)); - free(is_enabled); + if (is_enabled != NULL) { + memcpy(new_enabled, is_enabled, enabled_len*sizeof(bool)); + free(is_enabled); + } is_enabled=new_enabled; enabled_len=threadid+1; } @@ -68,8 +73,8 @@ void Scheduler::wake(Thread *t) } /** - * Remove one Thread from the scheduler. This implementation defaults to FIFO, - * if a thread is not already provided. + * Select a Thread. This implementation defaults to round-robin, if a + * thread is not already provided. * * @param t Thread to run, if chosen by an external entity (e.g., * ModelChecker). May be NULL to indicate no external choice. @@ -77,7 +82,6 @@ void Scheduler::wake(Thread *t) */ Thread * Scheduler::next_thread(Thread *t) { - printf("%p\n",t); if ( t == NULL ) { int old_curr_thread = curr_thread_index; while(true) { @@ -94,7 +98,6 @@ Thread * Scheduler::next_thread(Thread *t) } else { curr_thread_index = id_to_int(t->get_id()); } - printf("index=%u enabled=%u\n", curr_thread_index, is_enabled[curr_thread_index]); current = t; print();