EDK: Add implementation of data pipe consumer read threshold stuff.

mojo/edk/system/dispatcher_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/edk/system/dispatcher.h"
 
 #include <memory>
 #include <thread>
 #include <vector>
 
@@ skipping 50 matching lines @@
             d->ReadMessage(NullUserPointer(), NullUserPointer(), nullptr,
                            nullptr, MOJO_WRITE_MESSAGE_FLAG_NONE));
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             d->WriteData(NullUserPointer(), NullUserPointer(),
                          MOJO_WRITE_DATA_FLAG_NONE));
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             d->BeginWriteData(NullUserPointer(), NullUserPointer(),
                               MOJO_WRITE_DATA_FLAG_NONE));
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, d->EndWriteData(0));
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
+            d->SetDataPipeConsumerOptions(NullUserPointer()));
+  EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
+            d->GetDataPipeConsumerOptions(NullUserPointer(), 0));
+  EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             d->ReadData(NullUserPointer(), NullUserPointer(),
                         MOJO_READ_DATA_FLAG_NONE));
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             d->BeginReadData(NullUserPointer(), NullUserPointer(),
                              MOJO_READ_DATA_FLAG_NONE));
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, d->EndReadData(0));
   RefPtr<Dispatcher> new_dispatcher;
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             d->DuplicateBufferHandle(NullUserPointer(), &new_dispatcher));
   EXPECT_FALSE(new_dispatcher);
@@ skipping 29 matching lines @@
             d->ReadMessage(NullUserPointer(), NullUserPointer(), nullptr,
                            nullptr, MOJO_WRITE_MESSAGE_FLAG_NONE));
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             d->WriteData(NullUserPointer(), NullUserPointer(),
                          MOJO_WRITE_DATA_FLAG_NONE));
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             d->BeginWriteData(NullUserPointer(), NullUserPointer(),
                               MOJO_WRITE_DATA_FLAG_NONE));
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, d->EndWriteData(0));
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
+            d->SetDataPipeConsumerOptions(NullUserPointer()));
+  EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
+            d->GetDataPipeConsumerOptions(NullUserPointer(), 0));
+  EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             d->ReadData(NullUserPointer(), NullUserPointer(),
                         MOJO_READ_DATA_FLAG_NONE));
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             d->BeginReadData(NullUserPointer(), NullUserPointer(),
                              MOJO_READ_DATA_FLAG_NONE));
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, d->EndReadData(0));
   new_dispatcher = nullptr;
   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
             d->DuplicateBufferHandle(NullUserPointer(), &new_dispatcher));
   EXPECT_FALSE(new_dispatcher);
@@ skipping 14 matching lines @@
   EXPECT_EQ(0u, hss.satisfiable_signals);
 }
 
 enum class DispatcherOp {
   CLOSE = 0,
   WRITE_MESSAGE,
   READ_MESSAGE,
   WRITE_DATA,
   BEGIN_WRITE_DATA,
   END_WRITE_DATA,
+  SET_DATA_PIPE_CONSUMER_OPTIONS,
+  GET_DATA_PIPE_CONSUMER_OPTIONS,
   READ_DATA,
   BEGIN_READ_DATA,
   END_READ_DATA,
   DUPLICATE_BUFFER_HANDLE,
   GET_BUFFER_INFORMATION,
   MAP_BUFFER,
   ADD_AWAKABLE,
   REMOVE_AWAKABLE,
   COUNT
 };
@@ skipping 32 matching lines @@
                                       MOJO_WRITE_DATA_FLAG_NONE));
       break;
     case DispatcherOp::BEGIN_WRITE_DATA:
       EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
                 dispatcher->BeginWriteData(NullUserPointer(), NullUserPointer(),
                                            MOJO_WRITE_DATA_FLAG_NONE));
       break;
     case DispatcherOp::END_WRITE_DATA:
       EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, dispatcher->EndWriteData(0));
       break;
+    case DispatcherOp::SET_DATA_PIPE_CONSUMER_OPTIONS:
+      EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
+                dispatcher->SetDataPipeConsumerOptions(NullUserPointer()));
+      break;
+    case DispatcherOp::GET_DATA_PIPE_CONSUMER_OPTIONS:
+      EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
+                dispatcher->GetDataPipeConsumerOptions(NullUserPointer(), 0));
+      break;
     case DispatcherOp::READ_DATA:
       EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
                 dispatcher->ReadData(NullUserPointer(), NullUserPointer(),
                                      MOJO_READ_DATA_FLAG_NONE));
       break;
     case DispatcherOp::BEGIN_READ_DATA:
       EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT,
                 dispatcher->BeginReadData(NullUserPointer(), NullUserPointer(),
                                           MOJO_READ_DATA_FLAG_NONE));
       break;
@@ skipping 100 matching lines @@
     for (auto& thread : threads)
       thread.join();
 
     EXPECT_EQ(MOJO_RESULT_OK, d->Close());
   }
 }
 
 }  // namespace
 }  // namespace system
 }  // namespace mojo