X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=bundles%2Forg.simantics%2Fsrc%2Forg%2Fsimantics%2Finternal%2FFileServiceImpl.java;h=77d4b672471719b7d6f0a800c6c1c0ad69ca47eb;hb=refs%2Fchanges%2F38%2F238%2F2;hp=a836d19be4b75796e60548ed93d8478134fe10bf;hpb=24e2b34260f219f0d1644ca7a138894980e25b14;p=simantics%2Fplatform.git

diff --git a/bundles/org.simantics/src/org/simantics/internal/FileServiceImpl.java b/bundles/org.simantics/src/org/simantics/internal/FileServiceImpl.java
index a836d19be..77d4b6724 100644
--- a/bundles/org.simantics/src/org/simantics/internal/FileServiceImpl.java
+++ b/bundles/org.simantics/src/org/simantics/internal/FileServiceImpl.java
@@ -1,183 +1,183 @@
-package org.simantics.internal;
-
-import java.io.File;
-import java.io.FileFilter;
-import java.io.IOException;
-import java.util.ArrayDeque;
-import java.util.Collection;
-
-import org.eclipse.core.runtime.IProgressMonitor;
-import org.eclipse.core.runtime.IStatus;
-import org.eclipse.core.runtime.Status;
-import org.eclipse.core.runtime.jobs.Job;
-import org.simantics.utils.FileService;
-import org.simantics.utils.IOperation;
-import org.simantics.utils.IOperationListener;
-
-/**
- * @author Tuukka Lehtonen
- */
-public class FileServiceImpl implements FileService {
-
-	private static final long DELETION_DELAY_MS = 10000;
-	private static final long DELETION_ATTEMPT_INTERVAL_MS = 10000;
-
-	private static abstract class Op<R, E extends Exception> implements IOperation<R, E> {
-		protected boolean done;
-		protected R result;
-		@SuppressWarnings("unused")
-		protected E lastException;
-
-		@Override
-		public R waitFor() throws E {
-			synchronized(this) {
-				while (!isDone()) {
-					try {
-						wait();
-					} catch (InterruptedException e) {
-					}
-				}
-			}
-			return result;
-		}
-
-		@Override
-		public boolean isDone() {
-			return done;
-		}
-
-		@Override
-		public void addListener(IOperationListener<R, E> listener) {
-			throw new UnsupportedOperationException();
-		}
-
-		public abstract boolean tryExecute();
-
-	}
-
-	private static class Deletion extends Op<Boolean, IOException> {
-
-		File f;
-
-		EffortOption effort;
-		int tries;
-
-		public Deletion(File f, DeleteOption... options) {
-			this.f = f;
-			parseOptions(options);
-		}
-
-		private void parseOptions(DeleteOption[] options) {
-			for (DeleteOption opt : options) {
-				if (opt instanceof EffortOption) {
-					effort = (EffortOption) opt;
-				}
-			}
-		}
-
-		@Override
-		public boolean tryExecute() {
-			if (effort != null) {
-				if (tries > effort.maxTries) {
-					// Give up.
-					return true;
-				}
-			}
-			try {
-				deleteAll(f);
-				lastException = null;
-				result = true;
-				return true;
-			} catch (IOException e) {
-				++tries;
-				lastException = e;
-				return false;
-			}
-		}
-
-		public void deleteAll(File dir) throws IOException {
-			if (dir.isFile()) {
-				if (!dir.delete())
-					throw new IOException("Could not delete file: " + dir.getAbsolutePath());
-				return;
-			}
-			if (dir.isDirectory()) {
-				File[] fs = dir.listFiles((FileFilter) null);
-				if (fs == null)
-					return;
-
-				for (File f : fs) {
-					if (f.isDirectory()) {
-						deleteAll(f);
-					} else {
-						if (!f.delete()) {
-							throw new IOException("Could not delete file: " + f.getAbsolutePath());
-						}
-					}
-				}
-
-				if (!dir.delete()) {
-					throw new IOException("Could not delete directory: " + dir.getAbsolutePath());
-				}
-			} else if (dir.exists()) {
-				if (!dir.delete()) {
-					throw new IOException("Could not delete file: " + dir.getAbsolutePath());
-				}
-			}
-		}
-
-	}
-
-	private ArrayDeque<Deletion> deletionQueue = new ArrayDeque<Deletion>();
-	private DeletionJob deletionJob = new DeletionJob();
-
-	@Override
-	public IOperation<Boolean, IOException> scheduleDeleteIfExists(File file, DeleteOption... options) {
-		if (!file.exists())
-			return null;
-		synchronized (deletionQueue) {
-			Deletion d = new Deletion(file, options);
-			if (deletionQueue.contains(d))
-				return null;
-			deletionQueue.addLast(d);
-			deletionJob.schedule(DELETION_DELAY_MS);
-			return d;
-		}
-	}
-
-	class DeletionJob extends Job {
-
-		public DeletionJob() {
-			super("File background deletion");
-		}
-
-		@SuppressWarnings("unchecked")
-		private <O extends Op<?,?>> void process(Collection<O> ops) {
-			Object[] opa = ops.toArray();
-			for (int i = 0; i < opa.length; ++i) {
-				O op = (O) opa[i];
-				if (op.tryExecute()) {
-					// Success. Will be removed from queue.
-				} else {
-					opa[i] = null;
-				}
-			}
-			synchronized (ops) {
-				for (int i = 0; i < opa.length; ++i) {
-					if (opa[i] != null)
-						ops.remove(opa[i]);
-				}
-			}
-		}
-
-		@Override
-		protected IStatus run(IProgressMonitor monitor) {
-			process(deletionQueue);
-			if (!deletionQueue.isEmpty())
-				schedule(DELETION_ATTEMPT_INTERVAL_MS);
-			return Status.OK_STATUS;
-		}
-
-	}
-
-}
+package org.simantics.internal;
+
+import java.io.File;
+import java.io.FileFilter;
+import java.io.IOException;
+import java.util.ArrayDeque;
+import java.util.Collection;
+
+import org.eclipse.core.runtime.IProgressMonitor;
+import org.eclipse.core.runtime.IStatus;
+import org.eclipse.core.runtime.Status;
+import org.eclipse.core.runtime.jobs.Job;
+import org.simantics.utils.FileService;
+import org.simantics.utils.IOperation;
+import org.simantics.utils.IOperationListener;
+
+/**
+ * @author Tuukka Lehtonen
+ */
+public class FileServiceImpl implements FileService {
+
+	private static final long DELETION_DELAY_MS = 10000;
+	private static final long DELETION_ATTEMPT_INTERVAL_MS = 10000;
+
+	private static abstract class Op<R, E extends Exception> implements IOperation<R, E> {
+		protected boolean done;
+		protected R result;
+		@SuppressWarnings("unused")
+		protected E lastException;
+
+		@Override
+		public R waitFor() throws E {
+			synchronized(this) {
+				while (!isDone()) {
+					try {
+						wait();
+					} catch (InterruptedException e) {
+					}
+				}
+			}
+			return result;
+		}
+
+		@Override
+		public boolean isDone() {
+			return done;
+		}
+
+		@Override
+		public void addListener(IOperationListener<R, E> listener) {
+			throw new UnsupportedOperationException();
+		}
+
+		public abstract boolean tryExecute();
+
+	}
+
+	private static class Deletion extends Op<Boolean, IOException> {
+
+		File f;
+
+		EffortOption effort;
+		int tries;
+
+		public Deletion(File f, DeleteOption... options) {
+			this.f = f;
+			parseOptions(options);
+		}
+
+		private void parseOptions(DeleteOption[] options) {
+			for (DeleteOption opt : options) {
+				if (opt instanceof EffortOption) {
+					effort = (EffortOption) opt;
+				}
+			}
+		}
+
+		@Override
+		public boolean tryExecute() {
+			if (effort != null) {
+				if (tries > effort.maxTries) {
+					// Give up.
+					return true;
+				}
+			}
+			try {
+				deleteAll(f);
+				lastException = null;
+				result = true;
+				return true;
+			} catch (IOException e) {
+				++tries;
+				lastException = e;
+				return false;
+			}
+		}
+
+		public void deleteAll(File dir) throws IOException {
+			if (dir.isFile()) {
+				if (!dir.delete())
+					throw new IOException("Could not delete file: " + dir.getAbsolutePath());
+				return;
+			}
+			if (dir.isDirectory()) {
+				File[] fs = dir.listFiles((FileFilter) null);
+				if (fs == null)
+					return;
+
+				for (File f : fs) {
+					if (f.isDirectory()) {
+						deleteAll(f);
+					} else {
+						if (!f.delete()) {
+							throw new IOException("Could not delete file: " + f.getAbsolutePath());
+						}
+					}
+				}
+
+				if (!dir.delete()) {
+					throw new IOException("Could not delete directory: " + dir.getAbsolutePath());
+				}
+			} else if (dir.exists()) {
+				if (!dir.delete()) {
+					throw new IOException("Could not delete file: " + dir.getAbsolutePath());
+				}
+			}
+		}
+
+	}
+
+	private ArrayDeque<Deletion> deletionQueue = new ArrayDeque<Deletion>();
+	private DeletionJob deletionJob = new DeletionJob();
+
+	@Override
+	public IOperation<Boolean, IOException> scheduleDeleteIfExists(File file, DeleteOption... options) {
+		if (!file.exists())
+			return null;
+		synchronized (deletionQueue) {
+			Deletion d = new Deletion(file, options);
+			if (deletionQueue.contains(d))
+				return null;
+			deletionQueue.addLast(d);
+			deletionJob.schedule(DELETION_DELAY_MS);
+			return d;
+		}
+	}
+
+	class DeletionJob extends Job {
+
+		public DeletionJob() {
+			super("File background deletion");
+		}
+
+		@SuppressWarnings("unchecked")
+		private <O extends Op<?,?>> void process(Collection<O> ops) {
+			Object[] opa = ops.toArray();
+			for (int i = 0; i < opa.length; ++i) {
+				O op = (O) opa[i];
+				if (op.tryExecute()) {
+					// Success. Will be removed from queue.
+				} else {
+					opa[i] = null;
+				}
+			}
+			synchronized (ops) {
+				for (int i = 0; i < opa.length; ++i) {
+					if (opa[i] != null)
+						ops.remove(opa[i]);
+				}
+			}
+		}
+
+		@Override
+		protected IStatus run(IProgressMonitor monitor) {
+			process(deletionQueue);
+			if (!deletionQueue.isEmpty())
+				schedule(DELETION_ATTEMPT_INTERVAL_MS);
+			return Status.OK_STATUS;
+		}
+
+	}
+
+}