diff options
Diffstat (limited to 'Emby.Server.Implementations/Data/SqliteItemRepository.cs')
| -rw-r--r-- | Emby.Server.Implementations/Data/SqliteItemRepository.cs | 40 |
1 files changed, 20 insertions, 20 deletions
diff --git a/Emby.Server.Implementations/Data/SqliteItemRepository.cs b/Emby.Server.Implementations/Data/SqliteItemRepository.cs index 1d9cec87e..58fcf62d9 100644 --- a/Emby.Server.Implementations/Data/SqliteItemRepository.cs +++ b/Emby.Server.Implementations/Data/SqliteItemRepository.cs @@ -388,7 +388,7 @@ namespace Emby.Server.Implementations.Data { try { - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection()) { @@ -688,7 +688,7 @@ namespace Emby.Server.Implementations.Data tuples.Add(new Tuple<BaseItem, List<Guid>, BaseItem, string>(item, ancestorIds, topParent, userdataKey)); } - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection()) { @@ -1257,7 +1257,7 @@ namespace Emby.Server.Implementations.Data CheckDisposed(); //Logger.Info("Retrieving item {0}", id.ToString("N")); - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection(true)) { @@ -2083,7 +2083,7 @@ namespace Emby.Server.Implementations.Data var list = new List<ChapterInfo>(); - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection(true)) { @@ -2117,7 +2117,7 @@ namespace Emby.Server.Implementations.Data throw new ArgumentNullException("id"); } - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection(true)) { @@ -2198,7 +2198,7 @@ namespace Emby.Server.Implementations.Data var index = 0; - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection()) { @@ -2492,7 +2492,7 @@ namespace Emby.Server.Implementations.Data } } - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection(true)) { @@ -2687,7 +2687,7 @@ namespace Emby.Server.Implementations.Data statementTexts.Add(commandText); } - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection(true)) { @@ -2906,7 +2906,7 @@ namespace Emby.Server.Implementations.Data var list = new List<Guid>(); - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection(true)) { @@ -2977,7 +2977,7 @@ namespace Emby.Server.Implementations.Data var list = new List<Tuple<Guid, string>>(); - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection(true)) { @@ -3091,7 +3091,7 @@ namespace Emby.Server.Implementations.Data statementTexts.Add(commandText); } - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection(true)) { @@ -4461,7 +4461,7 @@ namespace Emby.Server.Implementations.Data var commandText = "select Guid,InheritedTags,(select group_concat(Tags, '|') from TypedBaseItems where (guid=outer.guid) OR (guid in (Select AncestorId from AncestorIds where ItemId=Outer.guid))) as NewInheritedTags from typedbaseitems as Outer where NewInheritedTags <> InheritedTags"; - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection()) { @@ -4535,7 +4535,7 @@ namespace Emby.Server.Implementations.Data CheckDisposed(); - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection()) { @@ -4595,7 +4595,7 @@ namespace Emby.Server.Implementations.Data var list = new List<string>(); - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection(true)) { @@ -4636,7 +4636,7 @@ namespace Emby.Server.Implementations.Data var list = new List<PersonInfo>(); - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection(true)) { @@ -4851,7 +4851,7 @@ namespace Emby.Server.Implementations.Data commandText += " Group By CleanValue"; - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection(true)) { @@ -5030,7 +5030,7 @@ namespace Emby.Server.Implementations.Data statementTexts.Add(countText); } - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection(true)) { @@ -5253,7 +5253,7 @@ namespace Emby.Server.Implementations.Data CheckDisposed(); - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection()) { @@ -5340,7 +5340,7 @@ namespace Emby.Server.Implementations.Data cmdText += " order by StreamIndex ASC"; - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection(true)) { @@ -5385,7 +5385,7 @@ namespace Emby.Server.Implementations.Data cancellationToken.ThrowIfCancellationRequested(); - lock (WriteLock) + using (WriteLock.Write()) { using (var connection = CreateConnection()) { |
