self-hosted/jellyfin
self-hosted/jellyfin
1
0
Fork 0
mirror of https://github.com/jellyfin/jellyfin synced 2024-10-14 19:54:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix possible race condition

Browse source
This commit is contained in:
Bond_009 2020-02-28 20:34:10 +01:00
parent d1e1aef5f7
commit e699e5d405
2 changed files with 9 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
MediaBrowser.Providers/Manager/ProviderManager.cs
View file

@ -970,20 +970,18 @@ namespace MediaBrowser.Providers.Manager
var id = item.Id; var id = item.Id;
_logger.LogInformation("OnRefreshProgress {0} {1}", id.ToString("N", CultureInfo.InvariantCulture), progress); _logger.LogInformation("OnRefreshProgress {0} {1}", id.ToString("N", CultureInfo.InvariantCulture), progress);
if (_activeRefreshes.TryAdd(id, progress)) // TODO: Need to hunt down the conditions for this happening
{ _activeRefreshes.AddOrUpdate(
RefreshProgress?.Invoke(this, new GenericEventArgs<Tuple<BaseItem, double>>(new Tuple<BaseItem, double>(item, progress))); id,
} (_) => throw new Exception(
else
{
// TODO: Need to hunt down the conditions for this happening
throw new Exception(
string.Format( string.Format(
CultureInfo.InvariantCulture, CultureInfo.InvariantCulture,
"Refresh for item {0} {1} is not in progress", "Refresh for item {0} {1} is not in progress",
item.GetType().Name, item.GetType().Name,
item.Id.ToString("N", CultureInfo.InvariantCulture))); item.Id.ToString("N", CultureInfo.InvariantCulture))),
} (_, _) => progress);
RefreshProgress?.Invoke(this, new GenericEventArgs<Tuple<BaseItem, double>>(new Tuple<BaseItem, double>(item, progress)));
} }
private readonly SimplePriorityQueue<Tuple<Guid, MetadataRefreshOptions>> _refreshQueue = private readonly SimplePriorityQueue<Tuple<Guid, MetadataRefreshOptions>> _refreshQueue =

1
MediaBrowser.Providers/MediaBrowser.Providers.csproj
View file

@ -22,6 +22,7 @@
<TargetFramework>netstandard2.1</TargetFramework> <TargetFramework>netstandard2.1</TargetFramework>
<GenerateAssemblyInfo>false</GenerateAssemblyInfo> <GenerateAssemblyInfo>false</GenerateAssemblyInfo>
<GenerateDocumentationFile>true</GenerateDocumentationFile> <GenerateDocumentationFile>true</GenerateDocumentationFile>
<LangVersion>preview</LangVersion>
</PropertyGroup> </PropertyGroup>
<!-- Code Analyzers--> <!-- Code Analyzers-->