chromium/ipc/ipc_sync_message.cc

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

#include "ipc/ipc_sync_message.h"

#include <stdint.h>

#include "base/atomic_sequence_num.h"
#include "base/check.h"
#include "base/notreached.h"
#include "base/synchronization/waitable_event.h"
#include "build/build_config.h"

namespace {

base::AtomicSequenceNumber g_next_id;

}  // namespace

namespace IPC {

#define kSyncMessageHeaderSize …

SyncMessage::SyncMessage(int32_t routing_id,
                         uint32_t type,
                         PriorityValue priority,
                         std::unique_ptr<MessageReplyDeserializer> deserializer)
    : … { … }

SyncMessage::~SyncMessage() = default;

std::unique_ptr<MessageReplyDeserializer> SyncMessage::TakeReplyDeserializer() { … }

bool SyncMessage::IsMessageReplyTo(const Message& msg, int request_id) { … }

base::PickleIterator SyncMessage::GetDataIterator(const Message* msg) { … }

int SyncMessage::GetMessageId(const Message& msg) { … }

Message* SyncMessage::GenerateReply(const Message* msg) { … }

bool SyncMessage::ReadSyncHeader(const Message& msg, SyncHeader* header) { … }

bool SyncMessage::WriteSyncHeader(Message* msg, const SyncHeader& header) { … }


bool MessageReplyDeserializer::SerializeOutputParameters(const Message& msg) { … }

PendingSyncMsg::PendingSyncMsg(int id,
                               std::unique_ptr<MessageReplyDeserializer> d,
                               std::unique_ptr<base::WaitableEvent> e)
    : … { … }

PendingSyncMsg::PendingSyncMsg(PendingSyncMsg&& that) = default;

PendingSyncMsg::~PendingSyncMsg() = default;

}  // namespace IPC