Add Mojo{Set,Get}DataPipeConsumerOptions() to the NaCl system thunks.

mojo/public/c/system/tests/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.
 
 // This file tests the C API.
 
 #include <string.h>
 
 #include "mojo/public/c/system/buffer.h"
 #include "mojo/public/c/system/data_pipe.h"
@@ skipping 56 matching lines @@
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             MojoWriteData(MOJO_HANDLE_INVALID, buffer, &buffer_size,
                           MOJO_WRITE_DATA_FLAG_NONE));
   write_pointer = nullptr;
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             MojoBeginWriteData(MOJO_HANDLE_INVALID, &write_pointer,
                                &buffer_size, MOJO_WRITE_DATA_FLAG_NONE));
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             MojoEndWriteData(MOJO_HANDLE_INVALID, 1u));
   buffer_size = static_cast<uint32_t>(sizeof(buffer));
-// TODO(vtl): Enable once I've added support for NaCl.
-#ifndef __native_client__
   MojoDataPipeConsumerOptions dpc_options = {
       sizeof(MojoDataPipeConsumerOptions), 0u};
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             MojoSetDataPipeConsumerOptions(MOJO_HANDLE_INVALID, &dpc_options));
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             MojoGetDataPipeConsumerOptions(
                 MOJO_HANDLE_INVALID, &dpc_options,
                 static_cast<uint32_t>(sizeof(dpc_options))));
-#endif
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             MojoReadData(MOJO_HANDLE_INVALID, buffer, &buffer_size,
                          MOJO_READ_DATA_FLAG_NONE));
   read_pointer = nullptr;
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             MojoBeginReadData(MOJO_HANDLE_INVALID, &read_pointer, &buffer_size,
                               MOJO_READ_DATA_FLAG_NONE));
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             MojoEndReadData(MOJO_HANDLE_INVALID, 1u));
 
@@ skipping 213 matching lines @@
             MojoWait(hc, MOJO_HANDLE_SIGNAL_READABLE, 1000, &state));
   EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, state.satisfied_signals);
   EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, state.satisfiable_signals);
 
   EXPECT_EQ(MOJO_RESULT_OK, MojoClose(hc));
 
   // TODO(vtl): Test the other way around -- closing the consumer should make
   // the producer never-writable?
 }
 
-// TODO(vtl): Enable once I've added support for NaCl.
-#ifndef __native_client__
 TEST(CoreTest, DataPipeReadThreshold) {
   MojoHandle hp = MOJO_HANDLE_INVALID;
   MojoHandle hc = MOJO_HANDLE_INVALID;
   EXPECT_EQ(MOJO_RESULT_OK, MojoCreateDataPipe(nullptr, &hp, &hc));
   EXPECT_NE(hp, MOJO_HANDLE_INVALID);
   EXPECT_NE(hc, MOJO_HANDLE_INVALID);
 
   MojoDataPipeConsumerOptions copts;
   static const uint32_t kCoptsSize = static_cast<uint32_t>(sizeof(copts));
 
@@ skipping 79 matching lines @@
   copts.read_threshold_num_bytes = 2u;
   EXPECT_EQ(MOJO_RESULT_OK, MojoSetDataPipeConsumerOptions(hc, &copts));
 
   // Should have the read threshold signal again.
   EXPECT_EQ(MOJO_RESULT_OK,
             MojoWait(hc, MOJO_HANDLE_SIGNAL_READ_THRESHOLD, 0, nullptr));
 
   EXPECT_EQ(MOJO_RESULT_OK, MojoClose(hp));
   EXPECT_EQ(MOJO_RESULT_OK, MojoClose(hc));
 }
-#endif
 
 // TODO(ncbray): enable this test once NaCl supports the corresponding APIs.
 #ifdef __native_client__
 #define MAYBE_BasicSharedBuffer DISABLED_BasicSharedBuffer
 #else
 #define MAYBE_BasicSharedBuffer BasicSharedBuffer
 #endif
 TEST(CoreTest, MAYBE_BasicSharedBuffer) {
   MojoHandle h0, h1;
   void* pointer;
@@ skipping 63 matching lines @@
 
 TEST(CoreTest, MinimalCppTest) {
   const char* failure = MinimalCppTest();
   EXPECT_FALSE(failure) << failure;
 }
 
 // TODO(vtl): Add multi-threaded tests.
 
 }  // namespace
 }  // namespace mojo