mirror of
git://git.proxmox.com/git/pve-storage.git
synced 2025-02-28 01:58:06 +03:00
f44e50fed1
create_base() uses '-ky' to prevent base images from being activated by default, similar to snapshots. This means we need to activate them like snapshots with the '-K' option.
363 lines
9.0 KiB
Perl
363 lines
9.0 KiB
Perl
package PVE::Storage::LvmThinPlugin;
|
|
|
|
use strict;
|
|
use warnings;
|
|
use Data::Dumper;
|
|
use IO::File;
|
|
use PVE::Tools qw(run_command trim);
|
|
use PVE::Storage::Plugin;
|
|
use PVE::Storage::LVMPlugin;
|
|
use PVE::JSONSchema qw(get_standard_option);
|
|
|
|
# see: man lvmthin
|
|
# lvcreate -n ThinDataLV -L LargeSize VG
|
|
# lvconvert --type thin-pool VG/ThinDataLV
|
|
# lvcreate -n pvepool -L 20G pve
|
|
# lvconvert --type thin-pool pve/pvepool
|
|
|
|
use base qw(PVE::Storage::LVMPlugin);
|
|
|
|
sub type {
|
|
return 'lvmthin';
|
|
}
|
|
|
|
sub plugindata {
|
|
return {
|
|
content => [ {images => 1, rootdir => 1}, { images => 1, rootdir => 1}],
|
|
};
|
|
}
|
|
|
|
sub properties {
|
|
return {
|
|
thinpool => {
|
|
description => "LVM thin pool LV name.",
|
|
type => 'string', format => 'pve-storage-vgname',
|
|
},
|
|
};
|
|
}
|
|
|
|
sub options {
|
|
return {
|
|
thinpool => { fixed => 1 },
|
|
vgname => { fixed => 1 },
|
|
nodes => { optional => 1 },
|
|
disable => { optional => 1 },
|
|
content => { optional => 1 },
|
|
};
|
|
}
|
|
|
|
sub parse_volname {
|
|
my ($class, $volname) = @_;
|
|
|
|
PVE::Storage::Plugin::parse_lvm_name($volname);
|
|
|
|
if ($volname =~ m/^((vm|base)-(\d+)-\S+)$/) {
|
|
return ('images', $1, $3, undef, undef, $2 eq 'base', 'raw');
|
|
}
|
|
|
|
die "unable to parse lvm volume name '$volname'\n";
|
|
}
|
|
|
|
sub filesystem_path {
|
|
my ($class, $scfg, $volname, $snapname) = @_;
|
|
|
|
my ($vtype, $name, $vmid) = $class->parse_volname($volname);
|
|
|
|
my $vg = $scfg->{vgname};
|
|
|
|
my $path = defined($snapname) ? "/dev/$vg/snap_${name}_$snapname": "/dev/$vg/$name";
|
|
|
|
return wantarray ? ($path, $vmid, $vtype) : $path;
|
|
}
|
|
|
|
sub alloc_image {
|
|
my ($class, $storeid, $scfg, $vmid, $fmt, $name, $size) = @_;
|
|
|
|
die "unsupported format '$fmt'" if $fmt ne 'raw';
|
|
|
|
die "illegal name '$name' - sould be 'vm-$vmid-*'\n"
|
|
if $name && $name !~ m/^vm-$vmid-/;
|
|
|
|
my $vgs = PVE::Storage::LVMPlugin::lvm_vgs();
|
|
|
|
my $vg = $scfg->{vgname};
|
|
|
|
die "no such volume group '$vg'\n" if !defined ($vgs->{$vg});
|
|
|
|
my $lvs = PVE::Storage::LVMPlugin::lvm_list_volumes($vg);
|
|
|
|
$name = PVE::Storage::LVMPlugin::lvm_find_free_diskname($lvs, $vg, $storeid, $vmid)
|
|
if !$name;
|
|
|
|
my $cmd = ['/sbin/lvcreate', '-aly', '-V', "${size}k", '--name', $name,
|
|
'--thinpool', "$vg/$scfg->{thinpool}" ];
|
|
|
|
run_command($cmd, errmsg => "lvcreate '$vg/$name' error");
|
|
|
|
return $name;
|
|
}
|
|
|
|
sub free_image {
|
|
my ($class, $storeid, $scfg, $volname, $isBase) = @_;
|
|
|
|
my $vg = $scfg->{vgname};
|
|
|
|
my $lvs = PVE::Storage::LVMPlugin::lvm_list_volumes($vg);
|
|
|
|
if (my $dat = $lvs->{$scfg->{vgname}}) {
|
|
|
|
# remove all volume snapshots first
|
|
foreach my $lv (keys %$dat) {
|
|
next if $lv !~ m/^snap_${volname}_(\w+)$/;
|
|
my $cmd = ['/sbin/lvremove', '-f', "$vg/$lv"];
|
|
run_command($cmd, errmsg => "lvremove snapshot '$vg/$lv' error");
|
|
}
|
|
|
|
# finally remove original (if exists)
|
|
if ($dat->{$volname}) {
|
|
my $cmd = ['/sbin/lvremove', '-f', "$vg/$volname"];
|
|
run_command($cmd, errmsg => "lvremove '$vg/$volname' error");
|
|
}
|
|
}
|
|
|
|
return undef;
|
|
}
|
|
|
|
sub list_images {
|
|
my ($class, $storeid, $scfg, $vmid, $vollist, $cache) = @_;
|
|
|
|
my $vgname = $scfg->{vgname};
|
|
|
|
$cache->{lvs} = PVE::Storage::LVMPlugin::lvm_list_volumes() if !$cache->{lvs};
|
|
|
|
my $res = [];
|
|
|
|
if (my $dat = $cache->{lvs}->{$vgname}) {
|
|
|
|
foreach my $volname (keys %$dat) {
|
|
|
|
next if $volname !~ m/^(vm|base)-(\d+)-/;
|
|
my $owner = $2;
|
|
|
|
my $info = $dat->{$volname};
|
|
|
|
next if $info->{lv_type} ne 'V';
|
|
|
|
next if $info->{pool_lv} ne $scfg->{thinpool};
|
|
|
|
my $volid = "$storeid:$volname";
|
|
|
|
if ($vollist) {
|
|
my $found = grep { $_ eq $volid } @$vollist;
|
|
next if !$found;
|
|
} else {
|
|
next if defined($vmid) && ($owner ne $vmid);
|
|
}
|
|
|
|
push @$res, {
|
|
volid => $volid, format => 'raw', size => $info->{lv_size}, vmid => $owner,
|
|
};
|
|
}
|
|
}
|
|
|
|
return $res;
|
|
}
|
|
|
|
sub list_thinpools {
|
|
my ($vg) = @_;
|
|
|
|
my $lvs = PVE::Storage::LVMPlugin::lvm_list_volumes($vg);
|
|
my $thinpools = [];
|
|
|
|
foreach my $lvname (keys %{$lvs->{$vg}}) {
|
|
next if $lvs->{$vg}->{$lvname}->{lv_type} ne 't';
|
|
push @$thinpools, { lv => $lvname };
|
|
}
|
|
|
|
return $thinpools;
|
|
}
|
|
|
|
sub status {
|
|
my ($class, $storeid, $scfg, $cache) = @_;
|
|
|
|
my $lvname = "$scfg->{vgname}/$scfg->{thinpool}";
|
|
|
|
$cache->{lvs} = PVE::Storage::LVMPlugin::lvm_list_volumes() if !$cache->{lvs};
|
|
|
|
my $lvs = $cache->{lvs};
|
|
|
|
return undef if !$lvs->{$scfg->{vgname}};
|
|
|
|
my $info = $lvs->{$scfg->{vgname}}->{$scfg->{thinpool}};
|
|
|
|
return undef if !$info;
|
|
|
|
return undef if $info->{lv_type} ne 't';
|
|
|
|
return ($info->{lv_size}, $info->{lv_size} - $info->{used}, $info->{used}, 1) if $info->{lv_size};
|
|
|
|
return undef;
|
|
}
|
|
|
|
sub activate_volume {
|
|
my ($class, $storeid, $scfg, $volname, $snapname, $cache) = @_;
|
|
|
|
my $vg = $scfg->{vgname};
|
|
|
|
# only snapshot volumes needs activation
|
|
if ($snapname) {
|
|
my $snapvol = "snap_${volname}_$snapname";
|
|
my $cmd = ['/sbin/lvchange', '-ay', '-K', "$vg/$snapvol"];
|
|
run_command($cmd, errmsg => "activate_volume '$vg/$snapvol' error");
|
|
} elsif ($volname =~ /^base-/) {
|
|
my $cmd = ['/sbin/lvchange', '-ay', '-K', "$vg/$volname"];
|
|
run_command($cmd, errmsg => "activate_volume '$vg/$volname' error");
|
|
} else {
|
|
# other volumes are active by default
|
|
}
|
|
}
|
|
|
|
sub deactivate_volume {
|
|
my ($class, $storeid, $scfg, $volname, $snapname, $cache) = @_;
|
|
|
|
my $vg = $scfg->{vgname};
|
|
|
|
# we only deactivate snapshot volumes
|
|
if ($snapname) {
|
|
my $snapvol = "snap_${volname}_$snapname";
|
|
my $cmd = ['/sbin/lvchange', '-an', "$vg/$snapvol"];
|
|
run_command($cmd, errmsg => "deactivate_volume '$vg/$snapvol' error");
|
|
} elsif ($volname =~ /^base-/) {
|
|
my $cmd = ['/sbin/lvchange', '-an', "$vg/$volname"];
|
|
run_command($cmd, errmsg => "deactivate_volume '$vg/$volname' error");
|
|
} else {
|
|
# other volumes are kept active
|
|
}
|
|
}
|
|
|
|
sub clone_image {
|
|
my ($class, $scfg, $storeid, $volname, $vmid, $snap) = @_;
|
|
|
|
my $vg = $scfg->{vgname};
|
|
|
|
my $lv;
|
|
|
|
if ($snap) {
|
|
$lv = "$vg/snap_${volname}_$snap";
|
|
} else {
|
|
my ($vtype, undef, undef, undef, undef, $isBase, $format) =
|
|
$class->parse_volname($volname);
|
|
|
|
die "clone_image only works on base images\n" if !$isBase;
|
|
|
|
$lv = "$vg/$volname";
|
|
}
|
|
|
|
my $lvs = PVE::Storage::LVMPlugin::lvm_list_volumes($vg);
|
|
|
|
my $name = PVE::Storage::LVMPlugin::lvm_find_free_diskname($lvs, $vg, $storeid, $vmid);
|
|
|
|
my $cmd = ['/sbin/lvcreate', '-n', $name, '-prw', '-kn', '-s', $lv];
|
|
run_command($cmd, errmsg => "clone image '$lv' error");
|
|
|
|
return $name;
|
|
}
|
|
|
|
sub create_base {
|
|
my ($class, $storeid, $scfg, $volname) = @_;
|
|
|
|
my ($vtype, $name, $vmid, $basename, $basevmid, $isBase) =
|
|
$class->parse_volname($volname);
|
|
|
|
die "create_base not possible with base image\n" if $isBase;
|
|
|
|
my $vg = $scfg->{vgname};
|
|
my $lvs = PVE::Storage::LVMPlugin::lvm_list_volumes($vg);
|
|
|
|
if (my $dat = $lvs->{$vg}) {
|
|
# to avoid confusion, reject if we find volume snapshots
|
|
foreach my $lv (keys %$dat) {
|
|
die "unable to create base volume - found snaphost '$lv'\n"
|
|
if $lv =~ m/^snap_${volname}_(\w+)$/;
|
|
}
|
|
}
|
|
|
|
my $newname = $name;
|
|
$newname =~ s/^vm-/base-/;
|
|
|
|
my $cmd = ['/sbin/lvrename', $vg, $volname, $newname];
|
|
run_command($cmd, errmsg => "lvrename '$vg/$volname' => '$vg/$newname' error");
|
|
|
|
# set inactive, read-only and activationskip flags
|
|
$cmd = ['/sbin/lvchange', '-an', '-pr', '-ky', "$vg/$newname"];
|
|
eval { run_command($cmd); };
|
|
warn $@ if $@;
|
|
|
|
my $newvolname = $newname;
|
|
|
|
return $newvolname;
|
|
}
|
|
|
|
# sub volume_resize {} reuse code from parent class
|
|
|
|
sub volume_snapshot {
|
|
my ($class, $scfg, $storeid, $volname, $snap) = @_;
|
|
|
|
my $vg = $scfg->{vgname};
|
|
my $snapvol = "snap_${volname}_$snap";
|
|
|
|
my $cmd = ['/sbin/lvcreate', '-n', $snapvol, '-pr', '-s', "$vg/$volname"];
|
|
run_command($cmd, errmsg => "lvcreate snapshot '$vg/$snapvol' error");
|
|
|
|
}
|
|
|
|
sub volume_snapshot_rollback {
|
|
my ($class, $scfg, $storeid, $volname, $snap) = @_;
|
|
|
|
my $vg = $scfg->{vgname};
|
|
my $snapvol = "snap_${volname}_$snap";
|
|
|
|
my $cmd = ['/sbin/lvremove', '-f', "$vg/$volname"];
|
|
run_command($cmd, errmsg => "lvremove '$vg/$volname' error");
|
|
|
|
$cmd = ['/sbin/lvcreate', '-kn', '-n', $volname, '-s', "$vg/$snapvol"];
|
|
run_command($cmd, errmsg => "lvm rollback '$vg/$snapvol' error");
|
|
}
|
|
|
|
sub volume_snapshot_delete {
|
|
my ($class, $scfg, $storeid, $volname, $snap) = @_;
|
|
|
|
my $vg = $scfg->{vgname};
|
|
my $snapvol = "snap_${volname}_$snap";
|
|
|
|
my $cmd = ['/sbin/lvremove', '-f', "$vg/$snapvol"];
|
|
run_command($cmd, errmsg => "lvremove snapshot '$vg/$snapvol' error");
|
|
}
|
|
|
|
sub volume_has_feature {
|
|
my ($class, $scfg, $feature, $storeid, $volname, $snapname, $running) = @_;
|
|
|
|
my $features = {
|
|
snapshot => { current => 1 },
|
|
clone => { base => 1, snap => 1},
|
|
template => { current => 1},
|
|
copy => { base => 1, current => 1, snap => 1},
|
|
sparseinit => { base => 1, current => 1},
|
|
};
|
|
|
|
my ($vtype, $name, $vmid, $basename, $basevmid, $isBase) =
|
|
$class->parse_volname($volname);
|
|
|
|
my $key = undef;
|
|
if($snapname){
|
|
$key = 'snap';
|
|
}else{
|
|
$key = $isBase ? 'base' : 'current';
|
|
}
|
|
return 1 if $features->{$feature}->{$key};
|
|
|
|
return undef;
|
|
}
|
|
|
|
1;
|