vnetplugin: on_delete_hook : verify if vnet exist in vm && ct

[pve-network.git] / PVE / Network / Network / VnetPlugin.pm

diff --git a/PVE/Network/Network/VnetPlugin.pm b/PVE/Network/Network/VnetPlugin.pm
index c2a4020786784e4d6dd3401c673fdef3151fccc5..f14db35d9e20632815f0a7bc6d9f5265f962321c 100644 (file)
--- a/PVE/Network/Network/VnetPlugin.pm
+++ b/PVE/Network/Network/VnetPlugin.pm
@@ -6,6 +6,12 @@ use PVE::Network::Network::Plugin;
 
 use base('PVE::Network::Network::Plugin');
 
+use PVE::Cluster;
+use PVE::LXC;
+use PVE::LXC::Config;
+use PVE::QemuServer;
+use PVE::QemuConfig;
+
 sub type {
     return 'vnet';
 }
@@ -17,16 +23,14 @@ sub properties {
        transportzone => {
             type => 'string',
             description => "transportzone id",
-           optional => 1,
        },
        tag => {
             type => 'integer',
             description => "vlan or vxlan id",
-           optional => 1,
        },
-        name => {
+        alias => {
             type => 'string',
-            description => "name of the network",
+            description => "alias name of the vnet",
            optional => 1,
         },
         mtu => {
@@ -54,15 +58,78 @@ sub properties {
 
 sub options {
     return {
-        transportzone => { optional => 1 },
-        tag => { optional => 1 },
-        name => { optional => 1 },
+        transportzone => { optional => 0},
+        tag => { optional => 0},
+        alias => { optional => 1 },
         ipv4 => { optional => 1 },
         ipv6 => { optional => 1 },
-        name => { optional => 1 },
         mtu => { optional => 1 },
     };
 }
 
+sub on_delete_hook {
+    my ($class, $networkid, $scfg) = @_;
+
+    # verify than no vm or ct have interfaces in this bridge
+    my $vmdata = read_local_vm_config();
+
+    foreach my $vmid (sort keys %{$vmdata->{qemu}}) {
+       my $conf = $vmdata->{qemu}->{$vmid};
+       foreach my $netid (sort keys %$conf) {
+           next if $netid !~ m/^net(\d+)$/;
+           my $net = PVE::QemuServer::parse_net($conf->{$netid});
+           die "vnet $networkid is used by vm $vmid" if $net->{bridge} eq $networkid;
+       }
+    }
+
+    foreach my $vmid (sort keys %{$vmdata->{lxc}}) {
+       my $conf = $vmdata->{lxc}->{$vmid};
+       foreach my $netid (sort keys %$conf) {
+           next if $netid !~ m/^net(\d+)$/;
+           my $net = PVE::LXC::Config->parse_lxc_network($conf->{$netid});
+           die "vnet $networkid is used by ct $vmid" if $net->{bridge} eq $networkid;
+       }
+    }
+
+}
+
+sub on_update_hook {
+    my ($class, $networkid, $scfg) = @_;
+
+    # verify that tag is not already defined in another vnet
+
+}
+
+sub read_local_vm_config {
+
+    my $qemu = {};
+    my $lxc = {};
+
+    my $vmdata = { qemu => $qemu, lxc => $lxc };
+
+    my $vmlist = PVE::Cluster::get_vmlist();
+    return $vmdata if !$vmlist || !$vmlist->{ids};
+    my $ids = $vmlist->{ids};
+
+    foreach my $vmid (keys %$ids) {
+       next if !$vmid;
+       my $d = $ids->{$vmid};
+       next if !$d->{node};
+       next if !$d->{type};
+       if ($d->{type} eq 'qemu') {
+           my $cfspath = PVE::QemuConfig->cfs_config_path($vmid);
+           if (my $conf = PVE::Cluster::cfs_read_file($cfspath)) {
+               $qemu->{$vmid} = $conf;
+           }
+       } elsif ($d->{type} eq 'lxc') {
+           my $cfspath = PVE::LXC::Config->cfs_config_path($vmid);
+           if (my $conf = PVE::Cluster::cfs_read_file($cfspath)) {
+               $lxc->{$vmid} = $conf;
+           }
+       }
+    }
+
+    return $vmdata;
+};
 
 1;