mirror of
https://github.com/duplicati/duplicati.git
synced 2025-11-27 19:10:29 +08:00
3b695cf065
This PR adds detection of the MacOS Photos folder, and intercepts reads and replaces them with PhotoKit calls. With this, it is possible to make backups of all MacOS Photos, even if they are not stored locally. The previous versions would just make a backup of the on-disk structure, which was not guaranteed to contain all photos, but instead has various indexing for finding photos, and may contain some original photos. The option `--photos-handling` controls how Duplicati now deals with the Photos folder. The options are: - `LibraryOnly`: Same as before, just treat it as a folder - `PhotosOnly`: Ignore the folder contents and just back up the actual photos - `PhotosAndLibrary` (default): Make a backup of the photos and the library on-disk. This may cause images to be stored twice, but de-duplication will usually limit the storage increase. The option `--photos-library-path` can be used to point to the on-disk Photo library that should be handled, in case the auto-detection does not pick it up. If this does not point to a valid Photoslibrary, or the path is not being backed up, no special handling will be done. Note that the restore is not restoring into Photos itself, but instead restores into a sub-folder in the Photolibrary that is called `dup_backup`. To get the photos out after a restore, one needs to right-click the Photolibrary folder, and choose "Show package contents" and then the `dup_backup` folder is revealed. This is done to keep all photos in the same folder, but avoid messing with the structure of the on-disk Photolibrary. A future update could allow restoring back into Photos, and metadata is captured for each image to eventually allow this. This fixes #6381
1408 lines
82 KiB
C#
1408 lines
82 KiB
C#
// Copyright (C) 2025, The Duplicati Team
|
|
// https://duplicati.com, hello@duplicati.com
|
|
//
|
|
// Permission is hereby granted, free of charge, to any person obtaining a
|
|
// copy of this software and associated documentation files (the "Software"),
|
|
// to deal in the Software without restriction, including without limitation
|
|
// the rights to use, copy, modify, merge, publish, distribute, sublicense,
|
|
// and/or sell copies of the Software, and to permit persons to whom the
|
|
// Software is furnished to do so, subject to the following conditions:
|
|
//
|
|
// The above copyright notice and this permission notice shall be included in
|
|
// all copies or substantial portions of the Software.
|
|
//
|
|
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
|
|
// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
|
|
// FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
|
|
// DEALINGS IN THE SOFTWARE.
|
|
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using System.IO;
|
|
using System.Linq;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using Duplicati.Library.Interface;
|
|
using Duplicati.Library.Main.Database;
|
|
using Duplicati.Library.Main.Operation.Backup;
|
|
using Duplicati.Library.Main.Volumes;
|
|
using Duplicati.Library.Utility;
|
|
|
|
namespace Duplicati.Library.Main.Operation
|
|
{
|
|
internal class RepairHandler
|
|
{
|
|
/// <summary>
|
|
/// The tag used for logging
|
|
/// </summary>
|
|
private static readonly string LOGTAG = Logging.Log.LogTagFromType<RepairHandler>();
|
|
private readonly Options m_options;
|
|
private readonly RepairResults m_result;
|
|
|
|
public RepairHandler(Options options, RepairResults result)
|
|
{
|
|
m_options = options;
|
|
m_result = result;
|
|
|
|
if (options.AllowPassphraseChange)
|
|
throw new UserInformationException(Strings.Common.PassphraseChangeUnsupported, "PassphraseChangeUnsupported");
|
|
}
|
|
|
|
public async Task RunAsync(IBackendManager backendManager, IFilter filter)
|
|
{
|
|
if (!File.Exists(m_options.Dbpath))
|
|
{
|
|
await RunRepairLocalAsync(backendManager, filter).ConfigureAwait(false);
|
|
await RunRepairCommon().ConfigureAwait(false);
|
|
m_result.EndTime = DateTime.UtcNow;
|
|
return;
|
|
}
|
|
|
|
long knownRemotes = -1;
|
|
try
|
|
{
|
|
await using var db =
|
|
await LocalRepairDatabase.CreateRepairDatabase(m_options.Dbpath, null, m_result.TaskControl.ProgressToken)
|
|
.ConfigureAwait(false);
|
|
knownRemotes = await db
|
|
.GetRemoteVolumes(m_result.TaskControl.ProgressToken)
|
|
.CountAsync(cancellationToken: m_result.TaskControl.ProgressToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Logging.Log.WriteWarningMessage(LOGTAG, "FailedToReadLocalDatabase", ex, "Failed to read local db {0}, error: {1}", m_options.Dbpath, ex.Message);
|
|
}
|
|
|
|
if (knownRemotes <= 0)
|
|
{
|
|
if (m_options.Dryrun)
|
|
{
|
|
Logging.Log.WriteDryrunMessage(LOGTAG, "PerformingDryrunRecreate", "Performing dryrun recreate");
|
|
}
|
|
else
|
|
{
|
|
var baseName = Path.ChangeExtension(m_options.Dbpath, "backup");
|
|
var i = 0;
|
|
while (File.Exists(baseName) && i++ < 1000)
|
|
baseName = Path.ChangeExtension(m_options.Dbpath, "backup-" + i.ToString());
|
|
|
|
Logging.Log.WriteInformationMessage(LOGTAG, "RenamingDatabase", "Renaming existing db from {0} to {1}", m_options.Dbpath, baseName);
|
|
File.Move(m_options.Dbpath, baseName);
|
|
}
|
|
|
|
await RunRepairLocalAsync(backendManager, filter).ConfigureAwait(false);
|
|
await RunRepairCommon().ConfigureAwait(false);
|
|
}
|
|
else
|
|
{
|
|
await RunRepairCommon().ConfigureAwait(false);
|
|
await RunRepairBrokenFilesets(backendManager).ConfigureAwait(false);
|
|
await RunRepairRemoteAsync(backendManager, m_result.TaskControl.ProgressToken).ConfigureAwait(false);
|
|
}
|
|
|
|
m_result.EndTime = DateTime.UtcNow;
|
|
|
|
}
|
|
|
|
public async Task RunRepairLocalAsync(IBackendManager backendManager, IFilter filter)
|
|
{
|
|
m_result.RecreateDatabaseResults = new RecreateDatabaseResults(m_result);
|
|
using (new Logging.Timer(LOGTAG, "RecreateDbForRepair", "Recreate database for repair"))
|
|
using (var f = m_options.Dryrun ? new TempFile() : null)
|
|
{
|
|
if (f != null && File.Exists(f))
|
|
File.Delete(f);
|
|
|
|
var filelistfilter = RestoreHandler.FilterNumberedFilelist(m_options.Time, m_options.Version);
|
|
|
|
await new RecreateDatabaseHandler(m_options, (RecreateDatabaseResults)m_result.RecreateDatabaseResults)
|
|
.RunAsync(m_options.Dryrun ? (string)f : m_options.Dbpath, backendManager, filter, filelistfilter, null)
|
|
.ConfigureAwait(false);
|
|
}
|
|
}
|
|
|
|
private async Task RunRepairRemoteAsync(IBackendManager backendManager, CancellationToken cancellationToken)
|
|
{
|
|
if (!File.Exists(m_options.Dbpath))
|
|
throw new UserInformationException(string.Format("Database file does not exist: {0}", m_options.Dbpath), "RepairDatabaseFileDoesNotExist");
|
|
|
|
m_result.OperationProgressUpdater.UpdateProgress(0);
|
|
|
|
await using var db =
|
|
await LocalRepairDatabase.CreateRepairDatabase(m_options.Dbpath, null, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
try
|
|
{
|
|
|
|
await Utility.UpdateOptionsFromDb(db, m_options, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
await Utility.VerifyOptionsAndUpdateDatabase(db, m_options, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
if (await db.PartiallyRecreated(cancellationToken).ConfigureAwait(false))
|
|
throw new UserInformationException("The database was only partially recreated. This database may be incomplete and the repair process is not allowed to alter remote files as that could result in data loss.", "DatabaseIsPartiallyRecreated");
|
|
|
|
if (await db.RepairInProgress(cancellationToken).ConfigureAwait(false))
|
|
throw new UserInformationException("The database was attempted repaired, but the repair did not complete. This database may be incomplete and the repair process is not allowed to alter remote files as that could result in data loss.", "DatabaseIsInRepairState");
|
|
|
|
// Ensure the database is consistent before we start fixing the remote
|
|
await db
|
|
.VerifyConsistencyForRepair(m_options.Blocksize, m_options.BlockhashSize, true, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
// If the last backup failed, guard the incomplete fileset, so we can create a synthetic filelist
|
|
var lastTempFilelist = await db
|
|
.GetLastIncompleteFilesetVolume(cancellationToken)
|
|
.ConfigureAwait(false);
|
|
var tp = await FilelistProcessor.RemoteListAnalysis(backendManager, m_options, db, m_result.BackendWriter, [lastTempFilelist.Name], null, FilelistProcessor.VerifyMode.VerifyAndCleanForced, cancellationToken).ConfigureAwait(false);
|
|
await db.Transaction
|
|
.CommitAsync("CommitRemoteListAnalysisTransaction", token: cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
var buffer = new byte[m_options.Blocksize];
|
|
var hashsize = m_options.BlockhashSize;
|
|
|
|
var missingRemoteFilesets = await db
|
|
.MissingRemoteFilesets(cancellationToken)
|
|
.ToListAsync(cancellationToken: cancellationToken)
|
|
.ConfigureAwait(false);
|
|
var missingLocalFilesets = await db
|
|
.MissingLocalFilesets(cancellationToken)
|
|
.ToListAsync(cancellationToken: cancellationToken)
|
|
.ConfigureAwait(false);
|
|
var emptyIndexFiles = await db
|
|
.EmptyIndexFiles(cancellationToken)
|
|
.ToListAsync(cancellationToken: cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
var progress = 0;
|
|
var targetProgess =
|
|
tp.ExtraVolumes.Count() +
|
|
tp.MissingVolumes.Count() +
|
|
tp.VerificationRequiredVolumes.Count() +
|
|
missingRemoteFilesets.Count +
|
|
missingLocalFilesets.Count +
|
|
emptyIndexFiles.Count;
|
|
|
|
// Find the most recent timestamp from either a fileset or a remote volume
|
|
var mostRecentLocal = await db
|
|
.GetRemoteVolumes(cancellationToken)
|
|
.Where(x => x.Type == RemoteVolumeType.Files)
|
|
.Select(x => VolumeBase.ParseFilename(x.Name).Time.ToLocalTime())
|
|
.Concat(db.FilesetTimes(cancellationToken).Select(x => x.Value.ToLocalTime()))
|
|
.Append(DateTime.MinValue)
|
|
.MaxAsync(cancellationToken: cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
var mostRecentRemote = tp.ParsedVolumes.Select(x => x.Time.ToLocalTime()).Append(DateTime.MinValue).Max();
|
|
if (mostRecentLocal < DateTime.UnixEpoch)
|
|
throw new UserInformationException("The local database has no fileset times. Consider deleting the local database and run the repair operation again.", "LocalDatabaseHasNoFilesetTimes");
|
|
if (mostRecentRemote > mostRecentLocal)
|
|
{
|
|
if (m_options.RepairIgnoreOutdatedDatabase)
|
|
Logging.Log.WriteWarningMessage(LOGTAG, "RemoteFilesNewerThanLocalDatabase", null, "The remote files are newer ({0}) than the local database ({1}), this is likely because the database is outdated. Continuing as the options force ignoring this.", mostRecentRemote, mostRecentLocal);
|
|
else
|
|
throw new UserInformationException($"The remote files are newer ({mostRecentRemote}) than the local database ({mostRecentLocal}), this is likely because the database is outdated. Consider deleting the local database and run the repair operation again. If this is expected, set the option \"--repair-ignore-outdated-database\" ", "RemoteFilesNewerThanLocalDatabase");
|
|
}
|
|
|
|
if (m_options.Dryrun)
|
|
{
|
|
if (!tp.ParsedVolumes.Any() && tp.OtherVolumes.Any())
|
|
{
|
|
if (tp.BackupPrefixes.Length == 1)
|
|
throw new UserInformationException(string.Format("Found no backup files with prefix {0}, but files with prefix {1}, did you forget to set the backup prefix?", m_options.Prefix, tp.BackupPrefixes[0]), "RemoteFolderEmptyWithPrefix");
|
|
else
|
|
throw new UserInformationException(string.Format("Found no backup files with prefix {0}, but files with prefixes {1}, did you forget to set the backup prefix?", m_options.Prefix, string.Join(", ", tp.BackupPrefixes)), "RemoteFolderEmptyWithPrefix");
|
|
}
|
|
else if (!tp.ParsedVolumes.Any() && tp.ExtraVolumes.Any())
|
|
{
|
|
throw new UserInformationException(string.Format("No files were missing, but {0} remote files were, found, did you mean to run recreate-database?", tp.ExtraVolumes.Count()), "NoRemoteFilesMissing");
|
|
}
|
|
}
|
|
|
|
if (tp.ExtraVolumes.Any() || tp.MissingVolumes.Any() || tp.VerificationRequiredVolumes.Any() || missingRemoteFilesets.Any() || missingLocalFilesets.Any() || emptyIndexFiles.Any())
|
|
{
|
|
if (tp.VerificationRequiredVolumes.Any())
|
|
{
|
|
await using var testdb =
|
|
await LocalTestDatabase.CreateAsync(db, null, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
foreach (var n in tp.VerificationRequiredVolumes)
|
|
try
|
|
{
|
|
if (!await m_result.TaskControl.ProgressRendevouz().ConfigureAwait(false))
|
|
{
|
|
await backendManager.WaitForEmptyAsync(testdb, cancellationToken).ConfigureAwait(false);
|
|
if (!m_options.Dryrun)
|
|
await testdb.Transaction
|
|
.CommitAsync("CommitEarlyExit", false, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
else
|
|
await testdb.Transaction
|
|
.RollBackAsync(cancellationToken)
|
|
.ConfigureAwait(false);
|
|
return;
|
|
}
|
|
|
|
progress++;
|
|
m_result.OperationProgressUpdater.UpdateProgress((float)progress / targetProgess);
|
|
|
|
KeyValuePair<string, IEnumerable<KeyValuePair<TestEntryStatus, string>>> res;
|
|
var (tf, hash, size) = await backendManager.GetWithInfoAsync(n.Name, n.Hash, n.Size, cancellationToken).ConfigureAwait(false);
|
|
using (tf)
|
|
res =
|
|
await TestHandler.TestVolumeInternals(testdb, n, tf, m_options, 1, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
if (res.Value.Any())
|
|
throw new Exception(string.Format("Remote verification failure: {0}", res.Value.First()));
|
|
|
|
if (!m_options.Dryrun)
|
|
{
|
|
Logging.Log.WriteInformationMessage(LOGTAG, "CapturedRemoteFileHash", "Sucessfully captured hash for {0}, updating database", n.Name);
|
|
await db
|
|
.UpdateRemoteVolume(n.Name, RemoteVolumeState.Verified, size, hash, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Logging.Log.WriteErrorMessage(LOGTAG, "RemoteFileVerificationError", ex, "Failed to perform verification for file: {0}, please run verify; message: {1}", n.Name, ex.Message);
|
|
if (ex.IsAbortException())
|
|
throw;
|
|
}
|
|
|
|
await db.Transaction
|
|
.CommitAsync("CommitVerificationTransaction", true, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
|
|
// TODO: It is actually possible to use the extra files if we parse them
|
|
foreach (var n in tp.ExtraVolumes)
|
|
try
|
|
{
|
|
if (!await m_result.TaskControl.ProgressRendevouz().ConfigureAwait(false))
|
|
{
|
|
await backendManager.WaitForEmptyAsync(db, cancellationToken).ConfigureAwait(false);
|
|
if (!m_options.Dryrun)
|
|
await db.Transaction
|
|
.CommitAsync("CommitEarlyExit", false, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
else
|
|
await db.Transaction
|
|
.RollBackAsync(cancellationToken)
|
|
.ConfigureAwait(false);
|
|
return;
|
|
}
|
|
|
|
progress++;
|
|
m_result.OperationProgressUpdater.UpdateProgress((float)progress / targetProgess);
|
|
|
|
// If this is a new index file, we can accept it if it matches our local data
|
|
// This makes it possible to augment the remote store with new index data
|
|
if (n.FileType == RemoteVolumeType.Index && m_options.IndexfilePolicy != Options.IndexFileStrategy.None)
|
|
{
|
|
try
|
|
{
|
|
(var tf, var hash, var size) = await backendManager.GetWithInfoAsync(n.File.Name, null, n.File.Size, cancellationToken).ConfigureAwait(false);
|
|
using (tf)
|
|
using (var ifr = new IndexVolumeReader(n.CompressionModule, tf, m_options, m_options.BlockhashSize))
|
|
{
|
|
foreach (var rv in ifr.Volumes)
|
|
{
|
|
var entry = await db
|
|
.GetRemoteVolume(rv.Filename, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
if (entry.ID < 0)
|
|
throw new Exception(string.Format("Unknown remote file {0} detected", rv.Filename));
|
|
|
|
if (!new[] { RemoteVolumeState.Uploading, RemoteVolumeState.Uploaded, RemoteVolumeState.Verified }.Contains(entry.State))
|
|
throw new Exception(string.Format("Volume {0} has local state {1}", rv.Filename, entry.State));
|
|
|
|
if (entry.Hash != rv.Hash || entry.Size != rv.Length || !new[] { RemoteVolumeState.Uploading, RemoteVolumeState.Uploaded, RemoteVolumeState.Verified }.Contains(entry.State))
|
|
throw new Exception(string.Format("Volume {0} hash/size mismatch ({1} - {2}) vs ({3} - {4})", rv.Filename, entry.Hash, entry.Size, rv.Hash, rv.Length));
|
|
|
|
await db
|
|
.CheckAllBlocksAreInVolume(rv.Filename, rv.Blocks, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
|
|
var blocksize = m_options.Blocksize;
|
|
foreach (var ixb in ifr.BlockLists)
|
|
await db
|
|
.CheckBlocklistCorrect(ixb.Hash, ixb.Length, ixb.Blocklist, blocksize, hashsize, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
// Register the new index file and link it to the block files
|
|
var selfid = await db
|
|
.RegisterRemoteVolume(n.File.Name, RemoteVolumeType.Index, RemoteVolumeState.Uploading, size, new TimeSpan(0), cancellationToken)
|
|
.ConfigureAwait(false);
|
|
foreach (var rv in ifr.Volumes)
|
|
{
|
|
// Guard against unknown block files
|
|
long id = await db
|
|
.GetRemoteVolumeID(rv.Filename, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
if (id == -1)
|
|
Logging.Log.WriteWarningMessage(LOGTAG, "UnknownBlockFile", null, "Index file {0} references unknown block file: {1}", n.File.Name, rv.Filename);
|
|
else
|
|
await db
|
|
.AddIndexBlockLink(selfid, id, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
|
|
if (!m_options.Dryrun)
|
|
await db.Transaction
|
|
.CommitAsync("CommitIndexFileTransaction", true, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
|
|
// All checks fine, we accept the new index file
|
|
Logging.Log.WriteInformationMessage(LOGTAG, "AcceptNewIndexFile", "Accepting new index file {0}", n.File.Name);
|
|
await db
|
|
.UpdateRemoteVolume(n.File.Name, RemoteVolumeState.Verified, size, hash, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
continue;
|
|
}
|
|
catch (Exception rex)
|
|
{
|
|
Logging.Log.WriteErrorMessage(LOGTAG, "FailedNewIndexFile", rex, "Failed to accept new index file: {0}, message: {1}", n.File.Name, rex.Message);
|
|
}
|
|
}
|
|
|
|
if (!m_options.Dryrun)
|
|
{
|
|
await db
|
|
.RegisterRemoteVolume(n.File.Name, n.FileType, n.File.Size, RemoteVolumeState.Deleting, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
await backendManager.DeleteAsync(n.File.Name, n.File.Size, false, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
else
|
|
Logging.Log.WriteDryrunMessage(LOGTAG, "WouldDeleteFile", "would delete file {0}", n.File.Name);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Logging.Log.WriteErrorMessage(LOGTAG, "FailedExtraFileCleanup", ex, "Failed to perform cleanup for extra file: {0}, message: {1}", n.File.Name, ex.Message);
|
|
if (ex.IsAbortException())
|
|
throw;
|
|
}
|
|
|
|
var missingDblocks = tp.MissingVolumes.Where(x => x.Type == RemoteVolumeType.Blocks);
|
|
if (!m_options.RebuildMissingDblockFiles && missingDblocks.Count() > 0)
|
|
throw new UserInformationException($"The backup storage destination is missing data files. You can either enable `--rebuild-missing-dblock-files` or run the purge-broken-files command to remove these files. The following files are missing: {string.Join(", ", missingDblocks.Select(x => x.Name))}", "MissingDblockFiles");
|
|
|
|
var anyDlistUploads = false;
|
|
foreach (var (filesetId, timestamp, isfull) in missingRemoteFilesets)
|
|
{
|
|
if (!await m_result.TaskControl.ProgressRendevouz().ConfigureAwait(false))
|
|
{
|
|
await backendManager.WaitForEmptyAsync(db, cancellationToken).ConfigureAwait(false);
|
|
if (!m_options.Dryrun)
|
|
await db.Transaction
|
|
.CommitAsync("CommitEarlyExit", false, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
else
|
|
await db.Transaction
|
|
.RollBackAsync(cancellationToken)
|
|
.ConfigureAwait(false);
|
|
return;
|
|
}
|
|
|
|
progress++;
|
|
m_result.OperationProgressUpdater.UpdateProgress((float)progress / targetProgess);
|
|
var fileTime =
|
|
await FilesetVolumeWriter.ProbeUnusedFilenameName(db, m_options, timestamp, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
var fsw = new FilesetVolumeWriter(m_options, fileTime);
|
|
Logging.Log.WriteInformationMessage(LOGTAG, "ReuploadingFileset", "Re-uploading fileset {0} from {1} as remote volume registration is missing, new filename: {2}", filesetId, timestamp, fsw.RemoteFilename);
|
|
|
|
if (!string.IsNullOrEmpty(m_options.ControlFiles))
|
|
foreach (var p in m_options.ControlFiles.Split(new char[] { System.IO.Path.PathSeparator }, StringSplitOptions.RemoveEmptyEntries))
|
|
fsw.AddControlFile(p, m_options.GetCompressionHintFromFilename(p));
|
|
|
|
fsw.CreateFilesetFile(isfull);
|
|
await db
|
|
.WriteFileset(fsw, filesetId, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
fsw.Close();
|
|
|
|
|
|
fsw.VolumeID = await db
|
|
.RegisterRemoteVolume(fsw.RemoteFilename, RemoteVolumeType.Files, -1, RemoteVolumeState.Temporary, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
await db
|
|
.LinkFilesetToVolume(filesetId, fsw.VolumeID, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
if (m_options.Dryrun)
|
|
{
|
|
fsw.Dispose();
|
|
Logging.Log.WriteDryrunMessage(LOGTAG, "WouldReUploadFileset", "would re-upload fileset {0}", fsw.RemoteFilename);
|
|
continue;
|
|
}
|
|
await backendManager.PutAsync(fsw, null, null, false, null, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
|
|
if (anyDlistUploads)
|
|
{
|
|
await backendManager.WaitForEmptyAsync(db, cancellationToken).ConfigureAwait(false);
|
|
await backendManager.FlushPendingMessagesAsync(db, cancellationToken).ConfigureAwait(false);
|
|
if (!m_options.Dryrun)
|
|
await db.Transaction
|
|
.CommitAsync("CommitFilesetTransaction", token: cancellationToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
|
|
foreach (var volumename in missingLocalFilesets)
|
|
{
|
|
var remoteVolume = await db
|
|
.GetRemoteVolume(volumename, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
using var tmpfile = await backendManager.GetAsync(remoteVolume.Name, remoteVolume.Hash, remoteVolume.Size, cancellationToken).ConfigureAwait(false);
|
|
var parsed = VolumeBase.ParseFilename(remoteVolume.Name);
|
|
using var stream = new FileStream(tmpfile, FileMode.Open, FileAccess.Read, FileShare.Read);
|
|
using var compressor = DynamicLoader.CompressionLoader.GetModule(parsed.CompressionModule, stream, ArchiveMode.Read, m_options.RawOptions);
|
|
await using var recreatedb = await LocalRecreateDatabase.CreateAsync(db, m_options, null, cancellationToken).ConfigureAwait(false);
|
|
if (compressor == null)
|
|
throw new UserInformationException(string.Format("Failed to load compression module: {0}", parsed.CompressionModule), "FailedToLoadCompressionModule");
|
|
|
|
var filesetid = await db
|
|
.CreateFileset(remoteVolume.ID, parsed.Time, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
await RecreateDatabaseHandler.RecreateFilesetFromRemoteList(recreatedb, compressor, filesetid, m_options, new FilterExpression(), cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
if (!m_options.Dryrun)
|
|
await recreatedb.Transaction
|
|
.CommitAsync("CommitRecreateFilesetTransaction", token: cancellationToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
|
|
if (!m_options.Dryrun && tp.MissingVolumes.Any())
|
|
await db
|
|
.TerminatedWithActiveUploads(cancellationToken, true)
|
|
.ConfigureAwait(false);
|
|
|
|
if (tp.MissingVolumes.Any(x => x.Type != RemoteVolumeType.Index && x.Type != RemoteVolumeType.Files && x.Type != RemoteVolumeType.Blocks))
|
|
throw new InvalidOperationException(string.Format("Unknown volume type {0} detected", tp.MissingVolumes.First(x => x.Type != RemoteVolumeType.Index && x.Type != RemoteVolumeType.Files && x.Type != RemoteVolumeType.Blocks).Type));
|
|
|
|
// Process each of the missing volumes in the order of blocks, files and index
|
|
// It is important that we process the blocks first, as the index files are derived from the blocks
|
|
|
|
void incrementProgress()
|
|
{
|
|
progress++;
|
|
m_result.OperationProgressUpdater.UpdateProgress((float)progress / targetProgess);
|
|
}
|
|
|
|
// Blocks are recreated with the entire list of missing files to handle cases where partial recreation is needed
|
|
await RunRepairDblocks(backendManager, db, missingDblocks, incrementProgress, cancellationToken).ConfigureAwait(false);
|
|
|
|
// Filesets are recreated one at a time
|
|
foreach (var n in tp.MissingVolumes.Where(x => x.Type == RemoteVolumeType.Files))
|
|
{
|
|
FilesetVolumeWriter newEntry = null;
|
|
incrementProgress();
|
|
|
|
try
|
|
{
|
|
var timestamp = VolumeBase.ParseFilename(n.Name).Time;
|
|
var fileTime =
|
|
await FilesetVolumeWriter.ProbeUnusedFilenameName(db, m_options, timestamp, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
var volumeWriter = newEntry = new FilesetVolumeWriter(m_options, fileTime);
|
|
|
|
await RunRepairDlist(backendManager, db, volumeWriter, n, fileTime, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
if (newEntry != null)
|
|
try { newEntry?.Dispose(); }
|
|
catch { }
|
|
|
|
Logging.Log.WriteErrorMessage(LOGTAG, "CleanupMissingFileError", ex, "Failed to perform cleanup for missing file: {0}, message: {1}", n.Name, ex.Message);
|
|
|
|
if (ex.IsAbortException())
|
|
throw;
|
|
}
|
|
}
|
|
|
|
// Index files are recreated one at a time, as they are derived from the blocks
|
|
foreach (var n in tp.MissingVolumes.Where(x => x.Type == RemoteVolumeType.Index))
|
|
{
|
|
IndexVolumeWriter newEntry = null;
|
|
incrementProgress();
|
|
|
|
try
|
|
{
|
|
// Check if the index file has already been deleted, beause the dblock was recreated
|
|
var currentState = (await db.GetRemoteVolume(n.Name, cancellationToken).ConfigureAwait(false)).State;
|
|
if (currentState == RemoteVolumeState.Deleted || currentState == RemoteVolumeState.Temporary || currentState == RemoteVolumeState.Deleting)
|
|
continue;
|
|
|
|
var w = newEntry = new IndexVolumeWriter(m_options);
|
|
await RunRepairDindex(backendManager, db, w, n, m_options, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
if (newEntry != null)
|
|
try { newEntry?.Dispose(); }
|
|
catch { }
|
|
|
|
Logging.Log.WriteErrorMessage(LOGTAG, "CleanupMissingFileError", ex, "Failed to perform cleanup for missing file: {0}, message: {1}", n.Name, ex.Message);
|
|
|
|
if (ex.IsAbortException())
|
|
throw;
|
|
}
|
|
}
|
|
|
|
foreach (var emptyIndexFile in emptyIndexFiles)
|
|
{
|
|
try
|
|
{
|
|
if (!await m_result.TaskControl.ProgressRendevouz().ConfigureAwait(false))
|
|
{
|
|
await backendManager.WaitForEmptyAsync(db, cancellationToken).ConfigureAwait(false);
|
|
// Implicit rollback
|
|
await db.Transaction
|
|
.RollBackAsync(cancellationToken)
|
|
.ConfigureAwait(false);
|
|
return;
|
|
}
|
|
|
|
progress++;
|
|
m_result.OperationProgressUpdater.UpdateProgress((float)progress / targetProgess);
|
|
|
|
if (m_options.Dryrun)
|
|
Logging.Log.WriteDryrunMessage(LOGTAG, "WouldDeleteEmptyIndexFile", "would delete empty index file {0}", emptyIndexFile.Name);
|
|
else
|
|
{
|
|
if (emptyIndexFile.Size > 2048)
|
|
{
|
|
Logging.Log.WriteWarningMessage(LOGTAG, "LargeEmptyIndexFile", null, "The empty index file {0} is larger than expected ({1} bytes), choosing not to delete it", emptyIndexFile.Name, emptyIndexFile.Size);
|
|
}
|
|
else
|
|
{
|
|
Logging.Log.WriteInformationMessage(LOGTAG, "DeletingEmptyIndexFile", "Deleting empty index file {0}", emptyIndexFile.Name);
|
|
await backendManager.DeleteAsync(emptyIndexFile.Name, emptyIndexFile.Size, false, cancellationToken).ConfigureAwait(false);
|
|
await backendManager.FlushPendingMessagesAsync(db, cancellationToken).ConfigureAwait(false);
|
|
// This commit mimics the pre
|
|
// Microsoft.Data.Sqlite backend way of not
|
|
// passing down a transaction to
|
|
// FlushPendingMessagesAsync, but maybe it
|
|
// is not needed anymore.
|
|
await db.Transaction
|
|
.CommitAsync(cancellationToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Logging.Log.WriteErrorMessage(LOGTAG, "CleanupEmptyIndexFileError", ex, "Failed to perform cleanup for empty index file: {0}, message: {1}", emptyIndexFile.Name, ex.Message);
|
|
|
|
if (ex.IsAbortException())
|
|
throw;
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
Logging.Log.WriteInformationMessage(LOGTAG, "DatabaseIsSynchronized", "Destination and database are synchronized, not making any changes");
|
|
}
|
|
|
|
m_result.OperationProgressUpdater.UpdateProgress(1);
|
|
await backendManager.WaitForEmptyAsync(db, cancellationToken).ConfigureAwait(false);
|
|
if (!m_options.Dryrun)
|
|
{
|
|
await db
|
|
.TerminatedWithActiveUploads(cancellationToken, false)
|
|
.ConfigureAwait(false);
|
|
await db.Transaction
|
|
.CommitAsync("CommitRepairTransaction", true, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
else
|
|
{
|
|
await db.Transaction
|
|
.RollBackAsync("RollbackRepairTransaction", true, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
}
|
|
catch (Exception)
|
|
{
|
|
// Implicit rollback
|
|
await db.Transaction.RollBackAsync(cancellationToken).ConfigureAwait(false);
|
|
throw;
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Repairs a single fileset by recreating it from the database content and uploading it.
|
|
/// </summary>
|
|
/// <param name="backendManager">The backend manager to use for uploading.</param>
|
|
/// <param name="db">The database to use for the repair.</param>
|
|
/// <param name="volumeWriter">The volume writer to use for the repair.</param>
|
|
/// <param name="originalVolume">The remote volume entry to repair.</param>
|
|
/// <param name="filesetTime">The time of the new fileset to create.</param>
|
|
/// <param name="cancellationToken">Cancellation token to cancel the operation.</param>
|
|
/// <returns>A task representing the asynchronous operation.</returns>
|
|
private async Task RunRepairDlist(IBackendManager backendManager, LocalRepairDatabase db, FilesetVolumeWriter volumeWriter, RemoteVolumeEntry originalVolume, DateTime filesetTime, CancellationToken cancellationToken)
|
|
{
|
|
volumeWriter.VolumeID = await db
|
|
.RegisterRemoteVolume(volumeWriter.RemoteFilename, RemoteVolumeType.Files, RemoteVolumeState.Temporary, -1, TimeSpan.Zero, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
(var prevFilesetId, var _, var isPrevFull) = await db
|
|
.GetFilesetFromRemotename(originalVolume.Name, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
if (!string.IsNullOrEmpty(m_options.ControlFiles))
|
|
foreach (var p in m_options.ControlFiles.Split(new char[] { System.IO.Path.PathSeparator }, StringSplitOptions.RemoveEmptyEntries))
|
|
volumeWriter.AddControlFile(p, m_options.GetCompressionHintFromFilename(p));
|
|
|
|
volumeWriter.CreateFilesetFile(isPrevFull);
|
|
var newFilesetID = await db
|
|
.CreateFileset(volumeWriter.VolumeID, filesetTime, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
await db
|
|
.UpdateFullBackupStateInFileset(newFilesetID, isPrevFull, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
await db
|
|
.LinkFilesetToVolume(newFilesetID, volumeWriter.VolumeID, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
await db
|
|
.MoveFilesFromFileset(newFilesetID, prevFilesetId, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
await db
|
|
.WriteFileset(volumeWriter, newFilesetID, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
volumeWriter.Close();
|
|
|
|
await db
|
|
.UpdateRemoteVolume(volumeWriter.RemoteFilename, RemoteVolumeState.Uploading, -1, null, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
await db
|
|
.UpdateRemoteVolume(originalVolume.Name, RemoteVolumeState.Deleted, originalVolume.Size, originalVolume.Hash, false, TimeSpan.FromHours(2), null, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
await backendManager.FlushPendingMessagesAsync(db, cancellationToken).ConfigureAwait(false);
|
|
|
|
if (m_options.Dryrun)
|
|
Logging.Log.WriteDryrunMessage(LOGTAG, "WouldReUploadFileset", "would upload fileset {0}, with size {1}, previous size {2}", originalVolume.Name, Library.Utility.Utility.FormatSizeString(new System.IO.FileInfo(volumeWriter.LocalFilename).Length), Library.Utility.Utility.FormatSizeString(originalVolume.Size));
|
|
else
|
|
{
|
|
await db.Transaction
|
|
.CommitAsync("CommitPriorToFilesetUpload", true, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
await backendManager.PutAsync(volumeWriter, null, null, false, null, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
|
|
await backendManager.WaitForEmptyAsync(db, cancellationToken).ConfigureAwait(false);
|
|
if (!m_options.Dryrun)
|
|
await db.Transaction
|
|
.CommitAsync("CommitFilesetTransaction", true, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Repairs a single index file by recreating it from the database content and uploading it.
|
|
/// </summary>
|
|
/// <param name="backendManager">The backend manager to use for uploading.</param>
|
|
/// <param name="db">The database to use for the repair.</param>
|
|
/// <param name="indexWriter">The volume writer to use for the repair.</param>
|
|
/// <param name="originalVolume">The remote volume entry to repair.</param>
|
|
/// <param name="options">The options for the current operation.</param>
|
|
/// <param name="cancellationToken">Cancellation token to cancel the operation.</param>
|
|
/// <returns>A task representing the asynchronous operation.</returns>
|
|
public static async Task RunRepairDindex(IBackendManager backendManager, LocalRepairDatabase db, IndexVolumeWriter indexWriter, IRemoteVolume originalVolume, Options options, CancellationToken cancellationToken)
|
|
{
|
|
indexWriter.VolumeID = await db
|
|
.RegisterRemoteVolume(indexWriter.RemoteFilename, RemoteVolumeType.Index, RemoteVolumeState.Uploading, -1, TimeSpan.Zero, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
var blockvolumeids = new List<long>();
|
|
using var h = HashFactory.CreateHasher(options.BlockHashAlgorithm);
|
|
await foreach (var blockvolume in db.GetBlockVolumesFromIndexName(originalVolume.Name, cancellationToken).ConfigureAwait(false))
|
|
{
|
|
indexWriter.StartVolume(blockvolume.Name);
|
|
var volumeid = await db
|
|
.GetRemoteVolumeID(blockvolume.Name, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
await foreach (var b in db.GetBlocks(volumeid, cancellationToken).ConfigureAwait(false))
|
|
indexWriter.AddBlock(b.Hash, b.Size);
|
|
|
|
indexWriter.FinishVolume(blockvolume.Hash, blockvolume.Size);
|
|
blockvolumeids.Add(volumeid);
|
|
|
|
if (options.IndexfilePolicy == Options.IndexFileStrategy.Full)
|
|
await foreach (var b in db.GetBlocklists(volumeid, options.Blocksize, options.BlockhashSize, cancellationToken).ConfigureAwait(false))
|
|
{
|
|
var bh = Convert.ToBase64String(h.ComputeHash(b.Buffer, 0, b.Size));
|
|
if (bh != b.Hash)
|
|
throw new Exception(string.Format("Internal consistency check failed, generated index block has wrong hash, {0} vs {1}", bh, b.Item1));
|
|
|
|
indexWriter.WriteBlocklist(b.Hash, b.Buffer, 0, b.Size);
|
|
}
|
|
}
|
|
|
|
foreach (var blockvolumeid in blockvolumeids)
|
|
await db
|
|
.AddIndexBlockLink(indexWriter.VolumeID, blockvolumeid, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
indexWriter.Close();
|
|
|
|
if (options.Dryrun)
|
|
Logging.Log.WriteDryrunMessage(LOGTAG, "WouldReUploadIndexFile", "would re-upload index file {0}, with size {1}, previous size {2}", originalVolume.Name, Library.Utility.Utility.FormatSizeString(new System.IO.FileInfo(indexWriter.LocalFilename).Length), Library.Utility.Utility.FormatSizeString(originalVolume.Size));
|
|
else
|
|
{
|
|
await db
|
|
.UpdateRemoteVolume(originalVolume.Name, RemoteVolumeState.Deleted, originalVolume.Size, originalVolume.Hash, false, TimeSpan.FromHours(2), null, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
await backendManager.FlushPendingMessagesAsync(db, cancellationToken).ConfigureAwait(false);
|
|
await backendManager.PutAsync(indexWriter, null, null, false, null, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
|
|
await backendManager.WaitForEmptyAsync(db, cancellationToken).ConfigureAwait(false);
|
|
if (!options.Dryrun)
|
|
await db.Transaction
|
|
.CommitAsync("CommitRepairTransaction", true, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Class for holding the state of a dblock volume that is being constructed.
|
|
/// </summary>
|
|
private sealed class InProgressDblockVolumes
|
|
{
|
|
/// <summary>
|
|
/// Database to use for the operation.
|
|
/// </summary>
|
|
private readonly LocalDatabase m_database;
|
|
/// <summary>
|
|
/// List of volumes to delete after the upload is complete.
|
|
/// </summary>
|
|
private readonly List<RemoteVolumeEntry> m_toDelete = new List<RemoteVolumeEntry>();
|
|
/// <summary>
|
|
/// Options for the current operation.
|
|
/// </summary>
|
|
private readonly Options m_options;
|
|
/// <summary>
|
|
/// Maximum size of the volume before it is considered full.
|
|
/// </summary>
|
|
private readonly long m_maxVolumeSize;
|
|
/// <summary>
|
|
/// The writers that are completed and ready to be uploaded.
|
|
/// </summary>
|
|
private readonly List<BlockVolumeWriter> m_completedWriters = new List<BlockVolumeWriter>();
|
|
/// <summary>
|
|
/// Writer for the current in-progress volume.
|
|
/// </summary>
|
|
private BlockVolumeWriter m_activeWriter;
|
|
/// <summary>
|
|
/// Flag indicating if any data has been added to the volume.
|
|
/// </summary>
|
|
private bool m_anyData = false;
|
|
|
|
/// <summary>
|
|
/// Constructor for the InProgressDblockVolume class.
|
|
/// </summary>
|
|
/// <param name="options">The options for the current operation.</param>
|
|
/// <param name="db">The database to use for registering a volume in progress.</param>
|
|
private InProgressDblockVolumes(Options options, LocalDatabase db)
|
|
{
|
|
m_database = db;
|
|
m_options = options;
|
|
m_maxVolumeSize = options.VolumeSize - m_options.Blocksize;
|
|
m_activeWriter = new BlockVolumeWriter(options);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Asynchronously creates a new instance of <see cref="InProgressDblockVolumes"/> and registers the initial volume.
|
|
/// </summary>
|
|
/// <param name="options">The options for the current operation.</param>
|
|
/// <param name="db">The database to use for registering the initial volume.</param>
|
|
/// <param name="cancellationToken">Cancellation token to cancel the operation.</param>
|
|
/// <returns>A task that completes with the new instance of <see cref="InProgressDblockVolumes"/>.</returns>
|
|
public static async Task<InProgressDblockVolumes> CreateAsync(Options options, LocalDatabase db, CancellationToken cancellationToken)
|
|
{
|
|
var ipdv = new InProgressDblockVolumes(options, db);
|
|
ipdv.m_activeWriter.VolumeID = await db
|
|
.RegisterRemoteVolume(ipdv.m_activeWriter.RemoteFilename, RemoteVolumeType.Blocks, RemoteVolumeState.Temporary, -1, TimeSpan.Zero, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
return ipdv;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Checks if any data has been added to the current volume.
|
|
/// </summary>
|
|
public bool AnyData => m_anyData;
|
|
/// <summary>
|
|
/// Checks if the current volume is full.
|
|
/// </summary>
|
|
private bool IsFull => m_activeWriter.Filesize > m_maxVolumeSize;
|
|
|
|
/// <summary>
|
|
/// Gets the volume ID of the current volume.
|
|
/// </summary>
|
|
public long VolumeID => m_activeWriter.VolumeID;
|
|
/// <summary>
|
|
/// Gets the remote filename of the current volume.
|
|
/// </summary>
|
|
public string RemoteFilename => m_activeWriter.RemoteFilename;
|
|
/// <summary>
|
|
/// Gets the list of volumes to delete after the upload is complete.
|
|
/// </summary>
|
|
public List<RemoteVolumeEntry> VolumesToDelete => m_toDelete;
|
|
/// <summary>
|
|
/// Gets the list of completed writers.
|
|
/// </summary>
|
|
public List<BlockVolumeWriter> CompletedWriters => m_completedWriters;
|
|
|
|
/// <summary>
|
|
/// Adds a block to the current volume, starting a new volume if the current one is full.
|
|
/// </summary>
|
|
/// <param name="hash">The hash of the block.</param>
|
|
/// <param name="buffer">The buffer containing the block data.</param>
|
|
/// <param name="offset">The offset in the buffer where the block data starts.</param>
|
|
/// <param name="size">The size of the block data.</param>
|
|
/// <param name="hint">The compression hint for the block.</param>
|
|
/// <param name="cancellationToken">Cancellation token to cancel the operation.</param>
|
|
/// <returns>A task that completes when the block is added.</returns>
|
|
public async Task AddBlock(string hash, byte[] buffer, int offset, int size, CompressionHint hint, CancellationToken cancellationToken)
|
|
{
|
|
await m_activeWriter
|
|
.AddBlock(hash, buffer, offset, size, hint)
|
|
.ConfigureAwait(false);
|
|
m_anyData = true;
|
|
if (IsFull)
|
|
await StartNewVolume(cancellationToken).ConfigureAwait(false);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Starts a new volume for the current operation.
|
|
/// </summary>
|
|
/// <param name="cancellationToken">Cancellation token to cancel the operation.</param>
|
|
/// <returns>A task that completes when the new volume is started.</returns>
|
|
public async Task StartNewVolume(CancellationToken cancellationToken)
|
|
{
|
|
if (!m_anyData)
|
|
return;
|
|
|
|
m_completedWriters.Add(m_activeWriter);
|
|
|
|
m_activeWriter = new BlockVolumeWriter(m_options);
|
|
m_activeWriter.VolumeID = await m_database
|
|
.RegisterRemoteVolume(m_activeWriter.RemoteFilename, RemoteVolumeType.Blocks, RemoteVolumeState.Temporary, -1, TimeSpan.Zero, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
m_anyData = false;
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Runs the repair process for missing dblock files.
|
|
/// </summary>
|
|
/// <param name="backendManager">The backend manager to use for uploading.</param>
|
|
/// <param name="db">The database to use for the repair.</param>
|
|
/// <param name="missingDblockFiles">The list of missing dblock files.</param>
|
|
/// <param name="incrementProgress"><The callback to increment the progress.</param>
|
|
/// <param name="cancellationToken">Cancellation token to cancel the operation.</param>
|
|
/// <returns>>A task that completes when the repair is finished.</returns>
|
|
private async Task RunRepairDblocks(IBackendManager backendManager, LocalRepairDatabase db, IEnumerable<RemoteVolumeEntry> missingDblockFiles, Action incrementProgress, CancellationToken cancellationToken)
|
|
{
|
|
var currentVolume =
|
|
await InProgressDblockVolumes.CreateAsync(m_options, db, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
foreach (var n in missingDblockFiles)
|
|
{
|
|
try
|
|
{
|
|
if (!await m_result.TaskControl.ProgressRendevouz().ConfigureAwait(false))
|
|
{
|
|
await backendManager.WaitForEmptyAsync(db, cancellationToken).ConfigureAwait(false);
|
|
if (!m_options.Dryrun)
|
|
await db.Transaction
|
|
.CommitAsync("CommitEarlyExit", false, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
return;
|
|
}
|
|
|
|
incrementProgress();
|
|
|
|
await RunRepairDblock(backendManager, db, n, currentVolume, cancellationToken).ConfigureAwait(false);
|
|
if (currentVolume.CompletedWriters.Count > 0)
|
|
await UploadCompletedBlockVolumes(backendManager, currentVolume, db, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Logging.Log.WriteErrorMessage(LOGTAG, "RepairDblockError", ex, "Failed to perform repair for dblock: {0}, message: {1}", n.Name, ex.Message);
|
|
if (ex.IsAbortException())
|
|
throw;
|
|
}
|
|
}
|
|
|
|
// If we have any data in the volume, complete it so it will be uploaded
|
|
if (currentVolume.AnyData)
|
|
await currentVolume.StartNewVolume(cancellationToken).ConfigureAwait(false);
|
|
// Complete any pending uploads
|
|
await UploadCompletedBlockVolumes(backendManager, currentVolume, db, cancellationToken).ConfigureAwait(false);
|
|
|
|
// After reset, we need to remove the temporary volume from the database
|
|
await db
|
|
.RemoveRemoteVolume(currentVolume.RemoteFilename, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Uploads all completed block volumes to the backend and deletes the old files.
|
|
/// </summary>
|
|
/// <param name="backendManager">The backend manager to use for uploading.</param>
|
|
/// <param name="activeVolume">The completed volume state to upload.</param>
|
|
/// <param name="db">The database to use for the upload.</param>
|
|
/// <param name="cancellationToken">Cancellation token to cancel the operation.</param>
|
|
/// <returns>>A task that completes when the upload is finished.</returns>
|
|
async Task UploadCompletedBlockVolumes(IBackendManager backendManager, InProgressDblockVolumes activeVolume, LocalRepairDatabase db, CancellationToken cancellationToken)
|
|
{
|
|
foreach (var completedVolume in activeVolume.CompletedWriters)
|
|
{
|
|
await db
|
|
.UpdateRemoteVolume(completedVolume.RemoteFilename, RemoteVolumeState.Uploading, -1, null, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
// Create a new index file that points to the new volume
|
|
IndexVolumeWriter newvolindex = null;
|
|
Func<Task> indexVolumeFinished = null;
|
|
if (m_options.IndexfilePolicy != Options.IndexFileStrategy.None)
|
|
{
|
|
newvolindex = new IndexVolumeWriter(m_options);
|
|
newvolindex.VolumeID = await db
|
|
.RegisterRemoteVolume(newvolindex.RemoteFilename, RemoteVolumeType.Index, RemoteVolumeState.Temporary, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
newvolindex.StartVolume(completedVolume.RemoteFilename);
|
|
await foreach (var b in db.GetBlocks(completedVolume.VolumeID, cancellationToken).ConfigureAwait(false))
|
|
newvolindex.AddBlock(b.Hash, b.Size);
|
|
|
|
await db
|
|
.AddIndexBlockLink(newvolindex.VolumeID, completedVolume.VolumeID, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
if (m_options.IndexfilePolicy == Options.IndexFileStrategy.Full)
|
|
indexVolumeFinished = async () =>
|
|
{
|
|
await foreach (var blocklist in db.GetBlocklists(completedVolume.VolumeID, m_options.Blocksize, m_options.BlockhashSize, cancellationToken).ConfigureAwait(false))
|
|
newvolindex.WriteBlocklist(blocklist.Item1, blocklist.Item2, 0, blocklist.Item3);
|
|
};
|
|
}
|
|
|
|
// All information is in place, we can now upload the new volume
|
|
await backendManager.FlushPendingMessagesAsync(db, cancellationToken).ConfigureAwait(false);
|
|
if (m_options.Dryrun)
|
|
Logging.Log.WriteDryrunMessage(LOGTAG, "WouldReplaceBlockFile", "would upload new block file {0}", completedVolume.RemoteFilename);
|
|
else
|
|
{
|
|
await db.Transaction
|
|
.CommitAsync("PostRepairPreUploadBlockVolume", token: cancellationToken)
|
|
.ConfigureAwait(false);
|
|
await backendManager.PutAsync(completedVolume, newvolindex, indexVolumeFinished, false, null, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
}
|
|
|
|
// Flush the database as we have new volumes uploaded
|
|
await backendManager.WaitForEmptyAsync(db, cancellationToken).ConfigureAwait(false);
|
|
|
|
// Prepare for deleting the old stuff
|
|
foreach (var vol in activeVolume.VolumesToDelete)
|
|
await db
|
|
.UpdateRemoteVolume(vol.Name, RemoteVolumeState.Deleting, vol.Size, vol.Hash, false, TimeSpan.FromHours(2), null, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
// Persist desired state prior to deleting the old files
|
|
if (!m_options.Dryrun)
|
|
await db.Transaction
|
|
.CommitAsync("PostRepairBlockVolume", token: cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
// Delete the old files
|
|
foreach (var vol in activeVolume.VolumesToDelete)
|
|
if (m_options.Dryrun)
|
|
Logging.Log.WriteDryrunMessage(LOGTAG, "WouldDeleteIndexFile", "would delete index file {0}", vol.Name);
|
|
else
|
|
await backendManager.DeleteAsync(vol.Name, vol.Size, false, cancellationToken).ConfigureAwait(false);
|
|
|
|
// All done, the new dblocks are now in place
|
|
await backendManager.WaitForEmptyAsync(db, cancellationToken).ConfigureAwait(false);
|
|
if (!m_options.Dryrun)
|
|
await db.Transaction
|
|
.CommitAsync("PostRepairBlockVolume", token: cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
activeVolume.CompletedWriters.Clear();
|
|
activeVolume.VolumesToDelete.Clear();
|
|
}
|
|
|
|
/// <summary>
|
|
/// Repairs a single dblock file by recreating it from available data.
|
|
/// </summary>
|
|
/// <param name="backendManager">The backend manager to use for uploading.</param>
|
|
/// <param name="db">The database to use for the repair.</param>
|
|
/// <param name="originalVolume">The remote volume entry to recreate.</param>
|
|
/// <param name="pendingVolume">The in-progress dblock volume to use for the recreate.</param>
|
|
/// <param name="cancellationToken">Cancellation token to cancel the operation.</param>
|
|
/// <returns>>A task that completes when the repair is finished.</returns>
|
|
private async Task RunRepairDblock(IBackendManager backendManager, LocalRepairDatabase db, RemoteVolumeEntry originalVolume, InProgressDblockVolumes pendingVolume, CancellationToken cancellationToken)
|
|
{
|
|
// The dblock files are the most complex to recreate
|
|
// as data can be either file contents, metadata or blocklist hashes
|
|
// We attempt to recover all three source parts in the steps below
|
|
await using var mbl = await db
|
|
.CreateBlockList(originalVolume.Name, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
var originalMissingBlockCount = await mbl
|
|
.GetMissingBlockCount(cancellationToken)
|
|
.ConfigureAwait(false);
|
|
var recoveredSourceBlocks = 0L;
|
|
|
|
// First we grab all known blocks from local files
|
|
string lastRestoredHash = null;
|
|
long lastRestoredSize = -1;
|
|
await foreach (var block in mbl.GetSourceFilesWithBlocks(m_options.Blocksize, cancellationToken).ConfigureAwait(false))
|
|
{
|
|
if (block.Hash == lastRestoredHash && block.Size == lastRestoredSize)
|
|
continue;
|
|
|
|
var size = (int)block.Size;
|
|
|
|
try
|
|
{
|
|
if (!File.Exists(block.File))
|
|
{
|
|
Logging.Log.WriteVerboseMessage(LOGTAG, "FileNotFound", null, "File not found: {0}", block.File);
|
|
continue;
|
|
}
|
|
|
|
using var f = File.OpenRead(block.File);
|
|
f.Position = block.Offset;
|
|
|
|
var buffer = new byte[m_options.Blocksize];
|
|
if (size != Library.Utility.Utility.ForceStreamRead(f, buffer, size))
|
|
{
|
|
Logging.Log.WriteVerboseMessage(LOGTAG, "FileLengthMismatch", null, "Block length mismatch on {0}, expected {1} but got {2}", block.File, size, f.Length);
|
|
continue;
|
|
}
|
|
|
|
using var blockhasher = HashFactory.CreateHasher(m_options.BlockHashAlgorithm);
|
|
var newhash = Convert.ToBase64String(blockhasher.ComputeHash(buffer, 0, size));
|
|
if (newhash != block.Hash)
|
|
{
|
|
Logging.Log.WriteVerboseMessage(LOGTAG, "FileHashMismatch", null, "Block hash mismatch on {0}, expected {1} but got {2}", block.File, block.Hash, newhash);
|
|
continue;
|
|
}
|
|
|
|
// Found it, no need to look again
|
|
lastRestoredHash = block.Hash;
|
|
lastRestoredSize = block.Size;
|
|
if (await mbl.SetBlockRestored(block.Hash, block.Size, pendingVolume.VolumeID, cancellationToken).ConfigureAwait(false))
|
|
{
|
|
recoveredSourceBlocks++;
|
|
await pendingVolume
|
|
.AddBlock(block.Hash, buffer, 0, size, CompressionHint.Default, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Logging.Log.WriteErrorMessage(LOGTAG, "FileAccessError", ex, "Failed to access file: {0}", block.File);
|
|
}
|
|
}
|
|
|
|
// Then grab all blocks with metadata
|
|
await foreach (var block in mbl.GetSourceItemsWithMetadataBlocks(cancellationToken).ConfigureAwait(false))
|
|
{
|
|
if (block.Hash == lastRestoredHash && block.Size == lastRestoredSize)
|
|
continue;
|
|
|
|
var size = (int)block.Size;
|
|
|
|
try
|
|
{
|
|
var isFile = File.Exists(block.Path);
|
|
var isDir = Directory.Exists(block.Path);
|
|
if (!isFile && !isDir)
|
|
{
|
|
Logging.Log.WriteVerboseMessage(LOGTAG, "EntryNotFound", null, "Entry not found: {0}", block.Path);
|
|
continue;
|
|
}
|
|
|
|
using var snapshot = Snapshots.SnapshotUtility.CreateNoSnapshot([block.Path], m_options.IgnoreAdvisoryLocking, m_options.SymlinkPolicy == Options.SymlinkStrategy.Follow, PermissionHelper.HasSeBackupPrivilege(), m_options.HandleMacOSPhotoLibrary, m_options.MacOSPhotoLibraryPath);
|
|
var entry = snapshot.GetFilesystemEntry(block.Path, isDir);
|
|
if (entry == null)
|
|
{
|
|
Logging.Log.WriteErrorMessage(LOGTAG, "FileAccessError", null, "Entry not found: {0}", block.Path);
|
|
continue;
|
|
}
|
|
|
|
var metadata = MetadataGenerator.GenerateMetadata(entry, entry.Attributes, m_options);
|
|
var metahash = Utility.WrapMetadata(metadata, m_options);
|
|
if (metahash.FileHash != block.Hash || metahash.Blob.Length != size)
|
|
{
|
|
Logging.Log.WriteVerboseMessage(LOGTAG, "MetadataHashMismatch", null, "Metadata block hash mismatch on {0}, expected {1} but got {2}", block.Path, block.Hash, metahash.FileHash);
|
|
continue;
|
|
}
|
|
|
|
// Found it, no need to look again
|
|
lastRestoredHash = block.Hash;
|
|
lastRestoredSize = block.Size;
|
|
if (await mbl.SetBlockRestored(block.Hash, block.Size, pendingVolume.VolumeID, cancellationToken).ConfigureAwait(false))
|
|
{
|
|
recoveredSourceBlocks++;
|
|
await pendingVolume
|
|
.AddBlock(block.Hash, metahash.Blob, 0, metahash.Blob.Length, CompressionHint.Default, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Logging.Log.WriteErrorMessage(LOGTAG, "FileAccessError", ex, "Failed to access file: {0}", block.Path);
|
|
}
|
|
}
|
|
|
|
// If we did not find any source blocks,
|
|
// we only have the database contents and duplicated blocks to work with
|
|
// so no point in creating a new dblock volume for storing this data
|
|
if (recoveredSourceBlocks != 0)
|
|
{
|
|
// Then restore any blocklists that are missing
|
|
using var blocklistHash = new MemoryStream();
|
|
LocalRepairDatabase.BlocklistHashesEntry lastBlocklist = null;
|
|
var blockhashsize = m_options.BlockhashSize;
|
|
var hashesPerBlock = m_options.Blocksize / m_options.BlockhashSize;
|
|
|
|
// Helper function to emit a blocklist hash
|
|
async Task EmitBlockListBlock()
|
|
{
|
|
blocklistHash.Position = 0;
|
|
using var blockhasher = HashFactory.CreateHasher(m_options.BlockHashAlgorithm);
|
|
var resulthash = Convert.ToBase64String(blockhasher.ComputeHash(blocklistHash));
|
|
var totalHashes = (lastBlocklist.BlocklistHashLength + m_options.Blocksize - 1) / m_options.Blocksize;
|
|
var hashesInLastBlock = totalHashes % hashesPerBlock;
|
|
var targetsize = lastBlocklist.Index >= totalHashes - 1
|
|
? hashesInLastBlock * blockhashsize
|
|
: hashesPerBlock * blockhashsize;
|
|
|
|
if (resulthash == lastBlocklist.BlocklistHash && targetsize == blocklistHash.Length)
|
|
{
|
|
if (await mbl.SetBlockRestored(resulthash, blocklistHash.Length, pendingVolume.VolumeID, cancellationToken).ConfigureAwait(false))
|
|
await pendingVolume
|
|
.AddBlock(resulthash, blocklistHash.ToArray(), 0, (int)blocklistHash.Length, CompressionHint.Default, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
else
|
|
{
|
|
Logging.Log.WriteWarningMessage(LOGTAG, "BlocklistHashMismatch", null, "Internal consistency issue: blocklist hash mismatch on {0} / {1}, expected {2} but got {3}", lastBlocklist.BlocklistHash, lastBlocklist.Index, lastBlocklist.Hash, resulthash);
|
|
}
|
|
|
|
blocklistHash.SetLength(0);
|
|
}
|
|
|
|
await foreach (var blocklist in mbl.GetBlocklistHashes(hashesPerBlock, cancellationToken).ConfigureAwait(false))
|
|
{
|
|
lastBlocklist ??= blocklist;
|
|
|
|
if (lastBlocklist.BlocksetId != blocklist.BlocksetId || lastBlocklist.BlocklistHashIndex != blocklist.BlocklistHashIndex)
|
|
await EmitBlockListBlock().ConfigureAwait(false);
|
|
|
|
var data = Convert.FromBase64String(blocklist.Hash);
|
|
blocklistHash.Write(data, 0, data.Length);
|
|
lastBlocklist = blocklist;
|
|
}
|
|
|
|
// Handle any trailing blocklist hash
|
|
if (blocklistHash.Length > 0)
|
|
await EmitBlockListBlock().ConfigureAwait(false);
|
|
|
|
//Then we grab all remote volumes that have the missing blocks
|
|
await foreach (var (tmpfile, _, _, name) in backendManager.GetFilesOverlappedAsync(await mbl.GetMissingBlockSources(cancellationToken).ToListAsync(cancellationToken: cancellationToken).ConfigureAwait(false), cancellationToken).ConfigureAwait(false))
|
|
{
|
|
try
|
|
{
|
|
var buffer = new byte[m_options.Blocksize];
|
|
using (tmpfile)
|
|
using (var f = new BlockVolumeReader(RestoreHandler.GetCompressionModule(name), tmpfile, m_options))
|
|
foreach (var b in f.Blocks)
|
|
if (await mbl.SetBlockRestored(b.Key, b.Value, pendingVolume.VolumeID, cancellationToken).ConfigureAwait(false))
|
|
if (f.ReadBlock(b.Key, buffer) == b.Value)
|
|
await pendingVolume
|
|
.AddBlock(b.Key, buffer, 0, (int)b.Value, CompressionHint.Default, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Logging.Log.WriteErrorMessage(LOGTAG, "RemoteFileAccessError", ex, "Failed to access remote file: {0}", name);
|
|
}
|
|
}
|
|
}
|
|
|
|
var missingBlocks = await mbl
|
|
.GetMissingBlockCount(cancellationToken)
|
|
.ConfigureAwait(false);
|
|
var recoveredBlocks = originalMissingBlockCount - missingBlocks;
|
|
if (recoveredBlocks == 0 || (m_options.DisablePartialDblockRecovery && missingBlocks > 0))
|
|
{
|
|
Logging.Log.WriteInformationMessage(LOGTAG, "RepairMissingBlocks", "Repair cannot acquire {0} required blocks for volume {1}, which are required by the following filesets: ", missingBlocks, originalVolume.Name);
|
|
await foreach (var f in mbl.GetFilesetsUsingMissingBlocks(cancellationToken).ConfigureAwait(false))
|
|
Logging.Log.WriteInformationMessage(LOGTAG, "AffectedFilesetName", f.Name);
|
|
|
|
var recoverymsg = string.Format("If you want to continue working with the database, you can use the \"{0}\" and \"{1}\" commands to purge the missing data from the database and the remote storage.", "list-broken-files", "purge-broken-files");
|
|
var logmsg = string.Format("Repair not possible, missing {0} blocks.\n" + recoverymsg, missingBlocks);
|
|
|
|
Logging.Log.WriteInformationMessage(LOGTAG, "RecoverySuggestion", null, logmsg);
|
|
throw new UserInformationException(logmsg, "RepairIsNotPossible");
|
|
}
|
|
else if (recoveredBlocks > 0)
|
|
{
|
|
if (missingBlocks > 0)
|
|
Logging.Log.WriteWarningMessage(LOGTAG, "RepairMissingBlocks", null, "Repair acquired {0} blocks for volume {1}, but {2} blocks are still missing. If you want to continue working with the database, you can use the \"{3}\" and \"{4}\" commands to purge the missing data from the database and the remote storage.", recoveredBlocks, originalVolume.Name, missingBlocks, "list-broken-files", "purge-broken-files");
|
|
|
|
// If we cannot fully recover the blocks, we will not be able to delete the old files.
|
|
// They will instead be registered with duplicated blocks, so the purge-broken-files command
|
|
// can remove them cleanly later
|
|
if (missingBlocks == 0)
|
|
{
|
|
pendingVolume.VolumesToDelete.Add(originalVolume);
|
|
var oldIndexFiles = await db
|
|
.GetIndexFilesReferencingBlockFile(originalVolume.ID, cancellationToken)
|
|
.ToListAsync(cancellationToken: cancellationToken)
|
|
.ConfigureAwait(false);
|
|
|
|
// Find all index files that point to the old volume
|
|
foreach (var oldIndexFile in oldIndexFiles)
|
|
{
|
|
var oldVolume = await db
|
|
.GetRemoteVolume(oldIndexFile, cancellationToken)
|
|
.ConfigureAwait(false);
|
|
if (oldVolume.State == RemoteVolumeState.Uploading || oldVolume.State == RemoteVolumeState.Uploaded || oldVolume.State == RemoteVolumeState.Verified)
|
|
{
|
|
var blockVolumesReferenced = await db
|
|
.GetBlockVolumesFromIndexName(oldIndexFile, cancellationToken)
|
|
.ToListAsync(cancellationToken: cancellationToken)
|
|
.ConfigureAwait(false);
|
|
if (blockVolumesReferenced.Any(x => x.Name != originalVolume.Name))
|
|
Logging.Log.WriteVerboseMessage(LOGTAG, "IndexFileNotDeleted", null, "Index file {0} references multiple remote volumes, skipping", oldVolume.Name);
|
|
else
|
|
pendingVolume.VolumesToDelete.Add(oldVolume);
|
|
}
|
|
else
|
|
{
|
|
Logging.Log.WriteVerboseMessage(LOGTAG, "IndexFileNotDeleted", null, "Index file {0} is not in a state to be deleted, skipping", oldVolume.Name);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Runs the repair process for broken filesets in the database.
|
|
/// </summary>
|
|
/// <param name="backendManager">The backend manager to use for accessing remote files.</param>
|
|
/// <returns>>A task that completes when the repair is finished.</returns>
|
|
/// <exception cref="UserInformationException">If the database doesn't exist.</exception>
|
|
public async Task RunRepairBrokenFilesets(IBackendManager backendManager)
|
|
{
|
|
if (!File.Exists(m_options.Dbpath))
|
|
throw new UserInformationException(string.Format("Database file does not exist: {0}", m_options.Dbpath), "DatabaseDoesNotExist");
|
|
|
|
await using var db =
|
|
await LocalRepairDatabase.CreateRepairDatabase(m_options.Dbpath, null, m_result.TaskControl.ProgressToken)
|
|
.ConfigureAwait(false);
|
|
|
|
var sets = await db
|
|
.GetFilesetsWithMissingFiles(m_result.TaskControl.ProgressToken)
|
|
.ToListAsync(cancellationToken: m_result.TaskControl.ProgressToken)
|
|
.ConfigureAwait(false);
|
|
|
|
if (sets.Count == 0)
|
|
return;
|
|
|
|
Logging.Log.WriteInformationMessage(LOGTAG, "RepairingBrokenFilesets", "Repairing {0} broken filesets", sets.Count);
|
|
var ix = 0;
|
|
foreach (var entry in sets)
|
|
{
|
|
ix++;
|
|
Logging.Log.WriteInformationMessage(LOGTAG, "RepairingBrokenFileset", "Repairing broken fileset {0} of {1}: {2}", ix, sets.Count, entry.Value);
|
|
var volume = await db
|
|
.GetRemoteVolumeFromFilesetID(entry.Key, m_result.TaskControl.ProgressToken)
|
|
.ConfigureAwait(false);
|
|
var parsed = VolumeBase.ParseFilename(volume.Name);
|
|
using var tmpfile = await backendManager.GetAsync(volume.Name, volume.Hash, volume.Size, CancellationToken.None).ConfigureAwait(false);
|
|
using var stream = new FileStream(tmpfile, FileMode.Open, FileAccess.Read, FileShare.Read);
|
|
using var compressor = DynamicLoader.CompressionLoader.GetModule(parsed.CompressionModule, stream, ArchiveMode.Read, m_options.RawOptions);
|
|
if (compressor == null)
|
|
throw new UserInformationException(string.Format("Failed to load compression module: {0}", parsed.CompressionModule), "FailedToLoadCompressionModule");
|
|
|
|
// Clear out the old fileset
|
|
await db
|
|
.DeleteFilesetEntries(entry.Key, m_result.TaskControl.ProgressToken)
|
|
.ConfigureAwait(false);
|
|
await using (var rdb = await LocalRecreateDatabase.CreateAsync(db, m_options, null, m_result.TaskControl.ProgressToken).ConfigureAwait(false))
|
|
{
|
|
await RecreateDatabaseHandler.RecreateFilesetFromRemoteList(rdb, compressor, entry.Key, m_options, new FilterExpression(), m_result.TaskControl.ProgressToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
|
|
await db.Transaction
|
|
.CommitAsync("PostRepairFileset", true, m_result.TaskControl.ProgressToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Runs the common repair operations on the database, such as fixing duplicate entries and missing blocklist hashes.
|
|
/// This method does not require any remote access and can be run without a backend manager.
|
|
/// </summary>
|
|
/// <returns>A task that completes when the repair is finished.</returns>
|
|
/// <exception cref="UserInformationException">If the database file does not exist.</exception>
|
|
public async Task RunRepairCommon()
|
|
{
|
|
if (!File.Exists(m_options.Dbpath))
|
|
throw new UserInformationException(string.Format("Database file does not exist: {0}", m_options.Dbpath), "DatabaseDoesNotExist");
|
|
|
|
m_result.OperationProgressUpdater.UpdateProgress(0);
|
|
|
|
await using var db =
|
|
await LocalRepairDatabase.CreateRepairDatabase(m_options.Dbpath, null, m_result.TaskControl.ProgressToken)
|
|
.ConfigureAwait(false);
|
|
|
|
await Utility.UpdateOptionsFromDb(db, m_options, m_result.TaskControl.ProgressToken)
|
|
.ConfigureAwait(false);
|
|
|
|
if (await db.RepairInProgress(m_result.TaskControl.ProgressToken).ConfigureAwait(false) || await db.PartiallyRecreated(m_result.TaskControl.ProgressToken).ConfigureAwait(false))
|
|
Logging.Log.WriteWarningMessage(LOGTAG, "InProgressDatabase", null, "The database is marked as \"in-progress\" and may be incomplete.");
|
|
|
|
await db.FixDuplicateMetahash(m_result.TaskControl.ProgressToken).ConfigureAwait(false);
|
|
await db.FixDuplicateFileentries(m_result.TaskControl.ProgressToken).ConfigureAwait(false);
|
|
await db
|
|
.FixDuplicateBlocklistHashes(m_options.Blocksize, m_options.BlockhashSize, m_result.TaskControl.ProgressToken)
|
|
.ConfigureAwait(false);
|
|
await db
|
|
.FixMissingBlocklistHashes(m_options.BlockHashAlgorithm, m_options.Blocksize, m_result.TaskControl.ProgressToken)
|
|
.ConfigureAwait(false);
|
|
await db
|
|
.FixEmptyMetadatasets(m_options, m_result.TaskControl.ProgressToken)
|
|
.ConfigureAwait(false);
|
|
}
|
|
}
|
|
}
|