chromium/components/cast/message_port/cast_core/message_port_core.cc

// Copyright 2021 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "components/cast/message_port/cast_core/message_port_core.h"

#include <string_view>

#include "components/cast/message_port/message_port.h"

namespace cast_api_bindings {

namespace {
const uint32_t kInvalidChannelId = …;
}  // namespace

MessagePortDescriptor::MessagePortDescriptor(uint32_t channel_id,
                                             bool peer_started)
    : … { … }

MessagePortDescriptor::MessagePortDescriptor(MessagePortDescriptor&& other)
    : … { … }

Message::Message(Message&& other)
    : … { … }

Message& Message::operator=(Message&&) = default;

Message::Message(const std::string& data) : … { … }

Message::Message(const std::string& data,
                 std::vector<std::unique_ptr<MessagePortCore>> ports)
    : … { … }

Message::~Message() = default;

MessagePortCore::MessagePortCore(uint32_t channel_id)
    : … { … }

MessagePortCore::MessagePortCore(MessagePortCore&& other) { … }

MessagePortCore::~MessagePortCore() = default;

void MessagePortCore::Assign(MessagePortCore&& other) { … }

void MessagePortCore::SetReceiver(Receiver* receiver) { … }

bool MessagePortCore::Accept(Message message) { … }

void MessagePortCore::AcceptInternal(Message message) { … }

bool MessagePortCore::AcceptResult(bool result) { … }

void MessagePortCore::AcceptResultInternal(bool result) { … }

void MessagePortCore::OnPeerStarted() { … }

void MessagePortCore::OnPeerError() { … }

void MessagePortCore::CheckPeerStartedInternal() { … }

void MessagePortCore::ProcessMessageQueue() { … }

bool MessagePortCore::PostMessage(std::string_view message) { … }

// static
MessagePortCore* MessagePortCore::FromMessagePort(MessagePort* port) { … }

bool MessagePortCore::PostMessageWithTransferables(
    std::string_view message,
    std::vector<std::unique_ptr<MessagePort>> ports) { … }

void MessagePortCore::PostMessageInternal(Message message) { … }

void MessagePortCore::OnPipeErrorInternal() { … }

void MessagePortCore::Close() { … }

bool MessagePortCore::IsValid() const { … }

bool MessagePortCore::CanPostMessage() const { … }

MessagePortDescriptor MessagePortCore::Transfer(MessageConnector* replacement) { … }

}  // namespace cast_api_bindings