Swap source and target in replication config, if VM was stolen.

diff --git a/PVE/ReplicationState.pm b/PVE/ReplicationState.pm
index 085119574dfbe02ecc2f43511e9df8612a05bfc3..2851b626331d6e926a594a3e7dd1ec2971e29bb1 100644 (file)
--- a/PVE/ReplicationState.pm
+++ b/PVE/ReplicationState.pm
@@ -254,8 +254,17 @@ sub job_status {
 
        my $target = $jobcfg->{target};
        if (!$jobcfg->{remove_job}) {
-           # never sync to local node
-           next if $target eq $local_node;
+           # check if vm was stolen (swapped source target)
+           if ($target eq $local_node) {
+               my $source = $jobcfg->{source};
+               if (defined($source) && $source ne $target) {
+                   $jobcfg = PVE::ReplicationConfig::swap_source_target_nolock($jobid);
+                   $cfg->{ids}->{$jobid} = $jobcfg;
+               } else {
+                   # never sync to local node
+                   next;
+               }
+           }
 
            next if !$get_disabled && $jobcfg->{disable};
        }