}
// *EXPERIMENTAL*
- // Returns true if all edges from=>to exist.
+ // Returns true if an edge from=>to exist.
// This function does not use any global state except for 'this' itself,
// and thus can be called from different threads w/o locking.
// This would be racy.
// FIXME: investigate how much we can prove about this race being "benign".
- bool hasAllEdges(const BV &from, uptr to) {
- for (typename BV::Iterator it(from); it.hasNext(); ) {
- uptr idx = it.next();
- if (!v[idx].getBit(to)) return false;
- }
- return true;
- }
+ bool hasEdge(uptr from, uptr to) { return v[from].getBit(to); }
// Returns true if the edge from=>to was removed.
bool removeEdge(uptr from, uptr to) {
recursive_locks[n_recursive_locks++] = lock_id;
return false;
}
- if (stk) {
- CHECK_LT(n_all_locks_, ARRAY_SIZE(all_locks_with_contexts_));
- // lock_id < BV::kSize, can cast to a smaller int.
- u32 lock_id_short = static_cast<u32>(lock_id);
- all_locks_with_contexts_[n_all_locks_++] = {lock_id_short, stk};
- }
+ CHECK_LT(n_all_locks_, ARRAY_SIZE(all_locks_with_contexts_));
+ // lock_id < BV::kSize, can cast to a smaller int.
+ u32 lock_id_short = static_cast<u32>(lock_id);
+ all_locks_with_contexts_[n_all_locks_++] = {lock_id_short, stk};
return true;
}
return bv_;
}
+ uptr getNumLocks() const { return n_all_locks_; }
+ uptr getLock(uptr idx) const { return all_locks_with_contexts_[idx].lock; }
+
private:
BV bv_;
uptr epoch_;
if (cur_node && local_epoch == current_epoch_ &&
local_epoch == nodeToEpoch(cur_node)) {
uptr cur_idx = nodeToIndexUnchecked(cur_node);
- return g_.hasAllEdges(dtls->getLocks(local_epoch), cur_idx);
+ for (uptr i = 0, n = dtls->getNumLocks(); i < n; i++) {
+ if (!g_.hasEdge(dtls->getLock(i), cur_idx))
+ return false;
+ }
+ return true;
}
return false;
}
from.clear();
from.setBit(1);
EXPECT_EQ(1U, g.addEdges(from, 4, added_edges, kMaxEdges));
- EXPECT_TRUE(g.hasAllEdges(from, 4));
- EXPECT_FALSE(g.hasAllEdges(from, 5));
+ EXPECT_TRUE(g.hasEdge(1, 4));
+ EXPECT_FALSE(g.hasEdge(1, 5));
EXPECT_EQ(1U, added_edges[0]);
from.setBit(2);
from.setBit(3);
- EXPECT_FALSE(g.hasAllEdges(from, 4));
EXPECT_EQ(2U, g.addEdges(from, 4, added_edges, kMaxEdges));
- EXPECT_TRUE(g.hasAllEdges(from, 4));
+ EXPECT_TRUE(g.hasEdge(2, 4));
+ EXPECT_FALSE(g.hasEdge(2, 5));
+ EXPECT_TRUE(g.hasEdge(3, 4));
+ EXPECT_FALSE(g.hasEdge(3, 5));
EXPECT_EQ(2U, added_edges[0]);
EXPECT_EQ(3U, added_edges[1]);
}