From ac290a2786206eb166b7f717c7f122ccc65a0cd2 Mon Sep 17 00:00:00 2001 From: Damonxue Date: Thu, 28 Nov 2024 14:50:36 +0800 Subject: [PATCH 1/2] finish to log compilied pkg. --- src/cargo/core/compiler/job_queue/mod.rs | 17 ++++++++++++++++- 1 file changed, 16 insertions(+), 1 deletion(-) diff --git a/src/cargo/core/compiler/job_queue/mod.rs b/src/cargo/core/compiler/job_queue/mod.rs index 7ab12a3a265..083fe134351 100644 --- a/src/cargo/core/compiler/job_queue/mod.rs +++ b/src/cargo/core/compiler/job_queue/mod.rs @@ -1118,7 +1118,22 @@ impl<'gctx> DrainState<'gctx> { } let unlocked = self.queue.finish(unit, &artifact); match artifact { - Artifact::All => self.timings.unit_finished(id, unlocked), + Artifact::All => { + self.timings.unit_finished(id, unlocked); + // Here we log the completion of a unit of work. + // This is useful for tracking the progress of the job queue. + debug!("Finished unit: {:?}", unit); + if unit.mode.is_doc() { + self.documented.insert(unit.pkg.package_id()); + build_runner.bcx.gctx.shell().status("Documented", &unit.pkg)?; + } else if unit.mode.is_doc_scrape() { + self.scraped.insert(unit.pkg.package_id()); + build_runner.bcx.gctx.shell().status("Scraped", &unit.pkg)?; + } else { + self.compiled.insert(unit.pkg.package_id()); + build_runner.bcx.gctx.shell().status("Compiled", &unit.pkg)?; + } + } Artifact::Metadata => self.timings.unit_rmeta_finished(id, unlocked), } Ok(()) From bb0a2795d50dd761882a0f6edbb0c2ada6a13d39 Mon Sep 17 00:00:00 2001 From: Damonxue Date: Thu, 28 Nov 2024 15:00:03 +0800 Subject: [PATCH 2/2] fmt. --- src/cargo/core/compiler/job_queue/mod.rs | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/src/cargo/core/compiler/job_queue/mod.rs b/src/cargo/core/compiler/job_queue/mod.rs index 083fe134351..05a9a44fff8 100644 --- a/src/cargo/core/compiler/job_queue/mod.rs +++ b/src/cargo/core/compiler/job_queue/mod.rs @@ -1125,13 +1125,21 @@ impl<'gctx> DrainState<'gctx> { debug!("Finished unit: {:?}", unit); if unit.mode.is_doc() { self.documented.insert(unit.pkg.package_id()); - build_runner.bcx.gctx.shell().status("Documented", &unit.pkg)?; + build_runner + .bcx + .gctx + .shell() + .status("Documented", &unit.pkg)?; } else if unit.mode.is_doc_scrape() { self.scraped.insert(unit.pkg.package_id()); build_runner.bcx.gctx.shell().status("Scraped", &unit.pkg)?; } else { self.compiled.insert(unit.pkg.package_id()); - build_runner.bcx.gctx.shell().status("Compiled", &unit.pkg)?; + build_runner + .bcx + .gctx + .shell() + .status("Compiled", &unit.pkg)?; } } Artifact::Metadata => self.timings.unit_rmeta_finished(id, unlocked),