X-Git-Url: https://gerrit.simantics.org/r/gitweb?p=simantics%2Fplatform.git;a=blobdiff_plain;f=bundles%2Forg.simantics.db.procore%2Fsrc%2Ffi%2Fvtt%2Fsimantics%2Fprocore%2Finternal%2FVirtualClusterBuilderImpl2.java;h=aaa209f1727a6182920a70b5a844af2275f71e0f;hp=1864d2a3b716ab74de71498bb623658ecc68783e;hb=97872f96afc18f4cd5b959d869fed80cd92f6aa1;hpb=969bd23cab98a79ca9101af33334000879fb60c5

diff --git a/bundles/org.simantics.db.procore/src/fi/vtt/simantics/procore/internal/VirtualClusterBuilderImpl2.java b/bundles/org.simantics.db.procore/src/fi/vtt/simantics/procore/internal/VirtualClusterBuilderImpl2.java
index 1864d2a3b..aaa209f17 100644
--- a/bundles/org.simantics.db.procore/src/fi/vtt/simantics/procore/internal/VirtualClusterBuilderImpl2.java
+++ b/bundles/org.simantics.db.procore/src/fi/vtt/simantics/procore/internal/VirtualClusterBuilderImpl2.java
@@ -1,140 +1,140 @@
-package fi.vtt.simantics.procore.internal;
-
-import gnu.trove.list.array.TByteArrayList;
-
-import org.simantics.db.Resource;
-import org.simantics.db.VirtualGraph;
-import org.simantics.db.WriteOnlyGraph;
-import org.simantics.db.exception.DatabaseException;
-import org.simantics.db.exception.RuntimeDatabaseException;
-import org.simantics.db.impl.ResourceImpl;
-import org.simantics.db.impl.graph.WriteGraphImpl;
-import org.simantics.db.impl.graph.WriteSupport;
-import org.simantics.db.service.ClusterBuilder2;
-import org.simantics.db.service.SerialisationSupport;
-
-public class VirtualClusterBuilderImpl2 implements ClusterBuilder2 {
-
-	final private SessionImplSocket session;
-	final private VirtualGraph vg;
-//    final private ClusterSupport cs;
-    final private SerialisationSupport ss;
-//    final private ClusterStream stream;
-//    final private WriteSupport support;
-//    final private WriteSupport support;
-    @SuppressWarnings("unused")
-    final private boolean allowImmutables;
-    
-    VirtualClusterBuilderImpl2(SessionImplSocket session, VirtualGraph vg, boolean allowImmutables) {
-    	this.session = session;
-    	this.vg = vg;
-        this.allowImmutables = allowImmutables;
-        ss = session.getService(SerialisationSupport.class);
-    }
-    
-    private WriteSupport getSupport() {
-        WriteGraphImpl graph = session.writeState.getGraph();
-        return graph.writeSupport;
-    }
-
-    @Override
-    public void newCluster() throws DatabaseException {
-    	// Do nothing
-    }
-
-    @Override
-    public void selectCluster(long cluster) throws DatabaseException {
-    	// Do nothing
-    }
-    
-    @Override
-    public void newCluster(int setHandle) throws DatabaseException {
-    	// Do nothing
-    }
-    
-    @Override
-    public void createClusterSet(int resource) throws DatabaseException {
-    	// Do nothing
-    }
-    
-    @Override
-    public int newResource() throws DatabaseException {
-    	Resource result = getSupport().createResource(vg); 
-    	return handle(result);
-    }
-
-    @Override
-    public int newResource(int set) throws DatabaseException {
-    	Resource result = getSupport().createResource(vg, resource(set));
-    	return handle(result);
-    }
-    
-    @Override
-    public int resource(Resource res) throws DatabaseException {
-        ResourceImpl r = (ResourceImpl)res;
-        return r.id;
-    }
-
-    @Override
-    public void addStatement(WriteOnlyGraph graph, int subject, int predicate, int object) throws DatabaseException {
-    	getSupport().claim(vg, subject, predicate, object);
-    }
-    
-//    public void applyPredicate(ClusterImpl impl, int predicate) {
-//        
-//        int clusterKey = ClusterTraitsBase.getClusterKeyFromResourceKeyNoThrow(predicate);
-//        ClusterImpl cluster = clusterArray[clusterKey]; 
-//        
-//        impl.change.addStatementIndex1(predicate, cluster.clusterUID, (byte)0, impl.foreignLookup);
-//        
-//    }
-//
-//    public void applyObject(ClusterImpl impl, int object) {
-//
-//        int clusterKey = ClusterTraitsBase.getClusterKeyFromResourceKeyNoThrow(object);
-//        ClusterImpl cluster = clusterArray[clusterKey]; 
-//        
-//        impl.change.addStatementIndex2(object, cluster.clusterUID, (byte)0, impl.foreignLookup);
-//        
-//    }
-
-    @Override
-    public Resource resource(int key) {
-        try {
-            return ss.getResource(key);
-        } catch (DatabaseException e) {
-            throw new RuntimeDatabaseException(e);
-        }
-    }
-    
-    @Override
-    public int handle(Resource r) {
-        return ((ResourceImpl)r).id;
-    }
-
-
-    TByteArrayList valueBytes = new TByteArrayList();
-    
-//    byte[] buffer = new byte[65536];
-//    int bufferOffset = 0;
-    int valueSubject = 0;
-//    int valueOffset = 0;
-    
-    @Override
-    public void beginValue(int subject) {
-    	valueBytes.clear();
-        valueSubject = subject;
-    }
-        
-    @Override
-    public void appendValue(int byteValue) throws DatabaseException {
-    	valueBytes.add((byte)byteValue);
-    }
-
-    @Override
-    public void endValue() throws DatabaseException {
-    	byte[] bytes = valueBytes.toArray();
-    	getSupport().claimValue(vg, valueSubject, bytes, bytes.length);
-    }
-    
-}
+package fi.vtt.simantics.procore.internal;
+
+import gnu.trove.list.array.TByteArrayList;
+
+import org.simantics.db.Resource;
+import org.simantics.db.VirtualGraph;
+import org.simantics.db.WriteOnlyGraph;
+import org.simantics.db.exception.DatabaseException;
+import org.simantics.db.exception.RuntimeDatabaseException;
+import org.simantics.db.impl.ResourceImpl;
+import org.simantics.db.impl.graph.WriteGraphImpl;
+import org.simantics.db.impl.graph.WriteSupport;
+import org.simantics.db.service.ClusterBuilder2;
+import org.simantics.db.service.SerialisationSupport;
+
+public class VirtualClusterBuilderImpl2 implements ClusterBuilder2 {
+
+	final private SessionImplSocket session;
+	final private VirtualGraph vg;
+//    final private ClusterSupport cs;
+    final private SerialisationSupport ss;
+//    final private ClusterStream stream;
+//    final private WriteSupport support;
+//    final private WriteSupport support;
+    @SuppressWarnings("unused")
+    final private boolean allowImmutables;
+    
+    VirtualClusterBuilderImpl2(SessionImplSocket session, VirtualGraph vg, boolean allowImmutables) {
+    	this.session = session;
+    	this.vg = vg;
+        this.allowImmutables = allowImmutables;
+        ss = session.getService(SerialisationSupport.class);
+    }
+    
+    private WriteSupport getSupport() {
+        WriteGraphImpl graph = session.writeState.getGraph();
+        return graph.writeSupport;
+    }
+
+    @Override
+    public void newCluster() throws DatabaseException {
+    	// Do nothing
+    }
+
+    @Override
+    public void selectCluster(long cluster) throws DatabaseException {
+    	// Do nothing
+    }
+    
+    @Override
+    public void newCluster(int setHandle) throws DatabaseException {
+    	// Do nothing
+    }
+    
+    @Override
+    public void createClusterSet(int resource) throws DatabaseException {
+    	// Do nothing
+    }
+    
+    @Override
+    public int newResource() throws DatabaseException {
+    	Resource result = getSupport().createResource(vg); 
+    	return handle(result);
+    }
+
+    @Override
+    public int newResource(int set) throws DatabaseException {
+    	Resource result = getSupport().createResource(vg, resource(set));
+    	return handle(result);
+    }
+    
+    @Override
+    public int resource(Resource res) throws DatabaseException {
+        ResourceImpl r = (ResourceImpl)res;
+        return r.id;
+    }
+
+    @Override
+    public void addStatement(WriteOnlyGraph graph, int subject, int predicate, int object) throws DatabaseException {
+    	getSupport().claim(vg, subject, predicate, object);
+    }
+    
+//    public void applyPredicate(ClusterImpl impl, int predicate) {
+//        
+//        int clusterKey = ClusterTraitsBase.getClusterKeyFromResourceKeyNoThrow(predicate);
+//        ClusterImpl cluster = clusterArray[clusterKey]; 
+//        
+//        impl.change.addStatementIndex1(predicate, cluster.clusterUID, (byte)0, impl.foreignLookup);
+//        
+//    }
+//
+//    public void applyObject(ClusterImpl impl, int object) {
+//
+//        int clusterKey = ClusterTraitsBase.getClusterKeyFromResourceKeyNoThrow(object);
+//        ClusterImpl cluster = clusterArray[clusterKey]; 
+//        
+//        impl.change.addStatementIndex2(object, cluster.clusterUID, (byte)0, impl.foreignLookup);
+//        
+//    }
+
+    @Override
+    public Resource resource(int key) {
+        try {
+            return ss.getResource(key);
+        } catch (DatabaseException e) {
+            throw new RuntimeDatabaseException(e);
+        }
+    }
+    
+    @Override
+    public int handle(Resource r) {
+        return ((ResourceImpl)r).id;
+    }
+
+
+    TByteArrayList valueBytes = new TByteArrayList();
+    
+//    byte[] buffer = new byte[65536];
+//    int bufferOffset = 0;
+    int valueSubject = 0;
+//    int valueOffset = 0;
+    
+    @Override
+    public void beginValue(int subject) {
+    	valueBytes.clear();
+        valueSubject = subject;
+    }
+        
+    @Override
+    public void appendValue(int byteValue) throws DatabaseException {
+    	valueBytes.add((byte)byteValue);
+    }
+
+    @Override
+    public void endValue() throws DatabaseException {
+    	byte[] bytes = valueBytes.toArray();
+    	getSupport().claimValue(vg, valueSubject, bytes, bytes.length);
+    }
+    
+}