X-Git-Url: http://demsky.eecs.uci.edu/git/?a=blobdiff_plain;f=threads.h;h=9fecdfd3c7466398c85ec3dfafebb314d5887bfa;hb=b59d5f84ac4800cc144fc7c8837d96181423d9ae;hp=9456a22f2fe4942b1004a87794fa3474eaeab26b;hpb=15190694fd79202132be5f6e056fa5c00893664e;p=model-checker.git diff --git a/threads.h b/threads.h index 9456a22..9fecdfd 100644 --- a/threads.h +++ b/threads.h @@ -11,10 +11,7 @@ #include "mymemory.h" #include "libthreads.h" - -typedef int thread_id_t; - -#define THREAD_ID_T_NONE -1 +#include "modeltypes.h" /** @brief Represents the state of a user Thread */ typedef enum thread_state { @@ -38,6 +35,7 @@ class ModelAction; /** @brief A Thread is created for each user-space thread */ class Thread { public: + Thread(thread_id_t tid); Thread(thrd_t *t, void (*func)(void *), void *a); ~Thread(); void complete(); @@ -84,6 +82,14 @@ public: */ void push_wait_list(ModelAction *act) { wait_list.push_back(act); } + unsigned int num_wait_list() { + return wait_list.size(); + } + + ModelAction * get_waiter(unsigned int i) { + return wait_list[i]; + } + ModelAction * get_pending() { return pending; } void set_pending(ModelAction *act) { pending = act; } /** @@ -96,6 +102,8 @@ public: return ret; } + bool is_model_thread() { return model_thread; } + friend void thread_startup(); SNAPSHOTALLOC @@ -118,7 +126,7 @@ private: * list is used for thread joins, where another Thread waits for this * Thread to complete */ - std::vector wait_list; + std::vector< ModelAction *, SnapshotAlloc > wait_list; /** * The value returned by the last action in this thread @@ -126,6 +134,9 @@ private: * @see Thread::get_return_value() */ uint64_t last_action_val; + + /** @brief Is this Thread a special model-checker thread? */ + const bool model_thread; }; Thread * thread_current();