X-Git-Url: http://plrg.eecs.uci.edu/git/?p=c11tester.git;a=blobdiff_plain;f=cyclegraph.h;h=f03c4ecf33496314387d99c28f19dc80f3839e27;hp=ed534170fd339ee42427535d38e3979e6d4cf496;hb=482c7447dd2f63823eb969c37dd6fb4e22991fde;hpb=857205edf46f2daefe0b6e471b902fcfd9c67df2 diff --git a/cyclegraph.h b/cyclegraph.h index ed534170..f03c4ecf 100644 --- a/cyclegraph.h +++ b/cyclegraph.h @@ -1,37 +1,133 @@ -#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 "action.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; + + template + bool checkReachable(const ModelAction *from, const T *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 *act); + CycleNode * getNode(const Promise *promise); + CycleNode * getNode_noCreate(const ModelAction *act) const; + CycleNode * getNode_noCreate(const Promise *promise) const; + 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__ */