Add a Mojo EDK for Chrome that uses one OS pipe per message pipe.

ipc/mojo/ipc_mojo_perftest.cc

 // 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 "base/lazy_instance.h"
 #include "base/run_loop.h"
 #include "ipc/ipc_perftest_support.h"
 #include "ipc/mojo/ipc_channel_mojo.h"
-#include "third_party/mojo/src/mojo/edk/embedder/test_embedder.h"
+#include "third_party/mojo/src/mojo/edk/embedder/platform_channel_pair.h"
+#include "third_party/mojo/src/mojo/edk/embedder/embedder.h"
 
 namespace {
 
 // This is needed because we rely on //base/test:test_support_perf and
 // it provides main() which doesn't have Mojo initialization.  We need
-// some way to call InitWithSimplePlatformSupport() only once before
-// using Mojo.
+// some way to call Init() only once before using Mojo.
 struct MojoInitialier {
   MojoInitialier() {
-    mojo::embedder::test::InitWithSimplePlatformSupport();
+    mojo::embedder::Init();
   }
 };
 
 base::LazyInstance<MojoInitialier> g_mojo_initializer
     = LAZY_INSTANCE_INITIALIZER;
 
 class MojoChannelPerfTest : public IPC::test::IPCChannelPerfTestBase {
 public:
   typedef IPC::test::IPCChannelPerfTestBase Super;
 
@@ skipping 28 matching lines @@
   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::embedder::PlatformChannelPair*> channels;
+  for (size_t i = 0; i < 10000; ++i) {
+    LOG(INFO) << "channels size: " << channels.size();
+    channels.push_back(new mojo::embedder::PlatformChannelPair());
+  }
+}
+
 class MojoTestClient : public IPC::test::PingPongTestClient {
  public:
   typedef IPC::test::PingPongTestClient SuperType;
 
   MojoTestClient();
 
   scoped_ptr<IPC::Channel> CreateChannel(IPC::Listener* listener) override;
 };
 
 MojoTestClient::MojoTestClient() {
@@ skipping 11 matching lines @@
   MojoTestClient client;
   int rv = client.RunMain();
 
   base::RunLoop run_loop;
   run_loop.RunUntilIdle();
 
   return rv;
 }
 
 }  // namespace