try {
- ReadGraphImpl queryGraph = graph.withParent(this);
+ ReadGraphImpl queryGraph = graph.withParent(this, null, true);
+ queryGraph.asyncBarrier.inc();
- if(!registered) {
- id.register(graph, this);
+ if (!registered) {
+ id.register(queryGraph, this);
registered = true;
}
-
- queryGraph.asyncBarrier.waitBarrier(id, graph);
+
+ queryGraph.asyncBarrier.dec();
+ queryGraph.asyncBarrier.waitBarrier(id, queryGraph);
} catch (Throwable t) {