aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorLuke Pulverenti <luke.pulverenti@gmail.com>2016-02-03 17:42:33 -0500
committerLuke Pulverenti <luke.pulverenti@gmail.com>2016-02-03 17:42:33 -0500
commit0b5b409354909a0f446aea9f69ae4fd7eb6be35d (patch)
tree063eec80313435827371aaecccbcc5584a4175d0
parent00ae190a276f51f488752ab76cee131b16671fa2 (diff)
update migration
-rw-r--r--MediaBrowser.Server.Implementations/Persistence/CleanDatabaseScheduledTask.cs11
-rw-r--r--MediaBrowser.Server.Implementations/Persistence/SqliteItemRepository.cs6
-rw-r--r--MediaBrowser.Server.Startup.Common/ApplicationHost.cs4
-rw-r--r--MediaBrowser.Server.Startup.Common/Migrations/DbMigration.cs2
4 files changed, 15 insertions, 8 deletions
diff --git a/MediaBrowser.Server.Implementations/Persistence/CleanDatabaseScheduledTask.cs b/MediaBrowser.Server.Implementations/Persistence/CleanDatabaseScheduledTask.cs
index f7c6fe502..5c600c249 100644
--- a/MediaBrowser.Server.Implementations/Persistence/CleanDatabaseScheduledTask.cs
+++ b/MediaBrowser.Server.Implementations/Persistence/CleanDatabaseScheduledTask.cs
@@ -10,6 +10,7 @@ using MediaBrowser.Model.Logging;
using System;
using System.Collections.Generic;
using System.Globalization;
+using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using CommonIO;
@@ -32,7 +33,7 @@ namespace MediaBrowser.Server.Implementations.Persistence
private readonly ILocalizationManager _localization;
private readonly ITaskManager _taskManager;
- public const int MigrationVersion = 17;
+ public const int MigrationVersion = 20;
public static bool EnableUnavailableMessage = false;
public CleanDatabaseScheduledTask(ILibraryManager libraryManager, IItemRepository itemRepo, ILogger logger, IServerConfigurationManager config, IFileSystem fileSystem, IHttpServer httpServer, ILocalizationManager localization, ITaskManager taskManager)
@@ -66,6 +67,10 @@ namespace MediaBrowser.Server.Implementations.Persistence
{
OnProgress(0);
+ // Ensure these objects are out of the database.
+ var rootChildren = _libraryManager.RootFolder.Children.ToList();
+ rootChildren = _libraryManager.GetUserRootFolder().Children.ToList();
+
var innerProgress = new ActionableProgress<double>();
innerProgress.RegisterAction(p =>
{
@@ -148,8 +153,6 @@ 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);
@@ -157,8 +160,6 @@ namespace MediaBrowser.Server.Implementations.Persistence
{
try
{
- LogMessage(string.Format("Saving item {0}", itemId));
-
await _itemRepo.SaveItem(item, cancellationToken).ConfigureAwait(false);
}
catch (OperationCanceledException)
diff --git a/MediaBrowser.Server.Implementations/Persistence/SqliteItemRepository.cs b/MediaBrowser.Server.Implementations/Persistence/SqliteItemRepository.cs
index 7898dc1ef..3dc37110e 100644
--- a/MediaBrowser.Server.Implementations/Persistence/SqliteItemRepository.cs
+++ b/MediaBrowser.Server.Implementations/Persistence/SqliteItemRepository.cs
@@ -583,16 +583,22 @@ namespace MediaBrowser.Server.Implementations.Persistence
CheckDisposed();
+ _logger.Info("SaveItems waiting on write lock");
+
await _writeLock.WaitAsync(cancellationToken).ConfigureAwait(false);
IDbTransaction transaction = null;
try
{
+ _logger.Info("SaveItems creating transaction");
+
transaction = _connection.BeginTransaction();
foreach (var item in items)
{
+ _logger.Info("Saving {0}", item.Id);
+
cancellationToken.ThrowIfCancellationRequested();
var index = 0;
diff --git a/MediaBrowser.Server.Startup.Common/ApplicationHost.cs b/MediaBrowser.Server.Startup.Common/ApplicationHost.cs
index 7f79653af..46dfd4469 100644
--- a/MediaBrowser.Server.Startup.Common/ApplicationHost.cs
+++ b/MediaBrowser.Server.Startup.Common/ApplicationHost.cs
@@ -328,6 +328,8 @@ namespace MediaBrowser.Server.Startup.Common
Logger.Info("Core startup complete");
HttpServer.GlobalResponse = null;
+ PerformPostInitMigrations();
+
Parallel.ForEach(GetExports<IServerEntryPoint>(), entryPoint =>
{
try
@@ -341,8 +343,6 @@ namespace MediaBrowser.Server.Startup.Common
});
LogManager.RemoveConsoleOutput();
-
- PerformPostInitMigrations();
}
public override Task Init(IProgress<double> progress)
diff --git a/MediaBrowser.Server.Startup.Common/Migrations/DbMigration.cs b/MediaBrowser.Server.Startup.Common/Migrations/DbMigration.cs
index 959543893..5a70467f7 100644
--- a/MediaBrowser.Server.Startup.Common/Migrations/DbMigration.cs
+++ b/MediaBrowser.Server.Startup.Common/Migrations/DbMigration.cs
@@ -25,7 +25,7 @@ namespace MediaBrowser.Server.Startup.Common.Migrations
Task.Run(async () =>
{
- await Task.Delay(1000).ConfigureAwait(false);
+ await Task.Delay(100).ConfigureAwait(false);
_taskManager.Execute<CleanDatabaseScheduledTask>();
});