Index: ipc/mojo/ipc_mojo_perftest.cc |
diff --git a/ipc/mojo/ipc_mojo_perftest.cc b/ipc/mojo/ipc_mojo_perftest.cc |
deleted file mode 100644 |
index d68762b28ecf92833388dc9d5ab46fc52d658bc4..0000000000000000000000000000000000000000 |
--- a/ipc/mojo/ipc_mojo_perftest.cc |
+++ /dev/null |
@@ -1,119 +0,0 @@ |
-// Copyright 2014 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 <stddef.h> |
-#include <memory> |
- |
-#include "base/memory/ptr_util.h" |
-#include "base/run_loop.h" |
-#include "base/threading/thread_task_runner_handle.h" |
-#include "build/build_config.h" |
-#include "ipc/ipc_perftest_support.h" |
-#include "ipc/mojo/ipc_channel_mojo.h" |
-#include "mojo/edk/embedder/embedder.h" |
-#include "mojo/edk/embedder/platform_channel_pair.h" |
-#include "mojo/edk/test/multiprocess_test_helper.h" |
-#include "mojo/edk/test/scoped_ipc_support.h" |
- |
-namespace IPC { |
-namespace { |
- |
-class MojoChannelPerfTest : public test::IPCChannelPerfTestBase { |
- public: |
- void TearDown() override { |
- ipc_support_.reset(); |
- test::IPCChannelPerfTestBase::TearDown(); |
- } |
- |
- std::unique_ptr<ChannelFactory> CreateChannelFactory( |
- const ChannelHandle& handle, |
- base::SequencedTaskRunner* runner) override { |
- ipc_support_.reset(new mojo::edk::test::ScopedIPCSupport(io_task_runner())); |
- return ChannelMojo::CreateServerFactory( |
- helper_.StartChild("MojoPerfTestClient")); |
- } |
- |
- bool StartClient() override { |
- return true; |
- } |
- |
- bool WaitForClientShutdown() override { |
- return helper_.WaitForChildTestShutdown(); |
- } |
- |
- mojo::edk::test::MultiprocessTestHelper helper_; |
- std::unique_ptr<mojo::edk::test::ScopedIPCSupport> ipc_support_; |
-}; |
- |
-TEST_F(MojoChannelPerfTest, ChannelPingPong) { |
- RunTestChannelPingPong(GetDefaultTestParams()); |
- |
- base::RunLoop run_loop; |
- run_loop.RunUntilIdle(); |
-} |
- |
-TEST_F(MojoChannelPerfTest, ChannelProxyPingPong) { |
- RunTestChannelProxyPingPong(GetDefaultTestParams()); |
- |
- base::RunLoop run_loop; |
- run_loop.RunUntilIdle(); |
-} |
- |
-// Test to see how many channels we can create. |
-TEST_F(MojoChannelPerfTest, DISABLED_MaxChannelCount) { |
-#if defined(OS_POSIX) |
- LOG(INFO) << "base::GetMaxFds " << base::GetMaxFds(); |
- base::SetFdLimit(20000); |
-#endif |
- |
- std::vector<mojo::edk::PlatformChannelPair*> channels; |
- for (size_t i = 0; i < 10000; ++i) { |
- LOG(INFO) << "channels size: " << channels.size(); |
- channels.push_back(new mojo::edk::PlatformChannelPair()); |
- } |
-} |
- |
-class MojoPerfTestClient : public test::PingPongTestClient { |
- public: |
- typedef test::PingPongTestClient SuperType; |
- |
- MojoPerfTestClient(); |
- |
- std::unique_ptr<Channel> CreateChannel(Listener* listener) override; |
- |
- int Run(MojoHandle handle); |
- |
- private: |
- mojo::edk::test::ScopedIPCSupport ipc_support_; |
- mojo::ScopedMessagePipeHandle handle_; |
-}; |
- |
-MojoPerfTestClient::MojoPerfTestClient() |
- : ipc_support_(base::ThreadTaskRunnerHandle::Get()) { |
- mojo::edk::test::MultiprocessTestHelper::ChildSetup(); |
-} |
- |
-std::unique_ptr<Channel> MojoPerfTestClient::CreateChannel(Listener* listener) { |
- return ChannelMojo::Create(std::move(handle_), Channel::MODE_CLIENT, |
- listener); |
-} |
- |
-int MojoPerfTestClient::Run(MojoHandle handle) { |
- handle_ = mojo::MakeScopedHandle(mojo::MessagePipeHandle(handle)); |
- return RunMain(); |
-} |
- |
-MULTIPROCESS_TEST_MAIN(MojoPerfTestClientTestChildMain) { |
- MojoPerfTestClient client; |
- int rv = mojo::edk::test::MultiprocessTestHelper::RunClientMain( |
- base::Bind(&MojoPerfTestClient::Run, base::Unretained(&client))); |
- |
- base::RunLoop run_loop; |
- run_loop.RunUntilIdle(); |
- |
- return rv; |
-} |
- |
-} // namespace |
-} // namespace IPC |