chromium/third_party/openscreen/src/cast/common/channel/virtual_connection_router.cc

// Copyright 2019 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/common/channel/virtual_connection_router.h"

#include <utility>

#include "cast/common/channel/cast_message_handler.h"
#include "cast/common/channel/connection_namespace_handler.h"
#include "cast/common/channel/message_util.h"
#include "cast/common/channel/proto/cast_channel.pb.h"
#include "util/osp_logging.h"

namespace openscreen::cast {

CastMessage;

VirtualConnectionRouter::SocketErrorHandler::~SocketErrorHandler() = default;

VirtualConnectionRouter::VirtualConnectionRouter() = default;

VirtualConnectionRouter::~VirtualConnectionRouter() = default;

void VirtualConnectionRouter::AddConnection(
    VirtualConnection virtual_connection,
    VirtualConnection::AssociatedData associated_data) { … }

bool VirtualConnectionRouter::RemoveConnection(
    const VirtualConnection& virtual_connection,
    VirtualConnection::CloseReason reason) { … }

void VirtualConnectionRouter::RemoveConnectionsByLocalId(
    const std::string& local_id) { … }

void VirtualConnectionRouter::RemoveConnectionsBySocketId(int socket_id) { … }

std::optional<const VirtualConnection::AssociatedData*>
VirtualConnectionRouter::GetConnectionData(
    const VirtualConnection& virtual_connection) const { … }

bool VirtualConnectionRouter::AddHandlerForLocalId(
    std::string local_id,
    CastMessageHandler* endpoint) { … }

bool VirtualConnectionRouter::RemoveHandlerForLocalId(
    const std::string& local_id) { … }

void VirtualConnectionRouter::TakeSocket(SocketErrorHandler* error_handler,
                                         std::unique_ptr<CastSocket> socket) { … }

void VirtualConnectionRouter::CloseSocket(int id) { … }

Error VirtualConnectionRouter::Send(VirtualConnection virtual_conn,
                                    CastMessage message) { … }

Error VirtualConnectionRouter::BroadcastFromLocalPeer(
    std::string local_id,
    proto::CastMessage message) { … }

void VirtualConnectionRouter::OnError(CastSocket* socket, const Error& error) { … }

void VirtualConnectionRouter::OnMessage(CastSocket* socket,
                                        CastMessage message) { … }

}  // namespace openscreen::cast