Skip to content

Commit

Permalink
fix(base): partial revert some changes that were introduced from deno…
Browse files Browse the repository at this point in the history
… upgrade PR (#415)
  • Loading branch information
nyannyacha authored Sep 30, 2024
1 parent 1c19701 commit db2cc41
Showing 1 changed file with 37 additions and 34 deletions.
71 changes: 37 additions & 34 deletions crates/base/src/deno_runtime.rs
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,6 @@ use std::time::Duration;
use tokio::sync::mpsc;
use tokio::time::interval;
use tokio_util::sync::CancellationToken;
use tracing::debug;

use crate::snapshot;
use event_worker::events::{EventMetadata, WorkerEventWithMetadata};
Expand Down Expand Up @@ -703,7 +702,7 @@ where
let mut accumulated_cpu_time_ns = 0i64;

let has_inspector = self.inspector().is_some();
let mut mod_result_rx = unsafe {
let mod_result_rx = unsafe {
self.js_runtime.v8_isolate().enter();

if has_inspector {
Expand Down Expand Up @@ -751,38 +750,38 @@ where
};
}

{
let event_loop_fut = self.run_event_loop(
name.as_deref(),
current_thread_id,
&maybe_cpu_usage_metrics_tx,
&mut accumulated_cpu_time_ns,
);

let mod_result = tokio::select! {
// Not using biased mode leads to non-determinism for relatively simple
// programs.
biased;

maybe_mod_result = &mut mod_result_rx => {
debug!("received module evaluate {:#?}", maybe_mod_result);
maybe_mod_result

}

event_loop_result = event_loop_fut => {
if let Err(err) = event_loop_result {
Err(anyhow!("event loop error while evaluating the module: {}", err))
} else {
mod_result_rx.await
}
}
};

if let Err(err) = mod_result {
return (Err(err), get_accumulated_cpu_time_ms!());
}
}
// {
// let event_loop_fut = self.run_event_loop(
// name.as_deref(),
// current_thread_id,
// &maybe_cpu_usage_metrics_tx,
// &mut accumulated_cpu_time_ns,
// );

// let mod_result = tokio::select! {
// // Not using biased mode leads to non-determinism for relatively simple
// // programs.
// biased;

// maybe_mod_result = &mut mod_result_rx => {
// debug!("received module evaluate {:#?}", maybe_mod_result);
// maybe_mod_result

// }

// event_loop_result = event_loop_fut => {
// if let Err(err) = event_loop_result {
// Err(anyhow!("event loop error while evaluating the module: {}", err))
// } else {
// mod_result_rx.await
// }
// }
// };

// if let Err(err) = mod_result {
// return (Err(err), get_accumulated_cpu_time_ms!());
// }
// }

if let Err(err) = self
.run_event_loop(
Expand All @@ -799,6 +798,10 @@ where
);
}

if let Err(err) = mod_result_rx.await {
return (Err(err), get_accumulated_cpu_time_ms!());
}

(Ok(()), get_accumulated_cpu_time_ms!())
}

Expand Down

0 comments on commit db2cc41

Please sign in to comment.