[mojo-edk] Add MojoWatch and MojoCancelWatch APIs

mojo/edk/test/mojo_test_base.h

 // Copyright 2016 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_EDK_TEST_MOJO_TEST_BASE_H_
 #define MOJO_EDK_TEST_MOJO_TEST_BASE_H_
 
 #include <string>
 #include <utility>
 
 #include "base/bind.h"
 #include "base/callback.h"
 #include "base/logging.h"
 #include "base/macros.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
-#include "base/message_loop/message_loop.h"
-#include "base/run_loop.h"
-#include "base/task_runner.h"
-#include "base/thread_task_runner_handle.h"
 #include "mojo/edk/embedder/embedder.h"
 #include "mojo/edk/test/multiprocess_test_helper.h"
 #include "mojo/public/c/system/types.h"
 #include "mojo/public/cpp/system/message_pipe.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 namespace mojo {
 namespace edk {
 namespace test {
 
@@ skipping 93 matching lines @@
   // Maps a buffer, writes some data into it, and unmaps it.
   static void WriteToBuffer(MojoHandle h,
                             size_t offset,
                             const base::StringPiece& s);
 
   // Maps a buffer, tests the value of some of its contents, and unmaps it.
   static void ExpectBufferContents(MojoHandle h,
                                    size_t offset,
                                    const base::StringPiece& s);
 
+  //////// Data pipe test utilities /////////
+
+  // Creates a new data pipe.
+  static void CreateDataPipe(MojoHandle* producer,
+                             MojoHandle* consumer,
+                             size_t capacity);
+
+  // Writes data to a data pipe.
+  static void WriteData(MojoHandle producer, const std::string& data);
+
+  // Reads data from a data pipe.
+  static std::string ReadData(MojoHandle consumer, size_t size);
+
  private:
   friend class ClientController;
 
-  base::MessageLoop message_loop_;
   std::vector<scoped_ptr<ClientController>> clients_;
 
   DISALLOW_COPY_AND_ASSIGN(MojoTestBase);
 };
 
 // Launches a new child process running the test client |client_name| connected
 // to a new message pipe bound to |pipe_name|. |pipe_name| is automatically
 // closed on test teardown.
 #define RUN_CHILD_ON_PIPE(client_name, pipe_name)                   \
     StartClientWithHandler(                                         \
@@ skipping 61 matching lines @@
 #else  // !defined(OS_IOS)
 #define DEFINE_TEST_CLIENT_WITH_PIPE(client_name, test_base, pipe_name)
 #define DEFINE_TEST_CLIENT_TEST_WITH_PIPE(client_name, test_base, pipe_name)
 #endif  // !defined(OS_IOS)
 
 }  // namespace test
 }  // namespace edk
 }  // namespace mojo
 
 #endif  // MOJO_EDK_TEST_MOJO_TEST_BASE_H_