Merge pull request #15 from nix-community/dev-disk

use /dev/disk/by-path for better nvme support
This commit is contained in:
Jörg Thalheim 2022-08-23 19:39:46 +01:00 committed by GitHub
commit 9bca66ca7d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -9,6 +9,30 @@ let {
body.mount = mount-f {}; body.mount = mount-f {};
helper.find-device = device: let
environment = helper.device-id device;
in
# DEVICE points already to /dev/disk, so we don't handle it via /dev/disk/by-path
if hasPrefix "/dev/disk" device then
"${environment}='${device}'"
else ''
${environment}=$(for x in /dev/disk/by-path/*; do
dev=$x
if [ "$(readlink -f $x)" = '${device}' ]; then
target=$dev
break
fi
done
if test -z $target; then
echo 'unable to find path of disk: ${device}, bailing out' >&2
exit 1
else
echo $target
fi)
'';
helper.device-id = device: "DEVICE${builtins.substring 0 5 (builtins.hashString "sha1" device)}";
config-f = q: x: config.${x.type} q x; config-f = q: x: config.${x.type} q x;
config.filesystem = q: x: { config.filesystem = q: x: {
@ -70,19 +94,24 @@ let {
create.noop = q: x: ""; create.noop = q: x: "";
create.partition = q: x: '' create.partition = q: x: let
parted -s ${q.device} mkpart ${x.part-type} ${x.fs-type or ""} ${x.start} ${x.end} env = helper.device-id q.device;
in ''
parted -s "''${${env}}" mkpart ${x.part-type} ${x.fs-type or ""} ${x.start} ${x.end}
# ensure /dev/disk/by-path/..-partN exists before continuing
udevadm trigger --subsystem-match=block; udevadm settle
${optionalString (x.bootable or false) '' ${optionalString (x.bootable or false) ''
parted -s ${q.device} set ${toString q.index} boot on parted -s "''${${env}}" set ${toString q.index} boot on
''} ''}
${concatMapStringsSep "" (flag: '' ${concatMapStringsSep "" (flag: ''
parted -s ${q.device} set ${toString q.index} ${flag} on parted -s "''${${env}}" set ${toString q.index} ${flag} on
'') (x.flags or [])} '') (x.flags or [])}
${create-f { device = q.device + toString q.index; } x.content} ${create-f { device = "\"\${${env}}\"-part" + toString q.index; } x.content}
''; '';
create.table = q: x: '' create.table = q: x: ''
parted -s ${q.device} mklabel ${x.format} ${helper.find-device q.device}
parted -s "''${${helper.device-id q.device}}" mklabel ${x.format}
${concatStrings (imap (index: create-f (q // { inherit index; })) x.partitions)} ${concatStrings (imap (index: create-f (q // { inherit index; })) x.partitions)}
''; '';
@ -91,8 +120,8 @@ let {
mount.filesystem = q: x: { mount.filesystem = q: x: {
fs.${x.mountpoint} = '' fs.${x.mountpoint} = ''
if ! findmnt "${q.device}" "/mnt${x.mountpoint}" > /dev/null 2>&1; then if ! findmnt ${q.device} "/mnt${x.mountpoint}" > /dev/null 2>&1; then
mount "${q.device}" "/mnt${x.mountpoint}" -o X-mount.mkdir mount ${q.device} "/mnt${x.mountpoint}" -o X-mount.mkdir
fi fi
''; '';
}; };
@ -102,6 +131,7 @@ let {
# attrValues returns values sorted by name. This is important, because it # attrValues returns values sorted by name. This is important, because it
# ensures that "/" is processed before "/foo" etc. # ensures that "/" is processed before "/foo" etc.
in '' in ''
${optionalString (hasAttr "table" z) (concatStringsSep "\n" (attrValues z.table))}
${optionalString (hasAttr "luks" z) (concatStringsSep "\n" (attrValues z.luks))} ${optionalString (hasAttr "luks" z) (concatStringsSep "\n" (attrValues z.luks))}
${optionalString (hasAttr "lvm" z) (concatStringsSep "\n" (attrValues z.lvm))} ${optionalString (hasAttr "lvm" z) (concatStringsSep "\n" (attrValues z.lvm))}
${optionalString (hasAttr "fs" z) (concatStringsSep "\n" (attrValues z.fs))} ${optionalString (hasAttr "fs" z) (concatStringsSep "\n" (attrValues z.fs))}
@ -129,8 +159,11 @@ let {
mount.noop = q: x: {}; mount.noop = q: x: {};
mount.partition = q: x: mount.partition = q: x:
mount-f { device = q.device + toString q.index; } x.content; mount-f { device = "\"\${${q.device}}\"-part" + toString q.index; } x.content;
mount.table = q: x: mount.table = q: x: (
foldl' recursiveUpdate {} (imap (index: mount-f (q // { inherit index; })) x.partitions); recursiveUpdate
(foldl' recursiveUpdate {} (imap (index: mount-f (q // { inherit index; device = helper.device-id q.device; })) x.partitions))
{table.${q.device} = helper.find-device q.device;}
);
} }