src/commands/cache_writeback.rs - main - githubmirror/thin-provisioning-tools

src/commands/cache_writeback.rs
168 строк6 KB
Ming-Hung Tsai
[commands] Fix version string compatibility issue with LVM
23 фев 2024, 12:55
23 фев 2024, 12:553cb749b
use clap::{value_parser, Arg, ArgAction};
use std::path::Path;

use crate::cache::check::{check, CacheCheckOptions};
use crate::cache::writeback::{writeback, CacheWritebackOptions};
use crate::commands::engine::*;
use crate::commands::utils::*;
use crate::commands::Command;
use crate::report::{parse_log_level, verbose_args};
use crate::version::*;

pub struct CacheWritebackCommand;

impl CacheWritebackCommand {
    fn cli(&self) -> clap::Command {
        let cmd = clap::Command::new(self.name())
            .next_display_order(None)
            .version(crate::tools_version!())
            .disable_version_flag(true)
            .about("Repair binary cache metadata, and write it to a different device or file")
            .arg(
                Arg::new("QUIET")
                    .help("Suppress output messages, return only exit code.")
                    .short('q')
                    .long("quiet")
                    .action(ArgAction::SetTrue),
            )
            .arg(
                Arg::new("NO_METADATA_UPDATE")
                    .help("Do not clear the dirty flags in metadata")
                    .long("no-metadata-update")
                    .action(ArgAction::SetTrue),
            )
            .arg(
                Arg::new("LIST_FAILED_BLOCKS")
                    .help("List any blocks that failed the writeback process")
                    .long("list-failed-blocks")
                    .action(ArgAction::SetTrue),
            )
            // options
            .arg(
                Arg::new("METADATA_DEV")
                    .help("Specify the cache metadata device")
                    .long("metadata-device")
                    .value_name("FILE")
                    .required(true),
            )
            .arg(
                Arg::new("ORIGIN_DEV")
                    .help("Specify the slow device begin cached")
                    .long("origin-device")
                    .value_name("FILE")
                    .required(true),
            )
            .arg(
                Arg::new("FAST_DEV")
                    .help(
                        "Specify the fast device containing the data that needs to be written back",
                    )
                    .long("fast-device")
                    .value_name("FILE")
                    .required(true),
            )
            .arg(
                Arg::new("ORIGIN_DEV_OFFSET")
                    .help("Specify the data offset within the slow device")
                    .long("origin-device-offset")
                    .value_name("SECTORS")
                    .value_parser(value_parser!(u64)),
            )
            .arg(
                Arg::new("FAST_DEV_OFFSET")
                    .help("Specify the data offset within the fast device")
                    .long("fast-device-offset")
                    .value_name("SECTORS")
                    .value_parser(value_parser!(u64)),
            )
            .arg(
                Arg::new("BUFFER_SIZE_MEG")
                    .help("Specify the size for the data cache, in megabytes")
                    .long("buffer-size-meg")
                    .value_name("MB")
                    .value_parser(value_parser!(usize)),
            )
            .arg(
                Arg::new("RETRY_COUNT")
                    .help("Specify how many times to retry data copying on failed data block")
                    .long("retry-count")
                    .value_name("CNT")
                    .value_parser(value_parser!(u32))
                    .default_value("0"),
            );
        verbose_args(engine_args(version_args(cmd)))
    }
}

impl<'a> Command<'a> for CacheWritebackCommand {
    fn name(&self) -> &'a str {
        "cache_writeback"
    }

    fn run(&self, args: &mut dyn Iterator<Item = std::ffi::OsString>) -> exitcode::ExitCode {
        let matches = self.cli().get_matches_from(args);
        display_version(&matches);

        let metadata_dev = Path::new(matches.get_one::<String>("METADATA_DEV").unwrap());
        let origin_dev = Path::new(matches.get_one::<String>("ORIGIN_DEV").unwrap());
        let fast_dev = Path::new(matches.get_one::<String>("FAST_DEV").unwrap());

        let report = mk_report(matches.get_flag("QUIET"));
        let log_level = match parse_log_level(&matches) {
            Ok(level) => level,
            Err(e) => return to_exit_code::<()>(&report, Err(anyhow::Error::msg(e))),
        };
        report.set_level(log_level);

        if let Err(e) = check_input_file(metadata_dev)
            .and_then(|_| check_input_file(origin_dev))
            .and_then(|_| check_input_file(fast_dev))
        {
            return to_exit_code::<()>(&report, Err(e));
        }

        let engine_opts = match parse_engine_opts(ToolType::Cache, &matches) {
            Ok(opt) => opt,
            Err(_) => return exitcode::USAGE,
        };

        let check_opts = CacheCheckOptions {
            dev: metadata_dev,
            engine_opts: engine_opts.clone(),
            sb_only: false,
            skip_mappings: false,
            skip_hints: false,
            skip_discards: false,
            ignore_non_fatal: false,
            auto_repair: false,
            clear_needs_check: false,
            report: report.clone(),
        };

        if check(check_opts).is_err() {
            report.fatal(
                "metadata contains errors (run cache_check for details).\n\
                perhaps you need to run cache_repair.",
            );
            return exitcode::DATAERR;
        }

        let opts = CacheWritebackOptions {
            metadata_dev,
            engine_opts,
            origin_dev,
            fast_dev,
            origin_dev_offset: matches.get_one::<u64>("ORIGIN_DEV_OFFSET").cloned(),
            fast_dev_offset: matches.get_one::<u64>("FAST_DEV_OFFSET").cloned(),
            buffer_size: matches
                .get_one::<usize>("BUFFER_SIZE_MEG")
                .map(|v| *v * 2048),
            list_failed_blocks: matches.get_flag("LIST_FAILED_BLOCKS"),
            update_metadata: !matches.get_flag("NO_METADATA_UPDATE"),
            retry_count: *matches.get_one::<u32>("RETRY_COUNT").unwrap(),
            report: report.clone(),
        };

        to_exit_code(&report, writeback(opts))
    }
}