mirror of
https://github.com/paradigmxyz/reth.git
synced 2026-04-30 03:01:58 -04:00
chore(tasks): remove quanta upkeep from runtime (#22540)
Co-authored-by: Amp <amp@ampcode.com>
This commit is contained in:
committed by
GitHub
parent
aed9014e1e
commit
d122c7b49c
1
Cargo.lock
generated
1
Cargo.lock
generated
@@ -10348,7 +10348,6 @@ dependencies = [
|
||||
"metrics",
|
||||
"parking_lot",
|
||||
"pin-project",
|
||||
"quanta",
|
||||
"rayon",
|
||||
"reth-metrics",
|
||||
"thiserror 2.0.18",
|
||||
|
||||
@@ -23,7 +23,6 @@ metrics.workspace = true
|
||||
|
||||
# misc
|
||||
dashmap.workspace = true
|
||||
quanta.workspace = true
|
||||
tracing.workspace = true
|
||||
thiserror.workspace = true
|
||||
|
||||
|
||||
@@ -268,10 +268,6 @@ struct RuntimeInner {
|
||||
/// The task monitors critical tasks for panics and fires the shutdown signal.
|
||||
/// Can be taken via [`Runtime::take_task_manager_handle`] to poll for panic errors.
|
||||
task_manager_handle: Mutex<Option<JoinHandle<Result<(), PanickedTaskError>>>>,
|
||||
/// Handle to the quanta upkeep thread that periodically refreshes the cached
|
||||
/// high-resolution timestamp used by [`quanta::Instant::recent()`].
|
||||
/// Dropped when the runtime is dropped, stopping the upkeep thread.
|
||||
_quanta_upkeep: Option<quanta::Handle>,
|
||||
}
|
||||
|
||||
// ── Runtime ───────────────────────────────────────────────────────────
|
||||
@@ -858,8 +854,6 @@ impl RuntimeBuilder {
|
||||
result
|
||||
});
|
||||
|
||||
let quanta_upkeep = quanta::Upkeep::new(Duration::from_millis(1)).start().ok();
|
||||
|
||||
let inner = RuntimeInner {
|
||||
_tokio_runtime: owned_runtime,
|
||||
handle,
|
||||
@@ -883,7 +877,6 @@ impl RuntimeBuilder {
|
||||
prewarming_pool,
|
||||
worker_map: WorkerMap::new(),
|
||||
task_manager_handle: Mutex::new(Some(task_manager_handle)),
|
||||
_quanta_upkeep: quanta_upkeep,
|
||||
};
|
||||
|
||||
Ok(Runtime(Arc::new(inner)))
|
||||
|
||||
Reference in New Issue
Block a user