From 40bcf6526b0b9e192fc01e7a3712e67ee4ce592c Mon Sep 17 00:00:00 2001 From: Dietmar Maurer Date: Wed, 28 Jun 2017 12:05:18 +0200 Subject: [PATCH] fix previous commit --- PVE/ReplicationState.pm | 2 ++ 1 file changed, 2 insertions(+) diff --git a/PVE/ReplicationState.pm b/PVE/ReplicationState.pm index 1e74809..09f6283 100644 --- a/PVE/ReplicationState.pm +++ b/PVE/ReplicationState.pm @@ -319,10 +319,12 @@ sub get_next_job { sub schedule_job_now { my ($jobcfg) = @_; + PVE::GuestHelpers::guest_migration_lock($jobcfg->{guest}, undef, sub { PVE::Tools::lock_file($state_lock, 10, sub { my $stateobj = read_state(); my $vmid = $jobcfg->{guest}; + my $plugin = PVE::ReplicationConfig->lookup($jobcfg->{type}); my $tid = $plugin->get_unique_target_id($jobcfg); # no not modify anything if there is no state return if !defined($stateobj->{$vmid}->{$tid}); -- 2.39.2