summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorTreehugger Robot <treehugger-gerrit@google.com>2021-12-05 07:26:26 +0000
committerGerrit Code Review <noreply-gerritcodereview@google.com>2021-12-05 07:26:26 +0000
commitae72a2d2bbc22ff8da5bc65142771f618dc031aa (patch)
treed67b0f818db0d2f05bbff0ae691a2c683e0981d4
parent62df5cf33408fa6543c9457acca8fe30ce89a8ff (diff)
parentfd24c6ed403531f970cce36a6abb44d580aba669 (diff)
downloadextras-ae72a2d2bbc22ff8da5bc65142771f618dc031aa.tar.gz
Merge "profcollectd: process reports on the main thread"
-rw-r--r--profcollectd/libprofcollectd/scheduler.rs14
1 files changed, 5 insertions, 9 deletions
diff --git a/profcollectd/libprofcollectd/scheduler.rs b/profcollectd/libprofcollectd/scheduler.rs
index b0b322e1..29a14ff4 100644
--- a/profcollectd/libprofcollectd/scheduler.rs
+++ b/profcollectd/libprofcollectd/scheduler.rs
@@ -97,15 +97,11 @@ impl Scheduler {
pub fn process(&self) -> Result<()> {
let trace_provider = self.trace_provider.clone();
- let handle = thread::spawn(move || {
- trace_provider
- .lock()
- .unwrap()
- .process(&TRACE_OUTPUT_DIR, &PROFILE_OUTPUT_DIR, BINARY_FILTER)
- .expect("Failed to process profiles.");
- });
-
- handle.join().map_err(|_| anyhow!("Profile process thread panicked."))?;
+ trace_provider
+ .lock()
+ .unwrap()
+ .process(&TRACE_OUTPUT_DIR, &PROFILE_OUTPUT_DIR, BINARY_FILTER)
+ .context("Failed to process profiles.")?;
Ok(())
}