jellyfin/MediaBrowser.Server.Implementations/Persistence/BaseSqliteRepository.cs

90 lines
2.4 KiB
C#
Raw Normal View History

2015-05-02 22:59:01 +00:00
using MediaBrowser.Model.Logging;
using System;
2016-02-10 18:13:24 +00:00
using System.Data;
2015-05-02 22:59:01 +00:00
using System.Threading;
2016-02-10 18:13:24 +00:00
using System.Threading.Tasks;
2015-05-02 22:59:01 +00:00
namespace MediaBrowser.Server.Implementations.Persistence
{
public abstract class BaseSqliteRepository : IDisposable
{
protected readonly SemaphoreSlim WriteLock = new SemaphoreSlim(1, 1);
protected ILogger Logger;
protected BaseSqliteRepository(ILogManager logManager)
{
Logger = logManager.GetLogger(GetType().Name);
}
2016-02-10 18:13:24 +00:00
private bool _disposed;
protected void CheckDisposed()
{
if (_disposed)
{
throw new ObjectDisposedException(GetType().Name + " has been disposed and cannot be accessed.");
}
}
2015-05-02 22:59:01 +00:00
public void Dispose()
{
2016-02-10 18:13:24 +00:00
_disposed = true;
2015-05-02 22:59:01 +00:00
Dispose(true);
GC.SuppressFinalize(this);
}
2016-02-10 18:13:24 +00:00
protected async Task Vacuum(IDbConnection connection)
{
CheckDisposed();
await WriteLock.WaitAsync().ConfigureAwait(false);
try
{
using (var cmd = connection.CreateCommand())
{
cmd.CommandText = "vacuum";
cmd.ExecuteNonQuery();
}
}
catch (Exception e)
{
Logger.ErrorException("Failed to vacuum:", e);
throw;
}
finally
{
WriteLock.Release();
}
}
2015-05-02 22:59:01 +00:00
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 abstract void CloseConnection();
}
}