final public class ExternalReadEntry<T> extends CacheEntryBase {
final LinkedList<T> items = new LinkedList<T>();
-
-// public ArrayList<Procedure<T>> procs;
protected ExternalRead<T> request;
@Override
public void removeEntry(QueryProcessor processor) {
- processor.externalReadMap.remove(request);
+ processor.cache.externalReadMap.remove(request);
}
@Override
}
- public void performFromCache(Object procedure) {
+ public Object performFromCache(Object procedure) {
Procedure<T> proc = (Procedure<T>)procedure;
proc.execute((T)getResult());
}
+
+ return getResult();
}
}
@Override
- public void performFromCache(ReadGraphImpl graph, Object provider, Object procedure) {
- performFromCache(procedure);
+ public Object performFromCache(ReadGraphImpl graph, Object provider, Object procedure) {
+ return performFromCache(procedure);
}
@Override