Add support for ICE reporting in lintcheck

This commit is contained in:
Jacherr 2024-03-08 18:32:29 +00:00 committed by blyxyas
parent a79db2aa51
commit 42d09703b4

View file

@ -19,12 +19,12 @@ use std::env::consts::EXE_SUFFIX;
use std::fmt::{self, Write as _}; use std::fmt::{self, Write as _};
use std::io::{self, ErrorKind}; use std::io::{self, ErrorKind};
use std::path::{Path, PathBuf}; use std::path::{Path, PathBuf};
use std::process::Command; use std::process::{Command, ExitStatus};
use std::sync::atomic::{AtomicUsize, Ordering}; use std::sync::atomic::{AtomicUsize, Ordering};
use std::time::Duration; use std::time::Duration;
use std::{env, fs, thread}; use std::{env, fs, thread};
use cargo_metadata::diagnostic::{Diagnostic, DiagnosticLevel}; use cargo_metadata::diagnostic::Diagnostic;
use cargo_metadata::Message; use cargo_metadata::Message;
use rayon::prelude::*; use rayon::prelude::*;
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
@ -90,16 +90,43 @@ struct Crate {
options: Option<Vec<String>>, options: Option<Vec<String>>,
} }
/// A single emitted output from clippy being executed on a crate. It may either be a
/// `ClippyWarning`, or a `RustcIce` caused by a panic within clippy. A crate may have many
/// `ClippyWarning`s but a maximum of one `RustcIce` (at which point clippy halts execution).
#[derive(Debug)]
enum ClippyCheckOutput {
ClippyWarning(ClippyWarning),
RustcIce(RustcIce),
}
#[derive(Debug)]
struct RustcIce {
pub crate_name: String,
pub ice_content: String,
}
impl RustcIce {
pub fn from_stderr_and_status(crate_name: &str, status: ExitStatus, stderr: &str) -> Option<Self> {
if status.code().unwrap_or(0) == 101
/* ice exit status */
{
Some(Self {
crate_name: crate_name.to_owned(),
ice_content: stderr.to_owned(),
})
} else {
None
}
}
}
/// A single warning that clippy issued while checking a `Crate` /// A single warning that clippy issued while checking a `Crate`
#[derive(Debug)] #[derive(Debug)]
struct ClippyWarning { struct ClippyWarning {
crate_name: String,
file: String, file: String,
line: usize, line: usize,
column: usize, column: usize,
lint_type: String, lint_type: String,
message: String, message: String,
is_ice: bool,
} }
#[allow(unused)] #[allow(unused)]
@ -124,13 +151,11 @@ impl ClippyWarning {
}; };
Some(Self { Some(Self {
crate_name: crate_name.to_owned(),
file, file,
line: span.line_start, line: span.line_start,
column: span.column_start, column: span.column_start,
lint_type, lint_type,
message: diag.message, message: diag.message,
is_ice: diag.level == DiagnosticLevel::Ice,
}) })
} }
@ -311,7 +336,7 @@ impl Crate {
config: &LintcheckConfig, config: &LintcheckConfig,
lint_filter: &[String], lint_filter: &[String],
server: &Option<LintcheckServer>, server: &Option<LintcheckServer>,
) -> Vec<ClippyWarning> { ) -> Vec<ClippyCheckOutput> {
// advance the atomic index by one // advance the atomic index by one
let index = target_dir_index.fetch_add(1, Ordering::SeqCst); let index = target_dir_index.fetch_add(1, Ordering::SeqCst);
// "loop" the index within 0..thread_limit // "loop" the index within 0..thread_limit
@ -335,9 +360,9 @@ impl Crate {
let shared_target_dir = clippy_project_root().join("target/lintcheck/shared_target_dir"); let shared_target_dir = clippy_project_root().join("target/lintcheck/shared_target_dir");
let mut cargo_clippy_args = if config.fix { let mut cargo_clippy_args = if config.fix {
vec!["--fix", "--"] vec!["--quiet", "--fix", "--"]
} else { } else {
vec!["--", "--message-format=json", "--"] vec!["--quiet", "--message-format=json", "--"]
}; };
let mut clippy_args = Vec::<&str>::new(); let mut clippy_args = Vec::<&str>::new();
@ -428,14 +453,21 @@ impl Crate {
} }
// get all clippy warnings and ICEs // get all clippy warnings and ICEs
let warnings: Vec<ClippyWarning> = Message::parse_stream(stdout.as_bytes()) let mut entries: Vec<ClippyCheckOutput> = Message::parse_stream(stdout.as_bytes())
.filter_map(|msg| match msg { .filter_map(|msg| match msg {
Ok(Message::CompilerMessage(message)) => ClippyWarning::new(message.message, &self.name, &self.version), Ok(Message::CompilerMessage(message)) => ClippyWarning::new(message.message, &self.name, &self.version),
_ => None, _ => None,
}) })
.map(ClippyCheckOutput::ClippyWarning)
.collect(); .collect();
warnings if let Some(ice) = RustcIce::from_stderr_and_status(&self.name, *status, &stderr) {
entries.push(ClippyCheckOutput::RustcIce(ice));
} else if !status.success() {
println!("non-ICE bad exit status for {} {}: {}", self.name, self.version, stderr);
}
entries
} }
} }
@ -635,7 +667,7 @@ fn main() {
LintcheckServer::spawn(recursive_options) LintcheckServer::spawn(recursive_options)
}); });
let mut clippy_warnings: Vec<ClippyWarning> = crates let mut clippy_entries: Vec<ClippyCheckOutput> = crates
.par_iter() .par_iter()
.flat_map(|krate| { .flat_map(|krate| {
krate.run_clippy_lints( krate.run_clippy_lints(
@ -651,7 +683,9 @@ fn main() {
.collect(); .collect();
if let Some(server) = server { if let Some(server) = server {
clippy_warnings.extend(server.warnings()); let server_clippy_entries = server.warnings().map(ClippyCheckOutput::ClippyWarning);
clippy_entries.extend(server_clippy_entries);
} }
// if we are in --fix mode, don't change the log files, terminate here // if we are in --fix mode, don't change the log files, terminate here
@ -659,20 +693,21 @@ fn main() {
return; return;
} }
// split up warnings and ices
let mut warnings: Vec<ClippyWarning> = vec![];
let mut raw_ices: Vec<RustcIce> = vec![];
for entry in clippy_entries {
if let ClippyCheckOutput::ClippyWarning(x) = entry {
warnings.push(x);
} else if let ClippyCheckOutput::RustcIce(x) = entry {
raw_ices.push(x);
}
}
// generate some stats // generate some stats
let (stats_formatted, new_stats) = gather_stats(&clippy_warnings); let (stats_formatted, new_stats) = gather_stats(&warnings);
// grab crashes/ICEs, save the crate name and the ice message let mut all_msgs: Vec<String> = warnings.iter().map(|warn| warn.to_output(config.markdown)).collect();
let ices: Vec<(&String, &String)> = clippy_warnings
.iter()
.filter(|warning| warning.is_ice)
.map(|w| (&w.crate_name, &w.message))
.collect();
let mut all_msgs: Vec<String> = clippy_warnings
.iter()
.map(|warn| warn.to_output(config.markdown))
.collect();
all_msgs.sort(); all_msgs.sort();
all_msgs.push("\n\n### Stats:\n\n".into()); all_msgs.push("\n\n### Stats:\n\n".into());
all_msgs.push(stats_formatted); all_msgs.push(stats_formatted);
@ -686,11 +721,18 @@ fn main() {
} }
write!(text, "{}", all_msgs.join("")).unwrap(); write!(text, "{}", all_msgs.join("")).unwrap();
text.push_str("\n\n### ICEs:\n"); text.push_str("\n\n### ICEs:\n");
for (cratename, msg) in &ices { for ice in &raw_ices {
let _: fmt::Result = write!(text, "{cratename}: '{msg}'"); let _: fmt::Result = write!(
text,
"{}:\n{}\n========================================\n\n",
ice.crate_name, ice.ice_content
);
} }
println!("Writing logs to {}", config.lintcheck_results_path.display()); println!("Writing logs to {}", config.lintcheck_results_path.display());
if !raw_ices.is_empty() {
println!("WARNING: at least one ICE reported, check log file");
}
fs::create_dir_all(config.lintcheck_results_path.parent().unwrap()).unwrap(); fs::create_dir_all(config.lintcheck_results_path.parent().unwrap()).unwrap();
fs::write(&config.lintcheck_results_path, text).unwrap(); fs::write(&config.lintcheck_results_path, text).unwrap();