Commit 9689b176 authored by Shu-yu Guo's avatar Shu-yu Guo Committed by Commit Bot

[top-level-await] Implement spec fix for cycle root detection

There is a bug in the top-level await spec draft such that async
strongly connected components are not always evaluated before their
depending modules.

See https://github.com/tc39/proposal-top-level-await/pull/161 for full
discussion and spec fix.

Bug: v8:11376
Change-Id: I88bf06afb2e9a5d8d0b757de8276f1d1242a875e
Reviewed-on: https://chromium-review.googlesource.com/c/v8/v8/+/2667772Reviewed-by: 's avatarAdam Klein <adamk@chromium.org>
Reviewed-by: 's avatarCamillo Bruni <cbruni@chromium.org>
Commit-Queue: Shu-yu Guo <syg@chromium.org>
Cr-Commit-Position: refs/heads/master@{#72508}
parent 64471ba9
...@@ -1663,6 +1663,7 @@ void SourceTextModule::SourceTextModulePrint(std::ostream& os) { // NOLINT ...@@ -1663,6 +1663,7 @@ void SourceTextModule::SourceTextModulePrint(std::ostream& os) { // NOLINT
os << "\n - origin: " << Brief(script.GetNameOrSourceURL()); os << "\n - origin: " << Brief(script.GetNameOrSourceURL());
os << "\n - requested_modules: " << Brief(requested_modules()); os << "\n - requested_modules: " << Brief(requested_modules());
os << "\n - import_meta: " << Brief(import_meta()); os << "\n - import_meta: " << Brief(import_meta());
os << "\n - cycle_root: " << Brief(cycle_root());
os << "\n"; os << "\n";
} }
......
...@@ -2342,6 +2342,7 @@ Handle<SourceTextModule> Factory::NewSourceTextModule( ...@@ -2342,6 +2342,7 @@ Handle<SourceTextModule> Factory::NewSourceTextModule(
module->set_flags(0); module->set_flags(0);
module->set_async(IsAsyncModule(sfi->kind())); module->set_async(IsAsyncModule(sfi->kind()));
module->set_async_evaluating(false); module->set_async_evaluating(false);
module->set_cycle_root(roots.the_hole_value());
module->set_async_parent_modules(*async_parent_modules); module->set_async_parent_modules(*async_parent_modules);
module->set_pending_async_dependencies(0); module->set_pending_async_dependencies(0);
return module; return module;
......
...@@ -111,6 +111,14 @@ class UnorderedModuleSet ...@@ -111,6 +111,14 @@ class UnorderedModuleSet
ZoneAllocator<Handle<Module>>(zone)) {} ZoneAllocator<Handle<Module>>(zone)) {}
}; };
Handle<SourceTextModule> SourceTextModule::GetCycleRoot(
Isolate* isolate) const {
CHECK_GE(status(), kEvaluated);
DCHECK(!cycle_root().IsTheHole(isolate));
Handle<SourceTextModule> root(SourceTextModule::cast(cycle_root()), isolate);
return root;
}
void SourceTextModule::AddAsyncParentModule(Isolate* isolate, void SourceTextModule::AddAsyncParentModule(Isolate* isolate,
Handle<SourceTextModule> module, Handle<SourceTextModule> module,
Handle<SourceTextModule> parent) { Handle<SourceTextModule> parent) {
......
...@@ -421,6 +421,7 @@ bool SourceTextModule::MaybeTransitionComponent( ...@@ -421,6 +421,7 @@ bool SourceTextModule::MaybeTransitionComponent(
DCHECK_LE(module->dfs_ancestor_index(), module->dfs_index()); DCHECK_LE(module->dfs_ancestor_index(), module->dfs_index());
if (module->dfs_ancestor_index() == module->dfs_index()) { if (module->dfs_ancestor_index() == module->dfs_index()) {
// This is the root of its strongly connected component. // This is the root of its strongly connected component.
Handle<SourceTextModule> cycle_root = module;
Handle<SourceTextModule> ancestor; Handle<SourceTextModule> ancestor;
do { do {
ancestor = stack->front(); ancestor = stack->front();
...@@ -430,6 +431,9 @@ bool SourceTextModule::MaybeTransitionComponent( ...@@ -430,6 +431,9 @@ bool SourceTextModule::MaybeTransitionComponent(
if (new_status == kInstantiated) { if (new_status == kInstantiated) {
if (!SourceTextModule::RunInitializationCode(isolate, ancestor)) if (!SourceTextModule::RunInitializationCode(isolate, ancestor))
return false; return false;
} else if (new_status == kEvaluated) {
DCHECK(ancestor->cycle_root().IsTheHole(isolate));
ancestor->set_cycle_root(*cycle_root);
} }
ancestor->SetStatus(new_status); ancestor->SetStatus(new_status);
} while (*ancestor != *module); } while (*ancestor != *module);
...@@ -642,9 +646,9 @@ MaybeHandle<Object> SourceTextModule::EvaluateMaybeAsync( ...@@ -642,9 +646,9 @@ MaybeHandle<Object> SourceTextModule::EvaluateMaybeAsync(
CHECK(module->status() == kInstantiated || module->status() == kEvaluated); CHECK(module->status() == kInstantiated || module->status() == kEvaluated);
// 3. If module.[[Status]] is "evaluated", set module to // 3. If module.[[Status]] is "evaluated", set module to
// GetAsyncCycleRoot(module). // module.[[CycleRoot]].
if (module->status() == kEvaluated) { if (module->status() == kEvaluated) {
module = GetAsyncCycleRoot(isolate, module); module = module->GetCycleRoot(isolate);
} }
// 4. If module.[[TopLevelCapability]] is not undefined, then // 4. If module.[[TopLevelCapability]] is not undefined, then
...@@ -759,37 +763,27 @@ void SourceTextModule::AsyncModuleExecutionFulfilled( ...@@ -759,37 +763,27 @@ void SourceTextModule::AsyncModuleExecutionFulfilled(
for (int i = 0; i < module->AsyncParentModuleCount(); i++) { for (int i = 0; i < module->AsyncParentModuleCount(); i++) {
Handle<SourceTextModule> m = module->GetAsyncParentModule(isolate, i); Handle<SourceTextModule> m = module->GetAsyncParentModule(isolate, i);
// a. If module.[[DFSIndex]] is not equal to module.[[DFSAncestorIndex]], // a. Decrement m.[[PendingAsyncDependencies]] by 1.
// then
if (module->dfs_index() != module->dfs_ancestor_index()) {
// i. Assert: m.[[DFSAncestorIndex]] is equal to
// module.[[DFSAncestorIndex]].
DCHECK_LE(m->dfs_ancestor_index(), module->dfs_ancestor_index());
}
// b. Decrement m.[[PendingAsyncDependencies]] by 1.
m->DecrementPendingAsyncDependencies(); m->DecrementPendingAsyncDependencies();
// c. If m.[[PendingAsyncDependencies]] is 0 and m.[[EvaluationError]] is // b. If m.[[PendingAsyncDependencies]] is 0 and m.[[EvaluationError]] is
// undefined, then // undefined, then
if (!m->HasPendingAsyncDependencies() && m->status() == kEvaluated) { if (!m->HasPendingAsyncDependencies() && m->status() == kEvaluated) {
// i. Assert: m.[[AsyncEvaluating]] is true. // i. Assert: m.[[AsyncEvaluating]] is true.
DCHECK(m->async_evaluating()); DCHECK(m->async_evaluating());
// ii. Let cycleRoot be ! GetAsyncCycleRoot(m). // ii. If m.[[CycleRoot]].[[EvaluationError]] is not undefined,
auto cycle_root = GetAsyncCycleRoot(isolate, m);
// iii. If cycleRoot.[[EvaluationError]] is not undefined,
// return undefined. // return undefined.
if (cycle_root->status() == kErrored) { if (m->GetCycleRoot(isolate)->status() == kErrored) {
return; return;
} }
// iv. If m.[[Async]] is true, then // iii. If m.[[Async]] is true, then
if (m->async()) { if (m->async()) {
// 1. Perform ! ExecuteAsyncModule(m). // 1. Perform ! ExecuteAsyncModule(m).
ExecuteAsyncModule(isolate, m); ExecuteAsyncModule(isolate, m);
} else { } else {
// v. Otherwise, // iv. Otherwise,
// 1. Let result be m.ExecuteModule(). // 1. Let result be m.ExecuteModule().
// 2. If result is a normal completion, // 2. If result is a normal completion,
Handle<Object> unused_result; Handle<Object> unused_result;
...@@ -1069,8 +1063,8 @@ MaybeHandle<Object> SourceTextModule::InnerModuleEvaluation( ...@@ -1069,8 +1063,8 @@ MaybeHandle<Object> SourceTextModule::InnerModuleEvaluation(
required_module->dfs_ancestor_index())); required_module->dfs_ancestor_index()));
} else { } else {
// iv. Otherwise, // iv. Otherwise,
// 1. Set requiredModule to GetAsyncCycleRoot(requiredModule). // 1. Set requiredModule to requiredModule.[[CycleRoot]].
required_module = GetAsyncCycleRoot(isolate, required_module); required_module = required_module->GetCycleRoot(isolate);
// 2. Assert: requiredModule.[[Status]] is "evaluated". // 2. Assert: requiredModule.[[Status]] is "evaluated".
CHECK_GE(required_module->status(), kEvaluated); CHECK_GE(required_module->status(), kEvaluated);
...@@ -1128,43 +1122,6 @@ MaybeHandle<Object> SourceTextModule::InnerModuleEvaluation( ...@@ -1128,43 +1122,6 @@ MaybeHandle<Object> SourceTextModule::InnerModuleEvaluation(
return result; return result;
} }
Handle<SourceTextModule> SourceTextModule::GetAsyncCycleRoot(
Isolate* isolate, Handle<SourceTextModule> module) {
// 1. Assert: module.[[Status]] is "evaluated".
CHECK_GE(module->status(), kEvaluated);
// 2. If module.[[AsyncParentModules]] is an empty List, return module.
if (module->AsyncParentModuleCount() == 0) {
return module;
}
// 3. Repeat, while module.[[DFSIndex]] is greater than
// module.[[DFSAncestorIndex]],
while (module->dfs_index() > module->dfs_ancestor_index()) {
// a. Assert: module.[[AsyncParentModules]] is a non-empty List.
DCHECK_GT(module->AsyncParentModuleCount(), 0);
// b. Let nextCycleModule be the first element of
// module.[[AsyncParentModules]].
Handle<SourceTextModule> next_cycle_module =
module->GetAsyncParentModule(isolate, 0);
// c. Assert: nextCycleModule.[[DFSAncestorIndex]] is less than or equal
// to module.[[DFSAncestorIndex]].
DCHECK_LE(next_cycle_module->dfs_ancestor_index(),
module->dfs_ancestor_index());
// d. Set module to nextCycleModule
module = next_cycle_module;
}
// 4. Assert: module.[[DFSIndex]] is equal to module.[[DFSAncestorIndex]].
DCHECK_EQ(module->dfs_index(), module->dfs_ancestor_index());
// 5. Return module.
return module;
}
void SourceTextModule::Reset(Isolate* isolate, void SourceTextModule::Reset(Isolate* isolate,
Handle<SourceTextModule> module) { Handle<SourceTextModule> module) {
Factory* factory = isolate->factory(); Factory* factory = isolate->factory();
......
...@@ -83,6 +83,9 @@ class SourceTextModule ...@@ -83,6 +83,9 @@ class SourceTextModule
Handle<SourceTextModule> module, Handle<SourceTextModule> module,
Handle<SourceTextModule> parent); Handle<SourceTextModule> parent);
// Get the non-hole cycle root. Only valid when status >= kEvaluated.
inline Handle<SourceTextModule> GetCycleRoot(Isolate* isolate) const;
// Returns a SourceTextModule, the // Returns a SourceTextModule, the
// ith parent in depth first traversal order of a given async child. // ith parent in depth first traversal order of a given async child.
inline Handle<SourceTextModule> GetAsyncParentModule(Isolate* isolate, inline Handle<SourceTextModule> GetAsyncParentModule(Isolate* isolate,
...@@ -169,10 +172,6 @@ class SourceTextModule ...@@ -169,10 +172,6 @@ class SourceTextModule
Isolate* isolate, Handle<SourceTextModule> module, Isolate* isolate, Handle<SourceTextModule> module,
ZoneForwardList<Handle<SourceTextModule>>* stack, Status new_status); ZoneForwardList<Handle<SourceTextModule>>* stack, Status new_status);
// Implementation of spec GetAsyncCycleRoot.
static V8_WARN_UNUSED_RESULT Handle<SourceTextModule> GetAsyncCycleRoot(
Isolate* isolate, Handle<SourceTextModule> module);
// Implementation of spec ExecuteModule is broken up into // Implementation of spec ExecuteModule is broken up into
// InnerExecuteAsyncModule for asynchronous modules and ExecuteModule // InnerExecuteAsyncModule for asynchronous modules and ExecuteModule
// for synchronous modules. // for synchronous modules.
......
...@@ -31,6 +31,11 @@ extern class SourceTextModule extends Module { ...@@ -31,6 +31,11 @@ extern class SourceTextModule extends Module {
// a JSObject afterwards. // a JSObject afterwards.
import_meta: TheHole|JSObject; import_meta: TheHole|JSObject;
// The first visited module of a cycle. For modules not in a cycle, this is
// the module itself. It's the hole before the module state transitions to
// kEvaluated.
cycle_root: SourceTextModule|TheHole;
async_parent_modules: ArrayList; async_parent_modules: ArrayList;
top_level_capability: JSPromise|Undefined; top_level_capability: JSPromise|Undefined;
......
// Copyright 2021 the V8 project authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
// Flags: --harmony-top-level-await
import "modules-skip-async-cycle-start.mjs"
assertEquals(globalThis.test_order, [
'2', 'async before', 'async after', '1',
'3', 'start',
]);
// Copyright 2021 the V8 project authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
// Flags: --harmony-top-level-await
import "modules-skip-async-cycle-2.mjs";
import "modules-skip-async-cycle-leaf.mjs";
if (globalThis.test_order === undefined) {
globalThis.test_order = [];
}
globalThis.test_order.push('1');
// Copyright 2021 the V8 project authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
// Flags: --harmony-top-level-await
import "modules-skip-async-cycle-1.mjs";
if (globalThis.test_order === undefined) {
globalThis.test_order = [];
}
globalThis.test_order.push('2');
// Copyright 2021 the V8 project authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
// Flags: --harmony-top-level-await
import "modules-skip-async-cycle-2.mjs";
if (globalThis.test_order === undefined) {
globalThis.test_order = [];
}
globalThis.test_order.push('3');
// Copyright 2021 the V8 project authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
// Flags: --harmony-top-level-await
if (globalThis.test_order === undefined) {
globalThis.test_order = [];
}
globalThis.test_order.push('async before');
await 0;
globalThis.test_order.push('async after');
// Copyright 2021 the V8 project authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
// Flags: --harmony-top-level-await
import "modules-skip-async-cycle-1.mjs";
import "modules-skip-async-cycle-3.mjs";
if (globalThis.test_order === undefined) {
globalThis.test_order = [];
}
globalThis.test_order.push('start');
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment