Merge pull request #2439 from MediaBrowser/dev

Dev
This commit is contained in:
Luke 2017-02-03 16:15:57 -05:00 committed by GitHub
commit 2906764298
3 changed files with 15 additions and 10 deletions

View File

@ -282,11 +282,6 @@ namespace Emby.Server.Core.IO
/// </summary> /// </summary>
/// <param name="path">The path.</param> /// <param name="path">The path.</param>
private void StartWatchingPath(string path) private void StartWatchingPath(string path)
{
// Creating a FileSystemWatcher over the LAN can take hundreds of milliseconds, so wrap it in a Task to do them all in parallel
Task.Run(() =>
{
try
{ {
if (!_fileSystem.DirectoryExists(path)) if (!_fileSystem.DirectoryExists(path))
{ {
@ -295,6 +290,17 @@ namespace Emby.Server.Core.IO
return; return;
} }
// Already being watched
if (_fileSystemWatchers.ContainsKey(path))
{
return;
}
// Creating a FileSystemWatcher over the LAN can take hundreds of milliseconds, so wrap it in a Task to do them all in parallel
Task.Run(() =>
{
try
{
var newWatcher = new FileSystemWatcher(path, "*") var newWatcher = new FileSystemWatcher(path, "*")
{ {
IncludeSubdirectories = true IncludeSubdirectories = true
@ -326,7 +332,6 @@ namespace Emby.Server.Core.IO
} }
else else
{ {
Logger.Info("Unable to add directory watcher for {0}. It already exists in the dictionary.", path);
newWatcher.Dispose(); newWatcher.Dispose();
} }

View File

@ -2112,7 +2112,7 @@ namespace Emby.Server.Implementations.LiveTv
if (timer == null) if (timer == null)
{ {
throw new ResourceNotFoundException(string.Format("Timer with Id {0} not found", id)); throw new ResourceNotFoundException(string.Format("SeriesTimer with Id {0} not found", id));
} }
var service = GetService(timer.ServiceName); var service = GetService(timer.ServiceName);

View File

@ -103,7 +103,7 @@ namespace MediaBrowser.Api.Playback.Hls
throw; throw;
} }
var waitForSegments = state.SegmentLength >= 10 ? 2 : 2; var waitForSegments = state.SegmentLength >= 10 ? 2 : 3;
await WaitForMinimumSegmentCount(playlist, waitForSegments, cancellationTokenSource.Token).ConfigureAwait(false); await WaitForMinimumSegmentCount(playlist, waitForSegments, cancellationTokenSource.Token).ConfigureAwait(false);
} }
} }