summaryrefslogtreecommitdiff
path: root/runtime/ops/worker_host.rs
diff options
context:
space:
mode:
authorSatya Rohith <me@satyarohith.com>2024-03-14 01:22:53 +0530
committerGitHub <noreply@github.com>2024-03-13 19:52:53 +0000
commitbbc211906dcd5043af549250343cd7b42fb45043 (patch)
tree49868b4b758290dcec6668f95495ce9d79ad6a86 /runtime/ops/worker_host.rs
parent0fd8f549e2194223eca2d4b17f4e96cd5a0f5fd5 (diff)
fix(ext/node): make worker ids sequential (#22884)
Diffstat (limited to 'runtime/ops/worker_host.rs')
-rw-r--r--runtime/ops/worker_host.rs4
1 files changed, 1 insertions, 3 deletions
diff --git a/runtime/ops/worker_host.rs b/runtime/ops/worker_host.rs
index 3cfad5abb..242d3bcda 100644
--- a/runtime/ops/worker_host.rs
+++ b/runtime/ops/worker_host.rs
@@ -95,7 +95,6 @@ deno_core::extension!(
},
state = |state, options| {
state.put::<WorkersTable>(WorkersTable::default());
- state.put::<WorkerId>(WorkerId::default());
let create_web_worker_cb_holder =
CreateWebWorkerCbHolder(options.create_web_worker_cb);
@@ -163,10 +162,9 @@ fn op_create_worker(
parent_permissions.clone()
};
let parent_permissions = parent_permissions.clone();
- let worker_id = state.take::<WorkerId>();
let create_web_worker_cb = state.borrow::<CreateWebWorkerCbHolder>().clone();
let format_js_error_fn = state.borrow::<FormatJsErrorFnHolder>().clone();
- state.put::<WorkerId>(worker_id.next().unwrap());
+ let worker_id = WorkerId::new();
let module_specifier = deno_core::resolve_url(&specifier)?;
let worker_name = args_name.unwrap_or_default();