aboutsummaryrefslogtreecommitdiff
path: root/Emby.Server.Implementations/Sync/SyncJobProcessor.cs
diff options
context:
space:
mode:
authorLuke Pulverenti <luke.pulverenti@gmail.com>2016-12-28 14:56:16 -0500
committerLuke Pulverenti <luke.pulverenti@gmail.com>2016-12-28 14:56:16 -0500
commit5e4bf3c36f31bc60a547937b107d0bb61968b9d6 (patch)
tree8474bd92c26da61f952bab7bb8973b0d2dde5e53 /Emby.Server.Implementations/Sync/SyncJobProcessor.cs
parentdb9eb64e9fe9453172052be0d2923cdb83bdca6a (diff)
add sync error handling
Diffstat (limited to 'Emby.Server.Implementations/Sync/SyncJobProcessor.cs')
-rw-r--r--Emby.Server.Implementations/Sync/SyncJobProcessor.cs10
1 files changed, 9 insertions, 1 deletions
diff --git a/Emby.Server.Implementations/Sync/SyncJobProcessor.cs b/Emby.Server.Implementations/Sync/SyncJobProcessor.cs
index 415757609..b1adc64df 100644
--- a/Emby.Server.Implementations/Sync/SyncJobProcessor.cs
+++ b/Emby.Server.Implementations/Sync/SyncJobProcessor.cs
@@ -515,8 +515,14 @@ namespace Emby.Server.Implementations.Sync
jobItem.Progress = 0;
- var syncOptions = _config.GetSyncOptions();
var job = _syncManager.GetJob(jobItem.JobId);
+ if (job == null)
+ {
+ _logger.Error("Job not found. Cannot complete the sync job.");
+ await _syncManager.CancelJobItem(jobItem.Id).ConfigureAwait(false);
+ return;
+ }
+
var user = _userManager.GetUserById(job.UserId);
if (user == null)
{
@@ -552,6 +558,8 @@ namespace Emby.Server.Implementations.Sync
}
}
+ var syncOptions = _config.GetSyncOptions();
+
var video = item as Video;
if (video != null)
{