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
|
// 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/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/cross_thread_functional.h"
namespace blink {
WorkletModuleTreeClient::WorkletModuleTreeClient(
Modulator* modulator,
scoped_refptr<base::SingleThreadTaskRunner> outside_settings_task_runner,
WorkletPendingTasks* pending_tasks)
: modulator_(modulator),
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) {
if (!module_script) {
// Step 3: "If script is null, then queue a task on outsideSettings's
// responsible event loop to run these steps:"
// The steps are implemented in WorkletPendingTasks::Abort().
PostCrossThreadTask(
*outside_settings_task_runner_, FROM_HERE,
CrossThreadBind(&WorkletPendingTasks::Abort,
WrapCrossThreadPersistent(pending_tasks_.Get())));
return;
}
// "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 should already be handled above.
//
// Check whether a syntax error happens.
if (module_script->HasErrorToRethrow()) {
PostCrossThreadTask(
*outside_settings_task_runner_, FROM_HERE,
CrossThreadBind(&WorkletPendingTasks::Abort,
WrapCrossThreadPersistent(pending_tasks_.Get())));
return;
}
// Step 4: "Run a module script given script."
ScriptValue error = modulator_->ExecuteModule(
module_script, Modulator::CaptureEvalErrorFlag::kReport);
WorkletGlobalScope* global_scope = ToWorkletGlobalScope(
ExecutionContext::From(modulator_->GetScriptState()));
global_scope->ReportingProxy().DidEvaluateModuleScript(error.IsEmpty());
// Step 5: "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,
CrossThreadBind(&WorkletPendingTasks::DecrementCounter,
WrapCrossThreadPersistent(pending_tasks_.Get())));
};
void WorkletModuleTreeClient::Trace(blink::Visitor* visitor) {
visitor->Trace(modulator_);
ModuleTreeClient::Trace(visitor);
}
} // namespace blink
|
