Don't return directory outside of lock, this is not optimal and instead we should have a lease system instead, but it seems to fix the concurency issues for now.

Author: jmd

src/DotJEM.Json.Index2.Management/Writer/IJsonIndexWriter.cs

@@ -150,14 +150,16 @@ private void Commit()
             if (callsRead < 1)
                 return;
 
+            using ILease<IndexWriter> lease = target.WriterLease;
             try
             {
-                using ILease<IndexWriter> lease = target.WriterLease;
                 lease.Value.Commit();
             }
             catch (Exception e)
             {
-                target.infoStream.WriteError("Failed to commit indexed data to storage.", e);
+                bool leaseExpired = lease.IsExpired;
+
+                target.infoStream.WriteError($"Failed to commit indexed data to storage. {leaseExpired}", e);
                 // SWALLOW FOR NOW
             }
         }

src/DotJEM.Json.Index2/IO/JsonIndexWriterManager.cs

@@ -165,7 +165,7 @@ public IndexWriter Value
             }
         }
 
-        public bool IsExpired => DateTime.Now - leaseTime > TimeSpan.FromSeconds(5);
+        public bool IsExpired => (DateTime.Now - leaseTime > TimeSpan.FromSeconds(5)) || IsDisposed;
 
         public TimeLimitedIndexWriterLease(IndexWriterManager manager, Action<TimeLimitedIndexWriterLease> onReturned)
         {
@@ -181,9 +181,6 @@ protected override void Dispose(bool disposing)
 
         public void Wait()
         {
-            if (IsDisposed)
-                return;
-
             if (IsExpired)
                 return;
 

src/DotJEM.Json.Index2/Storage/IJsonIndexStorageManager.cs

@@ -36,9 +36,6 @@ public Directory Directory
     {
         get
         {
-            if (directory != null)
-                return directory;
-
             lock (padlock)
             {
                 if (directory != null)
@@ -83,6 +80,8 @@ public void Delete()
             foreach (string file in directory.ListAll())
                 directory.DeleteFile(file);
             provider.Delete();
+
+
         }
     }
 }