aboutsummaryrefslogtreecommitdiff
path: root/Emby.Server.Implementations/Data
diff options
context:
space:
mode:
authorCody Robibero <cody@robibe.ro>2022-03-06 09:30:47 -0700
committerGitHub <noreply@github.com>2022-03-06 09:30:47 -0700
commit0a8bec1af44665509510022c491b6ee9b8179fe1 (patch)
tree0dffcdf0893a094273f9e993c03ff36c275a8007 /Emby.Server.Implementations/Data
parent973781c4824c7e703607d10ff92928634ba68916 (diff)
Revert "chore: Add a read only connection for routes like Shows/NextUp"
Diffstat (limited to 'Emby.Server.Implementations/Data')
-rw-r--r--Emby.Server.Implementations/Data/BaseSqliteRepository.cs8
-rw-r--r--Emby.Server.Implementations/Data/ManagedConnection.cs8
2 files changed, 4 insertions, 12 deletions
diff --git a/Emby.Server.Implementations/Data/BaseSqliteRepository.cs b/Emby.Server.Implementations/Data/BaseSqliteRepository.cs
index b86511482e..450688491a 100644
--- a/Emby.Server.Implementations/Data/BaseSqliteRepository.cs
+++ b/Emby.Server.Implementations/Data/BaseSqliteRepository.cs
@@ -98,16 +98,8 @@ namespace Emby.Server.Implementations.Data
/// <value>The write connection.</value>
protected SQLiteDatabaseConnection WriteConnection { get; set; }
- protected SQLiteDatabaseConnection ReadConnection { get; set; }
-
protected ManagedConnection GetConnection(bool readOnly = false)
{
- if (readOnly)
- {
- ReadConnection ??= SQLite3.Open(DbFilePath, ConnectionFlags.ReadOnly, null);
- return new ManagedConnection(ReadConnection, null);
- }
-
WriteLock.Wait();
if (WriteConnection != null)
{
diff --git a/Emby.Server.Implementations/Data/ManagedConnection.cs b/Emby.Server.Implementations/Data/ManagedConnection.cs
index fe09bdc2a4..11e33278d4 100644
--- a/Emby.Server.Implementations/Data/ManagedConnection.cs
+++ b/Emby.Server.Implementations/Data/ManagedConnection.cs
@@ -9,13 +9,13 @@ namespace Emby.Server.Implementations.Data
{
public sealed class ManagedConnection : IDisposable
{
- private readonly SemaphoreSlim? _writeLock;
+ private readonly SemaphoreSlim _writeLock;
private SQLiteDatabaseConnection? _db;
- private bool _disposed;
+ private bool _disposed = false;
- public ManagedConnection(SQLiteDatabaseConnection db, SemaphoreSlim? writeLock)
+ public ManagedConnection(SQLiteDatabaseConnection db, SemaphoreSlim writeLock)
{
_db = db;
_writeLock = writeLock;
@@ -73,7 +73,7 @@ namespace Emby.Server.Implementations.Data
return;
}
- _writeLock?.Release();
+ _writeLock.Release();
_db = null; // Don't dispose it
_disposed = true;