PVE/Network/SDN/Vnets.pm

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