summaryrefslogtreecommitdiffstats
path: root/third_party/mojo/src/mojo/edk/system/test_channel_endpoint_client.cc
diff options
context:
space:
mode:
Diffstat (limited to 'third_party/mojo/src/mojo/edk/system/test_channel_endpoint_client.cc')
-rw-r--r--third_party/mojo/src/mojo/edk/system/test_channel_endpoint_client.cc78
1 files changed, 0 insertions, 78 deletions
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 fc60cb3..0000000
--- 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