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

mojo/edk/system/core.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/core.h"
 
 #include <memory>
 #include <utility>
 #include <vector>
 
@@ skipping 421 matching lines @@
 MojoResult Core::EndWriteData(MojoHandle data_pipe_producer_handle,
                               uint32_t num_bytes_written) {
   RefPtr<Dispatcher> dispatcher;
   MojoResult result = GetDispatcher(data_pipe_producer_handle, &dispatcher);
   if (result != MOJO_RESULT_OK)
     return result;
 
   return dispatcher->EndWriteData(num_bytes_written);
 }
 
+MojoResult Core::SetDataPipeConsumerOptions(
+    MojoHandle data_pipe_consumer_handle,
+    UserPointer<const MojoDataPipeConsumerOptions> options) {
+  RefPtr<Dispatcher> dispatcher;
+  MojoResult result = GetDispatcher(data_pipe_consumer_handle, &dispatcher);
+  if (result != MOJO_RESULT_OK)
+    return result;
+
+  return dispatcher->SetDataPipeConsumerOptions(options);
+}
+
+MojoResult Core::GetDataPipeConsumerOptions(
+    MojoHandle data_pipe_consumer_handle,
+    UserPointer<MojoDataPipeConsumerOptions> options,
+    uint32_t options_num_bytes) {
+  RefPtr<Dispatcher> dispatcher;
+  MojoResult result = GetDispatcher(data_pipe_consumer_handle, &dispatcher);
+  if (result != MOJO_RESULT_OK)
+    return result;
+
+  return dispatcher->GetDataPipeConsumerOptions(options, options_num_bytes);
+}
+
 MojoResult Core::ReadData(MojoHandle data_pipe_consumer_handle,
                           UserPointer<void> elements,
                           UserPointer<uint32_t> num_bytes,
                           MojoReadDataFlags flags) {
   RefPtr<Dispatcher> dispatcher;
   MojoResult result = GetDispatcher(data_pipe_consumer_handle, &dispatcher);
   if (result != MOJO_RESULT_OK)
     return result;
 
   return dispatcher->ReadData(elements, num_bytes, flags);
@@ skipping 184 matching lines @@
   if (signals_states) {
     for (; i < num_handles; i++)
       signals_states[i] = dispatchers[i]->GetHandleSignalsState();
   }
 
   return result;
 }
 
 }  // namespace system
 }  // namespace mojo