Function find_diff

crates/ffi/src/kernel.rs:3251–3383

(
  a: &ix_common::env::Expr,
  b: &ix_common::env::Expr,
  path: &str,
)

                  &check.label,
                  self.in_flight_label_chars
                ),
                age.as_secs_f64()
              ));
            }
          }
        }
      }

      let mut entries: Vec<_> = active
        .iter()
        .filter_map(|slot| {
          slot.as_ref().map(|check| (check.started, check.label.clone()))
        })
        .collect();
      entries.sort_by_key(|(started, _)| *started);
      let in_flight = entries
        .into_iter()
        .take(self.in_flight_limit)
        .map(|(started, label)| {
          format!(
            "{} ({:.0}s)",
            compact_in_flight_label(&label, self.in_flight_label_chars),
            started.elapsed().as_secs_f64()
          )
        })
        .collect::<Vec<_>>();
      (in_flight, active_slow_lines)
    };
    let active_suffix = if in_flight.is_empty() {
      String::new()
    } else {
      format!(" · in-flight: {}", in_flight.join(", "))
    };
    let mem_suffix = kernel_check_mem_suffix(Some(&self.peak_rss_mib));

    self.log(&format!(
      "[rs_kernel_check] {done}/{} ({pct:.1}%) · {:.1}/s · elapsed {:.0}s{eta}{mem_suffix}{active_suffix}",
      self.total,
      rate,
      elapsed,
    ));
    for line in active_slow_lines {
      self.log(&line);
    }
  }

  fn log(&self, line: &str) {
    let _guard = self.print_lock.lock().unwrap();
    eprintln!("{line}");
  }
}

fn kernel_check_progress_interval() -> Option<Duration> {
  let ms = std::env::var("IX_KERNEL_CHECK_PROGRESS_MS")
    .ok()
    .or_else(|| std::env::var("IX_PROGRESS_MS").ok())
    .and_then(|s| s.parse::<u64>().ok())
    .unwrap_or(2000);