X-Git-Url: http://plrg.eecs.uci.edu/git/?p=c11tester.git;a=blobdiff_plain;f=promise.h;h=c131d743aa185d2972cd2d1922fb7ac43d6c3c8d;hp=fda00cc508229221e5965ea3c752443d503bb1ca;hb=963f325c5b5df37487e17c3a05f4d15efabb8870;hpb=ac06a98f90fe5c333cd8628e72e11f532c0c6444 diff --git a/promise.h b/promise.h index fda00cc5..c131d743 100644 --- a/promise.h +++ b/promise.h @@ -6,22 +6,58 @@ #ifndef __PROMISE_H__ #define __PROMISE_H__ + #include +#include +#include "modeltypes.h" +#include "mymemory.h" class ModelAction; +struct future_value { + uint64_t value; + modelclock_t expiration; + thread_id_t tid; +}; + class Promise { public: - Promise(ModelAction * act, uint64_t value); - ModelAction * get_action() { return read; } - int increment_threads() { return ++numthreads; } - uint64_t get_value() { return value; } + Promise(ModelAction *read, struct future_value fv); + ModelAction * get_action() const { return read; } + bool eliminate_thread(thread_id_t tid); + void add_thread(thread_id_t tid); + bool thread_is_available(thread_id_t tid) const; + bool has_failed() const; + void set_write(const ModelAction *act) { write = act; } + const ModelAction * get_write() const { return write; } + int get_num_available_threads() const { return num_available_threads; } + bool is_compatible(const ModelAction *act) const; + bool is_compatible_exclusive(const ModelAction *act) const; + + modelclock_t get_expiration() const { return fv.expiration; } + uint64_t get_value() const { return fv.value; } + struct future_value get_fv() const { return fv; } + + void print() const; + bool equals(const Promise *x) const { return this == x; } + bool equals(const ModelAction *x) const { return false; } + + SNAPSHOTALLOC private: - uint64_t value; - ModelAction *read; - unsigned int numthreads; + /** @brief Thread ID(s) for thread(s) that potentially can satisfy this + * promise */ + std::vector< bool, SnapshotAlloc > available_thread; + + int num_available_threads; + + const future_value fv; + + /** @brief The action which reads a promised value */ + ModelAction * const read; + + const ModelAction *write; }; #endif