Index: mojo/edk/system/multiprocess_message_pipe_unittest.cc |
diff --git a/mojo/edk/system/multiprocess_message_pipe_unittest.cc b/mojo/edk/system/multiprocess_message_pipe_unittest.cc |
index 3b521ccf8dfb442a5532e41e6df143363446d9ab..37248d1438ed9dc73dd92e86497bd62c0e68ee4f 100644 |
--- a/mojo/edk/system/multiprocess_message_pipe_unittest.cc |
+++ b/mojo/edk/system/multiprocess_message_pipe_unittest.cc |
@@ -32,6 +32,7 @@ |
#include "mojo/public/c/system/functions.h" |
#include "mojo/public/c/system/types.h" |
#include "mojo/public/cpp/system/simple_watcher.h" |
+#include "mojo/public/cpp/system/wait.h" |
#include "testing/gtest/include/gtest/gtest.h" |
@@ -777,16 +778,15 @@ DEFINE_TEST_CLIENT_WITH_PIPE(EchoServiceFactoryClient, |
MojoHandle p; |
ReadMessageWithHandles(h, &p, 1); |
- std::vector<MojoHandle> handles(2); |
- handles[0] = h; |
- handles[1] = p; |
+ std::vector<Handle> handles(2); |
+ handles[0] = Handle(h); |
+ handles[1] = Handle(p); |
std::vector<MojoHandleSignals> signals(2, MOJO_HANDLE_SIGNAL_READABLE); |
for (;;) { |
- uint32_t index; |
- CHECK_EQ(MojoWaitMany(handles.data(), signals.data(), |
- static_cast<uint32_t>(handles.size()), |
- MOJO_DEADLINE_INDEFINITE, &index, nullptr), |
- MOJO_RESULT_OK); |
+ size_t index; |
+ CHECK_EQ( |
+ mojo::WaitMany(handles.data(), signals.data(), handles.size(), &index), |
+ MOJO_RESULT_OK); |
DCHECK_LE(index, handles.size()); |
if (index == 0) { |
// If data is available on the first pipe, it should be an exit command. |
@@ -796,16 +796,16 @@ DEFINE_TEST_CLIENT_WITH_PIPE(EchoServiceFactoryClient, |
// If the second pipe, it should be a new handle requesting echo service. |
MojoHandle echo_request; |
ReadMessageWithHandles(p, &echo_request, 1); |
- handles.push_back(echo_request); |
+ handles.push_back(Handle(echo_request)); |
signals.push_back(MOJO_HANDLE_SIGNAL_READABLE); |
} else { |
// Otherwise it was one of our established echo pipes. Echo! |
- WriteMessage(handles[index], ReadMessage(handles[index])); |
+ WriteMessage(handles[index].value(), ReadMessage(handles[index].value())); |
} |
} |
for (size_t i = 1; i < handles.size(); ++i) |
- CloseHandle(handles[i]); |
+ CloseHandle(handles[i].value()); |
return 0; |
} |