ParallelFrontend scenario added for -Zthreads=8 run, check only

azhogin · azhogin · commit 00b1a2cdb365 · 2026-03-23T13:46:33.000+07:00
diff --git a/collector/src/bin/collector.rs b/collector/src/bin/collector.rs
@@ -177,7 +177,7 @@ fn generate_diffs(
                     return vec![];
                 }
                 match scenario {
-                    Scenario::Full | Scenario::IncrFull | Scenario::IncrUnchanged => {
+                    Scenario::Full | Scenario::IncrFull | Scenario::IncrUnchanged | Scenario::ParallelFrontend => {
                         vec![format!("{:?}", scenario)]
                     }
                     Scenario::IncrPatched => (0..benchmark.patches.len())
diff --git a/collector/src/compile/benchmark/mod.rs b/collector/src/compile/benchmark/mod.rs
@@ -451,6 +451,13 @@ impl Benchmark {
                         .await?;
                 }
 
+                if scenarios.contains(&Scenario::ParallelFrontend) {
+                    self.mk_cargo_process(toolchain, cwd, profile, backend, target)
+                        .processor(processor, Scenario::ParallelFrontend, "ParFront", None)
+                        .run_rustc(true)
+                        .await?;
+                }
+
                 // Rustdoc does not support incremental compilation
                 if !profile.is_doc() {
                     // An incremental build from scratch (slowest incremental case).
@@ -524,6 +531,10 @@ impl Benchmark {
         if scenario.is_incr() && profile.is_doc() {
             return false;
         }
+        // Testing parallel frontend only for 'check' profile
+        if *scenario == Scenario::ParallelFrontend && *profile != Profile::Check {
+            return false;
+        }
 
         let benchmark = database::Benchmark::from(self.name.0.as_str());
         let profile: database::Profile = (*profile).into();
@@ -532,7 +543,7 @@ impl Benchmark {
 
         match scenario {
             // For these scenarios, we can simply check if they were benchmarked or not
-            Scenario::Full | Scenario::IncrFull | Scenario::IncrUnchanged => {
+            Scenario::Full | Scenario::IncrFull | Scenario::IncrUnchanged | Scenario::ParallelFrontend => {
                 let test_case = CompileTestCase {
                     benchmark,
                     profile,
@@ -542,6 +553,7 @@ impl Benchmark {
                         Scenario::Full => database::Scenario::Empty,
                         Scenario::IncrFull => database::Scenario::IncrementalEmpty,
                         Scenario::IncrUnchanged => database::Scenario::IncrementalFresh,
+                        Scenario::ParallelFrontend => database::Scenario::ParallelFrontend,
                         Scenario::IncrPatched => unreachable!(),
                     },
                 };
diff --git a/collector/src/compile/benchmark/scenario.rs b/collector/src/compile/benchmark/scenario.rs
@@ -5,6 +5,7 @@ pub enum Scenario {
     IncrFull,
     IncrUnchanged,
     IncrPatched,
+    ParallelFrontend,
 }
 
 impl Scenario {
@@ -14,11 +15,12 @@ impl Scenario {
             Scenario::IncrFull,
             Scenario::IncrUnchanged,
             Scenario::IncrPatched,
+            Scenario::ParallelFrontend,
         ]
     }
 
     pub fn all_non_incr() -> Vec<Scenario> {
-        vec![Scenario::Full]
+        vec![Scenario::Full, Scenario::ParallelFrontend]
     }
 
     pub fn is_incr(self) -> bool {
diff --git a/collector/src/compile/execute/bencher.rs b/collector/src/compile/execute/bencher.rs
@@ -173,6 +173,7 @@ impl Processor for BenchProcessor<'_> {
                         Scenario::Full => database::Scenario::Empty,
                         Scenario::IncrFull => database::Scenario::IncrementalEmpty,
                         Scenario::IncrUnchanged => database::Scenario::IncrementalFresh,
+                        Scenario::ParallelFrontend => database::Scenario::ParallelFrontend,
                         Scenario::IncrPatched => {
                             let patch = data.patch.unwrap();
                             database::Scenario::IncrementalPatch(patch.name)
diff --git a/collector/src/compile/execute/mod.rs b/collector/src/compile/execute/mod.rs
@@ -112,8 +112,8 @@ impl PerfTool {
             | ProfileTool(LlvmIr)
             | ProfileTool(Eprintln) => true,
             // only incremental
-            ProfileTool(DepGraph) => scenario != Scenario::Full,
-            ProfileTool(LlvmLines) => scenario == Scenario::Full,
+            ProfileTool(DepGraph) => !matches!(scenario, Scenario::Full | Scenario::ParallelFrontend),
+            ProfileTool(LlvmLines) => matches!(scenario, Scenario::Full | Scenario::ParallelFrontend),
         }
     }
 }
@@ -409,6 +409,9 @@ impl<'a> CargoProcess<'a> {
             match self.profile {
                 Profile::Check => {
                     cmd.arg("--profile").arg("check");
+                    if Some(Scenario::ParallelFrontend) == self.processor_etc.as_ref().map(|v| v.1) {
+                        cmd.env("RUSTC_THREAD_COUNT", "8");
+                    }
                 }
                 Profile::Clippy => {
                     cmd.arg("--profile").arg("check");
diff --git a/database/src/lib.rs b/database/src/lib.rs
@@ -286,6 +286,8 @@ pub enum Scenario {
     IncrementalFresh,
     /// Cache is mostly up-to-date but some code has been changed
     IncrementalPatch(PatchName),
+    /// Parallel frontend
+    ParallelFrontend,
 }
 
 intern!(pub struct PatchName);
@@ -297,6 +299,7 @@ impl std::str::FromStr for Scenario {
             "full" => Scenario::Empty,
             "incr-full" => Scenario::IncrementalEmpty,
             "incr-unchanged" => Scenario::IncrementalFresh,
+            "par-front" => Scenario::ParallelFrontend,
             _ => {
                 if let Some(stripped) = s.strip_prefix("incr-patched: ") {
                     Scenario::IncrementalPatch(PatchName::from(stripped))
@@ -314,6 +317,7 @@ impl fmt::Display for Scenario {
             Scenario::Empty => write!(f, "full"),
             Scenario::IncrementalEmpty => write!(f, "incr-full"),
             Scenario::IncrementalFresh => write!(f, "incr-unchanged"),
+            Scenario::ParallelFrontend => write!(f, "par-front"),
             Scenario::IncrementalPatch(name) => write!(f, "incr-patched: {name}"),
         }
     }
@@ -325,6 +329,7 @@ impl Scenario {
             Scenario::Empty => "full".to_string(),
             Scenario::IncrementalEmpty => "incr-full".to_string(),
             Scenario::IncrementalFresh => "incr-unchanged".to_string(),
+            Scenario::ParallelFrontend => "par-front".to_string(),
             Scenario::IncrementalPatch(name) => format!("incr-patched-{name}"),
         }
     }
@@ -345,9 +350,14 @@ impl Ord for Scenario {
             (Scenario::IncrementalFresh, Scenario::Empty) => Ordering::Greater,
             (Scenario::IncrementalFresh, Scenario::IncrementalEmpty) => Ordering::Greater,
             (Scenario::IncrementalFresh, _) => Ordering::Less,
+            (Scenario::ParallelFrontend, Scenario::Empty) => Ordering::Greater,
+            (Scenario::ParallelFrontend, Scenario::IncrementalEmpty) => Ordering::Greater,
+            (Scenario::ParallelFrontend, Scenario::IncrementalFresh) => Ordering::Greater,
+            (Scenario::ParallelFrontend, _) => Ordering::Less,
             (Scenario::IncrementalPatch(_), Scenario::Empty) => Ordering::Greater,
             (Scenario::IncrementalPatch(_), Scenario::IncrementalEmpty) => Ordering::Greater,
             (Scenario::IncrementalPatch(_), Scenario::IncrementalFresh) => Ordering::Greater,
+            (Scenario::IncrementalPatch(_), Scenario::ParallelFrontend) => Ordering::Greater,
             (Scenario::IncrementalPatch(a), Scenario::IncrementalPatch(b)) => {
                 if a == "println" {
                     Ordering::Less
diff --git a/site/src/load.rs b/site/src/load.rs
@@ -99,6 +99,7 @@ impl SiteCtxt {
             database::Scenario::Empty,
             database::Scenario::IncrementalEmpty,
             database::Scenario::IncrementalFresh,
+            database::Scenario::ParallelFrontend,
             database::Scenario::IncrementalPatch("println".into()),
         ]
     }
diff --git a/site/src/request_handlers/dashboard.rs b/site/src/request_handlers/dashboard.rs
@@ -126,6 +126,7 @@ pub async fn handle_dashboard(
                     Scenario::Empty => cases.clean_averages = points,
                     Scenario::IncrementalEmpty => cases.base_incr_averages = points,
                     Scenario::IncrementalFresh => cases.clean_incr_averages = points,
+                    Scenario::ParallelFrontend => cases.clean_averages = points,
                     // we only have println patches here
                     Scenario::IncrementalPatch(_) => cases.println_incr_averages = points,
                 }

Original file line number	Diff line number	Diff line change
`@@ -177,7 +177,7 @@ fn generate_diffs(`
`177`	`177`	`return vec![];`
`178`	`178`	`}`
`179`	`179`	`match scenario {`
`180`		`- Scenario::Full \| Scenario::IncrFull \| Scenario::IncrUnchanged => {`
	`180`	`+ Scenario::Full \| Scenario::IncrFull \| Scenario::IncrUnchanged \| Scenario::ParallelFrontend => {`
`181`	`181`	`vec![format!("{:?}", scenario)]`
`182`	`182`	`}`
`183`	`183`	`Scenario::IncrPatched => (0..benchmark.patches.len())`
Original file line number	Diff line number	Diff line change
`@@ -5,6 +5,7 @@ pub enum Scenario {`
`5`	`5`	`IncrFull,`
`6`	`6`	`IncrUnchanged,`
`7`	`7`	`IncrPatched,`
	`8`	`+ ParallelFrontend,`
`8`	`9`	`}`
`9`	`10`
`10`	`11`	`impl Scenario {`
`@@ -14,11 +15,12 @@ impl Scenario {`
`14`	`15`	`Scenario::IncrFull,`
`15`	`16`	`Scenario::IncrUnchanged,`
`16`	`17`	`Scenario::IncrPatched,`
	`18`	`+ Scenario::ParallelFrontend,`
`17`	`19`	`]`
`18`	`20`	`}`
`19`	`21`
`20`	`22`	`pub fn all_non_incr() -> Vec<Scenario> {`
`21`		`- vec![Scenario::Full]`
	`23`	`+ vec![Scenario::Full, Scenario::ParallelFrontend]`
`22`	`24`	`}`
`23`	`25`
`24`	`26`	`pub fn is_incr(self) -> bool {`
Original file line number	Diff line number	Diff line change
`@@ -112,8 +112,8 @@ impl PerfTool {`
`112`	`112`	`\| ProfileTool(LlvmIr)`
`113`	`113`	`\| ProfileTool(Eprintln) => true,`
`114`	`114`	`// only incremental`
`115`		`- ProfileTool(DepGraph) => scenario != Scenario::Full,`
`116`		`- ProfileTool(LlvmLines) => scenario == Scenario::Full,`
	`115`	`+ ProfileTool(DepGraph) => !matches!(scenario, Scenario::Full \| Scenario::ParallelFrontend),`
	`116`	`+ ProfileTool(LlvmLines) => matches!(scenario, Scenario::Full \| Scenario::ParallelFrontend),`
`117`	`117`	`}`
`118`	`118`	`}`
`119`	`119`	`}`
`@@ -409,6 +409,9 @@ impl<'a> CargoProcess<'a> {`
`409`	`409`	`match self.profile {`
`410`	`410`	`Profile::Check => {`
`411`	`411`	`cmd.arg("--profile").arg("check");`
	`412`	`+ if Some(Scenario::ParallelFrontend) == self.processor_etc.as_ref().map(\|v\| v.1) {`
	`413`	`+ cmd.env("RUSTC_THREAD_COUNT", "8");`
	`414`	`+ }`
`412`	`415`	`}`
`413`	`416`	`Profile::Clippy => {`
`414`	`417`	`cmd.arg("--profile").arg("check");`
Original file line number	Diff line number	Diff line change
`@@ -99,6 +99,7 @@ impl SiteCtxt {`
`99`	`99`	`database::Scenario::Empty,`
`100`	`100`	`database::Scenario::IncrementalEmpty,`
`101`	`101`	`database::Scenario::IncrementalFresh,`
	`102`	`+ database::Scenario::ParallelFrontend,`
`102`	`103`	`database::Scenario::IncrementalPatch("println".into()),`
`103`	`104`	`]`
`104`	`105`	`}`
Original file line number	Diff line number	Diff line change
`@@ -126,6 +126,7 @@ pub async fn handle_dashboard(`
`126`	`126`	`Scenario::Empty => cases.clean_averages = points,`
`127`	`127`	`Scenario::IncrementalEmpty => cases.base_incr_averages = points,`
`128`	`128`	`Scenario::IncrementalFresh => cases.clean_incr_averages = points,`
	`129`	`+ Scenario::ParallelFrontend => cases.clean_averages = points,`
`129`	`130`	`// we only have println patches here`
`130`	`131`	`Scenario::IncrementalPatch(_) => cases.println_incr_averages = points,`
`131`	`132`	`}`