aboutsummaryrefslogtreecommitdiff
path: root/Emby.Server.Implementations
diff options
context:
space:
mode:
authorLuke Pulverenti <luke.pulverenti@gmail.com>2016-11-20 18:48:52 -0500
committerLuke Pulverenti <luke.pulverenti@gmail.com>2016-11-20 18:48:52 -0500
commite297e90bceeb3310e32142af406403d54875720d (patch)
tree27cedda92ea6452f148bbc87c59fbdbf50566174 /Emby.Server.Implementations
parent94e622e3a0cfcd14ad47ede3342dfab7a862c4d9 (diff)
update .net core startup
Diffstat (limited to 'Emby.Server.Implementations')
-rw-r--r--Emby.Server.Implementations/Data/BaseSqliteRepository.cs20
-rw-r--r--Emby.Server.Implementations/Data/SqliteItemRepository.cs8
-rw-r--r--Emby.Server.Implementations/LiveTv/TunerHosts/HdHomerun/HdHomerunLiveStream.cs5
3 files changed, 25 insertions, 8 deletions
diff --git a/Emby.Server.Implementations/Data/BaseSqliteRepository.cs b/Emby.Server.Implementations/Data/BaseSqliteRepository.cs
index 7836c8b41..c506411d4 100644
--- a/Emby.Server.Implementations/Data/BaseSqliteRepository.cs
+++ b/Emby.Server.Implementations/Data/BaseSqliteRepository.cs
@@ -12,12 +12,22 @@ namespace Emby.Server.Implementations.Data
public abstract class BaseSqliteRepository : IDisposable
{
protected string DbFilePath { get; set; }
- protected ReaderWriterLockSlim WriteLock = new ReaderWriterLockSlim(LockRecursionPolicy.NoRecursion);
+ protected ReaderWriterLockSlim WriteLock;
+
protected ILogger Logger { get; private set; }
protected BaseSqliteRepository(ILogger logger)
{
Logger = logger;
+
+ WriteLock = AllowLockRecursion ?
+ new ReaderWriterLockSlim(LockRecursionPolicy.SupportsRecursion) :
+ new ReaderWriterLockSlim(LockRecursionPolicy.NoRecursion);
+ }
+
+ protected virtual bool AllowLockRecursion
+ {
+ get { return false; }
}
protected virtual bool EnableConnectionPooling
@@ -86,7 +96,7 @@ namespace Emby.Server.Implementations.Data
var cacheSize = CacheSize;
if (cacheSize.HasValue)
{
-
+
}
if (EnableExclusiveMode)
@@ -206,11 +216,7 @@ namespace Emby.Server.Implementations.Data
return;
}
- connection.ExecuteAll(string.Join(";", new string[]
- {
- "alter table " + table,
- "add column " + columnName + " " + type + " NULL"
- }));
+ connection.Execute("alter table " + table + " add column " + columnName + " " + type + " NULL");
}
}
diff --git a/Emby.Server.Implementations/Data/SqliteItemRepository.cs b/Emby.Server.Implementations/Data/SqliteItemRepository.cs
index 255235cc7..150e4072a 100644
--- a/Emby.Server.Implementations/Data/SqliteItemRepository.cs
+++ b/Emby.Server.Implementations/Data/SqliteItemRepository.cs
@@ -95,6 +95,14 @@ namespace Emby.Server.Implementations.Data
DbFilePath = Path.Combine(_config.ApplicationPaths.DataPath, "library.db");
}
+ protected override bool AllowLockRecursion
+ {
+ get
+ {
+ return true;
+ }
+ }
+
private const string ChaptersTableName = "Chapters2";
protected override int? CacheSize
diff --git a/Emby.Server.Implementations/LiveTv/TunerHosts/HdHomerun/HdHomerunLiveStream.cs b/Emby.Server.Implementations/LiveTv/TunerHosts/HdHomerun/HdHomerunLiveStream.cs
index 1e8057f87..4852270d5 100644
--- a/Emby.Server.Implementations/LiveTv/TunerHosts/HdHomerun/HdHomerunLiveStream.cs
+++ b/Emby.Server.Implementations/LiveTv/TunerHosts/HdHomerun/HdHomerunLiveStream.cs
@@ -89,7 +89,10 @@ namespace Emby.Server.Implementations.LiveTv.TunerHosts.HdHomerun
{
Url = url,
CancellationToken = cancellationToken,
- BufferContent = false
+ BufferContent = false,
+
+ // Increase a little bit
+ TimeoutMs = 30000
}, "GET").ConfigureAwait(false))
{