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%2FClusterBuilderImpl.java;h=33d81a2eee9e40d075781d998b947931d1e9f670;hp=f38b8cb5fdf9a1eb82fa03b3ade3087c3a8e5f26;hb=5f777aa757a8eef106aeaf621d3b030162fa6bb8;hpb=969bd23cab98a79ca9101af33334000879fb60c5

diff --git a/bundles/org.simantics.db.procore/src/fi/vtt/simantics/procore/internal/ClusterBuilderImpl.java b/bundles/org.simantics.db.procore/src/fi/vtt/simantics/procore/internal/ClusterBuilderImpl.java
index f38b8cb5f..33d81a2ee 100644
--- a/bundles/org.simantics.db.procore/src/fi/vtt/simantics/procore/internal/ClusterBuilderImpl.java
+++ b/bundles/org.simantics.db.procore/src/fi/vtt/simantics/procore/internal/ClusterBuilderImpl.java
@@ -1,57 +1,57 @@
-package fi.vtt.simantics.procore.internal;
-
-import org.simantics.db.Resource;
-import org.simantics.db.exception.DatabaseException;
-import org.simantics.db.impl.ClusterI;
-import org.simantics.db.impl.ClusterTraitsBase;
-import org.simantics.db.impl.ResourceImpl;
-import org.simantics.db.procore.cluster.ClusterImpl;
-import org.simantics.db.service.ClusterBuilder;
-import org.simantics.db.service.ClusterUID;
-
-import fi.vtt.simantics.procore.internal.SessionImplSocket.WriteOnlySupport;
-
-public class ClusterBuilderImpl implements ClusterBuilder {
-    
-    final private ClusterTable clusterTable;
-    final private ClusterStream stream;
-    final private WriteOnlySupport support;
-    
-    ClusterBuilderImpl(SessionImplSocket session, WriteOnlySupport support) {
-        this.support = support;
-        this.stream = support.stream;
-        this.clusterTable = session.clusterTable;
-    }
-
-    @Override
-    public void newCluster() throws DatabaseException {
-        support.flushCluster();
-    }
-    
-    @Override
-    public ResourceHandle newResource() throws DatabaseException {
-        return new ResourceHandleImpl(support);
-    }
-    
-    @Override
-    public ResourceHandle resource(Resource res) throws DatabaseException {
-        ResourceImpl r = (ResourceImpl)res;
-        int clusterKey = ClusterTraitsBase.getClusterKeyFromResourceKey(r.id);
-        ClusterI cluster = clusterTable.getClusterByClusterKey(clusterKey);
-        return new ResourceHandleImpl(stream, (ClusterImpl)cluster, r.id);
-    }
-
-    @Override
-    public StatementHandle newStatement(ResourceHandle predicate, ResourceHandle object) throws DatabaseException {
-        ResourceHandleImpl p = (ResourceHandleImpl)predicate;
-        ResourceHandleImpl o = (ResourceHandleImpl)object;
-        int pResourceIndex = ClusterTraitsBase.getResourceIndexFromResourceKey(p.resourceKey);
-        ClusterI pCluster = clusterTable.getClusterByClusterKey(pResourceIndex);
-        ClusterUID pClusterUID = pCluster.getClusterUID();
-        int oResourceIndex = ClusterTraitsBase.getResourceIndexFromResourceKey(p.resourceKey);
-        ClusterI oCluster = clusterTable.getClusterByClusterKey(oResourceIndex);
-        ClusterUID oClusterUID = oCluster.getClusterUID();
-        return new StatementHandleImpl(p.resourceKey, (byte)0, o.resourceKey, (byte)0, pClusterUID,  oClusterUID);
-    }
-
-}
+package fi.vtt.simantics.procore.internal;
+
+import org.simantics.db.Resource;
+import org.simantics.db.exception.DatabaseException;
+import org.simantics.db.impl.ClusterI;
+import org.simantics.db.impl.ClusterTraitsBase;
+import org.simantics.db.impl.ResourceImpl;
+import org.simantics.db.procore.cluster.ClusterImpl;
+import org.simantics.db.service.ClusterBuilder;
+import org.simantics.db.service.ClusterUID;
+
+import fi.vtt.simantics.procore.internal.SessionImplSocket.WriteOnlySupport;
+
+public class ClusterBuilderImpl implements ClusterBuilder {
+    
+    final private ClusterTable clusterTable;
+    final private ClusterStream stream;
+    final private WriteOnlySupport support;
+    
+    ClusterBuilderImpl(SessionImplSocket session, WriteOnlySupport support) {
+        this.support = support;
+        this.stream = support.stream;
+        this.clusterTable = session.clusterTable;
+    }
+
+    @Override
+    public void newCluster() throws DatabaseException {
+        support.flushCluster();
+    }
+    
+    @Override
+    public ResourceHandle newResource() throws DatabaseException {
+        return new ResourceHandleImpl(support);
+    }
+    
+    @Override
+    public ResourceHandle resource(Resource res) throws DatabaseException {
+        ResourceImpl r = (ResourceImpl)res;
+        int clusterKey = ClusterTraitsBase.getClusterKeyFromResourceKey(r.id);
+        ClusterI cluster = clusterTable.getClusterByClusterKey(clusterKey);
+        return new ResourceHandleImpl(stream, (ClusterImpl)cluster, r.id);
+    }
+
+    @Override
+    public StatementHandle newStatement(ResourceHandle predicate, ResourceHandle object) throws DatabaseException {
+        ResourceHandleImpl p = (ResourceHandleImpl)predicate;
+        ResourceHandleImpl o = (ResourceHandleImpl)object;
+        int pResourceIndex = ClusterTraitsBase.getResourceIndexFromResourceKey(p.resourceKey);
+        ClusterI pCluster = clusterTable.getClusterByClusterKey(pResourceIndex);
+        ClusterUID pClusterUID = pCluster.getClusterUID();
+        int oResourceIndex = ClusterTraitsBase.getResourceIndexFromResourceKey(p.resourceKey);
+        ClusterI oCluster = clusterTable.getClusterByClusterKey(oResourceIndex);
+        ClusterUID oClusterUID = oCluster.getClusterUID();
+        return new StatementHandleImpl(p.resourceKey, (byte)0, o.resourceKey, (byte)0, pClusterUID,  oClusterUID);
+    }
+
+}