| Index: mojo/public/cpp/bindings/tests/synchronous_connector_unittest.cc
|
| diff --git a/mojo/public/cpp/bindings/tests/synchronous_connector_unittest.cc b/mojo/public/cpp/bindings/tests/synchronous_connector_unittest.cc
|
| deleted file mode 100644
|
| index 6aa629004f4578e543c1c209d632370145364172..0000000000000000000000000000000000000000
|
| --- a/mojo/public/cpp/bindings/tests/synchronous_connector_unittest.cc
|
| +++ /dev/null
|
| @@ -1,74 +0,0 @@
|
| -// Copyright 2016 The Chromium Authors. All rights reserved.
|
| -// 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/lib/synchronous_connector.h"
|
| -
|
| -#include <string.h>
|
| -
|
| -#include <string>
|
| -#include <utility>
|
| -
|
| -#include "gtest/gtest.h"
|
| -#include "mojo/public/cpp/bindings/lib/message_builder.h"
|
| -#include "mojo/public/cpp/bindings/message.h"
|
| -
|
| -namespace mojo {
|
| -namespace test {
|
| -namespace {
|
| -
|
| -void AllocMessage(const std::string& text, Message* message) {
|
| - size_t payload_size = text.length() + 1; // Plus null terminator.
|
| - MessageBuilder builder(1, payload_size);
|
| - memcpy(builder.buffer()->Allocate(payload_size), text.c_str(), payload_size);
|
| -
|
| - builder.message()->MoveTo(message);
|
| -}
|
| -
|
| -// Simple success case.
|
| -TEST(SynchronousConnectorTest, Basic) {
|
| - MessagePipe pipe;
|
| - internal::SynchronousConnector connector0(std::move(pipe.handle0));
|
| - internal::SynchronousConnector connector1(std::move(pipe.handle1));
|
| -
|
| - const std::string kText("hello world");
|
| - Message message;
|
| - AllocMessage(kText, &message);
|
| -
|
| - EXPECT_TRUE(connector0.Write(&message));
|
| -
|
| - Message message_received;
|
| - EXPECT_TRUE(connector1.BlockingRead(&message_received));
|
| -
|
| - EXPECT_EQ(
|
| - kText,
|
| - std::string(reinterpret_cast<const char*>(message_received.payload())));
|
| -}
|
| -
|
| -// Writing to a closed pipe should fail.
|
| -TEST(SynchronousConnectorTest, WriteToClosedPipe) {
|
| - MessagePipe pipe;
|
| - internal::SynchronousConnector connector0(std::move(pipe.handle0));
|
| -
|
| - // Close the other end of the pipe.
|
| - pipe.handle1.reset();
|
| -
|
| - Message message;
|
| - EXPECT_FALSE(connector0.Write(&message));
|
| -}
|
| -
|
| -// Reading from a closed pipe should fail (while waiting on it).
|
| -TEST(SynchronousConnectorTest, ReadFromClosedPipe) {
|
| - MessagePipe pipe;
|
| - internal::SynchronousConnector connector0(std::move(pipe.handle0));
|
| -
|
| - // Close the other end of the pipe.
|
| - pipe.handle1.reset();
|
| -
|
| - Message message;
|
| - EXPECT_FALSE(connector0.BlockingRead(&message));
|
| -}
|
| -
|
| -} // namespace
|
| -} // namespace test
|
| -} // namespace mojo
|
|
|