blob: b98c1b5fa7543d8d5d9412be75ae78a1bae0d414 (
plain)
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
|
// 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_object_proxy.h"
#include <memory>
#include <utility>
#include "base/memory/ptr_util.h"
#include "third_party/blink/renderer/core/workers/threaded_worklet_messaging_proxy.h"
#include "third_party/blink/renderer/core/workers/worker_thread.h"
#include "third_party/blink/renderer/core/workers/worklet_global_scope.h"
#include "third_party/blink/renderer/platform/loader/fetch/fetch_client_settings_object_snapshot.h"
namespace blink {
std::unique_ptr<ThreadedWorkletObjectProxy> ThreadedWorkletObjectProxy::Create(
ThreadedWorkletMessagingProxy* messaging_proxy_weak_ptr,
ParentExecutionContextTaskRunners* parent_execution_context_task_runners) {
DCHECK(messaging_proxy_weak_ptr);
return base::WrapUnique(new ThreadedWorkletObjectProxy(
messaging_proxy_weak_ptr, parent_execution_context_task_runners));
}
ThreadedWorkletObjectProxy::~ThreadedWorkletObjectProxy() = default;
void ThreadedWorkletObjectProxy::FetchAndInvokeScript(
const KURL& module_url_record,
network::mojom::FetchCredentialsMode credentials_mode,
std::unique_ptr<CrossThreadFetchClientSettingsObjectData>
outside_settings_object,
scoped_refptr<base::SingleThreadTaskRunner> outside_settings_task_runner,
WorkletPendingTasks* pending_tasks,
WorkerThread* worker_thread) {
WorkletGlobalScope* global_scope =
ToWorkletGlobalScope(worker_thread->GlobalScope());
global_scope->FetchAndInvokeScript(
module_url_record, credentials_mode,
new FetchClientSettingsObjectSnapshot(std::move(outside_settings_object)),
std::move(outside_settings_task_runner), pending_tasks);
}
ThreadedWorkletObjectProxy::ThreadedWorkletObjectProxy(
ThreadedWorkletMessagingProxy* messaging_proxy_weak_ptr,
ParentExecutionContextTaskRunners* parent_execution_context_task_runners)
: ThreadedObjectProxyBase(parent_execution_context_task_runners),
messaging_proxy_weak_ptr_(messaging_proxy_weak_ptr) {}
CrossThreadWeakPersistent<ThreadedMessagingProxyBase>
ThreadedWorkletObjectProxy::MessagingProxyWeakPtr() {
return messaging_proxy_weak_ptr_;
}
} // namespace blink
|
