1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
// Copyright 2017 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "third_party/blink/renderer/core/workers/worklet_module_tree_client.h"
#include "third_party/blink/public/platform/task_type.h"
#include "third_party/blink/renderer/bindings/core/v8/serialization/serialized_script_value.h"
#include "third_party/blink/renderer/core/script/module_script.h"
#include "third_party/blink/renderer/core/workers/worker_reporting_proxy.h"
#include "third_party/blink/renderer/core/workers/worklet_global_scope.h"
#include "third_party/blink/renderer/platform/scheduler/public/post_cross_thread_task.h"
#include "third_party/blink/renderer/platform/wtf/cross_thread_functional.h"
namespace blink {
WorkletModuleTreeClient::WorkletModuleTreeClient(
ScriptState* script_state,
scoped_refptr<base::SingleThreadTaskRunner> outside_settings_task_runner,
WorkletPendingTasks* pending_tasks)
: script_state_(script_state),
outside_settings_task_runner_(std::move(outside_settings_task_runner)),
pending_tasks_(pending_tasks) {}
// Implementation of the second half of the "fetch and invoke a worklet script"
// algorithm:
// https://drafts.css-houdini.org/worklets/#fetch-and-invoke-a-worklet-script
void WorkletModuleTreeClient::NotifyModuleTreeLoadFinished(
ModuleScript* module_script) {
// TODO(nhiroki): Call reporting proxy functions appropriately (e.g.,
// DidFailToFetchModuleScript(), WillEvaluateModuleScript()).
// "Note: Specifically, if a script fails to parse or fails to load over the
// network, it will reject the promise. If the script throws an error while
// first evaluating the promise it will resolve as classes may have been
// registered correctly."
// https://drafts.css-houdini.org/worklets/#fetch-a-worklet-script
//
// When a network failure happens, |module_script| should be nullptr, and the
// case will be handled by the step 3.
// When a parse failure happens, |module_script| has an error to rethrow, and
// the case will be handled by the step 4.
// Step 3: "If script is null, then queue a task on outsideSettings's
// responsible event loop to run these steps:"
if (!module_script) {
// Null |error_to_rethrow| will be replaced with AbortError.
PostCrossThreadTask(
*outside_settings_task_runner_, FROM_HERE,
CrossThreadBindOnce(&WorkletPendingTasks::Abort,
WrapCrossThreadPersistent(pending_tasks_.Get()),
/*error_to_rethrow=*/nullptr));
return;
}
// Step 4: "If script's error to rethrow is not null, then queue a task on
// outsideSettings's responsible event loop given script's error to rethrow to
// run these steps:
if (module_script->HasErrorToRethrow()) {
ScriptState::Scope scope(script_state_);
PostCrossThreadTask(
*outside_settings_task_runner_, FROM_HERE,
CrossThreadBindOnce(
&WorkletPendingTasks::Abort,
WrapCrossThreadPersistent(pending_tasks_.Get()),
SerializedScriptValue::SerializeAndSwallowExceptions(
script_state_->GetIsolate(),
module_script->CreateErrorToRethrow().V8Value())));
return;
}
// Step 5: "Run a module script given script."
ScriptValue error =
Modulator::From(script_state_)
->ExecuteModule(module_script,
Modulator::CaptureEvalErrorFlag::kReport);
auto* global_scope =
To<WorkletGlobalScope>(ExecutionContext::From(script_state_));
global_scope->ReportingProxy().DidEvaluateModuleScript(error.IsEmpty());
// Step 6: "Queue a task on outsideSettings's responsible event loop to run
// these steps:"
// The steps are implemented in WorkletPendingTasks::DecrementCounter().
PostCrossThreadTask(
*outside_settings_task_runner_, FROM_HERE,
CrossThreadBindOnce(&WorkletPendingTasks::DecrementCounter,
WrapCrossThreadPersistent(pending_tasks_.Get())));
}
void WorkletModuleTreeClient::Trace(Visitor* visitor) {
visitor->Trace(script_state_);
ModuleTreeClient::Trace(visitor);
}
} // namespace blink
|
