[pve-devel] [PATCH pve-manager 1/3] fix #3903: jobs-plugin: add remove vmid from jobs helper

[Hannes Laimer <h.laimer@proxmox.com>]

Signed-off-by: Hannes Laimer <h.laimer@proxmox.com>
---
 PVE/Jobs/Plugin.pm | 19 ++++++++++++++++++-
 1 file changed, 18 insertions(+), 1 deletion(-)

diff --git a/PVE/Jobs/Plugin.pm b/PVE/Jobs/Plugin.pm
index 6098360b..4883a193 100644
--- a/PVE/Jobs/Plugin.pm
+++ b/PVE/Jobs/Plugin.pm
@@ -3,7 +3,7 @@ package PVE::Jobs::Plugin;
 use strict;
 use warnings;
 
-use PVE::Cluster qw(cfs_register_file);
+use PVE::Cluster qw(cfs_register_file cfs_lock_file cfs_read_file cfs_write_file);
 
 use base qw(PVE::SectionConfig);
 
@@ -92,6 +92,23 @@ sub write_config {
     $class->SUPER::write_config($filename, $cfg);
 }
 
+sub remove_vmid_from_jobs {
+    my ($vmid) = @_;
+    cfs_lock_file('jobs.cfg', undef, sub {
+	my $jobs_data = cfs_read_file('jobs.cfg');
+	while((my $id, my $job) = each (%{$jobs_data->{ids}})){
+	    next if !defined($job->{vmid});
+	    $job->{vmid} = join(',', grep { $_ ne $vmid } PVE::Tools::split_list($job->{vmid}));
+	    if ($job->{vmid} eq '') {
+		delete $jobs_data->{ids}->{$id};
+	    } else {
+		$jobs_data->{ids}->{$id} = $job;
+	    }
+	}
+	cfs_write_file('jobs.cfg', $jobs_data);
+    });
+}
+
 sub run {
     my ($class, $cfg) = @_;
     # implement in subclass
-- 
2.30.2