chromium/components/cast/message_port/cast_core/message_port_core_with_task_runner.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_with_task_runner.h"

#include "base/functional/bind.h"
#include "base/logging.h"
#include "base/sequence_checker.h"
#include "base/task/sequenced_task_runner.h"

namespace cast_api_bindings {

namespace {
static uint32_t GenerateChannelId() { … }
}  // namespace

std::pair<MessagePortCoreWithTaskRunner, MessagePortCoreWithTaskRunner>
MessagePortCoreWithTaskRunner::CreatePair() { … }

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

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

MessagePortCoreWithTaskRunner::~MessagePortCoreWithTaskRunner() = default;

MessagePortCoreWithTaskRunner& MessagePortCoreWithTaskRunner::operator=(
    MessagePortCoreWithTaskRunner&& other) { … }

void MessagePortCoreWithTaskRunner::SetTaskRunner() { … }

void MessagePortCoreWithTaskRunner::AcceptOnSequence(Message message) { … }

void MessagePortCoreWithTaskRunner::AcceptResultOnSequence(bool result) { … }

void MessagePortCoreWithTaskRunner::CheckPeerStartedOnSequence() { … }

void MessagePortCoreWithTaskRunner::StartOnSequence() { … }

void MessagePortCoreWithTaskRunner::PostMessageOnSequence(Message message) { … }

void MessagePortCoreWithTaskRunner::OnPipeErrorOnSequence() { … }

bool MessagePortCoreWithTaskRunner::HasTaskRunner() const { … }

}  // namespace cast_api_bindings