1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
|
use anyhow::Result;
use std::path::{Path, PathBuf};
use thinp::cache::metadata_generator::CacheGenerator;
use thinp::file_utils;
use thinp::io_engine::SyncIoEngine;
use crate::args;
use crate::common::cache_xml_generator::write_xml;
use crate::common::process::*;
use crate::common::target::*;
use crate::common::test_dir::TestDir;
//-----------------------------------------------
pub fn mk_valid_xml(td: &mut TestDir) -> Result<PathBuf> {
let xml = td.mk_path("meta.xml");
// bs, cblocks, oblocks, res, dirty, version, hotspot_size
let mut gen = CacheGenerator::new(512, 128, 1024, 80, 50, 2, 16);
write_xml(&xml, &mut gen)?;
Ok(xml)
}
pub fn mk_valid_md(td: &mut TestDir) -> Result<PathBuf> {
let xml = td.mk_path("meta.xml");
let md = td.mk_path("meta.bin");
let mut gen = CacheGenerator::new(512, 4096, 32768, 80, 50, 2, 16);
write_xml(&xml, &mut gen)?;
let _file = file_utils::create_sized_file(&md, 4096 * 4096);
run_ok(cache_restore_cmd(args!["-i", &xml, "-o", &md]))?;
Ok(md)
}
//-----------------------------------------------
pub fn generate_metadata_leaks(
md: &Path,
nr_blocks: u64,
expected: u32,
actual: u32,
) -> Result<()> {
let nr_blocks_str = nr_blocks.to_string();
let expected_str = expected.to_string();
let actual_str = actual.to_string();
let args = args![
"-o",
&md,
"--create-metadata-leaks",
"--nr-blocks",
&nr_blocks_str,
"--expected",
&expected_str,
"--actual",
&actual_str
];
run_ok(cache_generate_damage_cmd(args))?;
Ok(())
}
//-----------------------------------------------
pub fn get_clean_shutdown(md: &Path) -> Result<bool> {
use thinp::cache::superblock::*;
let engine = SyncIoEngine::new(md, false)?;
let sb = read_superblock(&engine, SUPERBLOCK_LOCATION)?;
Ok(sb.flags.clean_shutdown)
}
pub fn get_needs_check(md: &Path) -> Result<bool> {
use thinp::cache::superblock::*;
let engine = SyncIoEngine::new(md, false)?;
let sb = read_superblock(&engine, SUPERBLOCK_LOCATION)?;
Ok(sb.flags.needs_check)
}
pub fn unset_clean_shutdown(md: &Path) -> Result<()> {
let args = args!["-o", &md, "--set-clean-shutdown=false"];
run_ok(cache_generate_metadata_cmd(args))?;
Ok(())
}
pub fn set_needs_check(md: &Path) -> Result<()> {
let args = args!["-o", &md, "--set-needs-check"];
run_ok(cache_generate_metadata_cmd(args))?;
Ok(())
}
//-----------------------------------------------
|
