michael.heier/jellyfin
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

update components

Browse Source
This commit is contained in:
Luke Pulverenti 2016-12-11 00:27:08 -05:00
parent 7669e821f1
commit 71919dcc05
3 changed files with 15 additions and 57 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
Emby.Server.Implementations/Data/BaseSqliteRepository.cs
View File

@ -343,46 +343,4 @@ namespace Emby.Server.Implementations.Data
return new WriteLockToken(obj); return new WriteLockToken(obj);
} }
} }
public static class SemaphpreSlimExtensions
{
private sealed class WriteLockToken : IDisposable
{
private SemaphoreSlim _sync;
public WriteLockToken(SemaphoreSlim sync)
{
_sync = sync;
var task = sync.WaitAsync();
Task.WaitAll(task);
}
public void Dispose()
{
if (_sync != null)
{
_sync.Release();
_sync = null;
}
}
}
public class DummyToken : IDisposable
{
public void Dispose()
{
}
}
public static IDisposable Read(this SemaphoreSlim obj)
{
return Write(obj);
}
public static IDisposable Write(this SemaphoreSlim obj)
{
//if (BaseSqliteRepository.ThreadSafeMode > 0)
//{
// return new DummyToken();
//}
return new WriteLockToken(obj);
}
}
} }

26
Emby.Server.Implementations/Data/SqliteItemRepository.cs
View File

@ -1257,7 +1257,7 @@ namespace Emby.Server.Implementations.Data
CheckDisposed(); CheckDisposed();
//Logger.Info("Retrieving item {0}", id.ToString("N")); //Logger.Info("Retrieving item {0}", id.ToString("N"));
using (WriteLock.Write()) using (WriteLock.Read())
{ {
using (var connection = CreateConnection(true)) using (var connection = CreateConnection(true))
{ {
@ -2083,7 +2083,7 @@ namespace Emby.Server.Implementations.Data
var list = new List<ChapterInfo>(); var list = new List<ChapterInfo>();
using (WriteLock.Write()) using (WriteLock.Read())
{ {
using (var connection = CreateConnection(true)) using (var connection = CreateConnection(true))
{ {
@ -2117,7 +2117,7 @@ namespace Emby.Server.Implementations.Data
throw new ArgumentNullException("id"); throw new ArgumentNullException("id");
} }
using (WriteLock.Write()) using (WriteLock.Read())
{ {
using (var connection = CreateConnection(true)) using (var connection = CreateConnection(true))
{ {
@ -2492,7 +2492,7 @@ namespace Emby.Server.Implementations.Data
} }
} }
using (WriteLock.Write()) using (WriteLock.Read())
{ {
using (var connection = CreateConnection(true)) using (var connection = CreateConnection(true))
{ {
@ -2687,7 +2687,7 @@ namespace Emby.Server.Implementations.Data
statementTexts.Add(commandText); statementTexts.Add(commandText);
} }
using (WriteLock.Write()) using (WriteLock.Read())
{ {
using (var connection = CreateConnection(true)) using (var connection = CreateConnection(true))
{ {
@ -2906,7 +2906,7 @@ namespace Emby.Server.Implementations.Data
var list = new List<Guid>(); var list = new List<Guid>();
using (WriteLock.Write()) using (WriteLock.Read())
{ {
using (var connection = CreateConnection(true)) using (var connection = CreateConnection(true))
{ {
@ -2977,7 +2977,7 @@ namespace Emby.Server.Implementations.Data
var list = new List<Tuple<Guid, string>>(); var list = new List<Tuple<Guid, string>>();
using (WriteLock.Write()) using (WriteLock.Read())
{ {
using (var connection = CreateConnection(true)) using (var connection = CreateConnection(true))
{ {
@ -3091,7 +3091,7 @@ namespace Emby.Server.Implementations.Data
statementTexts.Add(commandText); statementTexts.Add(commandText);
} }
using (WriteLock.Write()) using (WriteLock.Read())
{ {
using (var connection = CreateConnection(true)) using (var connection = CreateConnection(true))
{ {
@ -4595,7 +4595,7 @@ namespace Emby.Server.Implementations.Data
var list = new List<string>(); var list = new List<string>();
using (WriteLock.Write()) using (WriteLock.Read())
{ {
using (var connection = CreateConnection(true)) using (var connection = CreateConnection(true))
{ {
@ -4636,7 +4636,7 @@ namespace Emby.Server.Implementations.Data
var list = new List<PersonInfo>(); var list = new List<PersonInfo>();
using (WriteLock.Write()) using (WriteLock.Read())
{ {
using (var connection = CreateConnection(true)) using (var connection = CreateConnection(true))
{ {
@ -4851,7 +4851,7 @@ namespace Emby.Server.Implementations.Data
commandText += " Group By CleanValue"; commandText += " Group By CleanValue";
using (WriteLock.Write()) using (WriteLock.Read())
{ {
using (var connection = CreateConnection(true)) using (var connection = CreateConnection(true))
{ {
@ -5030,7 +5030,7 @@ namespace Emby.Server.Implementations.Data
statementTexts.Add(countText); statementTexts.Add(countText);
} }
using (WriteLock.Write()) using (WriteLock.Read())
{ {
using (var connection = CreateConnection(true)) using (var connection = CreateConnection(true))
{ {
@ -5340,7 +5340,7 @@ namespace Emby.Server.Implementations.Data
cmdText += " order by StreamIndex ASC"; cmdText += " order by StreamIndex ASC";
using (WriteLock.Write()) using (WriteLock.Read())
{ {
using (var connection = CreateConnection(true)) using (var connection = CreateConnection(true))
{ {

4
Emby.Server.Implementations/Data/SqliteUserDataRepository.cs
View File

@ -296,7 +296,7 @@ namespace Emby.Server.Implementations.Data
throw new ArgumentNullException("key"); throw new ArgumentNullException("key");
} }
using (WriteLock.Write()) using (WriteLock.Read())
{ {
using (var connection = CreateConnection(true)) using (var connection = CreateConnection(true))
{ {
@ -349,7 +349,7 @@ namespace Emby.Server.Implementations.Data
var list = new List<UserItemData>(); var list = new List<UserItemData>();
using (WriteLock.Write()) using (WriteLock.Read())
{ {
using (var connection = CreateConnection()) using (var connection = CreateConnection())
{ {