Mojo: Move waiting APIs to public library

mojo/common/data_pipe_utils.cc

 // Copyright 2014 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/common/data_pipe_utils.h"
 
 #include <utility>
 
 #include "base/bind.h"
+#include "mojo/public/cpp/system/wait.h"
 
 namespace mojo {
 namespace common {
 namespace {
 
 bool BlockingCopyHelper(ScopedDataPipeConsumerHandle source,
     const base::Callback<size_t(const void*, uint32_t)>& write_bytes) {
   for (;;) {
     const void* buffer;
     uint32_t num_bytes;
     MojoResult result = BeginReadDataRaw(
         source.get(), &buffer, &num_bytes, MOJO_READ_DATA_FLAG_NONE);
     if (result == MOJO_RESULT_OK) {
       size_t bytes_written = write_bytes.Run(buffer, num_bytes);
       result = EndReadDataRaw(source.get(), num_bytes);
       if (bytes_written < num_bytes || result != MOJO_RESULT_OK)
         return false;
     } else if (result == MOJO_RESULT_SHOULD_WAIT) {
-      result = Wait(source.get(),
-                    MOJO_HANDLE_SIGNAL_READABLE,
-                    MOJO_DEADLINE_INDEFINITE,
-                    nullptr);
+      result = Wait(source.get(), MOJO_HANDLE_SIGNAL_READABLE);
       if (result != MOJO_RESULT_OK) {
         // If the producer handle was closed, then treat as EOF.
         return result == MOJO_RESULT_FAILED_PRECONDITION;
       }
     } else if (result == MOJO_RESULT_FAILED_PRECONDITION) {
       // If the producer handle was closed, then treat as EOF.
       return true;
     } else {
       // Some other error occurred.
       break;
@@ skipping 33 matching lines @@
     if (result == MOJO_RESULT_OK) {
       char* char_buffer = static_cast<char*>(buffer);
       uint32_t byte_index = 0;
       while (it != source.end() && byte_index < buffer_num_bytes) {
         char_buffer[byte_index++] = *it++;
       }
       EndWriteDataRaw(destination.get(), byte_index);
       if (it == source.end())
         return true;
     } else if (result == MOJO_RESULT_SHOULD_WAIT) {
-      result = Wait(destination.get(), MOJO_HANDLE_SIGNAL_WRITABLE,
-                    MOJO_DEADLINE_INDEFINITE, nullptr);
+      result = Wait(destination.get(), MOJO_HANDLE_SIGNAL_WRITABLE);
       if (result != MOJO_RESULT_OK) {
         // If the consumer handle was closed, then treat as EOF.
         return result == MOJO_RESULT_FAILED_PRECONDITION;
       }
     } else {
       // If the consumer handle was closed, then treat as EOF.
       return result == MOJO_RESULT_FAILED_PRECONDITION;
     }
   }
 }
 
 }  // namespace common
 }  // namespace mojo