- @Override
- public void clearResult(QuerySupport support) {
- setResult(INVALID_RESULT);
- }
-
- final static DirectObjects entry(final QueryProcessor provider, final int r1, final int r2) {
-
- return (DirectObjects)provider.cache.directObjectsMap.get(id(r1,r2));
-
- }
-
- final static Collection<DirectObjects> entries(final QueryProcessor processor, final int r1) {
- DoubleKeyQueryHashMap<IntProcedure> hash = processor.cache.directObjectsMap;
- return hash.values(r1);
- }
-
- final static void runner(ReadGraphImpl graph, final int r1, final int r2, CacheEntry parent, final ListenerBase listener, final IntProcedure procedure) {
-
- QueryProcessor processor = graph.processor;
-
- DirectObjects entry = (DirectObjects)processor.cache.directObjectsMap.get(id(r1,r2));
- if(entry == null) {
-
- entry = new DirectObjects(r1, r2);
- entry.setPending();
- entry.clearResult(processor.querySupport);
- entry.putEntry(processor);
-
- processor.performForEach(graph, entry, parent, listener, procedure);
-
- } else {
-
- if(entry.isPending()) {
- synchronized(entry) {
- if(entry.isPending()) {
- processor.registerDependencies(graph, entry, parent, listener, procedure, false);
- entry.computeForEach(graph, processor, procedure, true);
- return;
- }
- }
- }
-
- processor.performForEach(graph, entry, parent, listener, procedure);
-
- }
-
- }
-
- final public static void queryEach(ReadGraphImpl graph, final int r1, final int r2, final QueryProcessor provider, final CacheEntry parent, final ListenerBase listener, final IntProcedure procedure) {
-
- assert(r1 != 0);
- assert(r2 != 0);
-
- if(parent == null && listener == null) {
- DirectObjects.computeForEach(graph, r1, r2, null, procedure);
- } else {
- runner(graph, r1, r2, parent, listener, procedure);
- }
-
- }
-
- @Override
- public BinaryQuery<IntProcedure> getEntry(QueryProcessor provider) {
- return provider.cache.directObjectsMap.get(id);
- }
-
- @Override
- public void putEntry(QueryProcessor provider) {
- provider.cache.directObjectsMap.put(id, this);
- }
+// @Override
+// public void clearResult(QuerySupport support) {
+// setResult(INVALID_RESULT);
+// }
+
+// final public static void queryEach(ReadGraphImpl graph, final int r1, final int r2, final QueryProcessor provider, final CacheEntry parent, final ListenerBase listener, final IntProcedure procedure) throws DatabaseException {
+//
+// assert(r1 != 0);
+// assert(r2 != 0);
+//
+// if(parent == null && listener == null) {
+// DirectObjects.computeForEach(graph, r1, r2, null, procedure);
+// } else {
+// QueryCache.runnerDirectObjects(graph, r1, r2, parent, listener, procedure);
+// }
+//
+// }