s390x: add support for IBM Z DASD disks

.travis.yml

@@ -6,9 +6,16 @@ rust:
   - beta
   - nightly
 
+arch:
+  - amd64
+  - s390x
+
 matrix:
   allow_failures:
     - rust: nightly
+    # VM apparently has broken network access
+    - rust: 1.41.0
+      arch: s390x
 
 env:
   global:

Cargo.toml

@@ -23,6 +23,9 @@ path = "src/main.rs"
 [profile.release]
 lto = true
 
+[target.'cfg(target_arch = "s390x")'.dependencies]
+gptman = { version = "^0.6", default-features = false }
+
 [dependencies]
 bincode = "^1.3"
 byte-unit = "^4.0"

scripts/coreos-installer-service

@@ -10,6 +10,9 @@ PERSIST_KERNEL_NET_PARAMS=("ipv6.disable" "net.ifnames" "net.naming-scheme")
 # List from https://www.mankier.com/7/dracut.cmdline#Description-Network
 PERSIST_DRACUT_NET_PARAMS=("ip" "ifname" "rd.route" "bootdev" "BOOTIF" "rd.bootif" "nameserver" "rd.peerdns" "biosdevname" "vlan" "bond" "team" "bridge" "rd.net.timeout.carrier" "coreos.no_persist_ip")
 
+# IBM S390X params to persist
+PERSIST_S390X_PARAMS=("rd.dasd" "rd.zfcp" "rd.znet" "zfcp.allow_lun_scan" "cio_ignore")
+
 args=("install")
 
 cmdline=( $(</proc/cmdline) )
@@ -61,19 +64,24 @@ if [ -n "${ignition_url}" -a "${ignition_url}" != "skip" ]; then
     args+=("--ignition-url" "${ignition_url}" "--insecure-ignition")
 fi
 
-# First-boot kernel arguments. Filter out any args that aren't in our
-# list of networking arguments to forward and store them in $firstboot_args
+# Forward whitelisted kernel arguments to the installed system. We have
+# separate sets of whitelists for first-boot kargs and persistent kargs.
+# Only pass --firstboot-kargs if additional networking options have been
+# specified, since the default in coreos-assembler specifies
+# `rd.neednet=1 ip=dhcp` when no options are persisted.
 firstboot_args=""
 for item in "${cmdline[@]}"; do
     for param in "${PERSIST_KERNEL_NET_PARAMS[@]}" "${PERSIST_DRACUT_NET_PARAMS[@]}"; do
         if [[ $item =~ ^$param(=.*)?$ ]]; then
             firstboot_args+="${item} "
         fi
     done
+    for param in "${PERSIST_S390X_PARAMS[@]}"; do
+        if [[ $item =~ ^$param(=.*)?$ ]]; then
+            args+=("--append-karg" "${item}")
+        fi
+    done
 done
-# Only pass firstboot-kargs if additional networking options have been
-# specified, since the default in ignition-dracut specifies
-# `rd.neednet=1 ip=dhcp` when no options are persisted
 if [ -n "${firstboot_args}" ]; then
     args+=("--firstboot-args" "rd.neednet=1 ${firstboot_args}")
 fi
@@ -94,4 +102,3 @@ udevadm settle
 # Install
 echo "coreos-installer ${args[@]}"
 coreos-installer "${args[@]}"
-

src/blockdev.rs

@@ -18,7 +18,7 @@ use nix::{errno::Errno, mount};
 use regex::Regex;
 use std::collections::HashMap;
 use std::convert::TryInto;
-use std::fs::{metadata, read_dir, read_link, read_to_string, remove_dir, File, OpenOptions};
+use std::fs::{metadata, read_dir, read_to_string, remove_dir, File, OpenOptions};
 use std::num::{NonZeroU32, NonZeroU64};
 use std::os::linux::fs::MetadataExt;
 use std::os::raw::c_int;
@@ -30,6 +30,7 @@ use std::thread::sleep;
 use std::time::Duration;
 
 use crate::errors::*;
+use crate::io::resolve_link;
 
 #[derive(Debug)]
 pub struct Disk {
@@ -374,21 +375,17 @@ impl Partition {
         // Now assume a kpartx "partition", where the path is a symlink to
         // an unpartitioned DM device node.
         // /sys/block/dm-1
-        match read_link(Path::new(&self.path)) {
-            Ok(target) => {
-                let devdir = basedir.join(
-                    Path::new(&target)
-                        .file_name()
-                        .chain_err(|| format!("target {} has no filename", self.path))?,
-                );
-                if devdir.exists() {
-                    return Ok(devdir);
-                }
+        let (target, is_link) = resolve_link(&self.path)?;
+        if is_link {
+            let devdir = basedir.join(
+                target
+                    .file_name()
+                    .chain_err(|| format!("target {} has no filename", target.display()))?,
+            );
+            if devdir.exists() {
+                return Ok(devdir);
             }
-            // ignore if not symlink
-            Err(e) if e.kind() == std::io::ErrorKind::InvalidInput => (),
-            Err(e) => return Err(e).chain_err(|| format!("reading link {}", self.path)),
-        };
+        }
 
         // Give up
         bail!(
@@ -572,7 +569,7 @@ mod ioctl {
     ioctl_read!(blkgetsize64, 0x12, 114, libc::size_t);
 }
 
-fn udev_settle() -> Result<()> {
+pub fn udev_settle() -> Result<()> {
     // "udevadm settle" silently no-ops if the udev socket is missing, and
     // then lsblk can't find partition labels.  Catch this early.
     if !Path::new("/run/udev/control").exists() {

src/download.rs

@@ -145,7 +145,14 @@ fn write_image_and_sig(
 
     // download and verify image
     // don't check sector size
-    write_image(source, &mut dest, decompress, None)?;
+    write_image(
+        source,
+        &mut dest,
+        path,
+        image_copy_default,
+        decompress,
+        None,
+    )?;
 
     // write signature, if relevant
     if let (false, Some(signature)) = (decompress, source.signature.as_ref()) {
@@ -164,12 +171,17 @@ fn write_image_and_sig(
 }
 
 /// Copy the image to disk and verify its signature.
-pub fn write_image(
+pub fn write_image<F>(
     source: &mut ImageSource,
     dest: &mut File,
+    dest_path: &Path,
+    image_copy: F,
     decompress: bool,
     expected_sector_size: Option<NonZeroU32>,
-) -> Result<()> {
+) -> Result<()>
+where
+    F: FnOnce(&[u8], &mut dyn Read, &mut File, &Path) -> Result<()>,
+{
     // wrap source for GPG verification
     let mut verify_reader: Box<dyn Read> = {
         if let Some(signature) = source.signature.as_ref() {
@@ -269,6 +281,27 @@ pub fn write_image(
         }
     }
 
+    // call the callback to copy the image
+    image_copy(&first_mb, &mut decompress_reader, dest, dest_path)?;
+
+    // flush
+    dest.flush().chain_err(|| "flushing data to disk")?;
+    dest.sync_all().chain_err(|| "syncing data to disk")?;
+
+    // if we reported progress using CRs, log final newline
+    if stderr_is_tty {
+        eprintln!();
+    }
+
+    Ok(())
+}
+
+pub fn image_copy_default(
+    first_mb: &[u8],
+    source: &mut dyn Read,
+    dest: &mut File,
+    _dest_path: &Path,
+) -> Result<()> {
     // Cache the first MiB and write zeroes to dest instead.  This ensures
     // that the disk image can't be used accidentally before its GPG signature
     // is verified.
@@ -287,23 +320,14 @@ pub fn write_image(
     // sparse-copy the image, falling back to non-sparse copy if hardware
     // acceleration is unavailable.  But BLKZEROOUT doesn't support
     // BLKDEV_ZERO_NOFALLBACK, so we'd risk gigabytes of redundant I/O.
-    copy(&mut decompress_reader, dest).chain_err(|| "decoding and writing image")?;
+    copy(source, dest).chain_err(|| "decoding and writing image")?;
 
     // verify_reader has now checked the signature, so fill in the first MiB
     dest.seek(SeekFrom::Start(0))
         .chain_err(|| "seeking to start of disk")?;
-    dest.write_all(&first_mb)
+    dest.write_all(first_mb)
         .chain_err(|| "writing to first MiB of disk")?;
 
-    // flush
-    dest.flush().chain_err(|| "flushing data to disk")?;
-    dest.sync_all().chain_err(|| "syncing data to disk")?;
-
-    // if we reported progress using CRs, log final newline
-    if stderr_is_tty {
-        eprintln!();
-    }
-
     Ok(())
 }