Changeset 392 for binary-improvements2/7dtd-server-fixes/src/FileCache

Timestamp:

Aug 8, 2022, 8:04:09 PM (2 years ago)

Author:

alloc

Message:

Added command to invalidate file caches
Added a debug+profiling build target

Location:

binary-improvements2/7dtd-server-fixes/src/FileCache

Files:

• AbstractCache.cs (modified) (1 diff)
• DirectAccess.cs (modified) (1 diff)
• MapTileCache.cs (modified) (1 diff)
• SimpleCache.cs (modified) (1 diff)

binary-improvements2/7dtd-server-fixes/src/FileCache/AbstractCache.cs

@@ +1 @@
+using System.Collections.Generic;
+
 namespace AllocsFixes.FileCache {
         public abstract class AbstractCache {
                 public abstract byte[] GetFileContent (string _filename);
+                public abstract (int, int) Invalidate ();
+
+                protected AbstractCache () {
+                        caches.Add (this);
+                }
+
+                private static readonly List<AbstractCache> caches = new List<AbstractCache> ();
+                public static (int, int) InvalidateAllCaches () {
+                        int filesDropped = 0;
+                        int bytesDropped = 0;
+                        
+                        foreach (AbstractCache cache in caches) {
+                                (int, int) returned = cache.Invalidate ();
+                                filesDropped += returned.Item1;
+                                bytesDropped += returned.Item2;
+                        }
+
+                        return (filesDropped, bytesDropped);
+                }
         }
 }

binary-improvements2/7dtd-server-fixes/src/FileCache/DirectAccess.cs

@@ -14 +14 @@
                         return null;
                 }
+
+                public override (int, int) Invalidate () {
+                        return (0, 0);
+                }
         }
 }

binary-improvements2/7dtd-server-fixes/src/FileCache/MapTileCache.cs

@@ -114 +114 @@
                 }
 
+                public override (int, int) Invalidate () {
+                        return (0, 0);
+                }
+
                 private static byte[] ReadAllBytes (string _path) {
                         using (FileStream fileStream = new FileStream(_path, FileMode.Open, FileAccess.Read, FileShare.Read, 4096)) {

binary-improvements2/7dtd-server-fixes/src/FileCache/SimpleCache.cs

@@ -29 +29 @@
                         return null;
                 }
+
+                public override (int, int) Invalidate () {
+                        (int, int) result = (0, 0);
+                        
+                        lock (fileCache) {
+                                result.Item1 = fileCache.Count;
+                                foreach ((string _, byte[] data) in fileCache) {
+                                        result.Item2 += data.Length;
+                                }
+                                
+                                fileCache.Clear ();
+                        }
+
+                        return result;
+                }
         }
 }