Mojo: add mojo_message_pipe_perftests

mojo/system/message_pipe_test_utils.h

Index: mojo/system/message_pipe_test_utils.h
diff --git a/mojo/system/message_pipe_test_utils.h b/mojo/system/message_pipe_test_utils.h
new file mode 100644
index 0000000000000000000000000000000000000000..153ee425cd97d4609dc9d777e53861edd340b19e
--- /dev/null
+++ b/mojo/system/message_pipe_test_utils.h
@@ -0,0 +1,66 @@
+// 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.
+
+#ifndef MOJO_SYSTEM_MESSAGE_PIPE_TEST_UTILS_H_
+#define MOJO_SYSTEM_MESSAGE_PIPE_TEST_UTILS_H_
+
+#include "mojo/common/test/multiprocess_test_helper.h"
+#include "mojo/embedder/simple_platform_support.h"
+#include "mojo/system/channel.h"
+#include "mojo/system/message_pipe.h"
+#include "mojo/system/test_utils.h"
+
+namespace mojo {
+namespace system {
+namespace test {
+
+MojoResult WaitIfNecessary(scoped_refptr<MessagePipe> mp,
+                           MojoHandleSignals signals,
+                           HandleSignalsState* signals_state);
+
+class ChannelThread {
+ public:
+  explicit ChannelThread(embedder::PlatformSupport* platform_support);
+  ~ChannelThread();
+
+  void Start(embedder::ScopedPlatformHandle platform_handle,
+             scoped_refptr<MessagePipe> message_pipe);
+  void Stop();
+
+ private:
+  void InitChannelOnIOThread(embedder::ScopedPlatformHandle platform_handle,
+                             scoped_refptr<MessagePipe> message_pipe);
+  void ShutdownChannelOnIOThread();
+
+  embedder::PlatformSupport* const platform_support_;
+  TestIOThread test_io_thread_;
+  scoped_refptr<Channel> channel_;
+
+  DISALLOW_COPY_AND_ASSIGN(ChannelThread);
+};
+
+class MultiprocessMessagePipeTestBase : public testing::Test {
+ public:
+  MultiprocessMessagePipeTestBase();
+  virtual ~MultiprocessMessagePipeTestBase();
+
+ protected:
+  void Init(scoped_refptr<MessagePipe> mp);
+
+  embedder::PlatformSupport* platform_support() { return &platform_support_; }
+  mojo::test::MultiprocessTestHelper* helper() { return &helper_; }
+
+ private:
+  embedder::SimplePlatformSupport platform_support_;
+  ChannelThread channel_thread_;
+  mojo::test::MultiprocessTestHelper helper_;
+
+  DISALLOW_COPY_AND_ASSIGN(MultiprocessMessagePipeTestBase);
+};
+
+}  // namespace test
+}  // namespace system
+}  // namespace mojo
+
+#endif  // MOJO_SYSTEM_MESSAGE_PIPE_TEST_HELPER_H_