chromium/mojo/public/cpp/bindings/direct_receiver.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 "mojo/public/cpp/bindings/direct_receiver.h"

#include "base/check.h"
#include "base/memory/ptr_util.h"
#include "base/task/single_thread_task_runner.h"
#include "mojo/core/embedder/embedder.h"
#include "mojo/core/ipcz_api.h"
#include "mojo/core/ipcz_driver/driver.h"
#include "mojo/core/ipcz_driver/transport.h"
#include "mojo/public/cpp/system/handle.h"
#include "third_party/ipcz/include/ipcz/ipcz.h"

namespace mojo::internal {

namespace {

thread_local ThreadLocalNode* g_thread_local_node;

}  // namespace

ThreadLocalNode::ThreadLocalNode(base::PassKey<ThreadLocalNode>)
    : … { … }

ThreadLocalNode::~ThreadLocalNode() { … }

// static
scoped_refptr<ThreadLocalNode> ThreadLocalNode::Get() { … }

// static
bool ThreadLocalNode::CurrentThreadHasInstance() { … }

ScopedMessagePipeHandle ThreadLocalNode::AdoptPipe(
    ScopedMessagePipeHandle pipe) { … }

void ThreadLocalNode::WatchForIncomingTransfers() { … }

// static
void ThreadLocalNode::OnTrapEvent(const IpczTrapEvent* event) { … }

void ThreadLocalNode::OnTransferredPortalAvailable() { … }

}  // namespace mojo::internal

namespace mojo {

bool IsDirectReceiverSupported() { … }

}  // namespace mojo