proxmox-mirrors/pve-guest-common
1
0
Fork 0
mirror of https://git.proxmox.com/git/pve-guest-common synced 2025-08-15 14:28:33 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

replication: find common snapshot: use additional information

Browse Source 
which is now available from the storage back-end.

The benefits are:

1. Ability to detect different snapshots even if they have the same
name. Rather hard to reach, but for example with:
Snapshots A -> B -> C -> __replicationXYZ
Remove B, rollback to C (causes __replicationXYZ to be removed),
create a new snapshot B. Previously, B was selected as replication
base, but it didn't match on source and target. Now, C is correctly
selected.
2. Smaller delta in some cases by not prefering replication snapshots
over config snapshots, but using the most recent possible one from
both types of snapshots.
3. Less code complexity for snapshot selection.

If the remote side is old, it's not possible to detect mismatch of
distinct snapshots with the same name, but the timestamps from the
local side can still be used.

Still limit to our snapshots (config and replication), because we
don't have guarantees for other snapshots (could be deleted in the
meantime, name might not fit import/export regex, etc.).

Signed-off-by: Fabian Ebner <f.ebner@proxmox.com>
This commit is contained in:
Fabian Ebner 2021-10-19 09:54:55 +02:00 committed by Fabian Grünbichler
parent 3200c404a9
commit b20bf9bf7d
1 changed files with 24 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
src/PVE/Replication.pm
View File

@ -31,6 +31,7 @@ sub find_common_replication_snapshot {
my ($ssh_info, $jobid, $vmid, $storecfg, $volumes, $storeid_list, $last_sync, $guest_conf, $logfunc) = @_;
my $parent_snapname = $guest_conf->{parent};
my $conf_snapshots = $guest_conf->{snapshots};
my $last_sync_snapname =
PVE::ReplicationState::replication_snapshot_name($jobid, $last_sync);
@ -57,24 +58,35 @@ sub find_common_replication_snapshot {
my $base_snapshots = {};
foreach my $volid (@$volumes) {
if (defined($last_snapshots->{$volid}) && defined($remote_snapshots->{$volid})) {
if ($last_snapshots->{$volid}->{$last_sync_snapname} &&
$remote_snapshots->{$volid}->{$last_sync_snapname}) {
my $local_info = $last_snapshots->{$volid};
my $remote_info = $remote_snapshots->{$volid};
if (defined($local_info) && defined($remote_info)) {
my $common_snapshot = sub {
my ($snap) = @_;
return 0 if !$local_info->{$snap} || !$remote_info->{$snap};
# Check for ID if remote side supports it already.
return $local_info->{$snap}->{id} eq $remote_info->{$snap}->{id}
if ref($remote_info->{$snap}) eq 'HASH';
return 1;
};
if ($common_snapshot->($last_sync_snapname)) {
$base_snapshots->{$volid} = $last_sync_snapname;
} elsif (defined($parent_snapname) &&
($last_snapshots->{$volid}->{$parent_snapname} &&
$remote_snapshots->{$volid}->{$parent_snapname})) {
} elsif (defined($parent_snapname) && $common_snapshot->($parent_snapname)) {
$base_snapshots->{$volid} = $parent_snapname;
} else {
# First, try all replication snapshots.
my $most_recent = [0, undef];
for my $remote_snap (keys $remote_snapshots->{$volid}->%*) {
next if !defined($last_snapshots->{$volid}->{$remote_snap});
for my $snapshot (keys $local_info->%*) {
next if !$common_snapshot->($snapshot);
next if !$conf_snapshots->{$snapshot} && !is_replication_snapshot($snapshot);
my $timestamp = ($remote_snap =~ /__replicate_\Q$vmid\E-(?:\d+)_(\d+)_/)[0];
next if !$timestamp;
my $timestamp = $local_info->{$snapshot}->{timestamp};
$most_recent = [$timestamp, $remote_snap] if $timestamp > $most_recent->[0];
$most_recent = [$timestamp, $snapshot] if $timestamp > $most_recent->[0];
}
if ($most_recent->[1]) {
@ -82,25 +94,6 @@ sub find_common_replication_snapshot {
next;
}
# Then, try config snapshots ($parent_snapname was already tested for above).
my $snapname = $parent_snapname // '';
# Be robust against loop, just in case.
# https://forum.proxmox.com/threads/snapshot-not-working.69511/post-312281
my $max_count = scalar(keys $guest_conf->{snapshots}->%*);
for (my $count = 0; $count < $max_count; $count++) {
last if defined($base_snapshots->{$volid});
my $snap_conf = $guest_conf->{snapshots}->{$snapname} || last;
$snapname = $snap_conf->{parent} // last;
if ($last_snapshots->{$volid}->{$snapname} &&
$remote_snapshots->{$volid}->{$snapname})
{
$base_snapshots->{$volid} = $snapname;
}
}
# The volume exists on the remote side, so trying a full sync won't work.
# Die early with a clean error.
die "No common base to restore the job state\n".