if(entry == null) {
graph.processor.schedule(new SessionTask(graph) {
@Override
- public void run(int thread) {
+ public void run0(int thread) {
try {
runnerReadEntry(graph, r, parent, listener, procedure, needsToBlock);
} catch (DatabaseException e) {
if(entry == null) {
graph.processor.schedule(new SessionTask(graph) {
@Override
- public void run(int thread) {
+ public void run0(int thread) {
try {
runnerAsyncReadEntry(graph, r, parent, listener, procedure, needsToBlock);
} catch (DatabaseException e) {
synchronized(externalReadEntryMap) {
existing = (ExternalReadEntry)externalReadEntryMap.get(r);
if(existing == null) {
- existing = new ExternalReadEntry(r);
+ existing = new ExternalReadEntry(r, graph);
existing.clearResult(querySupport);
existing.setPending();
externalReadEntryMap.put(id(r), existing);