- final static byte[] runner(final ReadGraphImpl graph, final int r, CacheEntry parent, final ListenerBase listener, final InternalProcedure<byte[]> procedure) {
-
- QueryProcessor processor = graph.processor;
-
- ValueQuery entry = (ValueQuery)processor.valueMap.get(r);
- if(entry == null) {
-
- entry = new ValueQuery(r);
- entry.setPending();
- entry.clearResult(processor.querySupport);
- entry.putEntry(processor);
-
- return (byte[])processor.performForEach(graph, entry, parent, listener, procedure);
-
- } else {
-
- return (byte[])processor.performForEach(graph, entry, parent, listener, procedure);
-
- }
-
- }
-
- final public static byte[] queryEach(ReadGraphImpl graph, final int r, final CacheEntry parent, final ListenerBase listener, final InternalProcedure<byte[]> procedure) {
-
- assert(r != 0);
-
- if(graph.parent == null && listener == null) {
- return ValueQuery.computeForEach(graph, r, null, procedure);
- } else {
- return runner(graph, r, parent, listener, procedure);
- }
-