public <T> T syncRequest(final Read<T> request) throws DatabaseException {
assert (request != null);
- ITask task = ThreadLogger.task(request);
+ //ITask task = ThreadLogger.task(request);
T result = (T)QueryCache.runnerReadEntry(this, request, parent, null, null, true);
- task.finish();
+ //task.finish();
return result;
}
assert (request != null);
- ITask task = ThreadLogger.task(request);
+ //ITask task = ThreadLogger.task(request);
ListenerBase listener = procedure != null ? getListenerBase(procedure) : null;
T result = QueryCache.resultReadEntry(this, request, parent, listener, procedure);
- task.finish();
+ //task.finish();
return result;
}
assert (request != null);
- ITask task = ThreadLogger.task(request);
+ //ITask task = ThreadLogger.task(request);
ListenerBase listener = getListenerBase(procedure);
T result = (T)QueryCache.runnerAsyncReadEntry(this, request, parent, listener, procedure, true);
- task.finish();
+ //task.finish();
return result;
}
assert (request != null);
assert (procedure != null);
- ITask task = ThreadLogger.task(request);
+ //ITask task = ThreadLogger.task(request);
AsyncBarrierImpl barrier = asyncBarrier;
if(barrier != null)
@Override
public void execute(AsyncReadGraph graph, T result) {
- task.finish();
+ //task.finish();
procedure.execute(graph, result);
if(barrier != null)
barrier.dec();
@Override
public void exception(AsyncReadGraph graph, Throwable throwable) {
- task.finish();
+ //task.finish();
procedure.exception(graph, throwable);
if(barrier != null)
barrier.dec();