X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.db.impl%2Fsrc%2Forg%2Fsimantics%2Fdb%2Fimpl%2Fgraph%2FReadGraphImpl.java;h=a693b29228e026c1e1f6a5c7f3652c8d4320eb4c;hb=f002990cb02c4842cdc992395117958f75fff68c;hp=cffbba51c75f852e44b215747e94efafa099e296;hpb=6839744ff43f5adaa2fc38121952dba846690558;p=simantics%2Fplatform.git

diff --git a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/graph/ReadGraphImpl.java b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/graph/ReadGraphImpl.java
index cffbba51c..a693b2922 100644
--- a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/graph/ReadGraphImpl.java
+++ b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/graph/ReadGraphImpl.java
@@ -188,6 +188,8 @@ import org.simantics.utils.DataContainer;
 import org.simantics.utils.Development;
 import org.simantics.utils.datastructures.Pair;
 import org.simantics.utils.datastructures.collections.CollectionUtils;
+import org.simantics.utils.threads.logger.ITask;
+import org.simantics.utils.threads.logger.ThreadLogger;
 import org.slf4j.LoggerFactory;
 
 import gnu.trove.map.hash.TObjectIntHashMap;
@@ -1923,7 +1925,12 @@ public class ReadGraphImpl implements AsyncReadGraph {
 	@Override
 	public <T> T syncRequest(final Read<T> request) throws DatabaseException {
 		assert (request != null);
-		return (T)QueryCache.runnerReadEntry(this, request, parent, null, null, true);
+
+		ITask task = ThreadLogger.task(request);
+		T result = (T)QueryCache.runnerReadEntry(this, request, parent, null, null, true);
+		task.finish();
+		return result;
+		
 	}
 
 	@Override
@@ -1943,9 +1950,11 @@ public class ReadGraphImpl implements AsyncReadGraph {
 
 		assert (request != null);
 
+		ITask task = ThreadLogger.task(request);
 		ListenerBase listener = procedure != null ? getListenerBase(procedure) : null;
-
-		return QueryCache.resultReadEntry(this, request, parent, listener, procedure);
+		T result = QueryCache.resultReadEntry(this, request, parent, listener, procedure);
+		task.finish();
+		return result;
 
 	}
 
@@ -2029,11 +2038,11 @@ public class ReadGraphImpl implements AsyncReadGraph {
 
 		assert (request != null);
 
+		ITask task = ThreadLogger.task(request);
 		ListenerBase listener = getListenerBase(procedure);
-
-//		BlockingAsyncProcedure<T> ap = new BlockingAsyncProcedure<>(this, procedure, request);
-		return (T)QueryCache.runnerAsyncReadEntry(this, request, parent, listener, procedure, true);
-//		return ap.get();
+		T result = (T)QueryCache.runnerAsyncReadEntry(this, request, parent, listener, procedure, true); 
+		task.finish();
+		return result;
 
 	}
 
@@ -5152,7 +5161,7 @@ public class ReadGraphImpl implements AsyncReadGraph {
 		assert (request != null);
 		assert (procedure != null);
 	
-		processor.schedule(new SessionTask(this) {
+		processor.scheduleNow(new SessionTask(this) {
 
 			@Override
 			public void run0(int thread) {
@@ -5232,13 +5241,29 @@ public class ReadGraphImpl implements AsyncReadGraph {
 		assert (request != null);
 		assert (procedure != null);
 
-		processor.schedule(new SessionTask(this) {
+		ITask task = ThreadLogger.task(request);
+
+		processor.scheduleNow(new SessionTask(this) {
 
 			@Override
 			public void run0(int thread) {
 				try {
 					final ListenerBase listener = getListenerBase(procedure);
-					QueryCache.runnerAsyncReadEntry(ReadGraphImpl.this, request, parent, listener, procedure, false);
+					QueryCache.runnerAsyncReadEntry(ReadGraphImpl.this, request, parent, listener, new AsyncProcedure<T>() {
+
+						@Override
+						public void execute(AsyncReadGraph graph, T result) {
+							task.finish();
+							procedure.execute(graph, result);
+						}
+
+						@Override
+						public void exception(AsyncReadGraph graph, Throwable throwable) {
+							task.finish();
+							procedure.exception(graph, throwable);
+						}
+						
+					}, false);
 				} catch (DatabaseException e) {
 					Logger.defaultLogError(e);
 				}
@@ -6312,7 +6337,7 @@ public class ReadGraphImpl implements AsyncReadGraph {
     public boolean performPending() {
         return processor.performPending(this);
     }
-
+    
     public Set<ReadGraphImpl> ancestorSet() {
         HashSet<ReadGraphImpl> result = new HashSet<>();
         ReadGraphImpl g = this;
@@ -6322,5 +6347,23 @@ public class ReadGraphImpl implements AsyncReadGraph {
         }
         return result;
     }
+    
+    public int getLevel() {
+        return getLevelStatic(this);
+    }
+    
+    private static int getLevelStatic(ReadGraphImpl impl) {
+        if(impl == null) return 0;
+        else return 1 + getLevelStatic(impl.parentGraph);
+    }
+    
+    public ReadGraphImpl getTopLevelGraph() {
+        return getTopLevelGraphStatic(this);
+    }
+
+    private static ReadGraphImpl getTopLevelGraphStatic(ReadGraphImpl impl) {
+        if(impl.parentGraph == null) return impl;
+        else return getTopLevelGraphStatic(impl.parentGraph);
+    }
 
 }