PVE::Replication::prepare - allow to pass undefined $jobid

And remove all replication snapshots in that case. This is useful
for snapshot rollback.

diff --git a/PVE/Replication.pm b/PVE/Replication.pm
index f978267e1f6ad7d9f7b3763a8c17b8013b510c4b..0fa0ffec96015cdbd8c8eb1e3b55f5f706dee7a0 100644 (file)
--- a/PVE/Replication.pm
+++ b/PVE/Replication.pm
@@ -79,15 +79,21 @@ sub prepare {
 
     $last_sync //= 0;
 
-    my ($prefix, $snapname) =
-       PVE::ReplicationState::replication_snapshot_name($jobid, $last_sync);
+    my ($prefix, $snapname);
+
+    if (defined($jobid)) {
+       ($prefix, $snapname) = PVE::ReplicationState::replication_snapshot_name($jobid, $last_sync);
+    } else {
+       $prefix = '__replicate_';
+    }
 
     my $last_snapshots = {};
     my $cleaned_replicated_volumes = {};
     foreach my $volid (@$volids) {
        my $list = PVE::Storage::volume_snapshot_list($storecfg, $volid);
        foreach my $snap (@$list) {
-           if ($snap eq $snapname || (defined($parent_snapname) && ($snap eq $parent_snapname))) {
+           if ((defined($snapname) && ($snap eq $snapname)) ||
+               (defined($parent_snapname) && ($snap eq $parent_snapname))) {
                $last_snapshots->{$volid}->{$snap} = 1;
            } elsif ($snap =~ m/^\Q$prefix\E/) {
                $logfunc->("delete stale replication snapshot '$snap' on $volid");