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

#include <stddef.h>
#include <stdint.h>
#include <string.h>

#include "mojo/public/cpp/bindings/message.h"
#include "mojo/public/cpp/bindings/tests/message_queue.h"
#include "testing/gtest/include/gtest/gtest.h"

namespace mojo {
namespace test {

void AllocRequestMessage(uint32_t name, const char* text, Message* message) { … }

void AllocResponseMessage(uint32_t name,
                          const char* text,
                          uint64_t request_id,
                          Message* message) { … }

MessageAccumulator::MessageAccumulator(MessageQueue* queue,
                                       base::OnceClosure closure)
    : … { … }

MessageAccumulator::~MessageAccumulator() { … }

bool MessageAccumulator::Accept(Message* message) { … }

ResponseGenerator::ResponseGenerator() { … }

bool ResponseGenerator::Accept(Message* message) { … }

bool ResponseGenerator::AcceptWithResponder(
    Message* message,
    std::unique_ptr<MessageReceiverWithStatus> responder) { … }

bool ResponseGenerator::SendResponse(uint32_t name,
                                     uint64_t request_id,
                                     const char* request_string,
                                     MessageReceiver* responder) { … }

LazyResponseGenerator::LazyResponseGenerator(base::OnceClosure closure)
    : … { … }

LazyResponseGenerator::~LazyResponseGenerator() = default;

bool LazyResponseGenerator::AcceptWithResponder(
    Message* message,
    std::unique_ptr<MessageReceiverWithStatus> responder) { … }

void LazyResponseGenerator::Complete(bool send_response) { … }

}  // namespace test
}  // namespace mojo