aboutsummaryrefslogtreecommitdiff
path: root/Emby.Server.Implementations/Data/ManagedConnection.cs
diff options
context:
space:
mode:
authorShadowghost <Ghost_of_Stone@web.de>2023-05-09 15:25:41 +0200
committerShadowghost <Ghost_of_Stone@web.de>2023-05-09 15:25:41 +0200
commit6cc1203c1b423ee2765be7e33aad56be374c8314 (patch)
tree57ce21874de41124f2626c5f06328bcb2e9734d5 /Emby.Server.Implementations/Data/ManagedConnection.cs
parent520c07e8cad3e4372f6a5214160d1600106a7bfd (diff)
parent92a0d26f31743ca0015fcc3e0a4fe094792ac63c (diff)
Merge branch 'master' into network-rewrite
Diffstat (limited to 'Emby.Server.Implementations/Data/ManagedConnection.cs')
-rw-r--r--Emby.Server.Implementations/Data/ManagedConnection.cs13
1 files changed, 6 insertions, 7 deletions
diff --git a/Emby.Server.Implementations/Data/ManagedConnection.cs b/Emby.Server.Implementations/Data/ManagedConnection.cs
index 11e33278d..e84ed8f91 100644
--- a/Emby.Server.Implementations/Data/ManagedConnection.cs
+++ b/Emby.Server.Implementations/Data/ManagedConnection.cs
@@ -2,23 +2,22 @@
using System;
using System.Collections.Generic;
-using System.Threading;
using SQLitePCL.pretty;
namespace Emby.Server.Implementations.Data
{
public sealed class ManagedConnection : IDisposable
{
- private readonly SemaphoreSlim _writeLock;
+ private readonly ConnectionPool _pool;
- private SQLiteDatabaseConnection? _db;
+ private SQLiteDatabaseConnection _db;
private bool _disposed = false;
- public ManagedConnection(SQLiteDatabaseConnection db, SemaphoreSlim writeLock)
+ public ManagedConnection(SQLiteDatabaseConnection db, ConnectionPool pool)
{
_db = db;
- _writeLock = writeLock;
+ _pool = pool;
}
public IStatement PrepareStatement(string sql)
@@ -73,9 +72,9 @@ namespace Emby.Server.Implementations.Data
return;
}
- _writeLock.Release();
+ _pool.Return(_db);
- _db = null; // Don't dispose it
+ _db = null!; // Don't dispose it
_disposed = true;
}
}