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

#include <string>
#include <string_view>
#include <utility>

#include "base/check.h"
#include "base/functional/bind.h"
#include "base/functional/callback.h"
#include "base/memory/raw_ptr_exclusion.h"
#include "base/memory/weak_ptr.h"
#include "base/not_fatal_until.h"
#include "mojo/public/cpp/bindings/message.h"

namespace mojo {

class ReceiverSetState::Entry::DispatchFilter : public MessageFilter { … };

ReceiverSetState::Entry::Entry(ReceiverSetState& state,
                               ReceiverId id,
                               std::unique_ptr<ReceiverState> receiver,
                               std::unique_ptr<MessageFilter> filter)
    : … { … }

ReceiverSetState::Entry::~Entry() = default;

void ReceiverSetState::Entry::WillDispatch() { … }

void ReceiverSetState::Entry::DidDispatchOrReject() { … }

void ReceiverSetState::Entry::OnDisconnect(uint32_t custom_reason_code,
                                           const std::string& description) { … }

ReceiverSetState::ReceiverSetState() = default;

ReceiverSetState::~ReceiverSetState() = default;

void ReceiverSetState::set_disconnect_handler(base::RepeatingClosure handler) { … }

void ReceiverSetState::set_disconnect_with_reason_handler(
    RepeatingConnectionErrorWithReasonCallback handler) { … }

ReportBadMessageCallback ReceiverSetState::GetBadMessageCallback() { … }

ReceiverId ReceiverSetState::Add(std::unique_ptr<ReceiverState> receiver,
                                 std::unique_ptr<MessageFilter> filter) { … }

bool ReceiverSetState::Remove(ReceiverId id) { … }

bool ReceiverSetState::RemoveWithReason(ReceiverId id,
                                        uint32_t custom_reason_code,
                                        const std::string& description) { … }

void ReceiverSetState::FlushForTesting() { … }

void ReceiverSetState::SetDispatchContext(void* context,
                                          ReceiverId receiver_id) { … }

void ReceiverSetState::OnDisconnect(ReceiverId id,
                                    uint32_t custom_reason_code,
                                    const std::string& description) { … }

}  // namespace mojo