X-Git-Url: https://gerrit.simantics.org/r/gitweb?p=simantics%2Fplatform.git;a=blobdiff_plain;f=bundles%2Forg.simantics.acorn%2Fsrc%2Forg%2Fsimantics%2Facorn%2FGraphClientImpl2.java;h=acf8b6e659bfe7de8393b4a046ab32b365bc300d;hp=904427b6d617f6682c78547db1dde17a419dff48;hb=refs%2Fchanges%2F24%2F324%2F1;hpb=74de2d9be56f36e925a0a5818f4b11a766812cff

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 904427b6d..acf8b6e65 100644
--- a/bundles/org.simantics.acorn/src/org/simantics/acorn/GraphClientImpl2.java
+++ b/bundles/org.simantics.acorn/src/org/simantics/acorn/GraphClientImpl2.java
@@ -725,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();
+    }
+    
 }