X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.acorn%2Fsrc%2Forg%2Fsimantics%2Facorn%2FGraphClientImpl2.java;h=acf8b6e659bfe7de8393b4a046ab32b365bc300d;hb=f9b0a9c48dd040142414f8d3e7ac43b502d3e203;hp=90af336aafdc079fe99b6210ad9d139211d86f45;hpb=3448b94a8e90047c88eb62a0542c1596acb701b8;p=simantics%2Fplatform.git

diff --git a/bundles/org.simantics.acorn/src/org/simantics/acorn/GraphClientImpl2.java b/bundles/org.simantics.acorn/src/org/simantics/acorn/GraphClientImpl2.java
index 90af336aa..acf8b6e65 100644
--- a/bundles/org.simantics.acorn/src/org/simantics/acorn/GraphClientImpl2.java
+++ b/bundles/org.simantics.acorn/src/org/simantics/acorn/GraphClientImpl2.java
@@ -21,6 +21,7 @@ import java.util.concurrent.Semaphore;
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.TimeUnit;
 
+import org.simantics.acorn.MainProgram.MainProgramRunnable;
 import org.simantics.acorn.exception.AcornAccessVerificationException;
 import org.simantics.acorn.exception.IllegalAcornStateException;
 import org.simantics.acorn.internal.ClusterChange;
@@ -86,6 +87,7 @@ public class GraphClientImpl2 implements Database.Session {
 	    load();
 	    ClusterSetsSupport cssi = locator.getService(ClusterSetsSupport.class); 
 	    cssi.setReadDirectory(clusters.lastSessionDirectory);
+	    cssi.updateWriteDirectory(clusters.workingDirectory);
 	    mainProgram = new MainProgram(this, clusters);
 	    executor.execute(mainProgram);
 	}
@@ -603,90 +605,111 @@ public class GraphClientImpl2 implements Database.Session {
 			clusters.clusterLRU.releaseMutex();
 		}
 	}
-	
+
 	@Override
 	public boolean undo(long[] changeSetIds, OnChangeSetUpdate onChangeSetUpdate) throws SDBException {
-	    try {
-    		final ArrayList<Pair<ClusterUID, byte[]>> clusterChanges = new ArrayList<Pair<ClusterUID, byte[]>>();
-    		
-    		UndoClusterSupport support = new UndoClusterSupport(clusters);
-    		
-    		final int changeSetId = clusters.state.headChangeSetId;
-    		
-    		if(ClusterUpdateProcessorBase.DEBUG)
-    			System.err.println(" === BEGIN UNDO ===");
-    		
-    		for(int i=0;i<changeSetIds.length;i++) {
-    			final long id = changeSetIds[changeSetIds.length-1-i];
-    			ArrayList<String> ccss = clusters.getChanges(id);
-    
-    			for(int j=0;j<ccss.size();j++) {
-    				String ccsid = ccss.get(ccss.size()-j-1);
-    				try {
-    					if(ClusterUpdateProcessorBase.DEBUG)
-    						System.err.println("performUndo " + ccsid);
-    					performUndo(ccsid, clusterChanges, support);
-    				} catch (DatabaseException e) {
-    					e.printStackTrace();
-    				}
-    			}
-    		}
-    
-    		if(ClusterUpdateProcessorBase.DEBUG)
-    			System.err.println(" === END UNDO ===");
-    
-    		for(int i=0;i<clusterChanges.size();i++) {
-    			
-    			final int changeSetIndex = i;
-    			
-    			final Pair<ClusterUID, byte[]> pair = clusterChanges.get(i);
-    			
-    			final ClusterUID cuid = pair.first;
-    			final byte[] data = pair.second;
-    
-    			onChangeSetUpdate.onChangeSetUpdate(new ChangeSetUpdate() {
-    
-    				@Override
-    				public long getChangeSetId() {
-    					return changeSetId;
-    				}
-    
-    				@Override
-    				public int getChangeSetIndex() {
-    					return 0;
-    				}
-    
-    				@Override
-    				public int getNumberOfClusterChangeSets() {
-    					return clusterChanges.size();
-    				}
-    
-    				@Override
-    				public int getIndexOfClusterChangeSet() {
-    					return changeSetIndex;
-    				}
-    
-    				@Override
-    				public byte[] getClusterId() {
-    					return cuid.asBytes();
-    				}
-    
-    				@Override
-    				public boolean getNewCluster() {
-    					return false;
-    				}
-    
-    				@Override
-    				public byte[] getData() {
-    					return data;
-    				}
-    
-    			});
-    		}
-        } catch (AcornAccessVerificationException | IllegalAcornStateException e1) {
-            throw new ProCoreException(e1);
-        }
+
+		Exception exception = mainProgram.runIdle(new MainProgramRunnable() {
+
+			@Override
+			public void run() throws Exception {
+
+				try {
+
+		    		final ArrayList<Pair<ClusterUID, byte[]>> clusterChanges = new ArrayList<Pair<ClusterUID, byte[]>>();
+		    		
+		    		UndoClusterSupport support = new UndoClusterSupport(clusters);
+		    		
+		    		final int changeSetId = clusters.state.headChangeSetId;
+		    		
+		    		if(ClusterUpdateProcessorBase.DEBUG)
+		    			System.err.println(" === BEGIN UNDO ===");
+		    		
+		    		for(int i=0;i<changeSetIds.length;i++) {
+		    			final long id = changeSetIds[changeSetIds.length-1-i];
+		    			ArrayList<String> ccss = clusters.getChanges(id);
+		    
+		    			for(int j=0;j<ccss.size();j++) {
+		    				String ccsid = ccss.get(ccss.size()-j-1);
+		    				try {
+		    					if(ClusterUpdateProcessorBase.DEBUG)
+		    						System.err.println("performUndo " + ccsid);
+		    					performUndo(ccsid, clusterChanges, support);
+		    				} catch (DatabaseException e) {
+		    					e.printStackTrace();
+		    				}
+		    			}
+		    		}
+		    
+		    		if(ClusterUpdateProcessorBase.DEBUG)
+		    			System.err.println(" === END UNDO ===");
+		    
+		    		for(int i=0;i<clusterChanges.size();i++) {
+		    			
+		    			final int changeSetIndex = i;
+		    			
+		    			final Pair<ClusterUID, byte[]> pair = clusterChanges.get(i);
+		    			
+		    			final ClusterUID cuid = pair.first;
+		    			final byte[] data = pair.second;
+		    
+		    			onChangeSetUpdate.onChangeSetUpdate(new ChangeSetUpdate() {
+		    
+		    				@Override
+		    				public long getChangeSetId() {
+		    					return changeSetId;
+		    				}
+		    
+		    				@Override
+		    				public int getChangeSetIndex() {
+		    					return 0;
+		    				}
+		    
+		    				@Override
+		    				public int getNumberOfClusterChangeSets() {
+		    					return clusterChanges.size();
+		    				}
+		    
+		    				@Override
+		    				public int getIndexOfClusterChangeSet() {
+		    					return changeSetIndex;
+		    				}
+		    
+		    				@Override
+		    				public byte[] getClusterId() {
+		    					return cuid.asBytes();
+		    				}
+		    
+		    				@Override
+		    				public boolean getNewCluster() {
+		    					return false;
+		    				}
+		    
+		    				@Override
+		    				public byte[] getData() {
+		    					return data;
+		    				}
+		    
+		    			});
+		    		}
+		        } catch (AcornAccessVerificationException | IllegalAcornStateException e1) {
+		            throw new ProCoreException(e1);
+		        }
+
+			}
+
+			@Override
+			public void done() {
+
+			}
+
+		});
+
+		if(exception instanceof SDBException) throw (SDBException)exception;
+		else if(exception != null) throw new IllegalAcornStateException(exception);
+		
 		return false;
+		
 	}
 	
 	public ServiceLocator getServiceLocator() {
@@ -702,29 +725,67 @@ public class GraphClientImpl2 implements Database.Session {
     public boolean rolledback() {
         return clusters.rolledback();
     }
+    
+    public void purge() throws IllegalAcornStateException {
+        clusters.purge(locator);
+    }
 
-	
-	
-	
-	
-	
-	
-	
-	
-	
-	
-	////////////////////////
-	
-	
-	
-	
-	
-	
-	
-	
-	
-	
-	
-	
+    public void purgeDatabase() {
+    	
+	    if (isClosing || unexpectedClose)
+	        return;
+	    
+		saver.execute(new Runnable() {
+
+			@Override
+			public void run() {
+				Transaction tr = null;
+				try {
+					// First take a write transaction
+					tr = askWriteTransaction(-1);
+					// Then make sure that MainProgram is idling
+					mainProgram.mutex.acquire();
+					try {
+						synchronized(mainProgram) {
+							if(mainProgram.operations.isEmpty()) {
+								purge();
+							} else {
+								// MainProgram is becoming busy again - delay snapshotting
+								return;
+							}
+						}
+					} finally {
+						mainProgram.mutex.release();
+					}
+				} catch (IllegalAcornStateException | ProCoreException e) {
+					Logger.defaultLogError("Purge failed", e);
+					unexpectedClose = true;
+				} catch (InterruptedException e) {
+					Logger.defaultLogError("Purge interrupted", e);
+				} finally {
+					try {
+						if(tr != null)
+							endTransaction(tr.getTransactionId());
+						if (unexpectedClose) {
+    						LifecycleSupport support = getServiceLocator().getService(LifecycleSupport.class);
+    	                    try {
+    	                        support.close();
+    	                    } catch (DatabaseException e1) {
+    	                        Logger.defaultLogError("Failed to close database as a safety measure due to failed purge", e1);
+    	                    }
+						}
+					} catch (ProCoreException e) {
+						Logger.defaultLogError("Failed to end purge write transaction", e);
+					}
+				}
+			}
+		});
+    	
+    }
+    
+    public long getTailChangeSetId() {
+    	return clusters.getTailChangeSetId();
+    }
+    
 }