PVE/Network/SDN/Vnets.pm

   1 package PVE::Network::SDN::Vnets;
   2
   3 use strict;
   4 use warnings;
   5
   6 use PVE::Cluster qw(cfs_read_file cfs_write_file cfs_lock_file);
   7 use Net::IP;
   8 use PVE::Network::SDN::Subnets;
   9 use PVE::Network::SDN::Zones;
  10
  11 use PVE::Network::SDN::VnetPlugin;
  12 PVE::Network::SDN::VnetPlugin->register();
  13 PVE::Network::SDN::VnetPlugin->init();
  14
  15 sub sdn_vnets_config {
  16     my ($cfg, $id, $noerr) = @_;
  17
  18     die "no sdn vnet ID specified\n" if !$id;
  19
  20     my $scfg = $cfg->{ids}->{$id};
  21     die "sdn vnet '$id' does not exist\n" if (!$noerr && !$scfg);
  22
  23     return $scfg;
  24 }
  25
  26 sub config {
  27     return cfs_read_file("sdn/vnets.cfg");
  28 }
  29
  30 sub write_config {
  31     my ($cfg) = @_;
  32
  33     cfs_write_file("sdn/vnets.cfg", $cfg);
  34 }
  35
  36 sub sdn_vnets_ids {
  37     my ($cfg) = @_;
  38
  39     return keys %{$cfg->{ids}};
  40 }
  41
  42 sub complete_sdn_vnet {
  43     my ($cmdname, $pname, $cvalue) = @_;
  44
  45     my $cfg = PVE::Network::SDN::Vnets::config();
  46
  47     return  $cmdname eq 'add' ? [] : [ PVE::Network::SDN::Vnets::sdn_vnet_ids($cfg) ];
  48 }
  49
  50 sub get_vnet {
  51     my ($vnetid, $running) = @_;
  52
  53     my $cfg = {};
  54     if($running) {
  55         my $cfg = PVE::Network::SDN::config();
  56         $cfg = $cfg->{vnets};
  57     } else {
  58         $cfg = PVE::Network::SDN::Vnets::config();
  59     }
  60
  61     my $vnet = PVE::Network::SDN::Vnets::sdn_vnets_config($cfg, $vnetid, 1);
  62
  63     return $vnet;
  64 }
  65
  66 sub get_subnets {
  67     my ($vnetid) = @_;
  68
  69     my $subnets = {};
  70     my $subnets_cfg = PVE::Network::SDN::Subnets::config();
  71     foreach my $subnetid (sort keys %{$subnets_cfg->{ids}}) {
  72         my $subnet = $subnets_cfg->{ids}->{$subnetid};
  73         next if !$subnet->{vnet} || $subnet->{vnet} ne $vnetid;
  74         $subnets->{$subnetid} = $subnet;
  75     }
  76     return $subnets;
  77
  78 }
  79
  80 sub get_next_free_ip {
  81     my ($vnetid, $hostname, $ipversion) = @_;
  82
  83     my $vnet = PVE::Network::SDN::Vnets::get_vnet($vnetid);
  84     my $zoneid = $vnet->{zone};
  85     my $zone = PVE::Network::SDN::Zones::get_zone($zoneid);
  86
  87     $ipversion = 4 if !$ipversion;
  88     my $subnets = PVE::Network::SDN::Vnets::get_subnets($vnetid, 1);
  89     my $ip = undef;
  90     my $subnetcount = 0;
  91
  92     foreach my $subnetid (sort keys %{$subnets}) {
  93         my $subnet = $subnets->{$subnetid};
  94         my ($network, $mask) = split(/-/, $subnetid);
  95
  96         next if $ipversion != Net::IP::ip_get_version($network);
  97         $subnetcount++;
  98         if ($subnet->{ipam}) {
  99             eval {
 100                 $ip = PVE::Network::SDN::Subnets::next_free_ip($zone, $subnetid, $subnet, $hostname);
 101             };
 102             warn $@ if $@;
 103         }
 104         last if $ip;
 105     }
 106     die "can't find any free ip" if !$ip && $subnetcount > 0;
 107
 108     return $ip;
 109 }
 110
 111 sub add_ip {
 112     my ($vnetid, $cidr, $hostname) = @_;
 113
 114     my $subnets = PVE::Network::SDN::Vnets::get_subnets($vnetid, 1);
 115     my $vnet = PVE::Network::SDN::Vnets::get_vnet($vnetid);
 116     my $zoneid = $vnet->{zone};
 117     my $zone = PVE::Network::SDN::Zones::get_zone($zoneid);
 118
 119     my ($ip, $mask) = split(/\//, $cidr);
 120     my ($subnetid, $subnet) = PVE::Network::SDN::Subnets::find_ip_subnet($ip, $subnets);
 121
 122     PVE::Network::SDN::Subnets::add_ip($zone, $subnetid, $subnet, $ip, $hostname);
 123 }
 124
 125 sub del_ip {
 126     my ($vnetid, $cidr, $hostname) = @_;
 127
 128     my $subnets = PVE::Network::SDN::Vnets::get_subnets($vnetid, 1);
 129     my $vnet = PVE::Network::SDN::Vnets::get_vnet($vnetid);
 130     my $zoneid = $vnet->{zone};
 131     my $zone = PVE::Network::SDN::Zones::get_zone($zoneid);
 132
 133     my ($ip, $mask) = split(/\//, $cidr);
 134     my ($subnetid, $subnet) = PVE::Network::SDN::Subnets::find_ip_subnet($ip, $subnets);
 135
 136     PVE::Network::SDN::Subnets::del_ip($zone, $subnetid, $subnet, $ip, $hostname);
 137 }
 138
 139 1;