in src/dumper.rs [352:378]
fn send_store_jobs(
sender: &Sender<Option<JobItem>>,
results: &mut HashMap<String, ObjectInfo>,
num_threads: usize,
output: Output,
check_cfi: bool,
collect_inlines: bool,
) -> common::Result<()> {
if results.len() == 1 {
let (_, d) = results.drain().take(1).next().unwrap();
self::store(&output, check_cfi, d)?;
} else {
for (_, d) in results.drain() {
sender
.send(Some(JobItem {
file: "".to_string(),
typ: JobType::Dump(d),
mapping: None,
collect_inlines,
}))
.unwrap();
}
}
poison_queue(sender, num_threads);
Ok(())
}