]>
git.proxmox.com Git - pve-storage.git/blob - PVE/Storage/LvmThinPlugin.pm
5e404df55e1117f70ef21f2e44bd61187e75926a
1 package PVE
::Storage
::LvmThinPlugin
;
7 use PVE
::Tools
qw(run_command trim);
8 use PVE
::Storage
::Plugin
;
9 use PVE
::Storage
::LVMPlugin
;
10 use PVE
::JSONSchema
qw(get_standard_option);
13 # lvcreate -n ThinDataLV -L LargeSize VG
14 # lvconvert --type thin-pool VG/ThinDataLV
15 # lvcreate -n pvepool -L 20G pve
16 # lvconvert --type thin-pool pve/pvepool
18 use base
qw(PVE::Storage::LVMPlugin);
26 content
=> [ {images
=> 1, rootdir
=> 1}, { images
=> 1, rootdir
=> 1}],
33 description
=> "LVM thin pool LV name.",
34 type
=> 'string', format
=> 'pve-storage-vgname',
41 thinpool
=> { fixed
=> 1 },
42 vgname
=> { fixed
=> 1 },
43 nodes
=> { optional
=> 1 },
44 disable
=> { optional
=> 1 },
45 content
=> { optional
=> 1 },
50 my ($class, $volname) = @_;
52 PVE
::Storage
::Plugin
::parse_lvm_name
($volname);
54 if ($volname =~ m/^((vm|base)-(\d+)-\S+)$/) {
55 return ('images', $1, $3, undef, undef, $2 eq 'base', 'raw');
58 die "unable to parse lvm volume name '$volname'\n";
62 my ($class, $scfg, $volname, $snapname) = @_;
64 my ($vtype, $name, $vmid) = $class->parse_volname($volname);
66 my $vg = $scfg->{vgname
};
68 my $path = defined($snapname) ?
"/dev/$vg/snap_${name}_$snapname": "/dev/$vg/$name";
70 return wantarray ?
($path, $vmid, $vtype) : $path;
74 my ($class, $storeid, $scfg, $vmid, $fmt, $name, $size) = @_;
76 die "unsupported format '$fmt'" if $fmt ne 'raw';
78 die "illegal name '$name' - sould be 'vm-$vmid-*'\n"
79 if $name && $name !~ m/^vm-$vmid-/;
81 my $vgs = PVE
::Storage
::LVMPlugin
::lvm_vgs
();
83 my $vg = $scfg->{vgname
};
85 die "no such volume group '$vg'\n" if !defined ($vgs->{$vg});
87 my $lvs = PVE
::Storage
::LVMPlugin
::lvm_list_volumes
($vg);
89 $name = PVE
::Storage
::LVMPlugin
::lvm_find_free_diskname
($lvs, $vg, $storeid, $vmid)
92 my $cmd = ['/sbin/lvcreate', '-aly', '-V', "${size}k", '--name', $name,
93 '--thinpool', "$vg/$scfg->{thinpool}" ];
95 run_command
($cmd, errmsg
=> "lvcreate '$vg/$name' error");
101 my ($class, $storeid, $scfg, $volname, $isBase) = @_;
103 my $vg = $scfg->{vgname
};
105 my $lvs = PVE
::Storage
::LVMPlugin
::lvm_list_volumes
($vg);
107 if (my $dat = $lvs->{$scfg->{vgname
}}) {
109 # remove all volume snapshots first
110 foreach my $lv (keys %$dat) {
111 next if $lv !~ m/^snap_${volname}_(\w+)$/;
112 my $cmd = ['/sbin/lvremove', '-f', "$vg/$lv"];
113 run_command
($cmd, errmsg
=> "lvremove snapshot '$vg/$lv' error");
116 # finally remove original (if exists)
117 if ($dat->{$volname}) {
118 my $cmd = ['/sbin/lvremove', '-f', "$vg/$volname"];
119 run_command
($cmd, errmsg
=> "lvremove '$vg/$volname' error");
127 my ($class, $storeid, $scfg, $vmid, $vollist, $cache) = @_;
129 my $vgname = $scfg->{vgname
};
131 $cache->{lvs
} = PVE
::Storage
::LVMPlugin
::lvm_list_volumes
() if !$cache->{lvs
};
135 if (my $dat = $cache->{lvs
}->{$vgname}) {
137 foreach my $volname (keys %$dat) {
139 next if $volname !~ m/^(vm|base)-(\d+)-/;
142 my $info = $dat->{$volname};
144 next if $info->{lv_type
} ne 'V';
146 next if $info->{pool_lv
} ne $scfg->{thinpool
};
148 my $volid = "$storeid:$volname";
151 my $found = grep { $_ eq $volid } @$vollist;
154 next if defined($vmid) && ($owner ne $vmid);
158 volid
=> $volid, format
=> 'raw', size
=> $info->{lv_size
}, vmid
=> $owner,
167 my ($class, $storeid, $scfg, $cache) = @_;
169 my $lvname = "$scfg->{vgname}/$scfg->{thinpool}";
171 $cache->{lvs
} = PVE
::Storage
::LVMPlugin
::lvm_list_volumes
() if !$cache->{lvs
};
173 my $lvs = $cache->{lvs
};
175 return undef if !$lvs->{$scfg->{vgname
}};
177 my $info = $lvs->{$scfg->{vgname
}}->{$scfg->{thinpool
}};
179 return undef if !$info;
181 return undef if $info->{lv_type
} ne 't';
183 return ($info->{lv_size
}, $info->{lv_size
} - $info->{used
}, $info->{used
}, 1) if $info->{lv_size
};
188 sub activate_volume
{
189 my ($class, $storeid, $scfg, $volname, $snapname, $cache) = @_;
191 my $vg = $scfg->{vgname
};
193 # only snapshot volumes needs activation
195 my $snapvol = "snap_${volname}_$snapname";
196 my $cmd = ['/sbin/lvchange', '-ay', '-K', "$vg/$snapvol"];
197 run_command
($cmd, errmsg
=> "activate_volume '$vg/$snapvol' error");
199 # other volumes are active by default
203 sub deactivate_volume
{
204 my ($class, $storeid, $scfg, $volname, $snapname, $cache) = @_;
206 my $vg = $scfg->{vgname
};
208 # we only deactivate snapshot volumes
210 my $snapvol = "snap_${volname}_$snapname";
211 my $cmd = ['/sbin/lvchange', '-an', "$vg/$snapvol"];
212 run_command
($cmd, errmsg
=> "deactivate_volume '$vg/$snapvol' error");
214 # other volumes are kept active
219 my ($class, $scfg, $storeid, $volname, $vmid, $snap) = @_;
221 die "clone_image from snapshots not implemented" if $snap;
223 my ($vtype, undef, undef, undef, undef, $isBase, $format) =
224 $class->parse_volname($volname);
226 die "clone_image only works on base images\n" if !$isBase;
228 my $vg = $scfg->{vgname
};
229 my $lvs = PVE
::Storage
::LVMPlugin
::lvm_list_volumes
($vg);
231 my $name = PVE
::Storage
::LVMPlugin
::lvm_find_free_diskname
($lvs, $vg, $storeid, $vmid);
233 my $cmd = ['/sbin/lvcreate', '-n', $name, '-prw', '-kn', '-s', "$vg/$volname"];
234 run_command
($cmd, errmsg
=> "clone image '$vg/$volname' error");
240 my ($class, $storeid, $scfg, $volname) = @_;
242 my ($vtype, $name, $vmid, $basename, $basevmid, $isBase) =
243 $class->parse_volname($volname);
245 die "create_base not possible with base image\n" if $isBase;
247 my $vg = $scfg->{vgname
};
248 my $lvs = PVE
::Storage
::LVMPlugin
::lvm_list_volumes
($vg);
250 if (my $dat = $lvs->{$vg}) {
251 # to avoid confusion, reject if we find volume snapshots
252 foreach my $lv (keys %$dat) {
253 die "unable to create base volume - found snaphost '$lv'\n"
254 if $lv =~ m/^snap_${volname}_(\w+)$/;
259 $newname =~ s/^vm-/base-/;
261 my $cmd = ['/sbin/lvrename', $vg, $volname, $newname];
262 run_command
($cmd, errmsg
=> "lvrename '$vg/$volname' => '$vg/$newname' error");
264 # set inactive, read-only and activationskip flags
265 $cmd = ['/sbin/lvchange', '-an', '-pr', '-ky', "$vg/$newname"];
266 eval { run_command
($cmd); };
269 my $newvolname = $newname;
274 # sub volume_resize {} reuse code from parent class
276 sub volume_snapshot
{
277 my ($class, $scfg, $storeid, $volname, $snap) = @_;
279 my $vg = $scfg->{vgname
};
280 my $snapvol = "snap_${volname}_$snap";
282 my $cmd = ['/sbin/lvcreate', '-n', $snapvol, '-pr', '-s', "$vg/$volname"];
283 run_command
($cmd, errmsg
=> "lvcreate snapshot '$vg/$snapvol' error");
287 sub volume_snapshot_rollback
{
288 my ($class, $scfg, $storeid, $volname, $snap) = @_;
290 my $vg = $scfg->{vgname
};
291 my $snapvol = "snap_${volname}_$snap";
293 my $cmd = ['/sbin/lvremove', '-f', "$vg/$volname"];
294 run_command
($cmd, errmsg
=> "lvremove '$vg/$volname' error");
296 $cmd = ['/sbin/lvcreate', '-kn', '-n', $volname, '-s', "$vg/$snapvol"];
297 run_command
($cmd, errmsg
=> "lvm rollback '$vg/$snapvol' error");
300 sub volume_snapshot_delete
{
301 my ($class, $scfg, $storeid, $volname, $snap) = @_;
303 my $vg = $scfg->{vgname
};
304 my $snapvol = "snap_${volname}_$snap";
306 my $cmd = ['/sbin/lvremove', '-f', "$vg/$snapvol"];
307 run_command
($cmd, errmsg
=> "lvremove snapshot '$vg/$snapvol' error");
310 sub volume_has_feature
{
311 my ($class, $scfg, $feature, $storeid, $volname, $snapname, $running) = @_;
314 snapshot
=> { current
=> 1 },
315 clone
=> { base
=> 1},
316 template
=> { current
=> 1},
317 copy
=> { base
=> 1, current
=> 1, snap
=> 1},
320 my ($vtype, $name, $vmid, $basename, $basevmid, $isBase) =
321 $class->parse_volname($volname);
327 $key = $isBase ?
'base' : 'current';
329 return 1 if $features->{$feature}->{$key};