( total: usize, quiet: bool, env_workers: Option<&str>, no_par: bool, available_parallelism: usize, )
| 1264 | return Err("kernel-check worker panicked".to_string()); |
| 1265 | } |
| 1266 | |
| 1267 | let mut ordered = Vec::with_capacity(total); |
| 1268 | for i in 0..total { |
| 1269 | match results[i].get() { |
| 1270 | Some(result) => ordered.push(result.clone()), |
| 1271 | None => { |
| 1272 | return Err(format!("kernel-check worker missed result index {i}")); |
| 1273 | }, |
| 1274 | } |
| 1275 | } |
| 1276 | Ok(ordered) |
| 1277 | } |
| 1278 | |
| 1279 | fn resolve_kernel_check_workers(total: usize, quiet: bool) -> usize { |
| 1280 | let env_workers = std::env::var("IX_KERNEL_CHECK_WORKERS").ok(); |
| 1281 | let no_par = std::env::var("IX_NO_PAR").ok().as_deref() == Some("1"); |
| 1282 | let available = thread::available_parallelism().map(|n| n.get()).unwrap_or(1); |
| 1283 | resolve_kernel_check_workers_from( |
| 1284 | total, |
| 1285 | quiet, |
no test coverage detected