MCPcopy Create free account
hub / github.com/argumentcomputer/ix / resolve_kernel_check_workers_from

Function resolve_kernel_check_workers_from

crates/ffi/src/kernel.rs:1266–1282  ·  view source on GitHub ↗
(
  total: usize,
  quiet: bool,
  env_workers: Option<&str>,
  no_par: bool,
  available_parallelism: usize,
)

Source from the content-addressed store, hash-verified

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
1279fn 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,

Callers 1

Calls 1

maxMethod · 0.45

Tested by

no test coverage detected