X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=org.simantics.g3d%2Fsrc%2Forg%2Fsimantics%2Fg3d%2Fscl%2FScriptNodeMap.java;h=b7a7de03e8b52f244e42aa49f45b73e308f8c389;hb=refs%2Fchanges%2F08%2F3908%2F2;hp=37b124e3f49757fdf2461ac3a8b9ceb012221041;hpb=53d55c24c779745f188bdb18d32f71d20acb61b2;p=simantics%2F3d.git

diff --git a/org.simantics.g3d/src/org/simantics/g3d/scl/ScriptNodeMap.java b/org.simantics.g3d/src/org/simantics/g3d/scl/ScriptNodeMap.java
index 37b124e3..b7a7de03 100644
--- a/org.simantics.g3d/src/org/simantics/g3d/scl/ScriptNodeMap.java
+++ b/org.simantics.g3d/src/org/simantics/g3d/scl/ScriptNodeMap.java
@@ -1,15 +1,17 @@
 package org.simantics.g3d.scl;
 
+import java.util.ArrayDeque;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.Collections;
+import java.util.Deque;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Set;
 import java.util.Stack;
 
 import org.simantics.db.ReadGraph;
-import org.simantics.db.Session;
+import org.simantics.db.RequestProcessor;
 import org.simantics.db.WriteGraph;
 import org.simantics.db.common.request.ReadRequest;
 import org.simantics.db.common.request.WriteRequest;
@@ -40,12 +42,12 @@ import org.simantics.utils.datastructures.Pair;
  *
  * @param <E>
  */
-public abstract class ScriptNodeMap<E extends INode> implements NodeMap<Object,E>, IMappingListener, NodeListener {
+public abstract class ScriptNodeMap<DBObject,E extends INode> implements NodeMap<DBObject,Object,E>, IMappingListener, NodeListener {
 
 	private static final boolean DEBUG = false;
 	
-	protected Session session;
-	protected IMapping<Object,E> mapping;
+	protected RequestProcessor session;
+	protected IMapping<DBObject,INode> mapping;
 	
 	protected ParentNode<E> rootNode;
 	
@@ -53,7 +55,7 @@ public abstract class ScriptNodeMap<E extends INode> implements NodeMap<Object,E
 	
 	private boolean dirty = false;
 	
-	public ScriptNodeMap(Session session, IMapping<Object,E> mapping, ParentNode<E> rootNode) {
+	public ScriptNodeMap(RequestProcessor session, IMapping<DBObject,INode> mapping, ParentNode<E> rootNode) {
 		this.session = session;
 		this.mapping = mapping;
 		this.rootNode = rootNode;
@@ -89,10 +91,9 @@ public abstract class ScriptNodeMap<E extends INode> implements NodeMap<Object,E
 		return Collections.EMPTY_LIST;
 	}
 	
-	@SuppressWarnings("unchecked")
 	@Override
 	public ParentNode<E> getRootNode() {
-		return (ParentNode<E>)rootNode;
+		return rootNode;
 	}
 	
 	
@@ -118,11 +119,9 @@ public abstract class ScriptNodeMap<E extends INode> implements NodeMap<Object,E
 
 	private boolean rangeModified = false;
 	
-	@SuppressWarnings("unchecked")
 	@Override
 	public void updateRenderObjectsFor(E node) {
-		nodes.add((E)node);
-
+		nodes.add(node);
 	}
 	
 	@SuppressWarnings("unchecked")
@@ -158,7 +157,6 @@ public abstract class ScriptNodeMap<E extends INode> implements NodeMap<Object,E
 		repaint();
 	}
 	
-	@SuppressWarnings("unchecked")
 	private void receiveUpdate(E node, String id, boolean db) {
 		if (DEBUG) System.out.println("receiveUpdate " + debugString(node)  + " " + id + " " + db);
 		synchronized (syncMutex) {
@@ -240,7 +238,7 @@ public abstract class ScriptNodeMap<E extends INode> implements NodeMap<Object,E
 		synchronized (syncMutex) {
 			graphUpdates = true;
 			mapping.getRangeModified().clear();
-			for (Object o : mapping.getDomain())
+			for (DBObject o : mapping.getDomain())
 				mapping.domainModified(o);
 			mapping.updateRange(graph);
 			graphModified.clear();
@@ -252,8 +250,9 @@ public abstract class ScriptNodeMap<E extends INode> implements NodeMap<Object,E
 		if (DEBUG) System.out.println("Graph update start");
 		synchronized (syncMutex) {
 			graphUpdates = true;
-			for (Object domainObject : mapping.getDomainModified()) {
-				E rangeObject = mapping.get(domainObject);
+			for (DBObject domainObject : mapping.getDomainModified()) {
+				@SuppressWarnings("unchecked")
+				E rangeObject = (E) mapping.get(domainObject);
 				if (rangeObject != null)
 					graphModified.add(rangeObject);
 			}
@@ -288,7 +287,6 @@ public abstract class ScriptNodeMap<E extends INode> implements NodeMap<Object,E
 				doCommit();
 			}
 			session.syncRequest(new ReadRequest() { 
-				@SuppressWarnings("unchecked")
 				@Override
 				public void run(ReadGraph graph) throws DatabaseException {
 					update(graph);
@@ -317,6 +315,7 @@ public abstract class ScriptNodeMap<E extends INode> implements NodeMap<Object,E
 	 * This code here synchronizes removed and added objects to collect deletable objects. (a deletable object is one which is removed but not added).  
 	 * 
 	 */
+	@SuppressWarnings("unused")
 	protected void syncDeletes() {
 		deleteUC.clear();
 		for (Pair<E, String> n : removed) {
@@ -338,6 +337,7 @@ public abstract class ScriptNodeMap<E extends INode> implements NodeMap<Object,E
 	/**
 	 * Clears deletable objects from mapping cache.
 	 */
+	@SuppressWarnings("unused")
 	protected void clearDeletes() {
 		if (DEBUG && delete.size() > 0) System.out.println("Delete");
 		for (E n : delete) {
@@ -360,6 +360,27 @@ public abstract class ScriptNodeMap<E extends INode> implements NodeMap<Object,E
 		
 		
 		synchronized (syncMutex) {
+		    // Check for overlapping additions and deletions, prevent deleting objects that are also added.
+            Deque<E> stack = new ArrayDeque<E>();
+            for (Pair<E, String> n : added) {
+                stack.add(n.first);
+            }
+            while (!stack.isEmpty()) {
+                E n = stack.pop();
+                for (int i = removed.size()-1; i >= 0; i--) {
+                    if (removed.get(i).first == n) {
+                        removed.remove(i);
+                        break;
+                    }
+                }
+                if (n instanceof ParentNode) {
+                    ParentNode<INode> pn = (ParentNode<INode>)n;
+                    for (INode cn : pn.getNodes()) {
+                        stack.push((E)cn);
+                    }
+                }
+            }
+            
 			rem.addAll(removed);
 			add.addAll(added);
 			for (E e : updated.getKeys()) {
@@ -538,7 +559,8 @@ public abstract class ScriptNodeMap<E extends INode> implements NodeMap<Object,E
 		
 	}
 	
-	public IMapping<Object,E> getMapping() {
+	@Override
+	public IMapping<DBObject,INode> getMapping() {
 		return mapping;
 	}