X-Git-Url: http://plrg.eecs.uci.edu/git/?p=c11tester.git;a=blobdiff_plain;f=cyclegraph.h;h=c0bd7d66167aea6bd71fa323efb29e18a57dfac4;hp=df9d46c17d108c51af33862cb1777a6b150ab515;hb=d3dffe991352938e5c2ab738ce70e3ec0f069d5f;hpb=1667e1f8017bd3f4bf5b1ef5712e3156577f99a2 diff --git a/cyclegraph.h b/cyclegraph.h index df9d46c1..c0bd7d66 100644 --- a/cyclegraph.h +++ b/cyclegraph.h @@ -1,38 +1,128 @@ -#ifndef CYCLEGRAPH_H -#define CYCLEGRAPH_H +/** + * @file cyclegraph.h + * @brief Data structure to track ordering constraints on modification order + * + * Used to determine whether a total order exists that satisfies the ordering + * constraints. + */ + +#ifndef __CYCLEGRAPH_H__ +#define __CYCLEGRAPH_H__ #include "hashtable.h" #include #include +#include "config.h" +#include "mymemory.h" +class Promise; class CycleNode; class ModelAction; +typedef std::vector< const Promise *, ModelAlloc > promise_list_t; + /** @brief A graph of Model Actions for tracking cycles. */ class CycleGraph { public: CycleGraph(); - void addEdge(ModelAction *from, ModelAction *to); - bool checkForCycles(); + ~CycleGraph(); + + template + void addEdge(const T from, const U to); + + bool checkForCycles() const; + void addRMWEdge(const ModelAction *from, const ModelAction *rmw); + bool checkPromise(const ModelAction *from, Promise *p) const; + bool checkReachable(const ModelAction *from, const ModelAction *to) const; + void startChanges(); + void commitChanges(); + void rollbackChanges(); +#if SUPPORT_MOD_ORDER_DUMP + void dumpNodes(FILE *file) const; + void dumpGraphToFile(const char *filename) const; +#endif + bool resolvePromise(ModelAction *reader, ModelAction *writer, + promise_list_t *mustResolve); + + SNAPSHOTALLOC private: - CycleNode * getNode(ModelAction *); - HashTable actionToNode; - bool checkReachable(CycleNode *from, CycleNode *to); + void addNodeEdge(CycleNode *fromnode, CycleNode *tonode); + void putNode(const ModelAction *act, CycleNode *node); + CycleNode * getNode(const ModelAction *); + CycleNode * getNode(const Promise *promise); + bool mergeNodes(CycleNode *node1, CycleNode *node2, + promise_list_t *mustMerge); + + HashTable *discovered; + + /** @brief A table for mapping ModelActions to CycleNodes */ + HashTable actionToNode; + /** @brief A table for mapping reader ModelActions to Promise + * CycleNodes */ + HashTable readerToPromiseNode; + +#if SUPPORT_MOD_ORDER_DUMP + std::vector nodeList; +#endif + bool checkReachable(const CycleNode *from, const CycleNode *to) const; + + /** @brief A flag: true if this graph contains cycles */ bool hasCycles; + bool oldCycles; + std::vector< CycleNode *, SnapshotAlloc > rollbackvector; + std::vector< CycleNode *, SnapshotAlloc > rmwrollbackvector; }; +/** + * @brief A node within a CycleGraph; corresponds either to one ModelAction or + * to a promised future value + */ class CycleNode { public: - CycleNode(ModelAction *action); - void addEdge(CycleNode * node); - std::vector * getEdges(); + CycleNode(const ModelAction *act); + CycleNode(const Promise *promise); + bool addEdge(CycleNode *node); + CycleNode * getEdge(unsigned int i) const; + unsigned int getNumEdges() const; + CycleNode * getBackEdge(unsigned int i) const; + unsigned int getNumBackEdges() const; + CycleNode * removeEdge(); + CycleNode * removeBackEdge(); + + bool setRMW(CycleNode *); + CycleNode * getRMW() const; + void clearRMW() { hasRMW = NULL; } + const ModelAction * getAction() const { return action; } + const Promise * getPromise() const { return promise; } + + void popEdge() { + edges.pop_back(); + } + bool is_promise() const { return !action; } + void resolvePromise(const ModelAction *writer); + + SNAPSHOTALLOC private: - ModelAction *action; - std::vector edges; + /** @brief The ModelAction that this node represents */ + const ModelAction *action; + + /** @brief The promise represented by this node; only valid when action + * is NULL */ + const Promise *promise; + + /** @brief The edges leading out from this node */ + std::vector< CycleNode *, SnapshotAlloc > edges; + + /** @brief The edges leading into this node */ + std::vector< CycleNode *, SnapshotAlloc > back_edges; + + /** Pointer to a RMW node that reads from this node, or NULL, if none + * exists */ + CycleNode *hasRMW; }; -#endif +#endif /* __CYCLEGRAPH_H__ */