chromium/third_party/openscreen/src/cast/streaming/public/rpc_messenger.cc

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

#include "cast/streaming/public/rpc_messenger.h"

#include <memory>
#include <string>
#include <utility>

#include "util/osp_logging.h"

namespace openscreen::cast {

namespace {

std::ostream& operator<<(std::ostream& out, const RpcMessage& message) { … }

}  // namespace

constexpr RpcMessenger::Handle RpcMessenger::kInvalidHandle;
constexpr RpcMessenger::Handle RpcMessenger::kAcquireRendererHandle;
constexpr RpcMessenger::Handle RpcMessenger::kAcquireDemuxerHandle;
constexpr RpcMessenger::Handle RpcMessenger::kFirstHandle;

RpcMessenger::RpcMessenger(SendMessageCallback send_message_cb)
    : … { … }

RpcMessenger::~RpcMessenger() { … }

RpcMessenger::Handle RpcMessenger::GetUniqueHandle() { … }

void RpcMessenger::RegisterMessageReceiverCallback(
    RpcMessenger::Handle handle,
    ReceiveMessageCallback callback) { … }

void RpcMessenger::UnregisterMessageReceiverCallback(
    RpcMessenger::Handle handle) { … }

void RpcMessenger::ProcessMessageFromRemote(const uint8_t* message,
                                         std::size_t message_len) { … }

void RpcMessenger::ProcessMessageFromRemote(
    std::unique_ptr<RpcMessage> message) { … }

void RpcMessenger::SendMessageToRemote(const RpcMessage& rpc) { … }

bool RpcMessenger::IsRegisteredForTesting(RpcMessenger::Handle handle) { … }

WeakPtr<RpcMessenger> RpcMessenger::GetWeakPtr() { … }

}  // namespace openscreen::cast