Mojo: Add a MojoCreateMessagePipeOptions struct parameter to MojoCreateMessagePipe.

mojo/public/c/system/tests/core_perftest.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.
 
 // This tests the performance of the C API.
 
 #include "mojo/public/c/system/core.h"
 
 #include <assert.h>
 #include <stddef.h>
@@ skipping 106 matching lines @@
  public:
   CorePerftest() : buffer_(NULL), num_bytes_(0) {}
   virtual ~CorePerftest() {}
 
   static void NoOp(void* /*closure*/) {
   }
 
   static void MessagePipe_CreateAndClose(void* closure) {
     CorePerftest* self = static_cast<CorePerftest*>(closure);
     MojoResult result MOJO_ALLOW_UNUSED;
-    result = MojoCreateMessagePipe(&self->h0_, &self->h1_);
+    result = MojoCreateMessagePipe(NULL, &self->h0_, &self->h1_);
     assert(result == MOJO_RESULT_OK);
     result = MojoClose(self->h0_);
     assert(result == MOJO_RESULT_OK);
     result = MojoClose(self->h1_);
     assert(result == MOJO_RESULT_OK);
   }
 
   static void MessagePipe_WriteAndRead(void* closure) {
     CorePerftest* self = static_cast<CorePerftest*>(closure);
     MojoResult result MOJO_ALLOW_UNUSED;
@@ skipping 24 matching lines @@
 #if !defined(WIN32)
   void DoMessagePipeThreadedTest(unsigned num_writers,
                                  unsigned num_readers,
                                  uint32_t num_bytes) {
     static const int64_t kPerftestTimeMicroseconds = 3 * 1000000;
 
     assert(num_writers > 0);
     assert(num_readers > 0);
 
     MojoResult result MOJO_ALLOW_UNUSED;
-    result = MojoCreateMessagePipe(&h0_, &h1_);
+    result = MojoCreateMessagePipe(NULL, &h0_, &h1_);
     assert(result == MOJO_RESULT_OK);
 
     std::vector<MessagePipeWriterThread*> writers;
     for (unsigned i = 0; i < num_writers; i++)
       writers.push_back(new MessagePipeWriterThread(h0_, num_bytes));
 
     std::vector<MessagePipeReaderThread*> readers;
     for (unsigned i = 0; i < num_readers; i++)
       readers.push_back(new MessagePipeReaderThread(h1_));
 
@@ skipping 83 matching lines @@
 }
 
 TEST_F(CorePerftest, MessagePipe_CreateAndClose) {
   mojo::test::IterateAndReportPerf("MessagePipe_CreateAndClose",
                                    &CorePerftest::MessagePipe_CreateAndClose,
                                    this);
 }
 
 TEST_F(CorePerftest, MessagePipe_WriteAndRead) {
   MojoResult result MOJO_ALLOW_UNUSED;
-  result = MojoCreateMessagePipe(&h0_, &h1_);
+  result = MojoCreateMessagePipe(NULL, &h0_, &h1_);
   assert(result == MOJO_RESULT_OK);
   char buffer[10000] = { 0 };
   buffer_ = buffer;
   num_bytes_ = 10u;
   mojo::test::IterateAndReportPerf("MessagePipe_WriteAndRead_10bytes",
                                    &CorePerftest::MessagePipe_WriteAndRead,
                                    this);
   num_bytes_ = 100u;
   mojo::test::IterateAndReportPerf("MessagePipe_WriteAndRead_100bytes",
                                    &CorePerftest::MessagePipe_WriteAndRead,
                                    this);
   num_bytes_ = 1000u;
   mojo::test::IterateAndReportPerf("MessagePipe_WriteAndRead_1000bytes",
                                    &CorePerftest::MessagePipe_WriteAndRead,
                                    this);
   num_bytes_ = 10000u;
   mojo::test::IterateAndReportPerf("MessagePipe_WriteAndRead_10000bytes",
                                    &CorePerftest::MessagePipe_WriteAndRead,
                                    this);
   result = MojoClose(h0_);
   assert(result == MOJO_RESULT_OK);
   result = MojoClose(h1_);
   assert(result == MOJO_RESULT_OK);
 }
 
 TEST_F(CorePerftest, MessagePipe_EmptyRead) {
   MojoResult result MOJO_ALLOW_UNUSED;
-  result = MojoCreateMessagePipe(&h0_, &h1_);
+  result = MojoCreateMessagePipe(NULL, &h0_, &h1_);
   assert(result == MOJO_RESULT_OK);
   mojo::test::IterateAndReportPerf("MessagePipe_EmptyRead",
                                    &CorePerftest::MessagePipe_EmptyRead,
                                    this);
   result = MojoClose(h0_);
   assert(result == MOJO_RESULT_OK);
   result = MojoClose(h1_);
   assert(result == MOJO_RESULT_OK);
 }
 
@@ skipping 13 matching lines @@
   DoMessagePipeThreadedTest(1u, 1u, 10000u);
 
   DoMessagePipeThreadedTest(3u, 3u, 10u);
   // 100 was done above.
   DoMessagePipeThreadedTest(3u, 3u, 1000u);
   DoMessagePipeThreadedTest(3u, 3u, 10000u);
 }
 #endif  // !defined(WIN32)
 
 }  // namespace