From: Brian Norris Date: Tue, 11 Dec 2012 23:22:56 +0000 (-0800) Subject: cyclegraph: uniform spacing, style X-Git-Tag: oopsla2013~440 X-Git-Url: http://demsky.eecs.uci.edu/git/?p=model-checker.git;a=commitdiff_plain;h=fc32611957cecd106751b62bc4de4aeddc9af56c cyclegraph: uniform spacing, style --- diff --git a/cyclegraph.cc b/cyclegraph.cc index 0528029..51066c9 100644 --- a/cyclegraph.cc +++ b/cyclegraph.cc @@ -15,7 +15,8 @@ CycleGraph::CycleGraph() : } /** CycleGraph destructor */ -CycleGraph::~CycleGraph() { +CycleGraph::~CycleGraph() +{ } /** @@ -23,10 +24,11 @@ CycleGraph::~CycleGraph() { * @param action The ModelAction to find a node for * @return The CycleNode paired with this action */ -CycleNode * CycleGraph::getNode(const ModelAction *action) { - CycleNode *node=actionToNode.get(action); - if (node==NULL) { - node=new CycleNode(action); +CycleNode * CycleGraph::getNode(const ModelAction *action) +{ + CycleNode *node = actionToNode.get(action); + if (node == NULL) { + node = new CycleNode(action); actionToNode.put(action, node); #if SUPPORT_MOD_ORDER_DUMP nodeList.push_back(node); @@ -41,12 +43,13 @@ CycleNode * CycleGraph::getNode(const ModelAction *action) { * @param to The edge points to this ModelAction * @param from The edge comes from this ModelAction */ -void CycleGraph::addEdge(const ModelAction *from, const ModelAction *to) { +void CycleGraph::addEdge(const ModelAction *from, const ModelAction *to) +{ ASSERT(from); ASSERT(to); - CycleNode *fromnode=getNode(from); - CycleNode *tonode=getNode(to); + CycleNode *fromnode = getNode(from); + CycleNode *tonode = getNode(to); if (!hasCycles) { // Reflexive edges are cycles @@ -54,26 +57,27 @@ void CycleGraph::addEdge(const ModelAction *from, const ModelAction *to) { } if (!hasCycles) { // Check for Cycles - hasCycles=checkReachable(tonode, fromnode); + hasCycles = checkReachable(tonode, fromnode); } if (fromnode->addEdge(tonode)) rollbackvector.push_back(fromnode); - CycleNode * rmwnode=fromnode->getRMW(); - - //If the fromnode has a rmwnode that is not the tonode, we - //should add an edge between its rmwnode and the tonode - - //If tonode is also a rmw, don't do this check as the execution is - //doomed and we'll catch the problem elsewhere, but we want to allow - //for the possibility of sending to's write value to rmwnode + CycleNode *rmwnode = fromnode->getRMW(); - if (rmwnode!=NULL&&!to->is_rmw()) { + /* + * If the fromnode has a rmwnode that is not the tonode, we should add + * an edge between its rmwnode and the tonode + * + * If tonode is also a rmw, don't do this check as the execution is + * doomed and we'll catch the problem elsewhere, but we want to allow + * for the possibility of sending to's write value to rmwnode + */ + if (rmwnode != NULL && !to->is_rmw()) { if (!hasCycles) { // Check for Cycles - hasCycles=checkReachable(tonode, rmwnode); + hasCycles = checkReachable(tonode, rmwnode); } if (rmwnode->addEdge(tonode)) @@ -86,16 +90,17 @@ void CycleGraph::addEdge(const ModelAction *from, const ModelAction *to) { * can occur in between the rmw and the from action. Only one RMW * action can read from a given write. */ -void CycleGraph::addRMWEdge(const ModelAction *from, const ModelAction *rmw) { +void CycleGraph::addRMWEdge(const ModelAction *from, const ModelAction *rmw) +{ ASSERT(from); ASSERT(rmw); - CycleNode *fromnode=getNode(from); - CycleNode *rmwnode=getNode(rmw); + CycleNode *fromnode = getNode(from); + CycleNode *rmwnode = getNode(rmw); /* Two RMW actions cannot read from the same write. */ if (fromnode->setRMW(rmwnode)) { - hasRMWViolation=true; + hasRMWViolation = true; } else { rmwrollbackvector.push_back(fromnode); } @@ -109,7 +114,7 @@ void CycleGraph::addRMWEdge(const ModelAction *from, const ModelAction *rmw) { */ for (unsigned int i = 0; i < fromnode->getNumEdges(); i++) { CycleNode *tonode = fromnode->getEdge(i); - if (tonode!=rmwnode) { + if (tonode != rmwnode) { if (rmwnode->addEdge(tonode)) rollbackvector.push_back(rmwnode); } @@ -123,33 +128,35 @@ void CycleGraph::addRMWEdge(const ModelAction *from, const ModelAction *rmw) { if (!hasCycles) { // With promises we could be setting up a cycle here if we aren't // careful...avoid it.. - hasCycles=checkReachable(rmwnode, fromnode); + hasCycles = checkReachable(rmwnode, fromnode); } if (fromnode->addEdge(rmwnode)) rollbackvector.push_back(fromnode); } #if SUPPORT_MOD_ORDER_DUMP -void CycleGraph::dumpNodes(FILE *file) { - for (unsigned int i=0;igetAction(); +void CycleGraph::dumpNodes(FILE *file) +{ + for (unsigned int i = 0; i < nodeList.size(); i++) { + CycleNode *cn = nodeList[i]; + const ModelAction *action = cn->getAction(); fprintf(file, "N%u [label=\"%u, T%u\"];\n",action->get_seq_number(),action->get_seq_number(), action->get_tid()); - if (cn->getRMW()!=NULL) { + if (cn->getRMW() != NULL) { fprintf(file, "N%u -> N%u[style=dotted];\n", action->get_seq_number(), cn->getRMW()->getAction()->get_seq_number()); } for (unsigned int j = 0; j < cn->getNumEdges(); j++) { CycleNode *dst = cn->getEdge(j); - const ModelAction *dstaction=dst->getAction(); + const ModelAction *dstaction = dst->getAction(); fprintf(file, "N%u -> N%u;\n", action->get_seq_number(), dstaction->get_seq_number()); } } } -void CycleGraph::dumpGraphToFile(const char *filename) { +void CycleGraph::dumpGraphToFile(const char *filename) +{ char buffer[200]; sprintf(buffer, "%s.dot",filename); - FILE *file=fopen(buffer, "w"); + FILE *file = fopen(buffer, "w"); fprintf(file, "digraph %s {\n",filename); dumpNodes(file); fprintf(file,"}\n"); @@ -163,7 +170,8 @@ void CycleGraph::dumpGraphToFile(const char *filename) { * @param to The ModelAction to reach * @return True, @a from can reach @a to; otherwise, false */ -bool CycleGraph::checkReachable(const ModelAction *from, const ModelAction *to) { +bool CycleGraph::checkReachable(const ModelAction *from, const ModelAction *to) +{ CycleNode *fromnode = actionToNode.get(from); CycleNode *tonode = actionToNode.get(to); @@ -179,16 +187,17 @@ bool CycleGraph::checkReachable(const ModelAction *from, const ModelAction *to) * @param to The CycleNode to reach * @return True, @a from can reach @a to; otherwise, false */ -bool CycleGraph::checkReachable(CycleNode *from, CycleNode *to) { +bool CycleGraph::checkReachable(CycleNode *from, CycleNode *to) +{ std::vector > queue; discovered->reset(); queue.push_back(from); discovered->put(from, from); - while(!queue.empty()) { - CycleNode * node=queue.back(); + while (!queue.empty()) { + CycleNode *node = queue.back(); queue.pop_back(); - if (node==to) + if (node == to) return true; for (unsigned int i = 0; i < node->getNumEdges(); i++) { @@ -202,16 +211,16 @@ bool CycleGraph::checkReachable(CycleNode *from, CycleNode *to) { return false; } -bool CycleGraph::checkPromise(const ModelAction *fromact, Promise *promise) { +bool CycleGraph::checkPromise(const ModelAction *fromact, Promise *promise) +{ std::vector > queue; discovered->reset(); CycleNode *from = actionToNode.get(fromact); - queue.push_back(from); discovered->put(from, from); - while(!queue.empty()) { - CycleNode * node=queue.back(); + while (!queue.empty()) { + CycleNode *node = queue.back(); queue.pop_back(); if (promise->increment_threads(node->getAction()->get_tid())) { @@ -229,19 +238,21 @@ bool CycleGraph::checkPromise(const ModelAction *fromact, Promise *promise) { return false; } -void CycleGraph::startChanges() { - ASSERT(rollbackvector.size()==0); - ASSERT(rmwrollbackvector.size()==0); - ASSERT(oldCycles==hasCycles); - ASSERT(oldRMWViolation==hasRMWViolation); +void CycleGraph::startChanges() +{ + ASSERT(rollbackvector.size() == 0); + ASSERT(rmwrollbackvector.size() == 0); + ASSERT(oldCycles == hasCycles); + ASSERT(oldRMWViolation == hasRMWViolation); } /** Commit changes to the cyclegraph. */ -void CycleGraph::commitChanges() { +void CycleGraph::commitChanges() +{ rollbackvector.resize(0); rmwrollbackvector.resize(0); - oldCycles=hasCycles; - oldRMWViolation=hasRMWViolation; + oldCycles = hasCycles; + oldRMWViolation = hasRMWViolation; } /** Rollback changes to the previous commit. */ @@ -298,16 +309,18 @@ unsigned int CycleNode::getNumEdges() const * Adds an edge from this CycleNode to another CycleNode. * @param node The node to which we add a directed edge */ -bool CycleNode::addEdge(CycleNode *node) { - for(unsigned int i=0;i * discovered; + HashTable *discovered; /** @brief A table for mapping ModelActions to CycleNodes */ HashTable actionToNode; @@ -62,18 +62,18 @@ class CycleGraph { class CycleNode { public: CycleNode(const ModelAction *action); - bool addEdge(CycleNode * node); + bool addEdge(CycleNode *node); CycleNode * getEdge(unsigned int i) const; unsigned int getNumEdges() const; bool setRMW(CycleNode *); - CycleNode* getRMW(); - const ModelAction * getAction() {return action;}; + CycleNode * getRMW() const; + const ModelAction * getAction() const { return action; } void popEdge() { edges.pop_back(); - }; + } void clearRMW() { - hasRMW=NULL; + hasRMW = NULL; } SNAPSHOTALLOC @@ -86,7 +86,7 @@ class CycleNode { /** Pointer to a RMW node that reads from this node, or NULL, if none * exists */ - CycleNode * hasRMW; + CycleNode *hasRMW; }; #endif