commit
a2c9994819
|
@ -332,7 +332,13 @@ namespace Emby.Server.Core.IO
|
|||
NotifyFilters.Attributes;
|
||||
|
||||
newWatcher.Created += watcher_Changed;
|
||||
|
||||
// Seeing mono crashes on background threads we can't catch, testing if this might help
|
||||
if (_environmentInfo.OperatingSystem == MediaBrowser.Model.System.OperatingSystem.Windows)
|
||||
{
|
||||
newWatcher.Deleted += watcher_Changed;
|
||||
}
|
||||
|
||||
newWatcher.Renamed += watcher_Changed;
|
||||
newWatcher.Changed += watcher_Changed;
|
||||
|
||||
|
|
|
@ -234,6 +234,8 @@ namespace Emby.Server.Implementations.LiveTv.TunerHosts
|
|||
numberString = null;
|
||||
}
|
||||
else
|
||||
{
|
||||
try
|
||||
{
|
||||
numberString = Path.GetFileNameWithoutExtension(mediaUrl.Split('/').Last());
|
||||
|
||||
|
@ -242,6 +244,12 @@ namespace Emby.Server.Implementations.LiveTv.TunerHosts
|
|||
numberString = null;
|
||||
}
|
||||
}
|
||||
catch
|
||||
{
|
||||
// Seeing occasional argument exception here
|
||||
numberString = null;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return numberString;
|
||||
|
|
|
@ -206,15 +206,16 @@ namespace MediaBrowser.Api
|
|||
var newLockData = request.LockData ?? false;
|
||||
var isLockedChanged = item.IsLocked != newLockData;
|
||||
|
||||
UpdateItem(request, item);
|
||||
|
||||
await item.UpdateToRepository(ItemUpdateType.MetadataEdit, CancellationToken.None).ConfigureAwait(false);
|
||||
|
||||
// Do this first so that metadata savers can pull the updates from the database.
|
||||
if (request.People != null)
|
||||
{
|
||||
await _libraryManager.UpdatePeople(item, request.People.Select(x => new PersonInfo { Name = x.Name, Role = x.Role, Type = x.Type }).ToList());
|
||||
}
|
||||
|
||||
UpdateItem(request, item);
|
||||
|
||||
await item.UpdateToRepository(ItemUpdateType.MetadataEdit, CancellationToken.None).ConfigureAwait(false);
|
||||
|
||||
if (isLockedChanged && item.IsFolder)
|
||||
{
|
||||
var folder = (Folder)item;
|
||||
|
|
|
@ -633,14 +633,17 @@ namespace MediaBrowser.Controller.Entities
|
|||
if (info.Path.StartsWith("Http", StringComparison.OrdinalIgnoreCase))
|
||||
{
|
||||
info.Protocol = MediaProtocol.Http;
|
||||
info.SupportsDirectStream = false;
|
||||
}
|
||||
else if (info.Path.StartsWith("Rtmp", StringComparison.OrdinalIgnoreCase))
|
||||
{
|
||||
info.Protocol = MediaProtocol.Rtmp;
|
||||
info.SupportsDirectStream = false;
|
||||
}
|
||||
else if (info.Path.StartsWith("Rtsp", StringComparison.OrdinalIgnoreCase))
|
||||
{
|
||||
info.Protocol = MediaProtocol.Rtsp;
|
||||
info.SupportsDirectStream = false;
|
||||
}
|
||||
else
|
||||
{
|
||||
|
|
|
@ -1180,11 +1180,11 @@ namespace MediaBrowser.Model.Dlna
|
|||
bool isInterlaced;
|
||||
if (bool.TryParse(value, out isInterlaced))
|
||||
{
|
||||
if (isInterlaced && condition.Condition == ProfileConditionType.Equals)
|
||||
if (!isInterlaced && condition.Condition == ProfileConditionType.Equals)
|
||||
{
|
||||
item.DeInterlace = true;
|
||||
}
|
||||
else if (!isInterlaced && condition.Condition == ProfileConditionType.NotEquals)
|
||||
else if (isInterlaced && condition.Condition == ProfileConditionType.NotEquals)
|
||||
{
|
||||
item.DeInterlace = true;
|
||||
}
|
||||
|
|
|
@ -13,17 +13,13 @@ using MediaBrowser.Model.Entities;
|
|||
using MediaBrowser.Model.Logging;
|
||||
using MediaBrowser.Model.Providers;
|
||||
using System;
|
||||
using System.Collections.Concurrent;
|
||||
using System.Collections.Generic;
|
||||
using System.IO;
|
||||
using System.Linq;
|
||||
using System.Threading;
|
||||
using System.Threading.Tasks;
|
||||
using MediaBrowser.Model.IO;
|
||||
|
||||
using MediaBrowser.Controller.Dto;
|
||||
using MediaBrowser.Controller.IO;
|
||||
using MediaBrowser.Model.IO;
|
||||
using MediaBrowser.Model.Serialization;
|
||||
using Priority_Queue;
|
||||
|
||||
|
@ -69,6 +65,7 @@ namespace MediaBrowser.Providers.Manager
|
|||
|
||||
private readonly Func<ILibraryManager> _libraryManagerFactory;
|
||||
private readonly IMemoryStreamFactory _memoryStreamProvider;
|
||||
private CancellationTokenSource _disposeCancellationTokenSource = new CancellationTokenSource();
|
||||
|
||||
/// <summary>
|
||||
/// Initializes a new instance of the <see cref="ProviderManager" /> class.
|
||||
|
@ -882,6 +879,13 @@ namespace MediaBrowser.Providers.Manager
|
|||
Tuple<Guid, MetadataRefreshOptions> refreshItem;
|
||||
var libraryManager = _libraryManagerFactory();
|
||||
|
||||
if (_disposed)
|
||||
{
|
||||
return;
|
||||
}
|
||||
|
||||
var cancellationToken = _disposeCancellationTokenSource.Token;
|
||||
|
||||
while (_refreshQueue.TryDequeue(out refreshItem))
|
||||
{
|
||||
if (_disposed)
|
||||
|
@ -902,18 +906,22 @@ namespace MediaBrowser.Providers.Manager
|
|||
var folder = item as Folder;
|
||||
if (folder != null)
|
||||
{
|
||||
await folder.ValidateChildren(new Progress<double>(), CancellationToken.None).ConfigureAwait(false);
|
||||
await folder.ValidateChildren(new Progress<double>(), cancellationToken).ConfigureAwait(false);
|
||||
}
|
||||
}
|
||||
|
||||
var artist = item as MusicArtist;
|
||||
var task = artist == null
|
||||
? RefreshItem(item, refreshItem.Item2, CancellationToken.None)
|
||||
: RefreshArtist(artist, refreshItem.Item2);
|
||||
? RefreshItem(item, refreshItem.Item2, cancellationToken)
|
||||
: RefreshArtist(artist, refreshItem.Item2, cancellationToken);
|
||||
|
||||
await task.ConfigureAwait(false);
|
||||
}
|
||||
}
|
||||
catch (OperationCanceledException)
|
||||
{
|
||||
break;
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
_logger.ErrorException("Error refreshing item", ex);
|
||||
|
@ -928,14 +936,14 @@ namespace MediaBrowser.Providers.Manager
|
|||
|
||||
private async Task RefreshItem(BaseItem item, MetadataRefreshOptions options, CancellationToken cancellationToken)
|
||||
{
|
||||
await item.RefreshMetadata(options, CancellationToken.None).ConfigureAwait(false);
|
||||
await item.RefreshMetadata(options, cancellationToken).ConfigureAwait(false);
|
||||
|
||||
// Collection folders don't validate their children so we'll have to simulate that here
|
||||
var collectionFolder = item as CollectionFolder;
|
||||
|
||||
if (collectionFolder != null)
|
||||
{
|
||||
await RefreshCollectionFolderChildren(options, collectionFolder).ConfigureAwait(false);
|
||||
await RefreshCollectionFolderChildren(options, collectionFolder, cancellationToken).ConfigureAwait(false);
|
||||
}
|
||||
else
|
||||
{
|
||||
|
@ -948,25 +956,23 @@ namespace MediaBrowser.Providers.Manager
|
|||
}
|
||||
}
|
||||
|
||||
private async Task RefreshCollectionFolderChildren(MetadataRefreshOptions options, CollectionFolder collectionFolder)
|
||||
private async Task RefreshCollectionFolderChildren(MetadataRefreshOptions options, CollectionFolder collectionFolder, CancellationToken cancellationToken)
|
||||
{
|
||||
foreach (var child in collectionFolder.Children.ToList())
|
||||
{
|
||||
await child.RefreshMetadata(options, CancellationToken.None).ConfigureAwait(false);
|
||||
await child.RefreshMetadata(options, cancellationToken).ConfigureAwait(false);
|
||||
|
||||
if (child.IsFolder)
|
||||
{
|
||||
var folder = (Folder)child;
|
||||
|
||||
await folder.ValidateChildren(new Progress<double>(), CancellationToken.None, options, true).ConfigureAwait(false);
|
||||
await folder.ValidateChildren(new Progress<double>(), cancellationToken, options, true).ConfigureAwait(false);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private async Task RefreshArtist(MusicArtist item, MetadataRefreshOptions options)
|
||||
private async Task RefreshArtist(MusicArtist item, MetadataRefreshOptions options, CancellationToken cancellationToken)
|
||||
{
|
||||
var cancellationToken = CancellationToken.None;
|
||||
|
||||
var albums = _libraryManagerFactory()
|
||||
.GetItemList(new InternalItemsQuery
|
||||
{
|
||||
|
@ -991,7 +997,7 @@ namespace MediaBrowser.Providers.Manager
|
|||
|
||||
try
|
||||
{
|
||||
await item.RefreshMetadata(options, CancellationToken.None).ConfigureAwait(false);
|
||||
await item.RefreshMetadata(options, cancellationToken).ConfigureAwait(false);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
|
@ -1009,6 +1015,11 @@ namespace MediaBrowser.Providers.Manager
|
|||
public void Dispose()
|
||||
{
|
||||
_disposed = true;
|
||||
|
||||
if (!_disposeCancellationTokenSource.IsCancellationRequested)
|
||||
{
|
||||
_disposeCancellationTokenSource.Cancel();
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
|
@ -8,6 +8,7 @@ using MediaBrowser.Common.Net;
|
|||
using MediaBrowser.Controller.Drawing;
|
||||
using MediaBrowser.Model.IO;
|
||||
using MediaBrowser.Model.Logging;
|
||||
using Emby.Drawing.Skia;
|
||||
|
||||
namespace MediaBrowser.Server.Startup.Common
|
||||
{
|
||||
|
@ -22,6 +23,15 @@ namespace MediaBrowser.Server.Startup.Common
|
|||
{
|
||||
if (!startupOptions.ContainsOption("-enablegdi"))
|
||||
{
|
||||
//try
|
||||
//{
|
||||
// return new SkiaEncoder(logManager.GetLogger("Skia"), appPaths, httpClient, fileSystem);
|
||||
//}
|
||||
//catch
|
||||
//{
|
||||
// logger.Error("Error loading Skia. Will revert to ImageMagick.");
|
||||
//}
|
||||
|
||||
try
|
||||
{
|
||||
return new ImageMagickEncoder(logManager.GetLogger("ImageMagick"), appPaths, httpClient, fileSystem);
|
||||
|
|
|
@ -114,6 +114,10 @@
|
|||
<Project>{6cfee013-6e7c-432b-ac37-cabf0880c69a}</Project>
|
||||
<Name>Emby.Drawing.ImageMagick</Name>
|
||||
</ProjectReference>
|
||||
<ProjectReference Include="..\Emby.Drawing.Skia\Emby.Drawing.Skia.csproj">
|
||||
<Project>{2312da6d-ff86-4597-9777-bceec32d96dd}</Project>
|
||||
<Name>Emby.Drawing.Skia</Name>
|
||||
</ProjectReference>
|
||||
<ProjectReference Include="..\Emby.Drawing\Emby.Drawing.csproj">
|
||||
<Project>{08fff49b-f175-4807-a2b5-73b0ebd9f716}</Project>
|
||||
<Name>Emby.Drawing</Name>
|
||||
|
|
|
@ -1,3 +1,3 @@
|
|||
using System.Reflection;
|
||||
|
||||
[assembly: AssemblyVersion("3.2.19.3")]
|
||||
[assembly: AssemblyVersion("3.2.19.4")]
|
||||
|
|
Loading…
Reference in New Issue
Block a user