aboutsummaryrefslogtreecommitdiff
path: root/MediaBrowser.Controller
diff options
context:
space:
mode:
authorLuke Pulverenti <luke.pulverenti@gmail.com>2013-04-15 14:45:58 -0400
committerLuke Pulverenti <luke.pulverenti@gmail.com>2013-04-15 14:45:58 -0400
commit2b8b98b59090ab6d077ac76cf9185da7d6ac126a (patch)
tree106a2b646aea6ec8e854d95414c2a2b09265a4e9 /MediaBrowser.Controller
parent3d9b862430f042af1bcb9a7cdffd446ed09f9ef9 (diff)
reduce scanning overhead a bit
Diffstat (limited to 'MediaBrowser.Controller')
-rw-r--r--MediaBrowser.Controller/Dto/DtoBuilder.cs16
-rw-r--r--MediaBrowser.Controller/Entities/Folder.cs2
-rw-r--r--MediaBrowser.Controller/Providers/BaseItemXmlParser.cs13
-rw-r--r--MediaBrowser.Controller/Providers/BaseMetadataProvider.cs2
-rw-r--r--MediaBrowser.Controller/Providers/FolderProviderFromXml.cs17
-rw-r--r--MediaBrowser.Controller/Providers/Movies/MovieProviderFromXml.cs23
-rw-r--r--MediaBrowser.Controller/Providers/TV/EpisodeProviderFromXml.cs40
-rw-r--r--MediaBrowser.Controller/Providers/TV/SeriesProviderFromXml.cs16
8 files changed, 73 insertions, 56 deletions
diff --git a/MediaBrowser.Controller/Dto/DtoBuilder.cs b/MediaBrowser.Controller/Dto/DtoBuilder.cs
index 84f9f8827..6e33f52e6 100644
--- a/MediaBrowser.Controller/Dto/DtoBuilder.cs
+++ b/MediaBrowser.Controller/Dto/DtoBuilder.cs
@@ -665,22 +665,6 @@ namespace MediaBrowser.Controller.Dto
}
/// <summary>
- /// Gets the library update info.
- /// </summary>
- /// <param name="changeEvent">The <see cref="ChildrenChangedEventArgs" /> instance containing the event data.</param>
- /// <returns>LibraryUpdateInfo.</returns>
- public static LibraryUpdateInfo GetLibraryUpdateInfo(ChildrenChangedEventArgs changeEvent)
- {
- return new LibraryUpdateInfo
- {
- Folder = GetBaseItemInfo(changeEvent.Folder),
- ItemsAdded = changeEvent.ItemsAdded.Select(GetBaseItemInfo),
- ItemsRemoved = changeEvent.ItemsRemoved.Select(i => i.Id),
- ItemsUpdated = changeEvent.ItemsUpdated.Select(i => i.Id)
- };
- }
-
- /// <summary>
/// Converts a UserItemData to a DTOUserItemData
/// </summary>
/// <param name="data">The data.</param>
diff --git a/MediaBrowser.Controller/Entities/Folder.cs b/MediaBrowser.Controller/Entities/Folder.cs
index b7508a641..f8db07fe3 100644
--- a/MediaBrowser.Controller/Entities/Folder.cs
+++ b/MediaBrowser.Controller/Entities/Folder.cs
@@ -659,7 +659,7 @@ namespace MediaBrowser.Controller.Entities
foreach (var tuple in list)
{
- if (tasks.Count > 50)
+ if (tasks.Count > 5)
{
await Task.WhenAll(tasks).ConfigureAwait(false);
}
diff --git a/MediaBrowser.Controller/Providers/BaseItemXmlParser.cs b/MediaBrowser.Controller/Providers/BaseItemXmlParser.cs
index e0091cd80..d5df769a9 100644
--- a/MediaBrowser.Controller/Providers/BaseItemXmlParser.cs
+++ b/MediaBrowser.Controller/Providers/BaseItemXmlParser.cs
@@ -49,8 +49,17 @@ namespace MediaBrowser.Controller.Providers
throw new ArgumentNullException();
}
+ var settings = new XmlReaderSettings
+ {
+ CheckCharacters = false,
+ IgnoreProcessingInstructions = true,
+ IgnoreComments = true,
+ IgnoreWhitespace = true,
+ ValidationType = ValidationType.None
+ };
+
// Use XmlReader for best performance
- using (var reader = XmlReader.Create(metadataFile))
+ using (var reader = XmlReader.Create(metadataFile, settings))
{
reader.MoveToContent();
@@ -93,7 +102,7 @@ namespace MediaBrowser.Controller.Providers
{
var type = reader.ReadElementContentAsString();
- if (!string.IsNullOrWhiteSpace(type) && !type.Equals("none",StringComparison.OrdinalIgnoreCase))
+ if (!string.IsNullOrWhiteSpace(type) && !type.Equals("none", StringComparison.OrdinalIgnoreCase))
{
item.DisplayMediaType = type;
}
diff --git a/MediaBrowser.Controller/Providers/BaseMetadataProvider.cs b/MediaBrowser.Controller/Providers/BaseMetadataProvider.cs
index 3f71e398a..b69ece418 100644
--- a/MediaBrowser.Controller/Providers/BaseMetadataProvider.cs
+++ b/MediaBrowser.Controller/Providers/BaseMetadataProvider.cs
@@ -31,6 +31,8 @@ namespace MediaBrowser.Controller.Providers
/// </summary>
protected readonly Guid Id;
+ protected static readonly SemaphoreSlim XmlParsingResourcePool = new SemaphoreSlim(5, 5);
+
/// <summary>
/// Supportses the specified item.
/// </summary>
diff --git a/MediaBrowser.Controller/Providers/FolderProviderFromXml.cs b/MediaBrowser.Controller/Providers/FolderProviderFromXml.cs
index d2c2d5b15..99744390a 100644
--- a/MediaBrowser.Controller/Providers/FolderProviderFromXml.cs
+++ b/MediaBrowser.Controller/Providers/FolderProviderFromXml.cs
@@ -58,7 +58,7 @@ namespace MediaBrowser.Controller.Providers
/// <returns>Task{System.Boolean}.</returns>
public override Task<bool> FetchAsync(BaseItem item, bool force, CancellationToken cancellationToken)
{
- return Task.Run(() => Fetch(item, cancellationToken));
+ return Fetch(item, cancellationToken);
}
/// <summary>
@@ -67,7 +67,7 @@ namespace MediaBrowser.Controller.Providers
/// <param name="item">The item.</param>
/// <param name="cancellationToken">The cancellation token.</param>
/// <returns><c>true</c> if XXXX, <c>false</c> otherwise</returns>
- private bool Fetch(BaseItem item, CancellationToken cancellationToken)
+ private async Task<bool> Fetch(BaseItem item, CancellationToken cancellationToken)
{
cancellationToken.ThrowIfCancellationRequested();
@@ -76,7 +76,18 @@ namespace MediaBrowser.Controller.Providers
if (metadataFile.HasValue)
{
var path = metadataFile.Value.Path;
- new BaseItemXmlParser<Folder>(Logger).Fetch((Folder)item, path, cancellationToken);
+
+ await XmlParsingResourcePool.WaitAsync(cancellationToken).ConfigureAwait(false);
+
+ try
+ {
+ new BaseItemXmlParser<Folder>(Logger).Fetch((Folder)item, path, cancellationToken);
+ }
+ finally
+ {
+ XmlParsingResourcePool.Release();
+ }
+
SetLastRefreshed(item, DateTime.UtcNow);
return true;
}
diff --git a/MediaBrowser.Controller/Providers/Movies/MovieProviderFromXml.cs b/MediaBrowser.Controller/Providers/Movies/MovieProviderFromXml.cs
index 279533636..1ed003e87 100644
--- a/MediaBrowser.Controller/Providers/Movies/MovieProviderFromXml.cs
+++ b/MediaBrowser.Controller/Providers/Movies/MovieProviderFromXml.cs
@@ -58,7 +58,7 @@ namespace MediaBrowser.Controller.Providers.Movies
/// <returns>Task{System.Boolean}.</returns>
public override Task<bool> FetchAsync(BaseItem item, bool force, CancellationToken cancellationToken)
{
- return Task.Run(() => Fetch(item, cancellationToken));
+ return Fetch(item, cancellationToken);
}
/// <summary>
@@ -67,7 +67,7 @@ namespace MediaBrowser.Controller.Providers.Movies
/// <param name="item">The item.</param>
/// <param name="cancellationToken">The cancellation token.</param>
/// <returns><c>true</c> if XXXX, <c>false</c> otherwise</returns>
- private bool Fetch(BaseItem item, CancellationToken cancellationToken)
+ private async Task<bool> Fetch(BaseItem item, CancellationToken cancellationToken)
{
cancellationToken.ThrowIfCancellationRequested();
@@ -77,14 +77,25 @@ namespace MediaBrowser.Controller.Providers.Movies
{
var path = metadataFile.Value.Path;
var boxset = item as BoxSet;
- if (boxset != null)
+
+ await XmlParsingResourcePool.WaitAsync(cancellationToken).ConfigureAwait(false);
+
+ try
{
- new BaseItemXmlParser<BoxSet>(Logger).Fetch(boxset, path, cancellationToken);
+ if (boxset != null)
+ {
+ new BaseItemXmlParser<BoxSet>(Logger).Fetch(boxset, path, cancellationToken);
+ }
+ else
+ {
+ new BaseItemXmlParser<Movie>(Logger).Fetch((Movie)item, path, cancellationToken);
+ }
}
- else
+ finally
{
- new BaseItemXmlParser<Movie>(Logger).Fetch((Movie)item, path, cancellationToken);
+ XmlParsingResourcePool.Release();
}
+
SetLastRefreshed(item, DateTime.UtcNow);
return true;
}
diff --git a/MediaBrowser.Controller/Providers/TV/EpisodeProviderFromXml.cs b/MediaBrowser.Controller/Providers/TV/EpisodeProviderFromXml.cs
index 483d1ddce..e6fb2eb4f 100644
--- a/MediaBrowser.Controller/Providers/TV/EpisodeProviderFromXml.cs
+++ b/MediaBrowser.Controller/Providers/TV/EpisodeProviderFromXml.cs
@@ -15,7 +15,8 @@ namespace MediaBrowser.Controller.Providers.TV
/// </summary>
public class EpisodeProviderFromXml : BaseMetadataProvider
{
- public EpisodeProviderFromXml(ILogManager logManager, IServerConfigurationManager configurationManager) : base(logManager, configurationManager)
+ public EpisodeProviderFromXml(ILogManager logManager, IServerConfigurationManager configurationManager)
+ : base(logManager, configurationManager)
{
}
@@ -55,7 +56,7 @@ namespace MediaBrowser.Controller.Providers.TV
/// <returns>Task{System.Boolean}.</returns>
public override Task<bool> FetchAsync(BaseItem item, bool force, CancellationToken cancellationToken)
{
- return Task.Run(() => Fetch(item, cancellationToken));
+ return Fetch(item, cancellationToken);
}
/// <summary>
@@ -84,42 +85,31 @@ namespace MediaBrowser.Controller.Providers.TV
/// <param name="item">The item.</param>
/// <param name="cancellationToken">The cancellation token.</param>
/// <returns><c>true</c> if XXXX, <c>false</c> otherwise</returns>
- private bool Fetch(BaseItem item, CancellationToken cancellationToken)
+ private async Task<bool> Fetch(BaseItem item, CancellationToken cancellationToken)
{
cancellationToken.ThrowIfCancellationRequested();
-
+
var metadataFile = Path.Combine(item.MetaLocation, Path.ChangeExtension(Path.GetFileName(item.Path), ".xml"));
- var episode = (Episode)item;
+ var file = item.ResolveArgs.Parent.ResolveArgs.GetMetaFileByPath(metadataFile);
- if (!FetchMetadata(episode, item.ResolveArgs.Parent, metadataFile, cancellationToken))
+ if (!file.HasValue)
{
- // Don't set last refreshed if we didn't do anything
return false;
}
- SetLastRefreshed(item, DateTime.UtcNow);
- return true;
- }
-
- /// <summary>
- /// Fetches the metadata.
- /// </summary>
- /// <param name="item">The item.</param>
- /// <param name="parent">The parent.</param>
- /// <param name="metadataFile">The metadata file.</param>
- /// <param name="cancellationToken">The cancellation token.</param>
- /// <returns><c>true</c> if XXXX, <c>false</c> otherwise</returns>
- private bool FetchMetadata(Episode item, Folder parent, string metadataFile, CancellationToken cancellationToken)
- {
- var file = parent.ResolveArgs.GetMetaFileByPath(metadataFile);
+ await XmlParsingResourcePool.WaitAsync(cancellationToken).ConfigureAwait(false);
- if (!file.HasValue)
+ try
{
- return false;
+ new EpisodeXmlParser(Logger).Fetch((Episode)item, metadataFile, cancellationToken);
+ }
+ finally
+ {
+ XmlParsingResourcePool.Release();
}
- new EpisodeXmlParser(Logger).Fetch(item, metadataFile, cancellationToken);
+ SetLastRefreshed(item, DateTime.UtcNow);
return true;
}
}
diff --git a/MediaBrowser.Controller/Providers/TV/SeriesProviderFromXml.cs b/MediaBrowser.Controller/Providers/TV/SeriesProviderFromXml.cs
index 8e42e9d55..556ef24c9 100644
--- a/MediaBrowser.Controller/Providers/TV/SeriesProviderFromXml.cs
+++ b/MediaBrowser.Controller/Providers/TV/SeriesProviderFromXml.cs
@@ -59,7 +59,7 @@ namespace MediaBrowser.Controller.Providers.TV
/// <returns>Task{System.Boolean}.</returns>
public override Task<bool> FetchAsync(BaseItem item, bool force, CancellationToken cancellationToken)
{
- return Task.Run(() => Fetch(item, cancellationToken));
+ return Fetch(item, cancellationToken);
}
/// <summary>
@@ -68,7 +68,7 @@ namespace MediaBrowser.Controller.Providers.TV
/// <param name="item">The item.</param>
/// <param name="cancellationToken">The cancellation token.</param>
/// <returns><c>true</c> if XXXX, <c>false</c> otherwise</returns>
- private bool Fetch(BaseItem item, CancellationToken cancellationToken)
+ private async Task<bool> Fetch(BaseItem item, CancellationToken cancellationToken)
{
cancellationToken.ThrowIfCancellationRequested();
@@ -78,7 +78,17 @@ namespace MediaBrowser.Controller.Providers.TV
{
var path = metadataFile.Value.Path;
- new SeriesXmlParser(Logger).Fetch((Series)item, path, cancellationToken);
+ await XmlParsingResourcePool.WaitAsync(cancellationToken).ConfigureAwait(false);
+
+ try
+ {
+ new SeriesXmlParser(Logger).Fetch((Series)item, path, cancellationToken);
+ }
+ finally
+ {
+ XmlParsingResourcePool.Release();
+ }
+
SetLastRefreshed(item, DateTime.UtcNow);
return true;