Mojo: Add a MojoCreateMessagePipeOptions struct parameter to MojoCreateMessagePipe.

mojo/system/core_unittest.cc

 // Copyright 2013 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 "mojo/system/core.h"
 
 #include <limits>
 
 #include "base/basictypes.h"
 #include "base/threading/platform_thread.h"
@@ skipping 169 matching lines @@
               core()->WaitMany(handles, flags, 2, MOJO_DEADLINE_INDEFINITE));
 
     EXPECT_EQ(MOJO_RESULT_OK, core()->Close(handles[0]));
     EXPECT_EQ(MOJO_RESULT_OK, core()->Close(handles[1]));
   }
 
   // |CreateMessagePipe()|:
   {
     MojoHandle h;
     EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
-              core()->CreateMessagePipe(NULL, NULL));
+              core()->CreateMessagePipe(NULL, NULL, NULL));
     EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
-              core()->CreateMessagePipe(&h, NULL));
+              core()->CreateMessagePipe(NULL, &h, NULL));
     EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
-              core()->CreateMessagePipe(NULL, &h));
+              core()->CreateMessagePipe(NULL, NULL, &h));
   }
 
   // |WriteMessage()|:
   // Only check arguments checked by |Core|, namely |handle|, |handles|, and
   // |num_handles|.
   {
     EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
               core()->WriteMessage(MOJO_HANDLE_INVALID, NULL, 0, NULL, 0,
                                    MOJO_WRITE_MESSAGE_FLAG_NONE));
 
@@ skipping 113 matching lines @@
   }
 }
 
 // TODO(vtl): test |Wait()| and |WaitMany()| properly
 //  - including |WaitMany()| with the same handle more than once (with
 //    same/different flags)
 
 TEST_F(CoreTest, MessagePipe) {
   MojoHandle h[2];
 
-  EXPECT_EQ(MOJO_RESULT_OK, core()->CreateMessagePipe(&h[0], &h[1]));
+  EXPECT_EQ(MOJO_RESULT_OK, core()->CreateMessagePipe(NULL, &h[0], &h[1]));
   // Should get two distinct, valid handles.
   EXPECT_NE(h[0], MOJO_HANDLE_INVALID);
   EXPECT_NE(h[1], MOJO_HANDLE_INVALID);
   EXPECT_NE(h[0], h[1]);
 
   // Neither should be readable.
   MojoWaitFlags flags[2] = { MOJO_WAIT_FLAG_READABLE, MOJO_WAIT_FLAG_READABLE };
   EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED,
             core()->WaitMany(h, flags, 2, 0));
 
@@ skipping 92 matching lines @@
   const uint32_t kWorldSize = static_cast<uint32_t>(sizeof(kWorld));
   char buffer[100];
   const uint32_t kBufferSize = static_cast<uint32_t>(sizeof(buffer));
   uint32_t num_bytes;
   MojoHandle handles[10];
   uint32_t num_handles;
   MojoHandle h_received;
 
   MojoHandle h_passing[2];
   EXPECT_EQ(MOJO_RESULT_OK,
-            core()->CreateMessagePipe(&h_passing[0], &h_passing[1]));
+            core()->CreateMessagePipe(NULL, &h_passing[0], &h_passing[1]));
 
   // Make sure that |h_passing[]| work properly.
   EXPECT_EQ(MOJO_RESULT_OK,
             core()->WriteMessage(h_passing[0],
                                  kHello, kHelloSize,
                                  NULL, 0,
                                  MOJO_WRITE_MESSAGE_FLAG_NONE));
   EXPECT_EQ(MOJO_RESULT_OK,
             core()->Wait(h_passing[1], MOJO_WAIT_FLAG_READABLE, 1000000000));
   num_bytes = kBufferSize;
@@ skipping 15 matching lines @@
                                  &h_passing[0], 1,
                                  MOJO_WRITE_MESSAGE_FLAG_NONE));
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             core()->WriteMessage(h_passing[0],
                                  kHello, kHelloSize,
                                  &h_passing[1], 1,
                                  MOJO_WRITE_MESSAGE_FLAG_NONE));
 
   MojoHandle h_passed[2];
   EXPECT_EQ(MOJO_RESULT_OK,
-            core()->CreateMessagePipe(&h_passed[0], &h_passed[1]));
+            core()->CreateMessagePipe(NULL, &h_passed[0], &h_passed[1]));
 
   // Make sure that |h_passed[]| work properly.
   EXPECT_EQ(MOJO_RESULT_OK,
             core()->WriteMessage(h_passed[0],
                                  kHello, kHelloSize,
                                  NULL, 0,
                                  MOJO_WRITE_MESSAGE_FLAG_NONE));
   EXPECT_EQ(MOJO_RESULT_OK,
             core()->Wait(h_passed[1], MOJO_WAIT_FLAG_READABLE, 1000000000));
   num_bytes = kBufferSize;
@@ skipping 191 matching lines @@
   const char kWorld[] = "world!!!";
   const uint32_t kWorldSize = static_cast<uint32_t>(sizeof(kWorld));
   char buffer[100];
   const uint32_t kBufferSize = static_cast<uint32_t>(sizeof(buffer));
   uint32_t num_bytes;
   MojoHandle handles[10];
   uint32_t num_handles;
 
   MojoHandle h_passing[2];
   EXPECT_EQ(MOJO_RESULT_OK,
-            core()->CreateMessagePipe(&h_passing[0], &h_passing[1]));
+            core()->CreateMessagePipe(NULL, &h_passing[0], &h_passing[1]));
 
   MojoHandle ph, ch;
   EXPECT_EQ(MOJO_RESULT_OK,
             core()->CreateDataPipe(NULL, &ph, &ch));
 
   // Send |ch| from |h_passing[0]| to |h_passing[1]|.
   EXPECT_EQ(MOJO_RESULT_OK,
             core()->WriteMessage(h_passing[0],
                                  kHello, kHelloSize,
                                  &ch, 1,
@@ skipping 172 matching lines @@
   EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passing[1]));
   EXPECT_EQ(MOJO_RESULT_OK, core()->Close(ph));
   EXPECT_EQ(MOJO_RESULT_OK, core()->Close(ch));
 }
 
 // TODO(vtl): Test |DuplicateBufferHandle()| and |MapBuffer()|.
 
 }  // namespace
 }  // namespace system
 }  // namespace mojo