AsyncProcedure<T> procedure = entry != null ? entry : procedure_;
- ReadGraphImpl queryGraph = graph.withParent(entry);
+ ReadGraphImpl queryGraph = graph.withParent(entry, null, needsToBlock);
queryGraph.asyncBarrier.inc();
- ReadGraphImpl executeGraph = graph.withParent(graph.parent);
+ ReadGraphImpl executeGraph = graph.withParent(graph.parent, null, needsToBlock);
executeGraph.asyncBarrier.inc();
try {
} finally {
executeGraph.asyncBarrier.dec();
- executeGraph.asyncBarrier.waitBarrier(procedure, executeGraph);
+ if(needsToBlock)
+ executeGraph.asyncBarrier.waitBarrier(procedure, executeGraph);
}