X-Git-Url: http://demsky.eecs.uci.edu/git/?a=blobdiff_plain;f=promise.h;h=84d5aa49b3af7b8156ef4744e270f128c6a0cabf;hb=130a35155171503883aaf18e57f8957ce63d06e8;hp=0adc3de1aabb47d9d8df7a007d59eb09f391a257;hpb=875ebf8e11b4bdd702604785837b6b91b748900d;p=model-checker.git diff --git a/promise.h b/promise.h index 0adc3de..84d5aa4 100644 --- a/promise.h +++ b/promise.h @@ -8,12 +8,13 @@ #define __PROMISE_H__ #include -#include #include "modeltypes.h" #include "mymemory.h" +#include "stl-model.h" class ModelAction; +class ModelExecution; struct future_value { uint64_t value; @@ -23,13 +24,14 @@ struct future_value { class Promise { public: - Promise(ModelAction *read, struct future_value fv); + Promise(const ModelExecution *execution, ModelAction *read, struct future_value fv); bool add_reader(ModelAction *reader); ModelAction * get_reader(unsigned int i) const; unsigned int get_num_readers() const { return readers.size(); } bool eliminate_thread(thread_id_t tid); void add_thread(thread_id_t tid); bool thread_is_available(thread_id_t tid) const; + unsigned int max_available_thread_idx() const; bool has_failed() const; void set_write(const ModelAction *act) { write = act; } const ModelAction * get_write() const { return write; } @@ -43,6 +45,8 @@ class Promise { uint64_t get_value() const { return fv.value; } struct future_value get_fv() const { return fv; } + int get_index() const; + void print() const; bool equals(const Promise *x) const { return this == x; } @@ -50,16 +54,19 @@ class Promise { SNAPSHOTALLOC private: + /** @brief The execution which created this Promise */ + const ModelExecution *execution; + /** @brief Thread ID(s) for thread(s) that potentially can satisfy this * promise */ - std::vector< bool, SnapshotAlloc > available_thread; + SnapVector available_thread; int num_available_threads; const future_value fv; /** @brief The action(s) which read the promised future value */ - std::vector< ModelAction *, SnapshotAlloc > readers; + SnapVector readers; const ModelAction *write; };