summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAnna Henningsen <anna@addaleax.net>2020-07-14 19:06:37 +0200
committerMyles Borins <mylesborins@github.com>2020-07-20 16:42:56 -0400
commitb878e3223e58c3d3fa4cb550ebdde12913b0e9b4 (patch)
treecdc9331760d26790236f22016672e01d1736ec4c
parent95afc2e50e5cbd0ce888b2f25564f0473bcfbe80 (diff)
downloadnode-new-b878e3223e58c3d3fa4cb550ebdde12913b0e9b4.tar.gz
src: add callback scope for native immediates
This ensures that microtasks scheduled by native immediates are run after the tasks are done. In particular, this affects the inspector integration since 6f9f546406820dc. Fixes: https://github.com/nodejs/node/issues/33002 Refs: https://github.com/nodejs/node/pull/32523 PR-URL: https://github.com/nodejs/node/pull/34366 Reviewed-By: Benjamin Gruenbaum <benjamingr@gmail.com> Reviewed-By: Gerhard Stöbich <deb2001-github@yahoo.de> Reviewed-By: James M Snell <jasnell@gmail.com>
-rw-r--r--src/env.cc3
-rw-r--r--test/async-hooks/test-late-hook-enable.js16
-rw-r--r--test/cctest/test_environment.cc26
3 files changed, 38 insertions, 7 deletions
diff --git a/src/env.cc b/src/env.cc
index bcaa50bd01..b92ea0ac99 100644
--- a/src/env.cc
+++ b/src/env.cc
@@ -657,6 +657,9 @@ void Environment::RunAndClearInterrupts() {
void Environment::RunAndClearNativeImmediates(bool only_refed) {
TraceEventScope trace_scope(TRACING_CATEGORY_NODE1(environment),
"RunAndClearNativeImmediates", this);
+ HandleScope handle_scope(isolate_);
+ InternalCallbackScope cb_scope(this, Object::New(isolate_), { 0, 0 });
+
size_t ref_count = 0;
// Handle interrupts first. These functions are not allowed to throw
diff --git a/test/async-hooks/test-late-hook-enable.js b/test/async-hooks/test-late-hook-enable.js
index 0ffa6b24a3..82a80b24bb 100644
--- a/test/async-hooks/test-late-hook-enable.js
+++ b/test/async-hooks/test-late-hook-enable.js
@@ -17,14 +17,16 @@ const fnsToTest = [setTimeout, (cb) => {
});
});
}, (cb) => {
- process.nextTick(() => {
- cb();
+ setImmediate(() => {
+ process.nextTick(() => {
+ cb();
- // We need to keep the event loop open for this to actually work
- // since destroy hooks are triggered in unrefed Immediates
- setImmediate(() => {
- hook.disable();
- assert.strictEqual(fnsToTest.length, 0);
+ // We need to keep the event loop open for this to actually work
+ // since destroy hooks are triggered in unrefed Immediates
+ setImmediate(() => {
+ hook.disable();
+ assert.strictEqual(fnsToTest.length, 0);
+ });
});
});
}];
diff --git a/test/cctest/test_environment.cc b/test/cctest/test_environment.cc
index 6de332b59b..27706044b8 100644
--- a/test/cctest/test_environment.cc
+++ b/test/cctest/test_environment.cc
@@ -533,3 +533,29 @@ TEST_F(EnvironmentTest, ExitHandlerTest) {
node::LoadEnvironment(*env, "process.exit(42)").ToLocalChecked();
EXPECT_EQ(callback_calls, 1);
}
+
+TEST_F(EnvironmentTest, SetImmediateMicrotasks) {
+ int called = 0;
+
+ {
+ const v8::HandleScope handle_scope(isolate_);
+ const Argv argv;
+ Env env {handle_scope, argv};
+
+ node::LoadEnvironment(*env,
+ [&](const node::StartExecutionCallbackInfo& info)
+ -> v8::MaybeLocal<v8::Value> {
+ return v8::Object::New(isolate_);
+ });
+
+ (*env)->SetImmediate([&](node::Environment* env_arg) {
+ EXPECT_EQ(env_arg, *env);
+ isolate_->EnqueueMicrotask([](void* arg) {
+ ++*static_cast<int*>(arg);
+ }, &called);
+ }, node::CallbackFlags::kRefed);
+ uv_run(&current_loop, UV_RUN_DEFAULT);
+ }
+
+ EXPECT_EQ(called, 1);
+}