X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.acorn%2Fsrc%2Forg%2Fsimantics%2Facorn%2Finternal%2FClusterUpdateProcessor.java;fp=bundles%2Forg.simantics.acorn%2Fsrc%2Forg%2Fsimantics%2Facorn%2Finternal%2FClusterUpdateProcessor.java;h=0044d72d83b3d92736834ecf2a5bd9c00c43e18f;hb=a0687ce02bac73aad9e0d7ddc85625016604f0db;hp=0000000000000000000000000000000000000000;hpb=be5eb160a811a04ecd6364ebb58f24e8218d3f9c;p=simantics%2Fplatform.git

diff --git a/bundles/org.simantics.acorn/src/org/simantics/acorn/internal/ClusterUpdateProcessor.java b/bundles/org.simantics.acorn/src/org/simantics/acorn/internal/ClusterUpdateProcessor.java
new file mode 100644
index 000000000..0044d72d8
--- /dev/null
+++ b/bundles/org.simantics.acorn/src/org/simantics/acorn/internal/ClusterUpdateProcessor.java
@@ -0,0 +1,86 @@
+package org.simantics.acorn.internal;
+
+import org.simantics.acorn.ClusterManager;
+import org.simantics.acorn.cluster.ClusterImpl;
+import org.simantics.acorn.lru.CachingClusterSupport;
+import org.simantics.acorn.lru.ClusterUpdateOperation;
+import org.simantics.db.exception.DatabaseException;
+import org.simantics.db.impl.ClusterSupport;
+import org.simantics.db.service.ClusterUID;
+
+public class ClusterUpdateProcessor extends ClusterUpdateProcessorBase {
+	
+	final ClusterSupport support;
+	final ClusterUpdateOperation info;
+	private ClusterImpl cluster;
+	
+	public ClusterUpdateProcessor(ClusterManager client, ClusterSupport support, byte[] operations, ClusterUpdateOperation info) throws DatabaseException {
+		super(client, operations);
+		this.support = support;
+		this.info = info;
+	}
+	
+	@Override
+	void create() throws DatabaseException {
+		cluster.createResource(support);
+	}
+
+	@Override
+	void delete(int ri) throws DatabaseException {
+		
+		boolean oldValueEx = cluster.isValueEx(ri);
+		byte[] old = cluster.getValue(ri, support);
+		if(old != null) cluster.removeValue(ri, support);
+		info.ccs.oldValueEx.add(oldValueEx ? (byte)1 : 0);
+		info.ccs.oldValues.add(old);
+		
+	}
+
+	@Override
+	void modify(int resourceKey, long offset, int size, byte[] bytes, int pos)
+			throws DatabaseException {
+		
+		cluster = (ClusterImpl)cluster.modiValueEx(resourceKey, offset, size, bytes, pos, support);
+		manager.modiFileEx(cluster.getClusterUID(), resourceKey, offset, size, bytes, pos, support);
+		
+	}
+
+	@Override
+	void set(int resourceKey, byte[] bytes, int length)
+			throws DatabaseException {
+		
+		byte[] old = cluster.getValue(resourceKey, support);
+		boolean oldValueEx = cluster.isValueEx(resourceKey);
+		cluster = (ClusterImpl)cluster.setValue(resourceKey, valueBuffer, length, support);
+		info.ccs.oldValueEx.add(oldValueEx ? (byte)1 : 0);
+		info.ccs.oldValues.add(old);
+		
+	}
+
+	@Override
+	void claim(int resourceKey, int predicateKey, int objectKey, ClusterUID puid, ClusterUID ouid)
+			throws DatabaseException {
+		
+		ClusterImpl c = (ClusterImpl)cluster.addRelation(resourceKey, puid, predicateKey, ouid, objectKey, support);
+		if(c != null) cluster = c;
+		info.ccs.statementMask.add(c != null ? (byte)1 : 0);
+		
+	}
+
+	@Override
+	void deny(int resourceKey, int predicateKey, int objectKey, ClusterUID puid, ClusterUID ouid)
+			throws DatabaseException {
+		
+		boolean modified = cluster.removeRelation(resourceKey, predicateKey, objectKey, support);
+		info.ccs.statementMask.add(modified ? (byte)1 : 0);
+
+	}
+
+	public ClusterImpl process(ClusterImpl cluster) {
+		this.cluster = cluster;
+		process();
+		info.finish();
+		return this.cluster;
+	}
+	
+}