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%2FClusterManager.java;h=2f04d7eda1af9f9976fdb182b1cab3e89b89cd01;hp=9725ffe8da2df0aabb169b301b955642781205dd;hb=03fac449ec81e88669169d671bb386eb93ac060d;hpb=95e05b3cc3208ec57118e8167a090c9b90edfaf2

diff --git a/bundles/org.simantics.acorn/src/org/simantics/acorn/ClusterManager.java b/bundles/org.simantics.acorn/src/org/simantics/acorn/ClusterManager.java
index 9725ffe8d..2f04d7eda 100644
--- a/bundles/org.simantics.acorn/src/org/simantics/acorn/ClusterManager.java
+++ b/bundles/org.simantics.acorn/src/org/simantics/acorn/ClusterManager.java
@@ -47,8 +47,9 @@ public class ClusterManager {
 	private ArrayList<String> currentChanges = new ArrayList<String>();
 
 	public final Path dbFolder;
-	public Path lastSessionDirectory;
-	public Path workingDirectory;
+	private FileCache fileCache;
+	Path lastSessionDirectory;
+	Path workingDirectory;
 
 	public LRU<String, ClusterStreamChunk> streamLRU;
 	public LRU<Long, ChangeSetInfo> csLRU;
@@ -67,8 +68,9 @@ public class ClusterManager {
 	 * 
 	 */
 
-	public ClusterManager(Path dbFolder) {
+	public ClusterManager(Path dbFolder, FileCache fileCache) {
 		this.dbFolder = dbFolder;
+		this.fileCache = fileCache;
 	}
 
 	public ArrayList<String> getChanges(long changeSetId) throws AcornAccessVerificationException, IllegalAcornStateException {
@@ -469,7 +471,7 @@ public class ClusterManager {
     			Path readDir = dbFolder.resolve(parts[1]);
     			int offset = Integer.parseInt(parts[2]);
     			int length = Integer.parseInt(parts[3]);
-    			FileInfo info = new FileInfo(fileLRU, readDir, parts[0], offset, length);
+    			FileInfo info = new FileInfo(fileLRU, fileCache, readDir, parts[0], offset, length);
     			fileLRU.map(info);
     		}
     		// Update chunks
@@ -490,7 +492,7 @@ public class ClusterManager {
     			Long revisionId = Long.parseLong(parts[0]);
     			int offset = Integer.parseInt(parts[2]);
     			int length = Integer.parseInt(parts[3]);
-    			ChangeSetInfo info = new ChangeSetInfo(csLRU, readDir, revisionId, offset, length);
+    			ChangeSetInfo info = new ChangeSetInfo(csLRU, fileCache, readDir, revisionId, offset, length);
     			csLRU.map(info);
     		}
     		
@@ -604,7 +606,7 @@ public class ClusterManager {
 		try {
 			ArrayList<String> csids = new ArrayList<String>(currentChanges);
 			currentChanges = new ArrayList<String>();
-			new ChangeSetInfo(csLRU, changeSetId, data, csids);
+			new ChangeSetInfo(csLRU, fileCache, changeSetId, data, csids);
 		} catch (Throwable t) {
 			throw new IllegalAcornStateException(t);
 		} finally {
@@ -671,7 +673,7 @@ public class ClusterManager {
 			try {
 				info = fileLRU.get(key);
 				if (info == null) {
-					info = new FileInfo(fileLRU, key, (int) (offset + size));
+					info = new FileInfo(fileLRU, fileCache, key, (int) (offset + size));
 				}
 			} catch (Throwable t) {
 				throw new IllegalAcornStateException(t);
@@ -707,5 +709,9 @@ public class ClusterManager {
     public long getTailChangeSetId() {
     	return state.tailChangeSetId;
     }
-    
+
+    public FileCache getFileCache() {
+        return fileCache;
+    }
+
 }