From 30d6e2cd6ce0702faaec73b7ffb59d9844fb6967 Mon Sep 17 00:00:00 2001
From: Luke Pulverenti <luke.pulverenti@gmail.com>
Date: Mon, 15 Apr 2013 11:10:12 -0400
Subject: made library scan a bit more conservative

---
 MediaBrowser.Controller/Entities/Folder.cs         |  89 ++++++----
 .../MediaBrowser.Controller.csproj                 |   3 +-
 MediaBrowser.Controller/MediaInfo/FFMpegManager.cs |   7 -
 .../Providers/MediaInfo/AudioImageProvider.cs      | 101 +++++++++++
 .../MediaInfo/FFMpegAudioImageProvider.cs          | 143 ----------------
 .../MediaInfo/FFMpegVideoImageProvider.cs          | 188 ---------------------
 6 files changed, 156 insertions(+), 375 deletions(-)
 create mode 100644 MediaBrowser.Controller/Providers/MediaInfo/AudioImageProvider.cs
 delete mode 100644 MediaBrowser.Controller/Providers/MediaInfo/FFMpegAudioImageProvider.cs
 delete mode 100644 MediaBrowser.Controller/Providers/MediaInfo/FFMpegVideoImageProvider.cs

(limited to 'MediaBrowser.Controller')

diff --git a/MediaBrowser.Controller/Entities/Folder.cs b/MediaBrowser.Controller/Entities/Folder.cs
index 5816b23f8..b7508a641 100644
--- a/MediaBrowser.Controller/Entities/Folder.cs
+++ b/MediaBrowser.Controller/Entities/Folder.cs
@@ -542,6 +542,7 @@ namespace MediaBrowser.Controller.Entities
 
             var options = new ParallelOptions
             {
+                MaxDegreeOfParallelism = 50
             };
 
             Parallel.ForEach(nonCachedChildren, options, child =>
@@ -606,6 +607,12 @@ namespace MediaBrowser.Controller.Entities
                         _children.Add(item);
                     }
 
+                    if (saveTasks.Count > 50)
+                    {
+                        await Task.WhenAll(saveTasks).ConfigureAwait(false);
+                        saveTasks.Clear();
+                    }
+
                     saveTasks.Add(LibraryManager.SaveItem(item, CancellationToken.None));
                 }
 
@@ -642,65 +649,77 @@ namespace MediaBrowser.Controller.Entities
         /// <param name="cancellationToken">The cancellation token.</param>
         /// <param name="recursive">if set to <c>true</c> [recursive].</param>
         /// <returns>Task.</returns>
-        private Task RefreshChildren(IEnumerable<Tuple<BaseItem, bool>> children, IProgress<double> progress, CancellationToken cancellationToken, bool? recursive)
+        private async Task RefreshChildren(IEnumerable<Tuple<BaseItem, bool>> children, IProgress<double> progress, CancellationToken cancellationToken, bool? recursive)
         {
             var list = children.ToList();
 
             var percentages = new ConcurrentDictionary<Guid, double>(list.Select(i => new KeyValuePair<Guid, double>(i.Item1.Id, 0)));
 
-            var tasks = list.Select(tuple => Task.Run(async () =>
+            var tasks = new List<Task>();
+
+            foreach (var tuple in list)
             {
-                cancellationToken.ThrowIfCancellationRequested();
+                if (tasks.Count > 50)
+                {
+                    await Task.WhenAll(tasks).ConfigureAwait(false);
+                }
 
-                var child = tuple.Item1;
+                Tuple<BaseItem, bool> currentTuple = tuple;
 
-                //refresh it
-                await child.RefreshMetadata(cancellationToken, resetResolveArgs: child.IsFolder).ConfigureAwait(false);
+                tasks.Add(Task.Run(async () =>
+                {
+                    cancellationToken.ThrowIfCancellationRequested();
 
-                // Refresh children if a folder and the item changed or recursive is set to true
-                var refreshChildren = child.IsFolder && (tuple.Item2 || (recursive.HasValue && recursive.Value));
+                    var child = currentTuple.Item1;
 
-                if (refreshChildren)
-                {
-                    // Don't refresh children if explicitly set to false
-                    if (recursive.HasValue && recursive.Value == false)
+                    //refresh it
+                    await child.RefreshMetadata(cancellationToken, resetResolveArgs: child.IsFolder).ConfigureAwait(false);
+
+                    // Refresh children if a folder and the item changed or recursive is set to true
+                    var refreshChildren = child.IsFolder && (currentTuple.Item2 || (recursive.HasValue && recursive.Value));
+
+                    if (refreshChildren)
                     {
-                        refreshChildren = false;
+                        // Don't refresh children if explicitly set to false
+                        if (recursive.HasValue && recursive.Value == false)
+                        {
+                            refreshChildren = false;
+                        }
                     }
-                }
 
-                if (refreshChildren)
-                {
-                    cancellationToken.ThrowIfCancellationRequested();
+                    if (refreshChildren)
+                    {
+                        cancellationToken.ThrowIfCancellationRequested();
 
-                    var innerProgress = new ActionableProgress<double>();
+                        var innerProgress = new ActionableProgress<double>();
 
-                    innerProgress.RegisterAction(p =>
+                        innerProgress.RegisterAction(p =>
+                        {
+                            percentages.TryUpdate(child.Id, p / 100, percentages[child.Id]);
+
+                            var percent = percentages.Values.Sum();
+                            percent /= list.Count;
+
+                            progress.Report((90 * percent) + 10);
+                        });
+
+                        await ((Folder)child).ValidateChildren(innerProgress, cancellationToken, recursive).ConfigureAwait(false);
+                    }
+                    else
                     {
-                        percentages.TryUpdate(child.Id, p / 100, percentages[child.Id]);
+                        percentages.TryUpdate(child.Id, 1, percentages[child.Id]);
 
                         var percent = percentages.Values.Sum();
                         percent /= list.Count;
 
                         progress.Report((90 * percent) + 10);
-                    });
-
-                    await ((Folder) child).ValidateChildren(innerProgress, cancellationToken, recursive).ConfigureAwait(false);
-                }
-                else
-                {
-                    percentages.TryUpdate(child.Id, 1, percentages[child.Id]);
-
-                    var percent = percentages.Values.Sum();
-                    percent /= list.Count;
-
-                    progress.Report((90 * percent) + 10);
-                }
-            }));
+                    }
+                }));
+            }
 
             cancellationToken.ThrowIfCancellationRequested();
 
-            return Task.WhenAll(tasks);
+            await Task.WhenAll(tasks).ConfigureAwait(false);
         }
 
         /// <summary>
diff --git a/MediaBrowser.Controller/MediaBrowser.Controller.csproj b/MediaBrowser.Controller/MediaBrowser.Controller.csproj
index 90d3810d0..9dd558308 100644
--- a/MediaBrowser.Controller/MediaBrowser.Controller.csproj
+++ b/MediaBrowser.Controller/MediaBrowser.Controller.csproj
@@ -148,7 +148,7 @@
     <Compile Include="Providers\IImageEnhancer.cs" />
     <Compile Include="Providers\ImagesByNameProvider.cs" />
     <Compile Include="Providers\MediaInfo\BaseFFMpegProvider.cs" />
-    <Compile Include="Providers\MediaInfo\FFMpegAudioImageProvider.cs" />
+    <Compile Include="Providers\MediaInfo\AudioImageProvider.cs" />
     <Compile Include="Providers\MediaInfo\BaseFFProbeProvider.cs" />
     <Compile Include="Providers\BaseProviderInfo.cs" />
     <Compile Include="Providers\Movies\FanArtMovieProvider.cs" />
@@ -170,7 +170,6 @@
     <Compile Include="Providers\TV\RemoteSeriesProvider.cs" />
     <Compile Include="Providers\TV\SeriesProviderFromXml.cs" />
     <Compile Include="Providers\TV\SeriesXmlParser.cs" />
-    <Compile Include="Providers\MediaInfo\FFMpegVideoImageProvider.cs" />
     <Compile Include="Resolvers\IResolverIgnoreRule.cs" />
     <Compile Include="Resolvers\EntityResolutionHelper.cs" />
     <Compile Include="Resolvers\ResolverPriority.cs" />
diff --git a/MediaBrowser.Controller/MediaInfo/FFMpegManager.cs b/MediaBrowser.Controller/MediaInfo/FFMpegManager.cs
index 4700f41f5..509d1e187 100644
--- a/MediaBrowser.Controller/MediaInfo/FFMpegManager.cs
+++ b/MediaBrowser.Controller/MediaInfo/FFMpegManager.cs
@@ -23,12 +23,6 @@ namespace MediaBrowser.Controller.MediaInfo
         /// <value>The video image cache.</value>
         internal FileSystemRepository VideoImageCache { get; set; }
 
-        /// <summary>
-        /// Gets or sets the image cache.
-        /// </summary>
-        /// <value>The image cache.</value>
-        internal FileSystemRepository AudioImageCache { get; set; }
-
         /// <summary>
         /// Gets or sets the subtitle cache.
         /// </summary>
@@ -54,7 +48,6 @@ namespace MediaBrowser.Controller.MediaInfo
             _libraryManager = libraryManager;
 
             VideoImageCache = new FileSystemRepository(VideoImagesDataPath);
-            AudioImageCache = new FileSystemRepository(AudioImagesDataPath);
             SubtitleCache = new FileSystemRepository(SubtitleCachePath);
         }
 
diff --git a/MediaBrowser.Controller/Providers/MediaInfo/AudioImageProvider.cs b/MediaBrowser.Controller/Providers/MediaInfo/AudioImageProvider.cs
new file mode 100644
index 000000000..05e4ba1e3
--- /dev/null
+++ b/MediaBrowser.Controller/Providers/MediaInfo/AudioImageProvider.cs
@@ -0,0 +1,101 @@
+using MediaBrowser.Controller.Configuration;
+using MediaBrowser.Controller.Entities;
+using MediaBrowser.Controller.Entities.Audio;
+using MediaBrowser.Model.Entities;
+using MediaBrowser.Model.Logging;
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace MediaBrowser.Controller.Providers.MediaInfo
+{
+    /// <summary>
+    /// Uses ffmpeg to create video images
+    /// </summary>
+    public class AudioImageProvider : BaseMetadataProvider
+    {
+        /// <summary>
+        /// Initializes a new instance of the <see cref="BaseMetadataProvider" /> class.
+        /// </summary>
+        /// <param name="logManager">The log manager.</param>
+        /// <param name="configurationManager">The configuration manager.</param>
+        public AudioImageProvider(ILogManager logManager, IServerConfigurationManager configurationManager)
+            : base(logManager, configurationManager)
+        {
+        }
+
+        /// <summary>
+        /// The true task result
+        /// </summary>
+        protected static readonly Task<bool> TrueTaskResult = Task.FromResult(true);
+
+        /// <summary>
+        /// Supportses the specified item.
+        /// </summary>
+        /// <param name="item">The item.</param>
+        /// <returns><c>true</c> if XXXX, <c>false</c> otherwise</returns>
+        public override bool Supports(BaseItem item)
+        {
+            return item.LocationType == LocationType.FileSystem && item is Audio;
+        }
+
+        /// <summary>
+        /// Override this to return the date that should be compared to the last refresh date
+        /// to determine if this provider should be re-fetched.
+        /// </summary>
+        /// <param name="item">The item.</param>
+        /// <returns>DateTime.</returns>
+        protected override DateTime CompareDate(BaseItem item)
+        {
+            return item.DateModified;
+        }
+
+        /// <summary>
+        /// Gets the priority.
+        /// </summary>
+        /// <value>The priority.</value>
+        public override MetadataProviderPriority Priority
+        {
+            get { return MetadataProviderPriority.Last; }
+        }
+
+        /// <summary>
+        /// Needses the refresh internal.
+        /// </summary>
+        /// <param name="item">The item.</param>
+        /// <param name="providerInfo">The provider info.</param>
+        /// <returns><c>true</c> if XXXX, <c>false</c> otherwise</returns>
+        protected override bool NeedsRefreshInternal(BaseItem item, BaseProviderInfo providerInfo)
+        {
+            if (!string.IsNullOrEmpty(item.PrimaryImagePath))
+            {
+                return false;
+            }
+            return base.NeedsRefreshInternal(item, providerInfo);
+        }
+
+        /// <summary>
+        /// Fetches metadata and returns true or false indicating if any work that requires persistence was done
+        /// </summary>
+        /// <param name="item">The item.</param>
+        /// <param name="force">if set to <c>true</c> [force].</param>
+        /// <param name="cancellationToken">The cancellation token.</param>
+        /// <returns>Task{System.Boolean}.</returns>
+        public override Task<bool> FetchAsync(BaseItem item, bool force, CancellationToken cancellationToken)
+        {
+            if (force || string.IsNullOrEmpty(item.PrimaryImagePath))
+            {
+                var album = item.ResolveArgs.Parent as MusicAlbum;
+
+                if (album != null)
+                {
+                    // First try to use the parent's image
+                    item.PrimaryImagePath = item.ResolveArgs.Parent.PrimaryImagePath;
+                }
+            }
+
+            SetLastRefreshed(item, DateTime.UtcNow);
+            return TrueTaskResult;
+        }
+    }
+}
diff --git a/MediaBrowser.Controller/Providers/MediaInfo/FFMpegAudioImageProvider.cs b/MediaBrowser.Controller/Providers/MediaInfo/FFMpegAudioImageProvider.cs
deleted file mode 100644
index e1cbc6932..000000000
--- a/MediaBrowser.Controller/Providers/MediaInfo/FFMpegAudioImageProvider.cs
+++ /dev/null
@@ -1,143 +0,0 @@
-using MediaBrowser.Common.MediaInfo;
-using MediaBrowser.Controller.Configuration;
-using MediaBrowser.Controller.Entities;
-using MediaBrowser.Controller.Entities.Audio;
-using MediaBrowser.Model.Entities;
-using MediaBrowser.Model.Logging;
-using System;
-using System.Collections.Concurrent;
-using System.Linq;
-using System.Threading;
-using System.Threading.Tasks;
-
-namespace MediaBrowser.Controller.Providers.MediaInfo
-{
-    /// <summary>
-    /// Uses ffmpeg to create video images
-    /// </summary>
-    public class FFMpegAudioImageProvider : BaseFFMpegProvider<Audio>
-    {
-        public FFMpegAudioImageProvider(ILogManager logManager, IServerConfigurationManager configurationManager, IMediaEncoder mediaEncoder)
-            : base(logManager, configurationManager, mediaEncoder)
-        {
-        }
-
-        /// <summary>
-        /// The true task result
-        /// </summary>
-        protected static readonly Task<bool> TrueTaskResult = Task.FromResult(true);
-
-        /// <summary>
-        /// Gets the priority.
-        /// </summary>
-        /// <value>The priority.</value>
-        public override MetadataProviderPriority Priority
-        {
-            get { return MetadataProviderPriority.Last; }
-        }
-
-        /// <summary>
-        /// The _locks
-        /// </summary>
-        private readonly ConcurrentDictionary<string, SemaphoreSlim> _locks = new ConcurrentDictionary<string, SemaphoreSlim>();
-
-        /// <summary>
-        /// Gets the lock.
-        /// </summary>
-        /// <param name="filename">The filename.</param>
-        /// <returns>System.Object.</returns>
-        private SemaphoreSlim GetLock(string filename)
-        {
-            return _locks.GetOrAdd(filename, key => new SemaphoreSlim(1, 1));
-        }
-
-        /// <summary>
-        /// Needses the refresh internal.
-        /// </summary>
-        /// <param name="item">The item.</param>
-        /// <param name="providerInfo">The provider info.</param>
-        /// <returns><c>true</c> if XXXX, <c>false</c> otherwise</returns>
-        protected override bool NeedsRefreshInternal(BaseItem item, BaseProviderInfo providerInfo)
-        {
-            if (!string.IsNullOrEmpty(item.PrimaryImagePath))
-            {
-                return false;
-            }
-            return base.NeedsRefreshInternal(item, providerInfo);
-        }
-
-        /// <summary>
-        /// Fetches metadata and returns true or false indicating if any work that requires persistence was done
-        /// </summary>
-        /// <param name="item">The item.</param>
-        /// <param name="force">if set to <c>true</c> [force].</param>
-        /// <param name="cancellationToken">The cancellation token.</param>
-        /// <returns>Task{System.Boolean}.</returns>
-        public override async Task<bool> FetchAsync(BaseItem item, bool force, CancellationToken cancellationToken)
-        {
-            var success = ProviderRefreshStatus.Success;
-
-            if (force || string.IsNullOrEmpty(item.PrimaryImagePath))
-            {
-                var album = item.ResolveArgs.Parent as MusicAlbum;
-
-                if (album != null)
-                {
-                    // First try to use the parent's image
-                    item.PrimaryImagePath = item.ResolveArgs.Parent.PrimaryImagePath;
-                }
-
-                // If it's still empty see if there's an embedded image
-                if (force || string.IsNullOrEmpty(item.PrimaryImagePath))
-                {
-                    var audio = (Audio)item;
-
-                    if (audio.MediaStreams != null && audio.MediaStreams.Any(s => s.Type == MediaStreamType.Video))
-                    {
-                        var filename = album != null && string.IsNullOrEmpty(audio.Album + album.DateModified.Ticks) ? (audio.Id.ToString() + audio.DateModified.Ticks) : audio.Album;
-
-                        var path = Kernel.Instance.FFMpegManager.AudioImageCache.GetResourcePath(filename + "_primary", ".jpg");
-
-                        if (!Kernel.Instance.FFMpegManager.AudioImageCache.ContainsFilePath(path))
-                        {
-                            var semaphore = GetLock(path);
-
-                            // Acquire a lock
-                            await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
-
-                            // Check again
-                            if (!Kernel.Instance.FFMpegManager.AudioImageCache.ContainsFilePath(path))
-                            {
-                                try
-                                {
-                                    await MediaEncoder.ExtractImage(new[] { audio.Path }, InputType.AudioFile, null, path, cancellationToken).ConfigureAwait(false);
-                                }
-                                catch
-                                {
-                                    success = ProviderRefreshStatus.Failure;
-                                }
-                                finally
-                                {
-                                    semaphore.Release();
-                                }
-                            }
-                            else
-                            {
-                                semaphore.Release();
-                            }
-                        }
-
-                        if (success == ProviderRefreshStatus.Success)
-                        {
-                            // Image is already in the cache
-                            audio.PrimaryImagePath = path;
-                        }
-                    }
-                }
-            }
-
-            SetLastRefreshed(item, DateTime.UtcNow, success);
-            return true;
-        }
-    }
-}
diff --git a/MediaBrowser.Controller/Providers/MediaInfo/FFMpegVideoImageProvider.cs b/MediaBrowser.Controller/Providers/MediaInfo/FFMpegVideoImageProvider.cs
deleted file mode 100644
index dff4a4ea1..000000000
--- a/MediaBrowser.Controller/Providers/MediaInfo/FFMpegVideoImageProvider.cs
+++ /dev/null
@@ -1,188 +0,0 @@
-using MediaBrowser.Common.IO;
-using MediaBrowser.Common.MediaInfo;
-using MediaBrowser.Controller.Configuration;
-using MediaBrowser.Controller.Entities;
-using MediaBrowser.Model.Entities;
-using MediaBrowser.Model.Logging;
-using System;
-using System.Linq;
-using System.Threading;
-using System.Threading.Tasks;
-
-namespace MediaBrowser.Controller.Providers.MediaInfo
-{
-    /// <summary>
-    /// Uses ffmpeg to create video images
-    /// </summary>
-    public class FfMpegVideoImageProvider : BaseFFMpegProvider<Video>
-    {
-        /// <summary>
-        /// The _iso manager
-        /// </summary>
-        private readonly IIsoManager _isoManager;
-
-        /// <summary>
-        /// Initializes a new instance of the <see cref="FfMpegVideoImageProvider" /> class.
-        /// </summary>
-        /// <param name="isoManager">The iso manager.</param>
-        /// <param name="logManager">The log manager.</param>
-        /// <param name="configurationManager">The configuration manager.</param>
-        /// <param name="mediaEncoder">The media encoder.</param>
-        public FfMpegVideoImageProvider(IIsoManager isoManager, ILogManager logManager, IServerConfigurationManager configurationManager, IMediaEncoder mediaEncoder)
-            : base(logManager, configurationManager, mediaEncoder)
-        {
-            _isoManager = isoManager;
-        }
-
-        /// <summary>
-        /// Gets the priority.
-        /// </summary>
-        /// <value>The priority.</value>
-        public override MetadataProviderPriority Priority
-        {
-            get { return MetadataProviderPriority.Last; }
-        }
-
-        /// <summary>
-        /// Supportses the specified item.
-        /// </summary>
-        /// <param name="item">The item.</param>
-        /// <returns><c>true</c> if XXXX, <c>false</c> otherwise</returns>
-        public override bool Supports(BaseItem item)
-        {
-            if (item.LocationType != LocationType.FileSystem)
-            {
-                return false;
-            }
-
-            var video = item as Video;
-
-            if (video != null)
-            {
-                if (video.VideoType == VideoType.Iso && _isoManager.CanMount(item.Path))
-                {
-                    return true;
-                }
-
-                // We can only extract images from folder rips if we know the largest stream path
-                return video.VideoType == VideoType.VideoFile || video.VideoType == VideoType.BluRay || video.VideoType == VideoType.Dvd;
-            }
-
-            return false;
-        }
-
-        /// <summary>
-        /// Needses the refresh internal.
-        /// </summary>
-        /// <param name="item">The item.</param>
-        /// <param name="providerInfo">The provider info.</param>
-        /// <returns><c>true</c> if XXXX, <c>false</c> otherwise</returns>
-        protected override bool NeedsRefreshInternal(BaseItem item, BaseProviderInfo providerInfo)
-        {
-            if (!string.IsNullOrEmpty(item.PrimaryImagePath))
-            {
-                return false;
-            }
-            return base.NeedsRefreshInternal(item, providerInfo);
-        }
-
-        /// <summary>
-        /// The true task result
-        /// </summary>
-        protected static readonly Task<bool> TrueTaskResult = Task.FromResult(true);
-
-        /// <summary>
-        /// Fetches metadata and returns true or false indicating if any work that requires persistence was done
-        /// </summary>
-        /// <param name="item">The item.</param>
-        /// <param name="force">if set to <c>true</c> [force].</param>
-        /// <param name="cancellationToken">The cancellation token.</param>
-        /// <returns>Task{System.Boolean}.</returns>
-        public override Task<bool> FetchAsync(BaseItem item, bool force, CancellationToken cancellationToken)
-        {
-            if (force || string.IsNullOrEmpty(item.PrimaryImagePath))
-            {
-                var video = (Video)item;
-
-                // We can only extract images from videos if we know there's an embedded video stream
-                if (video.MediaStreams != null && video.MediaStreams.Any(m => m.Type == MediaStreamType.Video))
-                {
-                    var filename = item.Id + "_" + item.DateModified.Ticks + "_primary";
-
-                    var path = Kernel.Instance.FFMpegManager.VideoImageCache.GetResourcePath(filename, ".jpg");
-
-                    if (!Kernel.Instance.FFMpegManager.VideoImageCache.ContainsFilePath(path))
-                    {
-                        return ExtractImage(video, path, cancellationToken);
-                    }
-
-                    // Image is already in the cache
-                    item.PrimaryImagePath = path;
-                }
-            }
-
-            SetLastRefreshed(item, DateTime.UtcNow);
-            return TrueTaskResult;
-        }
-
-        /// <summary>
-        /// Mounts the iso if needed.
-        /// </summary>
-        /// <param name="item">The item.</param>
-        /// <param name="cancellationToken">The cancellation token.</param>
-        /// <returns>IsoMount.</returns>
-        protected Task<IIsoMount> MountIsoIfNeeded(Video item, CancellationToken cancellationToken)
-        {
-            if (item.VideoType == VideoType.Iso)
-            {
-                return _isoManager.Mount(item.Path, cancellationToken);
-            }
-
-            return NullMountTaskResult;
-        }
-
-        /// <summary>
-        /// Extracts the image.
-        /// </summary>
-        /// <param name="video">The video.</param>
-        /// <param name="path">The path.</param>
-        /// <param name="cancellationToken">The cancellation token.</param>
-        /// <returns>Task{System.Boolean}.</returns>
-        private async Task<bool> ExtractImage(Video video, string path, CancellationToken cancellationToken)
-        {
-            var isoMount = await MountIsoIfNeeded(video, cancellationToken).ConfigureAwait(false);
-
-            try
-            {
-                // If we know the duration, grab it from 10% into the video. Otherwise just 10 seconds in.
-                // Always use 10 seconds for dvd because our duration could be out of whack
-                var imageOffset = video.VideoType != VideoType.Dvd && video.RunTimeTicks.HasValue &&
-                                  video.RunTimeTicks.Value > 0
-                                      ? TimeSpan.FromTicks(Convert.ToInt64(video.RunTimeTicks.Value * .1))
-                                      : TimeSpan.FromSeconds(10);
-
-                InputType type;
-
-                var inputPath = MediaEncoderHelpers.GetInputArgument(video, isoMount, out type);
-
-                await MediaEncoder.ExtractImage(inputPath, type, imageOffset, path, cancellationToken).ConfigureAwait(false);
-
-                video.PrimaryImagePath = path;
-                SetLastRefreshed(video, DateTime.UtcNow);
-            }
-            catch
-            {
-                SetLastRefreshed(video, DateTime.UtcNow, ProviderRefreshStatus.Failure);
-            }
-            finally
-            {
-                if (isoMount != null)
-                {
-                    isoMount.Dispose();
-                }
-            }
-
-            return true;
-        }
-    }
-}
-- 
cgit v1.2.3