On 12/13/2017 03:46 PM, Wolfgang Link wrote:
> If last_sync is 0 then the VM config was stolen
> or the VM migrated by HA manager in case of a node failure.

note:
We use the 'stolen' terminology in the HA manager too, the function
responsible for it is even called 'steal_service' :)

If last_sync is 0 then the VM config was stolen (either manually or
by HA recovery).

> On this precondition the replication snapshot should not deleted.
> This snapshot will be used to restore the replication.
> ---
>  PVE/Replication.pm | 9 ++++++---
>  1 file changed, 6 insertions(+), 3 deletions(-)
> 
> diff --git a/PVE/Replication.pm b/PVE/Replication.pm
> index ce2109e..dac0994 100644
> --- a/PVE/Replication.pm
> +++ b/PVE/Replication.pm
> @@ -134,10 +134,13 @@ sub prepare {
>           if ((defined($snapname) && ($snap eq $snapname)) ||
>               (defined($parent_snapname) && ($snap eq $parent_snapname))) {
>               $last_snapshots->{$volid}->{$snap} = 1;
> -         } elsif ($snap =~ m/^\Q$prefix\E/) {
> +         } elsif ($snap =~ m/^\Q$prefix\E/ && $last_sync != 0) {
>               $logfunc->("delete stale replication snapshot '$snap' on 
> $volid");
>               PVE::Storage::volume_snapshot_delete($storecfg, $volid, $snap);
>               $cleaned_replicated_volumes->{$volid} = 1;
> +         # Last_sync=0 and a replication snapshot only occur, if the VM was 
> stolen
> +         } elsif ($snap =~ m/^\Q$prefix\E/) {

Hmm, with this we have to checks for if the $snap matches the prefix,
maybe do something in the like of:

} elsif ($snap =~ m/^\Q$prefix\E/) {
     if ($last_sync) {
           ...
     } else {
          # last_sync==0 but a snapshot => the VM was stolen (HA or manual move)
          $last_snapshots->{$volid}->{$snap} = 1;
     }
}


> +             $last_snapshots->{$volid}->{$snap} = 1;
>           }
>       }
>      }
> @@ -207,11 +210,11 @@ sub replicate {
>           }
>  
>           my $ssh_info = PVE::Cluster::get_ssh_info($jobcfg->{target});
> -         remote_prepare_local_job($ssh_info, $jobid, $vmid, [], $store_list, 
> 0, undef, 1, $logfunc);
> +         remote_prepare_local_job($ssh_info, $jobid, $vmid, [], $store_list, 
> 1, undef, 1, $logfunc);
>  
>       }
>       # remove all local replication snapshots (lastsync => 0)

you change last_sync to 1 below, does the comment above still holds?

> -     prepare($storecfg, $sorted_volids, $jobid, 0, undef, $logfunc);
> +     prepare($storecfg, $sorted_volids, $jobid, 1, undef, $logfunc);
>  
>       PVE::ReplicationConfig::delete_job($jobid); # update config
>       $logfunc->("job removed");
> 


_______________________________________________
pve-devel mailing list
pve-devel@pve.proxmox.com
https://pve.proxmox.com/cgi-bin/mailman/listinfo/pve-devel

Reply via email to