]>
git.proxmox.com Git - pve-storage.git/blob - PVE/Diskmanage.pm
2a0a01531363d7c5fea85dc9806236da48668838
1 package PVE
::Diskmanage
;
11 use PVE
::Tools
qw(extract_param run_command file_get_contents file_read_firstline dir_glob_regex dir_glob_foreach trim);
13 my $SMARTCTL = "/usr/sbin/smartctl";
14 my $ZPOOL = "/sbin/zpool";
15 my $SGDISK = "/sbin/sgdisk";
16 my $PVS = "/sbin/pvs";
17 my $LVS = "/sbin/lvs";
18 my $UDEVADM = "/bin/udevadm";
19 my $LSBLK = "/bin/lsblk";
21 sub verify_blockdev_path
{
24 die "missing path" if !$rel_path;
25 my $path = abs_path
($rel_path);
26 die "failed to get absolute path to $rel_path\n" if !$path;
28 die "got unusual device path '$path'\n" if $path !~ m
|^/dev/(.*)$|;
30 $path = "/dev/$1"; # untaint
32 assert_blockdev
($path);
38 my ($dev, $noerr) = @_;
40 if ($dev !~ m
|^/dev/| || !(-b
$dev)) {
41 return undef if $noerr;
42 die "not a valid block device\n";
49 my ($disk, $uuid) = @_;
51 assert_blockdev
($disk);
53 # we should already have checked if it is in use in the api call
54 # but we check again for safety
55 die "disk $disk is already in use\n" if disk_is_used
($disk);
57 my $id = $uuid || 'R';
58 run_command
([$SGDISK, $disk, '-U', $id]);
68 my $disklist = get_disks
($dev, 1);
70 die "'$disk' is not a valid local disk\n" if !defined($disklist->{$dev});
71 return 1 if $disklist->{$dev}->{used
};
77 my ($disk, $healthonly) = @_;
79 assert_blockdev
($disk);
85 if ($disk =~ m!^/dev/(nvme\d+n\d+)$!) {
86 my $info = get_sysdir_info
("/sys/block/$1");
87 $disk = "/dev/".($info->{device
}
88 or die "failed to get nvme controller device for $disk\n");
91 my $cmd = [$SMARTCTL, '-H'];
92 push @$cmd, '-A', '-f', 'brief' if !$healthonly;
96 $returncode = run_command
($cmd, noerr
=> 1, outfunc
=> sub{
99 # ATA SMART attributes, e.g.:
100 # ID# ATTRIBUTE_NAME FLAGS VALUE WORST THRESH FAIL RAW_VALUE
101 # 1 Raw_Read_Error_Rate POSR-K 100 100 000 - 0
103 # SAS and NVME disks, e.g.:
104 # Data Units Written: 5,584,952 [2.85 TB]
105 # Accumulated start-stop cycles: 34
107 if (defined($type) && $type eq 'ata' && $line =~ m/^([ \d]{2}\d)\s+(\S+)\s+(\S{6})\s+(\d+)\s+(\d+)\s+(\S+)\s+(\S+)\s+(.*)$/) {
111 $entry->{name
} = $2 if defined $2;
112 $entry->{flags
} = $3 if defined $3;
113 # the +0 makes a number out of the strings
114 $entry->{value
} = $4+0 if defined $4;
115 $entry->{worst
} = $5+0 if defined $5;
116 # some disks report the default threshold as --- instead of 000
117 if (defined($6) && $6 eq '---') {
118 $entry->{threshold
} = 0;
120 $entry->{threshold
} = $6+0 if defined $6;
122 $entry->{fail
} = $7 if defined $7;
123 $entry->{raw
} = $8 if defined $8;
124 $entry->{id
} = $1 if defined $1;
125 push @{$smartdata->{attributes
}}, $entry;
126 } elsif ($line =~ m/(?:Health Status|self\-assessment test result): (.*)$/ ) {
127 $smartdata->{health
} = $1;
128 } elsif ($line =~ m/Vendor Specific SMART Attributes with Thresholds:/) {
130 delete $smartdata->{text
};
131 } elsif ($line =~ m/=== START OF (READ )?SMART DATA SECTION ===/) {
133 } elsif (defined($type) && $type eq 'text') {
134 $smartdata->{text
} = '' if !defined $smartdata->{text
};
135 $smartdata->{text
} .= "$line\n";
136 # extract wearout from nvme text, allow for decimal values
137 if ($line =~ m/Percentage Used:.*(\d+(?:\.\d+)?)\%/i) {
138 $smartdata->{wearout
} = 100 - $1;
140 } elsif ($line =~ m/SMART Disabled/) {
141 $smartdata->{health
} = "SMART Disabled";
147 # bit 0 and 1 mark an severe smartctl error
148 # all others are for disk status, so ignore them
150 if ((defined($returncode) && ($returncode & 0b00000011)) || $err) {
151 die "Error getting S.M.A.R.T. data: Exit code: $returncode\n";
154 $smartdata->{type
} = $type;
159 sub get_parttype_info
() {
160 my $cmd = [$LSBLK, '--json', '-o', 'path,parttype'];
164 run_command
($cmd, outfunc
=> sub {
166 $output .= "$line\n";
170 return $res if $output eq '';
172 my $parsed = eval { decode_json
($output) };
174 my $list = $parsed->{blockdevices
} // [];
176 foreach my $dev (@$list) {
177 next if !($dev->{parttype
});
178 my $type = $dev->{parttype
};
179 $res->{$type} = [] if !defined($res->{$type});
180 push @{$res->{$type}}, $dev->{path
};
186 my $get_devices_by_partuuid = sub {
187 my ($parttype_map, $uuids, $res) = @_;
189 $res = {} if !defined($res);
191 foreach my $uuid (sort keys %$uuids) {
192 map { $res->{$_} = $uuids->{$uuid} } @{$parttype_map->{$uuid}};
198 sub get_zfs_devices
{
199 my ($parttype_map) = @_;
202 return {} if ! -x
$ZPOOL;
204 # use zpool and parttype uuid,
205 # because log and cache do not have
208 run_command
([$ZPOOL, 'list', '-HPLv'], outfunc
=> sub {
211 if ($line =~ m
|^\t([^\t]+)\t|) {
218 # because maybe zfs tools are not installed
222 "6a898cc3-1dd2-11b2-99a6-080020736631" => 1, # apple
223 "516e7cba-6ecf-11d6-8ff8-00022d09712b" => 1, # bsd
227 $res = $get_devices_by_partuuid->($parttype_map, $uuids, $res);
232 sub get_lvm_devices
{
233 my ($parttype_map) = @_;
236 run_command
([$PVS, '--noheadings', '--readonly', '-o', 'pv_name'], outfunc
=> sub{
239 if ($line =~ m
|^/dev/|) {
245 # if something goes wrong, we do not want
246 # to give up, but indicate an error has occured
250 "e6d6d379-f507-44c2-a23c-238f2a3df928" => 1,
253 $res = $get_devices_by_partuuid->($parttype_map, $uuids, $res);
258 sub get_ceph_journals
{
259 my ($parttype_map) = @_;
263 '45b0969e-9b03-4f30-b4c6-b4b80ceff106' => 1, # journal
264 '30cd0809-c2b2-499c-8879-2d6b78529876' => 2, # db
265 '5ce17fce-4087-4169-b7ff-056cc58473f9' => 3, # wal
266 'cafecafe-9b03-4f30-b4c6-b4b80ceff106' => 4, # block
269 $res = $get_devices_by_partuuid->($parttype_map, $uuids, $res);
274 # reads the lv_tags and matches them with the devices
275 sub get_ceph_volume_infos
{
278 my $cmd = [ $LVS, '-S', 'lv_name=~^osd-', '-o', 'devices,lv_name,lv_tags',
279 '--noheadings', '--readonly', '--separator', ';' ];
281 run_command
($cmd, outfunc
=> sub {
283 $line =~ s/(?:^\s+)|(?:\s+$)//g; # trim whitespaces
285 my $fields = [ split(';', $line) ];
287 # lvs syntax is /dev/sdX(Y) where Y is the start (which we do not need)
288 my ($dev) = $fields->[0] =~ m
|^(/dev/[a-z
]+)|;
289 if ($fields->[1] =~ m
|^osd-
([^-]+)-|) {
291 # $result autovivification is wanted, to not creating empty hashes
292 if (($type eq 'block' || $type eq 'data') && $fields->[2] =~ m/ceph.osd_id=([^,]+)/) {
293 $result->{$dev}->{osdid
} = $1;
294 $result->{$dev}->{bluestore
} = ($type eq 'block');
295 if ($fields->[2] =~ m/ceph\.encrypted=1/) {
296 $result->{$dev}->{encrypted
} = 1;
299 # undef++ becomes '1' (see `perldoc perlop`: Auto-increment)
300 $result->{$dev}->{$type}++;
314 run_command
([$UDEVADM, 'info', '-p', $dev, '--query', 'all'], outfunc
=> sub {
320 return undef if !$info;
322 return undef if $info !~ m/^E: DEVTYPE=disk$/m;
323 return undef if $info =~ m/^E: ID_CDROM/m;
325 # we use this, because some disks are not simply in /dev
326 # e.g. /dev/cciss/c0d0
327 if ($info =~ m/^E: DEVNAME=(\S+)$/m) {
328 $data->{devpath
} = $1;
330 return if !defined($data->{devpath
});
332 $data->{serial
} = 'unknown';
333 if ($info =~ m/^E: ID_SERIAL_SHORT=(\S+)$/m) {
334 $data->{serial
} = $1;
338 if ($info =~ m/^E: ID_PART_TABLE_TYPE=gpt$/m) {
344 if ($info =~ m/^E: ID_ATA_ROTATION_RATE_RPM=(\d+)$/m) {
348 if ($info =~ m/^E: ID_BUS=usb$/m) {
352 if ($info =~ m/^E: ID_MODEL=(.+)$/m) {
356 $data->{wwn
} = 'unknown';
357 if ($info =~ m/^E: ID_WWN=(.*)$/m) {
364 sub get_sysdir_info
{
367 return undef if ! -d
"$sysdir/device";
371 my $size = file_read_firstline
("$sysdir/size");
372 return undef if !$size;
374 # linux always considers sectors to be 512 bytes,
375 # independently of real block size
376 $data->{size
} = $size * 512;
378 # dir/queue/rotational should be 1 for hdd, 0 for ssd
379 $data->{rotational
} = file_read_firstline
("$sysdir/queue/rotational") // -1;
381 $data->{vendor
} = file_read_firstline
("$sysdir/device/vendor") || 'unknown';
382 $data->{model
} = file_read_firstline
("$sysdir/device/model") || 'unknown';
384 if (defined(my $device = readlink("$sysdir/device"))) {
385 # strip directory and untaint:
386 ($data->{device
}) = $device =~ m!([^/]+)$!;
392 sub get_wear_leveling_info
{
393 my ($smartdata, $model) = @_;
394 my $attributes = $smartdata->{attributes
};
396 if (defined($smartdata->{wearout
})) {
397 return $smartdata->{wearout
};
411 # find target attr id
415 foreach my $vendor (keys %$vendormap) {
416 if ($model =~ m/$vendor/i) {
417 $attrid = $vendormap->{$vendor};
418 # found the attribute
424 $attrid = $vendormap->{default};
427 foreach my $attr (@$attributes) {
428 next if $attr->{id
} != $attrid;
429 $wearout = $attr->{value
};
439 my $dh = IO
::Dir-
>new ($dir);
442 while (defined(my $tmp = $dh->read)) {
443 next if $tmp eq '.' || $tmp eq '..';
454 if (-l
$sysdir && readlink($sysdir) =~ m
|host
[^/]*/session
[^/]*|) {
462 my ($disks, $nosmart) = @_;
467 my $mounts = PVE
::ProcFSTools
::parse_proc_mounts
();
469 foreach my $mount (@$mounts) {
470 next if $mount->[0] !~ m
|^/dev/|;
471 $mounted->{abs_path
($mount->[0])} = $mount->[1];
474 my $dev_is_mounted = sub {
476 return $mounted->{$dev};
479 my $parttype_map = get_parttype_info
();
481 my $journalhash = get_ceph_journals
($parttype_map);
482 my $ceph_volume_infos = get_ceph_volume_infos
();
484 my $zfshash = get_zfs_devices
($parttype_map);
486 my $lvmhash = get_lvm_devices
($parttype_map);
488 my $disk_regex = ".*";
489 if (defined($disks)) {
492 } elsif (ref($disks) ne 'ARRAY') {
493 die "disks is not a string or array reference\n";
495 # we get cciss/c0d0 but need cciss!c0d0
496 map { s
|cciss
/|cciss
!| } @$disks;
498 $disk_regex = "(?:" . join('|', @$disks) . ")";
501 dir_glob_foreach
('/sys/block', $disk_regex, sub {
503 # whitelisting following devices
504 # hdX: ide block device
505 # sdX: sd block device
506 # vdX: virtual block device
507 # xvdX: xen virtual block device
508 # nvmeXnY: nvme devices
509 # cciss!cXnY: cciss devices
510 return if $dev !~ m/^(h|s|x?v)d[a-z]+$/ &&
511 $dev !~ m/^nvme\d+n\d+$/ &&
512 $dev !~ m/^cciss\!c\d+d\d+$/;
514 my $data = get_udev_info
("/sys/block/$dev");
515 return if !defined($data);
516 my $devpath = $data->{devpath
};
518 my $sysdir = "/sys/block/$dev";
520 # we do not want iscsi devices
521 return if is_iscsi
($sysdir);
523 my $sysdata = get_sysdir_info
($sysdir);
524 return if !defined($sysdata);
526 my $type = 'unknown';
528 if ($sysdata->{rotational
} == 0) {
531 } elsif ($sysdata->{rotational
} == 1) {
532 if ($data->{rpm
} != -1) {
534 } elsif ($data->{usb
}) {
540 my $health = 'UNKNOWN';
545 my $smartdata = get_smart_data
($devpath, ($type ne 'ssd'));
546 $health = $smartdata->{health
} if $smartdata->{health
};
548 if ($type eq 'ssd') {
549 # if we have an ssd we try to get the wearout indicator
550 my $wearval = get_wear_leveling_info
($smartdata, $data->{model
} || $sysdata->{model
});
551 $wearout = $wearval if defined($wearval);
558 $used = 'LVM' if $lvmhash->{$devpath};
560 $used = 'mounted' if &$dev_is_mounted($devpath);
562 $used = 'ZFS' if $zfshash->{$devpath};
564 # we replaced cciss/ with cciss! above
565 # but in the result we need cciss/ again
566 # because the caller might want to check the
567 # result again with the original parameter
568 if ($dev =~ m
|^cciss
!|) {
569 $dev =~ s
|^cciss
!|cciss
/|;
572 $disklist->{$dev} = {
573 vendor
=> $sysdata->{vendor
},
574 model
=> $data->{model
} || $sysdata->{model
},
575 size
=> $sysdata->{size
},
576 serial
=> $data->{serial
},
588 my $osdencrypted = 0;
590 my $journal_count = 0;
594 my $found_partitions;
596 my $found_mountpoints;
599 my $partpath = $devpath;
601 # remove part after last / to
602 # get the base path for the partitions
603 # e.g. from /dev/cciss/c0d0 get /dev/cciss
604 $partpath =~ s/\/[^\/]+$//;
606 dir_glob_foreach
("$sysdir", "$dev.+", sub {
609 $found_partitions = 1;
611 if (my $mp = &$dev_is_mounted("$partpath/$part")) {
612 $found_mountpoints = 1;
613 if ($mp =~ m
|^/var/lib
/ceph/osd/ceph-
(\d
+)$|) {
618 if ($lvmhash->{"$partpath/$part"}) {
622 if ($zfshash->{"$partpath/$part"}) {
626 if (my $journal_part = $journalhash->{"$partpath/$part"}) {
627 $journal_count++ if $journal_part == 1;
628 $db_count++ if $journal_part == 2;
629 $wal_count++ if $journal_part == 3;
630 $bluestore = 1 if $journal_part == 4;
633 if (!dir_is_empty
("$sysdir/$part/holders") && !$found_lvm) {
638 if (my $ceph_volume = $ceph_volume_infos->{$devpath}) {
639 $journal_count += $ceph_volume->{journal
} // 0;
640 $db_count += $ceph_volume->{db
} // 0;
641 $wal_count += $ceph_volume->{wal
} // 0;
642 if (defined($ceph_volume->{osdid
})) {
643 $osdid = $ceph_volume->{osdid
};
644 $bluestore = 1 if $ceph_volume->{bluestore
};
645 $osdencrypted = 1 if $ceph_volume->{encrypted
};
649 $used = 'mounted' if $found_mountpoints && !$used;
650 $used = 'LVM' if $found_lvm && !$used;
651 $used = 'ZFS' if $found_zfs && !$used;
652 $used = 'Device Mapper' if $found_dm && !$used;
653 $used = 'partitions' if $found_partitions && !$used;
655 # multipath, software raid, etc.
656 # this check comes in last, to show more specific info
658 $used = 'Device Mapper' if !$used && !dir_is_empty
("$sysdir/holders");
660 $disklist->{$dev}->{used
} = $used if $used;
661 $disklist->{$dev}->{osdid
} = $osdid;
662 $disklist->{$dev}->{journals
} = $journal_count if $journal_count;
663 $disklist->{$dev}->{bluestore
} = $bluestore if $osdid != -1;
664 $disklist->{$dev}->{osdencrypted
} = $osdencrypted if $osdid != -1;
665 $disklist->{$dev}->{db
} = $db_count if $db_count;
666 $disklist->{$dev}->{wal
} = $wal_count if $wal_count;
674 my ($part_path) = @_;
676 my ($mode, $rdev) = (stat($part_path))[2,6];
678 next if !$mode || !S_ISBLK
($mode) || !$rdev;
679 my $major = PVE
::Tools
::dev_t_major
($rdev);
680 my $minor = PVE
::Tools
::dev_t_minor
($rdev);
681 my $partnum_path = "/sys/dev/block/$major:$minor/";
685 $partnum = file_read_firstline
("${partnum_path}partition");
687 die "Partition does not exists\n" if !defined($partnum);
689 #untaint and ensure it is a int
690 if ($partnum =~ m/(\d+)/) {
692 die "Partition number $partnum is invalid\n" if $partnum > 128;
694 die "Failed to get partition number\n";
701 my ($part_path) = @_;
703 my $dev = $1 if $part_path =~ m
|^/dev/(.*)$|;
704 my $link = readlink "/sys/class/block/$dev";
705 my $block_dev = $1 if $link =~ m
|([^/]*)/$dev$|;
707 die "Can't parse parent device\n" if !defined($block_dev);
708 die "No valid block device\n" if index($dev, $block_dev) == -1;
710 $block_dev = "/dev/$block_dev";
711 die "Block device does not exsists\n" if !(-b
$block_dev);
716 sub locked_disk_action
{
718 my $res = PVE
::Tools
::lock_file
('/run/lock/pve-diskmanage.lck', undef, $sub);
723 sub assert_disk_unused
{
726 die "device '$dev' is already in use\n" if disk_is_used
($dev);
731 sub append_partition
{
732 my ($dev, $size) = @_;
735 $devname =~ s
|^/dev/||;
738 dir_glob_foreach
("/sys/block/$devname", qr
/\Q
$devname\E.*?
(\d
+)/, sub {
739 my ($part, $partid) = @_;
741 if ($partid >= $newpartid) {
742 $newpartid = $partid + 1;
746 $size = PVE
::Tools
::convert_size
($size, 'b' => 'mb');
748 run_command
([ $SGDISK, '-n', "$newpartid:0:+${size}M", $dev ],
749 errmsg
=> "error creating partition '$newpartid' on '$dev'");
753 # loop again to detect the real partiton device which does not always follow
754 # a strict $devname$partition scheme like /dev/nvme0n1 -> /dev/nvme0n1p1
755 dir_glob_foreach
("/sys/block/$devname", qr
/\Q
$devname\E.*$newpartid/, sub {
758 $partition = "/dev/$part";