X-Git-Url: https://gerrit.simantics.org/r/gitweb?p=simantics%2Fplatform.git;a=blobdiff_plain;f=bundles%2Forg.simantics.db.impl%2Fsrc%2Forg%2Fsimantics%2Fdb%2Fimpl%2Fquery%2FExternalReadEntry.java;h=2980b9b15f72e9a54b00a96fe06a397ef60b59b6;hp=556d5fc3e12b8d2df0d5e42ea2efb2221a8fb65f;hb=HEAD;hpb=77ba75dcaf7d7c16187907f0661916d48e99edf6

diff --git a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/ExternalReadEntry.java b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/ExternalReadEntry.java
index 556d5fc3e..2980b9b15 100644
--- a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/ExternalReadEntry.java
+++ b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/ExternalReadEntry.java
@@ -28,7 +28,7 @@ final public class ExternalReadEntry<T> extends CacheEntryBase<AsyncProcedure<T>
     final LinkedList<T> items = new LinkedList<T>();
 
     protected ExternalRead<T> id;
-    protected ReadGraphImpl graph;
+    protected QueryProcessor processor;
     protected boolean registered = false;
 
     @Override
@@ -49,7 +49,7 @@ final public class ExternalReadEntry<T> extends CacheEntryBase<AsyncProcedure<T>
     public void discard() {
         id.unregistered();
         id = null;
-        graph = null;
+        processor = null;
         super.discard();
     }
 
@@ -65,7 +65,7 @@ final public class ExternalReadEntry<T> extends CacheEntryBase<AsyncProcedure<T>
     public ExternalReadEntry(ExternalRead<T> request, ReadGraphImpl graph) {
         assert request != null;
         this.id = request;
-        this.graph = graph;
+        this.processor = graph.processor;
     }
     
     @Override
@@ -180,7 +180,7 @@ final public class ExternalReadEntry<T> extends CacheEntryBase<AsyncProcedure<T>
     	
 		try {
 			
-			ReadGraphImpl queryGraph = graph.withParent(this);
+			ReadGraphImpl queryGraph = graph.withParent(this, null, true);
 
 			if(!registered) {
 				id.register(graph, this);
@@ -213,7 +213,7 @@ final public class ExternalReadEntry<T> extends CacheEntryBase<AsyncProcedure<T>
 
     		synchronized(items) {
     			items.addLast(result);
-				graph.processor.updatePrimitive(id);
+				processor.updatePrimitive(id);
     			// TODO: implement flags/logic in ExternalRead to state that all but the latest request result can be evaporated
     			// In some cases where data is produced really fast this might be necessary but currently this queueing will do.
     		}
@@ -229,7 +229,12 @@ final public class ExternalReadEntry<T> extends CacheEntryBase<AsyncProcedure<T>
 
 	@Override
 	public boolean isDisposed() {
-		return registered && (isDiscarded() || !graph.processor.isBound(this));
+		return registered && (isDiscarded() || !processor.isBound(this));
 	}
-    
+
+    @Override
+    public String classId() {
+        return null;
+    }
+
 }