X-Git-Url: http://plrg.eecs.uci.edu/git/?p=c11tester.git;a=blobdiff_plain;f=cyclegraph.h;h=83d3db21d77cdfc192f0bd286d21fee188de7fac;hp=d0258d180f6e60546bc9619b1b3f56c86bda33de;hb=ff29187c639cdb032debdb036d2c9062f77879b0;hpb=6c42e6f6e00d6283bce4e9086b111b4b78509ded diff --git a/cyclegraph.h b/cyclegraph.h index d0258d18..83d3db21 100644 --- a/cyclegraph.h +++ b/cyclegraph.h @@ -1,57 +1,175 @@ -/** @file cyclegraph.h @brief Data structure to track ordering - * constraints on modification order. The idea is to see whether a - * total order exists that satisfies the ordering constriants.*/ +/** + * @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 +#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(); ~CycleGraph(); - void addEdge(const ModelAction *from, const ModelAction *to); - bool checkForCycles(); - void addRMWEdge(const ModelAction *from, const ModelAction *to); + 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(const ModelAction *); + 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(CycleNode *from, CycleNode *to); + 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 to one ModelAction */ +/** + * @brief A node within a CycleGraph; corresponds either to one ModelAction or + * to a promised future value + */ class CycleNode { public: - CycleNode(const 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(); + 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: /** @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 edges; + 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; + CycleNode *hasRMW; }; -#endif +/* + * @brief Adds an edge between objects + * + * This function will add an edge between any two objects which can be + * associated with a CycleNode. That is, if they have a CycleGraph::getNode + * implementation. + * + * The object to is ordered after the object from. + * + * @param to The edge points to this object, of type T + * @param from The edge comes from this object, of type U + */ +template +void CycleGraph::addEdge(const T from, const U to) +{ + ASSERT(from); + ASSERT(to); + + CycleNode *fromnode = getNode(from); + CycleNode *tonode = getNode(to); + + addNodeEdge(fromnode, tonode); +} + +/** + * Checks whether one ModelAction can reach another ModelAction/Promise + * @param from The ModelAction from which to begin exploration + * @param to The ModelAction or Promise to reach + * @return True, @a from can reach @a to; otherwise, false + */ +template +bool CycleGraph::checkReachable(const ModelAction *from, const T *to) const +{ + CycleNode *fromnode = getNode_noCreate(from); + CycleNode *tonode = getNode_noCreate(to); + + if (!fromnode || !tonode) + return false; + + return checkReachable(fromnode, tonode); +} + +#endif /* __CYCLEGRAPH_H__ */