switch recordings to ts when preserving original audio

1 files changed, 38 insertions, 2 deletions

diff --git a/MediaBrowser.Server.Implementations/Persistence/BaseSqliteRepository.cs b/MediaBrowser.Server.Implementations/Persistence/BaseSqliteRepository.cs
index 709971797..eec5b4b76 100644
--- a/MediaBrowser.Server.Implementations/Persistence/BaseSqliteRepository.cs
+++ b/MediaBrowser.Server.Implementations/Persistence/BaseSqliteRepository.cs
@@ -8,6 +8,7 @@ namespace MediaBrowser.Server.Implementations.Persistence
 {
     public abstract class BaseSqliteRepository : IDisposable
     {
+        protected readonly SemaphoreSlim WriteLock = new SemaphoreSlim(1, 1);
         protected readonly IDbConnector DbConnector;
         protected ILogger Logger;
 
@@ -19,11 +20,16 @@ namespace MediaBrowser.Server.Implementations.Persistence
             Logger = logManager.GetLogger(GetType().Name);
         }
 
+        protected virtual bool EnableConnectionPooling
+        {
+            get { return true; }
+        }
+
         protected virtual async Task<IDbConnection> CreateConnection(bool isReadOnly = false)
         {
             var connection = await DbConnector.Connect(DbFilePath, false, true).ConfigureAwait(false);
 
-            connection.RunQueries(new []
+            connection.RunQueries(new[]
             {
                 "pragma temp_store = memory"
 
@@ -45,12 +51,15 @@ namespace MediaBrowser.Server.Implementations.Persistence
         {
             _disposed = true;
             Dispose(true);
+            GC.SuppressFinalize(this);
         }
 
         protected async Task Vacuum(IDbConnection connection)
         {
             CheckDisposed();
 
+            await WriteLock.WaitAsync().ConfigureAwait(false);
+
             try
             {
                 using (var cmd = connection.CreateCommand())
@@ -65,14 +74,41 @@ namespace MediaBrowser.Server.Implementations.Persistence
 
                 throw;
             }
+            finally
+            {
+                WriteLock.Release();
+            }
         }
 
+        private readonly object _disposeLock = new object();
+
         /// <summary>
         /// Releases unmanaged and - optionally - managed resources.
         /// </summary>
         /// <param name="dispose"><c>true</c> to release both managed and unmanaged resources; <c>false</c> to release only unmanaged resources.</param>
         protected virtual void Dispose(bool dispose)
         {
+            if (dispose)
+            {
+                try
+                {
+                    lock (_disposeLock)
+                    {
+                        WriteLock.Wait();
+
+                        CloseConnection();
+                    }
+                }
+                catch (Exception ex)
+                {
+                    Logger.ErrorException("Error disposing database", ex);
+                }
+            }
+        }
+
+        protected virtual void CloseConnection()
+        {
+
         }
     }
-}
+}
\ No newline at end of file