X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.db.impl%2Fsrc%2Forg%2Fsimantics%2Fdb%2Fimpl%2Fquery%2FAsyncMultiReadEntry.java;h=1791c50acccb37eb0fb41dbf4c3c149e0fc1c6d7;hb=a6c431919eb2ef9a06623cf0b9daa1fd5a04669c;hp=a2a7aded168da11f23e65011de56fe42194cf8b6;hpb=0f268b9157bfa6399692f8aa42f532a0c0d68c1c;p=simantics%2Fplatform.git

diff --git a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/AsyncMultiReadEntry.java b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/AsyncMultiReadEntry.java
index a2a7aded1..1791c50ac 100644
--- a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/AsyncMultiReadEntry.java
+++ b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/AsyncMultiReadEntry.java
@@ -14,19 +14,18 @@ package org.simantics.db.impl.query;
 import java.util.ArrayList;
 
 import org.simantics.db.AsyncReadGraph;
-import org.simantics.db.common.exception.DebugException;
+import org.simantics.db.common.GraphSemaphore;
+import org.simantics.db.exception.DatabaseException;
 import org.simantics.db.impl.graph.ReadGraphImpl;
 import org.simantics.db.procedure.AsyncMultiProcedure;
 import org.simantics.db.request.AsyncMultiRead;
 import org.simantics.db.request.RequestFlags;
 
-final public class AsyncMultiReadEntry<T> extends CacheEntryBase {
-
-//    public ArrayList<AsyncMultiProcedure<T>> procs = null;
+final public class AsyncMultiReadEntry<T> extends CacheEntryBase<AsyncMultiProcedure<T>> {
 
     protected AsyncMultiRead<T> request;
     
-    public AsyncMultiReadEntry(AsyncMultiRead<T> request) {
+    AsyncMultiReadEntry(AsyncMultiRead<T> request) {
     	this.request = request;
     }
     
@@ -49,55 +48,22 @@ final public class AsyncMultiReadEntry<T> extends CacheEntryBase {
     
     final synchronized public void finish(AsyncReadGraph graph) {
     	
-//    	new Exception("finish " + this).printStackTrace();
-    	
-    	if(!isPending()) {
-    		System.err.println("aff");
-    	}
-    	
     	assert(isPending());
 
-//        ArrayList<AsyncMultiProcedure<T>> p = null;
-
         synchronized(this) {
-
         	setReady();
-//            p = procs;
-//            procs = null; 
-        
         }
         
-//        if(p != null) {
-//	        ArrayList<T> v = (ArrayList<T>)getResult();
-//	        if(v != null) {
-//	            for(AsyncMultiProcedure<T> proc : p) {
-//	                for(T t : v) proc.execute(graph, t);
-//	            }
-//	        }
-//	        
-//	        for(AsyncMultiProcedure<T>  proc : p) proc.finished(graph);
-//        }
-        
     }
 
     final synchronized public void except(AsyncReadGraph graph, Throwable t) {
 
     	assert(isPending());
 
-//        ArrayList<AsyncMultiProcedure<T>> p = null;
-
         synchronized(this) {
-
         	except(t);
-//            p = procs;
-//            procs = null; 
-        
         }
         
-//        if(p != null) {
-//	        for(AsyncMultiProcedure<T>  proc : p) proc.exception(graph, t);
-//        }
-        
     }
 
     @SuppressWarnings("unchecked")
@@ -121,42 +87,45 @@ final public class AsyncMultiReadEntry<T> extends CacheEntryBase {
         return new Query() {
 
 			@Override
-			public void recompute(ReadGraphImpl graph, Object provider, CacheEntry entry) {
-				
-				QueryProcessor qp = (QueryProcessor)provider;
-
-				final ReadGraphImpl parentGraph = ReadGraphImpl.forRecompute(entry, qp); 
+			public void recompute(ReadGraphImpl graph) {
 
 				try {
 
-				    request.perform(parentGraph , new AsyncMultiProcedure<T>() {
+					GraphSemaphore s = new GraphSemaphore(graph, 0);
+
+					request.perform(graph , new AsyncMultiProcedure<T>() {
+
+						@Override
+						public void execute(AsyncReadGraph graph, T result) {
+							addOrSet(result);
+						}
+
+						public void finished(AsyncReadGraph graph) {
+							finish(graph);
+							s.release();
+						};
+
+						@Override
+						public void exception(AsyncReadGraph graph, Throwable t) {
+							except(t);
+							s.release();
+						}
 
-                        @Override
-                        public void execute(AsyncReadGraph graph, T result) {
-                            addOrSet(result);
-                        }
-                        
-                        public void finished(AsyncReadGraph graph) {
-                        	finish(graph);
-                        };
-        				
-        				@Override
-        				public void exception(AsyncReadGraph graph, Throwable t) {
-                            except(t);
-        	            }
+					});
 
-                    });
+					s.waitFor(1);
 
 				} catch (Throwable t) {
-                    except(t);
-                    if(DebugException.DEBUG) new DebugException(t).printStackTrace();
-                }
+					
+					except(t);
+					
+				}
 				
 			}
 
 			@Override
 			public void removeEntry(QueryProcessor processor) {
-		    	processor.cache.asyncMultiReadMap.remove(request);
+		    	processor.cache.remove(AsyncMultiReadEntry.this);
 			}
 
 			@Override
@@ -176,9 +145,7 @@ final public class AsyncMultiReadEntry<T> extends CacheEntryBase {
 
 	@SuppressWarnings("unchecked")
 	@Override
-	public Object performFromCache(ReadGraphImpl graph, Object provider, Object procedure) {
-		
-		final AsyncMultiProcedure<T> proc = (AsyncMultiProcedure<T>)procedure;
+	public Object performFromCache(ReadGraphImpl graph, AsyncMultiProcedure<T> proc) {
 
         if(isExcepted()) {
 
@@ -211,16 +178,6 @@ final public class AsyncMultiReadEntry<T> extends CacheEntryBase {
 		return getResult();
 		
 	}
-
-//	@Override
-//	public void performFromCache(int callerThread, Object provider,
-//			Object procedure) {
-//
-//	    QueryProvider2 queryProvider = (QueryProvider2)provider;
-//	    ReadGraphImpl graph = ReadGraphImpl.forFromCache(callerThread, null, new ReadGraphSupportImpl(null, queryProvider, null));
-//		performFromCache(graph, provider, procedure);
-//		
-//	}
 	
 	@Override
 	public String toString() {
@@ -228,4 +185,9 @@ final public class AsyncMultiReadEntry<T> extends CacheEntryBase {
 		else return request.toString() + statusOrException;
 	}
 
+	//@Override
+	public Object compute(ReadGraphImpl graph, AsyncMultiProcedure<T> procedure) throws DatabaseException {
+    	return graph.processor.cache.performQuery(graph, request, this, procedure);
+	}
+
 }