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
98
99
100
101
102
103
104
105
106
107
|
// Copyright 2016 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/threaded_worklet_messaging_proxy.h"
#include "base/single_thread_task_runner.h"
#include "third_party/blink/public/platform/task_type.h"
#include "third_party/blink/renderer/bindings/core/v8/v8_cache_options.h"
#include "third_party/blink/renderer/core/dom/document.h"
#include "third_party/blink/renderer/core/execution_context/security_context.h"
#include "third_party/blink/renderer/core/frame/csp/content_security_policy.h"
#include "third_party/blink/renderer/core/inspector/thread_debugger.h"
#include "third_party/blink/renderer/core/origin_trials/origin_trial_context.h"
#include "third_party/blink/renderer/core/script/script.h"
#include "third_party/blink/renderer/core/workers/global_scope_creation_params.h"
#include "third_party/blink/renderer/core/workers/threaded_worklet_object_proxy.h"
#include "third_party/blink/renderer/core/workers/worker_clients.h"
#include "third_party/blink/renderer/core/workers/worker_inspector_proxy.h"
#include "third_party/blink/renderer/core/workers/worklet_global_scope.h"
#include "third_party/blink/renderer/core/workers/worklet_module_responses_map.h"
#include "third_party/blink/renderer/core/workers/worklet_pending_tasks.h"
#include "third_party/blink/renderer/platform/cross_thread_functional.h"
#include "third_party/blink/renderer/platform/web_task_runner.h"
namespace blink {
ThreadedWorkletMessagingProxy::ThreadedWorkletMessagingProxy(
ExecutionContext* execution_context)
: ThreadedMessagingProxyBase(execution_context) {}
void ThreadedWorkletMessagingProxy::Initialize(
WorkerClients* worker_clients,
WorkletModuleResponsesMap* module_responses_map) {
DCHECK(IsMainThread());
if (AskedToTerminate())
return;
worklet_object_proxy_ =
CreateObjectProxy(this, GetParentExecutionContextTaskRunners());
Document* document = ToDocument(GetExecutionContext());
ContentSecurityPolicy* csp = document->GetContentSecurityPolicy();
DCHECK(csp);
auto global_scope_creation_params =
std::make_unique<GlobalScopeCreationParams>(
document->Url(), ScriptType::kModule, document->UserAgent(),
csp->Headers().get(), document->GetReferrerPolicy(),
document->GetSecurityOrigin(), document->IsSecureContext(),
worker_clients, document->AddressSpace(),
OriginTrialContext::GetTokens(document).get(),
base::UnguessableToken::Create(),
std::make_unique<WorkerSettings>(document->GetSettings()),
kV8CacheOptionsDefault, module_responses_map);
// Worklets share the pre-initialized backing thread so that we don't have to
// specify the backing thread startup data.
InitializeWorkerThread(std::move(global_scope_creation_params),
base::nullopt);
}
void ThreadedWorkletMessagingProxy::Trace(blink::Visitor* visitor) {
ThreadedMessagingProxyBase::Trace(visitor);
}
void ThreadedWorkletMessagingProxy::FetchAndInvokeScript(
const KURL& module_url_record,
network::mojom::FetchCredentialsMode credentials_mode,
scoped_refptr<base::SingleThreadTaskRunner> outside_settings_task_runner,
WorkletPendingTasks* pending_tasks) {
DCHECK(IsMainThread());
PostCrossThreadTask(
*GetWorkerThread()->GetTaskRunner(TaskType::kInternalLoading), FROM_HERE,
CrossThreadBind(&ThreadedWorkletObjectProxy::FetchAndInvokeScript,
CrossThreadUnretained(worklet_object_proxy_.get()),
module_url_record, credentials_mode,
std::move(outside_settings_task_runner),
WrapCrossThreadPersistent(pending_tasks),
CrossThreadUnretained(GetWorkerThread())));
}
void ThreadedWorkletMessagingProxy::WorkletObjectDestroyed() {
DCHECK(IsMainThread());
ParentObjectDestroyed();
}
void ThreadedWorkletMessagingProxy::TerminateWorkletGlobalScope() {
DCHECK(IsMainThread());
TerminateGlobalScope();
}
std::unique_ptr<ThreadedWorkletObjectProxy>
ThreadedWorkletMessagingProxy::CreateObjectProxy(
ThreadedWorkletMessagingProxy* messaging_proxy,
ParentExecutionContextTaskRunners* parent_execution_context_task_runners) {
return ThreadedWorkletObjectProxy::Create(
messaging_proxy, parent_execution_context_task_runners);
}
ThreadedWorkletObjectProxy&
ThreadedWorkletMessagingProxy::WorkletObjectProxy() {
DCHECK(worklet_object_proxy_);
return *worklet_object_proxy_;
}
} // namespace blink
|
