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

diff --git a/bundles/org.simantics.acorn/src/org/simantics/acorn/internal/UndoClusterUpdateProcessor.java b/bundles/org.simantics.acorn/src/org/simantics/acorn/internal/UndoClusterUpdateProcessor.java
new file mode 100644
index 000000000..d545e51ad
--- /dev/null
+++ b/bundles/org.simantics.acorn/src/org/simantics/acorn/internal/UndoClusterUpdateProcessor.java
@@ -0,0 +1,112 @@
+package org.simantics.acorn.internal;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+
+import org.simantics.acorn.ClusterManager;
+import org.simantics.acorn.lru.ClusterChangeSet;
+import org.simantics.acorn.lru.ClusterStreamChunk;
+import org.simantics.acorn.lru.ClusterChangeSet.Entry;
+import org.simantics.acorn.lru.ClusterChangeSet.Type;
+import org.simantics.db.exception.DatabaseException;
+import org.simantics.db.service.ClusterUID;
+
+public class UndoClusterUpdateProcessor extends ClusterUpdateProcessorBase {
+	
+	public final static boolean DEBUG = false;
+
+	final private ClusterChangeSet ccs;
+	
+	private int oldValuesIndex = 0;
+	private int statementMaskIndex = 0;
+	
+	final public List<Entry> entries = new ArrayList<Entry>();
+	
+	public UndoClusterUpdateProcessor(ClusterManager client, ClusterStreamChunk chunk, ClusterChangeSet ccs) throws DatabaseException {
+		super(client, readOperation(client, chunk, ccs));
+		this.ccs = ccs;
+	}
+	
+	private static byte[] readOperation(ClusterManager manager, ClusterStreamChunk chunk, ClusterChangeSet ccs) {
+		
+//		ClusterStreamChunk chunk;
+//		manager.streamLRU.acquireMutex();
+//		try {
+//			chunk = ccs.getChunk(manager);
+//		} catch (Throwable t) {
+//			throw new IllegalStateException(t);
+//		} finally {
+//			manager.streamLRU.releaseMutex();
+//		}
+//
+//		chunk.acquireMutex();
+//		try {
+//		chunk.ve
+			chunk.makeResident();
+			return chunk.getOperation(ccs.chunkOffset);
+//		} catch (Throwable t) {
+//			throw new IllegalStateException(t);
+//		} finally {
+//			chunk.releaseMutex();
+//		}
+	}
+	
+	@Override
+	void create() throws DatabaseException {
+	}
+
+	@Override
+	void delete(int ri) throws DatabaseException {
+		
+		byte[] old = ccs.oldValues.get(oldValuesIndex);
+		boolean oldValueEx = ccs.oldValueEx.get(oldValuesIndex) > 0;
+		oldValuesIndex++;
+		
+		if(old != null) {
+			entries.add(new Entry(ri, oldValueEx, old, null));
+		}
+		
+	}
+
+	@Override
+	void modify(int resourceKey, long offset, int size, byte[] bytes, int pos)
+			throws DatabaseException {
+		
+	}
+
+	@Override
+	void set(int resourceKey, byte[] bytes, int length)
+			throws DatabaseException {
+
+		byte[] old = ccs.oldValues.get(oldValuesIndex);
+		boolean oldValueEx = ccs.oldValueEx.get(oldValuesIndex) > 0;
+		oldValuesIndex++;
+
+		entries.add(new Entry(resourceKey, oldValueEx, old, Arrays.copyOf(valueBuffer, length)));
+		
+	}
+
+	@Override
+	void claim(int resourceKey, int predicateKey, int objectKey, ClusterUID puid, ClusterUID ouid)
+			throws DatabaseException {
+		
+		boolean add = ccs.statementMask.get(statementMaskIndex++) > 0;
+		if(add) {
+			entries.add(new Entry(Type.ADD, resourceKey, puid, predicateKey & 0xFFF, ouid, objectKey & 0xFFF));
+		}
+		
+	}
+
+	@Override
+	void deny(int resourceKey, int predicateKey, int objectKey, ClusterUID puid, ClusterUID ouid)
+			throws DatabaseException {
+		
+		boolean remove = ccs.statementMask.get(statementMaskIndex++) > 0;
+		if(remove) {
+			entries.add(new Entry(Type.REMOVE, resourceKey, puid, predicateKey & 0xFFF, ouid, objectKey & 0xFFF));
+		}
+
+	}
+	
+}