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

mojo/edk/system/core.cc

Index: mojo/edk/system/core.cc
diff --git a/mojo/edk/system/core.cc b/mojo/edk/system/core.cc
index 28fd0ac8ec456aa3202ffbf1dd22136116dd9769..c0cdd3f3e1fc221e581e4d9b158f2d5969a9b30c 100644
--- a/mojo/edk/system/core.cc
+++ b/mojo/edk/system/core.cc
@@ -439,6 +439,29 @@ MojoResult Core::EndWriteData(MojoHandle data_pipe_producer_handle,
   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,