public void propagateChangesInQueryCache(final ReadGraphImpl graph) {
+ ReadGraphImpl syncGraph = graph.forSyncExecute();
+ syncGraph.asyncBarrier.inc();
+ propagateChangesInQueryCache_(syncGraph);
+ syncGraph.asyncBarrier.dec();
+ syncGraph.asyncBarrier.waitBarrier(this, syncGraph);
+
+ }
+
+
+ public void propagateChangesInQueryCache_(final ReadGraphImpl graph) {
+
// Make sure that listening has performed its work
listening.sync();
public void invalidateResource(final int resource) {
if(lastInvalidate == resource) return;
- scheduledValueUpdates.add(resource);
+ //scheduledValueUpdates.add(resource);
+ scheduledInvalidates.add(resource);
lastInvalidate = resource;
cache.dirty = true;
}