aboutsummaryrefslogtreecommitdiff
path: root/MediaBrowser.Server.Implementations/Persistence/CleanDatabaseScheduledTask.cs
diff options
context:
space:
mode:
authorLuke Pulverenti <luke.pulverenti@gmail.com>2016-02-03 16:56:00 -0500
committerLuke Pulverenti <luke.pulverenti@gmail.com>2016-02-03 16:56:00 -0500
commit00ae190a276f51f488752ab76cee131b16671fa2 (patch)
tree1c4f6e635923a28264f7c923d1571c6f10c7bf11 /MediaBrowser.Server.Implementations/Persistence/CleanDatabaseScheduledTask.cs
parent6cb1f77789171f4be7a4c6cd9e075eb4e8b6eff0 (diff)
update upgrade process
Diffstat (limited to 'MediaBrowser.Server.Implementations/Persistence/CleanDatabaseScheduledTask.cs')
-rw-r--r--MediaBrowser.Server.Implementations/Persistence/CleanDatabaseScheduledTask.cs14
1 files changed, 14 insertions, 0 deletions
diff --git a/MediaBrowser.Server.Implementations/Persistence/CleanDatabaseScheduledTask.cs b/MediaBrowser.Server.Implementations/Persistence/CleanDatabaseScheduledTask.cs
index 76a6e6d40..f7c6fe502 100644
--- a/MediaBrowser.Server.Implementations/Persistence/CleanDatabaseScheduledTask.cs
+++ b/MediaBrowser.Server.Implementations/Persistence/CleanDatabaseScheduledTask.cs
@@ -64,6 +64,8 @@ namespace MediaBrowser.Server.Implementations.Persistence
public async Task Execute(CancellationToken cancellationToken, IProgress<double> progress)
{
+ OnProgress(0);
+
var innerProgress = new ActionableProgress<double>();
innerProgress.RegisterAction(p =>
{
@@ -146,6 +148,8 @@ namespace MediaBrowser.Server.Implementations.Persistence
if (itemId != Guid.Empty)
{
+ LogMessage(string.Format("Querying item {0}", itemId));
+
// Somehow some invalid data got into the db. It probably predates the boundary checking
var item = _libraryManager.GetItemById(itemId);
@@ -153,6 +157,8 @@ namespace MediaBrowser.Server.Implementations.Persistence
{
try
{
+ LogMessage(string.Format("Saving item {0}", itemId));
+
await _itemRepo.SaveItem(item, cancellationToken).ConfigureAwait(false);
}
catch (OperationCanceledException)
@@ -175,6 +181,14 @@ namespace MediaBrowser.Server.Implementations.Persistence
progress.Report(100);
}
+ private void LogMessage(string msg)
+ {
+ if (EnableUnavailableMessage)
+ {
+ _logger.Info(msg);
+ }
+ }
+
private async Task CleanDeadItems(CancellationToken cancellationToken, IProgress<double> progress)
{
var itemIds = _libraryManager.GetItemIds(new InternalItemsQuery