chromium/third_party/blink/renderer/modules/shared_storage/shared_storage_worklet_messaging_proxy.cc

// Copyright 2023 The Chromium Authors
// 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/modules/shared_storage/shared_storage_worklet_messaging_proxy.h"

#include <utility>

#include "mojo/public/cpp/bindings/pending_remote.h"
#include "mojo/public/cpp/bindings/remote.h"
#include "third_party/blink/public/mojom/shared_storage/shared_storage_worklet_service.mojom-blink.h"
#include "third_party/blink/public/mojom/worker/worklet_global_scope_creation_params.mojom-blink.h"
#include "third_party/blink/renderer/bindings/core/v8/serialization/serialized_script_value.h"
#include "third_party/blink/renderer/core/workers/threaded_worklet_object_proxy.h"
#include "third_party/blink/renderer/modules/shared_storage/shared_storage_worklet_thread.h"
#include "third_party/blink/renderer/platform/scheduler/public/post_cross_thread_task.h"
#include "third_party/blink/renderer/platform/wtf/cross_thread_copier.h"
#include "third_party/blink/renderer/platform/wtf/cross_thread_copier_base.h"
#include "third_party/blink/renderer/platform/wtf/cross_thread_copier_mojo.h"
#include "third_party/blink/renderer/platform/wtf/cross_thread_functional.h"

namespace blink {

SharedStorageWorkletMessagingProxy::SharedStorageWorkletMessagingProxy(
    scoped_refptr<base::SingleThreadTaskRunner> main_thread_runner,
    mojo::PendingReceiver<mojom::blink::SharedStorageWorkletService> receiver,
    mojom::blink::WorkletGlobalScopeCreationParamsPtr
        global_scope_creation_params,
    base::OnceClosure worklet_terminated_callback)
    : … { … }

void SharedStorageWorkletMessagingProxy::
    InitializeSharedStorageWorkletServiceOnWorkletThread(
        scoped_refptr<base::SingleThreadTaskRunner> main_thread_runner,
        CrossThreadHandle<SharedStorageWorkletMessagingProxy>
            cross_thread_handle,
        WorkerThread* worker_thread,
        mojo::PendingReceiver<mojom::blink::SharedStorageWorkletService>
            receiver) { … }

void SharedStorageWorkletMessagingProxy::
    OnSharedStorageWorkletServiceDisconnectedOnWorkletThread(
        scoped_refptr<base::SingleThreadTaskRunner> main_thread_runner,
        CrossThreadHandle<SharedStorageWorkletMessagingProxy>
            cross_thread_handle) { … }

void SharedStorageWorkletMessagingProxy::WorkerThreadTerminated() { … }

void SharedStorageWorkletMessagingProxy::Trace(Visitor* visitor) const { … }

std::unique_ptr<WorkerThread>
SharedStorageWorkletMessagingProxy::CreateWorkerThread() { … }

}  // namespace blink