Index: third_party/mojo/src/mojo/edk/system/test_channel_endpoint_client.cc |
diff --git a/third_party/mojo/src/mojo/edk/system/test_channel_endpoint_client.cc b/third_party/mojo/src/mojo/edk/system/test_channel_endpoint_client.cc |
deleted file mode 100644 |
index fc60cb3cca16457f2a6b586942ad91f343f0e583..0000000000000000000000000000000000000000 |
--- a/third_party/mojo/src/mojo/edk/system/test_channel_endpoint_client.cc |
+++ /dev/null |
@@ -1,78 +0,0 @@ |
-// Copyright 2015 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 "third_party/mojo/src/mojo/edk/system/test_channel_endpoint_client.h" |
- |
-#include "base/synchronization/waitable_event.h" |
-#include "testing/gtest/include/gtest/gtest.h" |
-#include "third_party/mojo/src/mojo/edk/system/message_in_transit.h" |
- |
-namespace mojo { |
-namespace system { |
-namespace test { |
- |
-TestChannelEndpointClient::TestChannelEndpointClient() |
- : port_(0), read_event_(nullptr) { |
-} |
- |
-void TestChannelEndpointClient::Init(unsigned port, ChannelEndpoint* endpoint) { |
- MutexLocker locker(&mutex_); |
- ASSERT_EQ(0u, port_); |
- ASSERT_FALSE(endpoint_); |
- port_ = port; |
- endpoint_ = endpoint; |
-} |
- |
-bool TestChannelEndpointClient::IsDetached() const { |
- MutexLocker locker(&mutex_); |
- return !endpoint_; |
-} |
- |
-size_t TestChannelEndpointClient::NumMessages() const { |
- MutexLocker locker(&mutex_); |
- return messages_.Size(); |
-} |
- |
-scoped_ptr<MessageInTransit> TestChannelEndpointClient::PopMessage() { |
- MutexLocker locker(&mutex_); |
- if (messages_.IsEmpty()) |
- return nullptr; |
- return messages_.GetMessage(); |
-} |
- |
-void TestChannelEndpointClient::SetReadEvent(base::WaitableEvent* read_event) { |
- MutexLocker locker(&mutex_); |
- read_event_ = read_event; |
-} |
- |
-bool TestChannelEndpointClient::OnReadMessage(unsigned port, |
- MessageInTransit* message) { |
- MutexLocker locker(&mutex_); |
- |
- EXPECT_EQ(port_, port); |
- EXPECT_TRUE(endpoint_); |
- messages_.AddMessage(make_scoped_ptr(message)); |
- |
- if (read_event_) |
- read_event_->Signal(); |
- |
- return true; |
-} |
- |
-void TestChannelEndpointClient::OnDetachFromChannel(unsigned port) { |
- MutexLocker locker(&mutex_); |
- |
- EXPECT_EQ(port_, port); |
- ASSERT_TRUE(endpoint_); |
- endpoint_->DetachFromClient(); |
- endpoint_ = nullptr; |
-} |
- |
-TestChannelEndpointClient::~TestChannelEndpointClient() { |
- EXPECT_FALSE(endpoint_); |
-} |
- |
-} // namespace test |
-} // namespace system |
-} // namespace mojo |