]> gerrit.simantics Code Review - simantics/platform.git/blobdiff - bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/AssertedStatements.java
Still working for multiple readers
[simantics/platform.git] / bundles / org.simantics.db.impl / src / org / simantics / db / impl / query / AssertedStatements.java
index a9ce7c6f8c7334926e2c132b05a21bd941e9592d..eba1205e1f94dfd4a5dac0177d0b56cfc90d8a51 100644 (file)
@@ -137,7 +137,7 @@ final public class AssertedStatements extends CollectionBinaryQuery<TripleIntPro
         
     }
 
-       @Override
+       //@Override
        public Object compute(ReadGraphImpl graph, final TripleIntProcedure procedure) throws DatabaseException {
                computeForEach(graph, r1(), r2(), this, procedure);
                return getResult();
@@ -145,7 +145,7 @@ final public class AssertedStatements extends CollectionBinaryQuery<TripleIntPro
 
     public static void computeForEach(ReadGraphImpl graph, final int type, final int predicate, final AssertedStatements entry, final TripleIntProcedure procedure) throws DatabaseException {
 
-       RelationInfo ri = QueryCache.resultRelationInfoQuery(graph, predicate, entry, null, QueryCache.emptyRelationInfoProcedure);
+       RelationInfo ri = QueryCache.resultRelationInfoQuery(graph, predicate, entry, null);
        
         final AtomicInteger found = new AtomicInteger(0);
 
@@ -364,9 +364,6 @@ final public class AssertedStatements extends CollectionBinaryQuery<TripleIntPro
 
     private boolean addOrSet(int s, int p, int o) {
        
-       if(!isPending())
-               System.err.println("asd");
-        
        assert(isPending());
         
         IntArray value = (IntArray)getResult();
@@ -401,9 +398,6 @@ final public class AssertedStatements extends CollectionBinaryQuery<TripleIntPro
     
     static void finish(ReadGraphImpl graph, AssertedStatements entry) {
         
-       if(!entry.isPending())
-               System.err.println("asd");
-       
        assert(entry.isPending());
        if(entry != null) {
                synchronized(entry) {