diff options
| author | Luke Pulverenti <luke.pulverenti@gmail.com> | 2015-02-03 13:55:15 -0500 |
|---|---|---|
| committer | Luke Pulverenti <luke.pulverenti@gmail.com> | 2015-02-03 13:55:15 -0500 |
| commit | 0f88525d618f3f8c7fdc0bc515a2357dac8fee63 (patch) | |
| tree | eb33d92704f9076198ace029c01718eedf007aff /MediaBrowser.Server.Implementations/Sync/SyncManager.cs | |
| parent | 7fd4b974814011d15a9c0d43226e0c6e51f6162b (diff) | |
clean up sync temp files when canceling jobs
Diffstat (limited to 'MediaBrowser.Server.Implementations/Sync/SyncManager.cs')
| -rw-r--r-- | MediaBrowser.Server.Implementations/Sync/SyncManager.cs | 22 |
1 files changed, 22 insertions, 0 deletions
diff --git a/MediaBrowser.Server.Implementations/Sync/SyncManager.cs b/MediaBrowser.Server.Implementations/Sync/SyncManager.cs index 3c5b27d63..6a4bc9cc4 100644 --- a/MediaBrowser.Server.Implementations/Sync/SyncManager.cs +++ b/MediaBrowser.Server.Implementations/Sync/SyncManager.cs @@ -309,6 +309,17 @@ namespace MediaBrowser.Server.Implementations.Sync await _repo.DeleteJob(id).ConfigureAwait(false); + var path = GetSyncJobProcessor().GetTemporaryPath(id); + + try + { + _fileSystem.DeleteDirectory(path, true); + } + catch (Exception ex) + { + _logger.ErrorException("Error deleting directory {0}", ex, path); + } + if (SyncJobCancelled != null) { EventHelper.FireEventIfNotNull(SyncJobCancelled, this, new GenericEventArgs<SyncJob> @@ -706,6 +717,17 @@ namespace MediaBrowser.Server.Implementations.Sync var processor = GetSyncJobProcessor(); await processor.UpdateJobStatus(jobItem.JobId).ConfigureAwait(false); + + var path = processor.GetTemporaryPath(jobItem); + + try + { + _fileSystem.DeleteDirectory(path, true); + } + catch (Exception ex) + { + _logger.ErrorException("Error deleting directory {0}", ex, path); + } } public async Task MarkJobItemForRemoval(string id) |
