chromium/mojo/public/cpp/bindings/lib/pipe_control_message_proxy.cc

// Copyright 2015 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/pipe_control_message_proxy.h"

#include <stddef.h>

#include <tuple>
#include <utility>

#include "mojo/public/cpp/bindings/lib/message_fragment.h"
#include "mojo/public/cpp/bindings/lib/serialization.h"
#include "mojo/public/cpp/bindings/message.h"
#include "mojo/public/interfaces/bindings/pipe_control_messages.mojom.h"

namespace mojo {
namespace {

const char kMessageTag[] = …;

Message ConstructRunOrClosePipeMessage(
    pipe_control::RunOrClosePipeInputPtr input_ptr) { … }

}  // namespace

PipeControlMessageProxy::PipeControlMessageProxy(MessageReceiver* receiver)
    : … { … }

void PipeControlMessageProxy::NotifyPeerEndpointClosed(
    InterfaceId id,
    const std::optional<DisconnectReason>& reason) { … }

void PipeControlMessageProxy::PausePeerUntilFlushCompletes(PendingFlush flush) { … }

void PipeControlMessageProxy::FlushAsync(AsyncFlusher flusher) { … }

// static
Message PipeControlMessageProxy::ConstructPeerEndpointClosedMessage(
    InterfaceId id,
    const std::optional<DisconnectReason>& reason) { … }

}  // namespace mojo