Revision control

Copy as Markdown

Other Tools

#![cfg(target_os = "macos")]
mod common;
use common::start_child_and_return;
use minidump::{
CrashReason, Minidump, MinidumpBreakpadInfo, MinidumpMemoryList, MinidumpMiscInfo,
MinidumpModuleList, MinidumpSystemInfo, MinidumpThreadList,
};
use minidump_writer::minidump_writer::MinidumpWriter;
fn get_crash_reason<'a, T: std::ops::Deref<Target = [u8]> + 'a>(
md: &Minidump<'a, T>,
) -> CrashReason {
let exc: minidump::MinidumpException<'_> =
md.get_stream().expect("unable to find exception stream");
exc.get_crash_reason(
minidump::system_info::Os::MacOs,
if cfg!(target_arch = "x86_64") {
minidump::system_info::Cpu::X86_64
} else if cfg!(target_arch = "aarch64") {
minidump::system_info::Cpu::Arm64
} else {
unimplemented!()
},
)
}
struct Captured<'md> {
#[allow(dead_code)]
task: u32,
thread: u32,
minidump: Minidump<'md, memmap2::Mmap>,
}
fn capture_minidump(name: &str, exception_kind: u32) -> Captured<'_> {
// Create a mach port server to retrieve the crash details from the child
let mut server = crash_context::ipc::Server::create(&std::ffi::CString::new(name).unwrap())
.expect("failed to create mach port service");
let mut child = start_child_and_return(&[name, &exception_kind.to_string()]);
// Wait for the child to spinup and report a crash context to us
let mut rcc = server
.try_recv_crash_context(Some(std::time::Duration::from_secs(5)))
.expect("failed to receive context")
.expect("receive timed out");
let mut tmpfile = tempfile::Builder::new().prefix(name).tempfile().unwrap();
let task = rcc.crash_context.task;
let thread = rcc.crash_context.thread;
let mut dumper = MinidumpWriter::with_crash_context(rcc.crash_context);
dumper
.dump(tmpfile.as_file_mut())
.expect("failed to write minidump");
// Signal the child that we've received and processed the crash context
rcc.acker
.send_ack(1, Some(std::time::Duration::from_secs(2)))
.expect("failed to send ack");
child.kill().expect("failed to kill child");
let minidump = Minidump::read_path(tmpfile.path()).expect("failed to read minidump");
Captured {
task,
thread,
minidump,
}
}
#[test]
fn dump_external_process() {
if std::env::var("CI").is_ok() {
println!("test disabled, consistently times out because of potato runners");
return;
}
let approximate_proc_start_time = std::time::SystemTime::now()
.duration_since(std::time::SystemTime::UNIX_EPOCH)
.unwrap()
.as_secs();
let md = capture_minidump(
"dump_external_process",
mach2::exception_types::EXC_BREAKPOINT,
)
.minidump;
let crash_reason = get_crash_reason(&md);
assert!(matches!(
crash_reason,
CrashReason::MacGeneral(minidump_common::errors::ExceptionCodeMac::EXC_BREAKPOINT, _)
));
let _: MinidumpModuleList = md.get_stream().expect("Couldn't find MinidumpModuleList");
let _: MinidumpThreadList = md.get_stream().expect("Couldn't find MinidumpThreadList");
let _: MinidumpMemoryList = md.get_stream().expect("Couldn't find MinidumpMemoryList");
let _: MinidumpSystemInfo = md.get_stream().expect("Couldn't find MinidumpSystemInfo");
let _: MinidumpBreakpadInfo = md.get_stream().expect("Couldn't find MinidumpBreakpadInfo");
let misc_info: MinidumpMiscInfo = md.get_stream().expect("Couldn't find MinidumpMiscInfo");
if let minidump::RawMiscInfo::MiscInfo2(mi) = &misc_info.raw {
// Unfortunately the minidump format only has 32-bit precision for the
// process start time
let process_create_time = mi.process_create_time as u64;
assert!(
process_create_time >= approximate_proc_start_time
&& process_create_time <= approximate_proc_start_time + 2
);
// I've tried busy looping to spend CPU time to get this up, but
// MACH_TASK_BASIC_INFO which should give terminated thread times only ever
// reports 0, and TASK_THREAD_TIMES_INFO which should show active thread
// times I've only been able to get upt to a few thousand microseconds
// even when busy looping for well over a second, and those get truncated
// to whole seconds. And it seems that crashpad doesn't have tests around
// this, though that's hard to say given how tedious it is finding stuff
// in that bloated codebase
// assert!(mi.process_user_time > 0);
// assert!(mi.process_kernel_time > 0);
// These aren't currently available on aarch64, or if they are, they
// are not via the same sysctlbyname mechanism. Would be nice if Apple
// documented...anything
if cfg!(target_arch = "x86_64") {
assert!(mi.processor_max_mhz > 0);
assert!(mi.processor_current_mhz > 0);
}
} else {
panic!("unexpected misc info type {:?}", misc_info);
}
}
/// Validates we can actually walk the stack for each thread in the minidump,
/// this is using minidump-processor, which (currently) depends on breakpad
/// symbols, however https://github.com/mozilla/dump_syms is not available as
/// a library https://github.com/mozilla/dump_syms/issues/253, so we just require
/// that it already be installed, hence the ignore
#[test]
fn stackwalks() {
if std::env::var("CI").is_ok() {
println!("test disabled, consistently times out because of potato runners");
return;
}
println!("generating minidump...");
let md = capture_minidump("stackwalks", mach2::exception_types::EXC_BREAKPOINT);
// Generate the breakpad symbols
println!("generating symbols...");
dump_syms::dumper::single_file(
&dump_syms::dumper::Config {
output: dump_syms::dumper::Output::Store(".test-symbols".into()),
symbol_server: None,
debug_id: None,
code_id: None,
arch: if cfg!(target_arch = "aarch64") {
"arm64"
} else if cfg!(target_arch = "x86_64") {
"x86_64"
} else {
panic!("invalid MacOS target architecture")
},
num_jobs: 2, // default this
check_cfi: false,
emit_inlines: false,
mapping_var: None,
mapping_src: None,
mapping_dest: None,
mapping_file: None,
},
"target/debug/test",
)
.expect("failed to dump symbols");
let provider = minidump_unwind::Symbolizer::new(minidump_unwind::simple_symbol_supplier(vec![
".test-symbols".into(),
]));
let state = futures::executor::block_on(async {
minidump_processor::process_minidump(&md.minidump, &provider).await
})
.unwrap();
//state.print(&mut std::io::stdout()).map_err(|_| ()).unwrap();
// We expect at least 2 threads, one of which is the fake crashing thread
let fake_crash_thread = state
.threads
.iter()
.find(|cs| cs.thread_id == md.thread)
.expect("failed to find crash thread");
assert_eq!(
fake_crash_thread.thread_name.as_deref(),
Some("test-thread")
);
assert!(
fake_crash_thread.frames.iter().any(|sf| {
sf.function_name
.as_ref()
.map_or(false, |fname| fname.ends_with("wait_until_killed"))
}),
"unable to locate expected function"
);
let mod_list: MinidumpModuleList = md
.minidump
.get_stream()
.expect("Couldn't find MinidumpModuleList");
// Ensure we found dyld
assert!(mod_list
.iter()
.any(|module| &module.name == "/usr/lib/dyld"));
}