| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "mojo/edk/embedder/embedder.h" | 5 #include "mojo/edk/embedder/embedder.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/command_line.h" | 8 #include "base/command_line.h" |
| 9 #include "base/logging.h" | 9 #include "base/logging.h" |
| 10 #include "base/message_loop/message_loop.h" | 10 #include "base/message_loop/message_loop.h" |
| (...skipping 114 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 125 | 125 |
| 126 char read_buffer[20000] = {}; | 126 char read_buffer[20000] = {}; |
| 127 uint32_t num_bytes = static_cast<uint32_t>(sizeof(read_buffer)); | 127 uint32_t num_bytes = static_cast<uint32_t>(sizeof(read_buffer)); |
| 128 MojoHandle ports[10]; | 128 MojoHandle ports[10]; |
| 129 uint32_t num_ports; | 129 uint32_t num_ports; |
| 130 EXPECT_EQ(MOJO_RESULT_OK, | 130 EXPECT_EQ(MOJO_RESULT_OK, |
| 131 MojoReadMessage(client_mp, read_buffer, &num_bytes, &ports[0], | 131 MojoReadMessage(client_mp, read_buffer, &num_bytes, &ports[0], |
| 132 &num_ports, MOJO_READ_MESSAGE_FLAG_NONE)); | 132 &num_ports, MOJO_READ_MESSAGE_FLAG_NONE)); |
| 133 EXPECT_EQ(write_size, num_bytes); | 133 EXPECT_EQ(write_size, num_bytes); |
| 134 EXPECT_STREQ(kHello, read_buffer); | 134 EXPECT_STREQ(kHello, read_buffer); |
| 135 EXPECT_EQ(1, num_ports); | 135 EXPECT_EQ(1u, num_ports); |
| 136 | 136 |
| 137 | 137 |
| 138 client_mp2 = ports[0]; | 138 client_mp2 = ports[0]; |
| 139 EXPECT_EQ(MOJO_RESULT_OK, MojoWait(client_mp2, MOJO_HANDLE_SIGNAL_READABLE, | 139 EXPECT_EQ(MOJO_RESULT_OK, MojoWait(client_mp2, MOJO_HANDLE_SIGNAL_READABLE, |
| 140 MOJO_DEADLINE_INDEFINITE, &state)); | 140 MOJO_DEADLINE_INDEFINITE, &state)); |
| 141 EXPECT_EQ(kSignalReadadableWritable, state.satisfied_signals); | 141 EXPECT_EQ(kSignalReadadableWritable, state.satisfied_signals); |
| 142 EXPECT_EQ(kSignalAll, state.satisfiable_signals); | 142 EXPECT_EQ(kSignalAll, state.satisfiable_signals); |
| 143 | 143 |
| 144 | 144 |
| 145 EXPECT_EQ(MOJO_RESULT_OK, | 145 EXPECT_EQ(MOJO_RESULT_OK, |
| 146 MojoReadMessage(client_mp2, read_buffer, &num_bytes, &client_mp3, | 146 MojoReadMessage(client_mp2, read_buffer, &num_bytes, &client_mp3, |
| 147 &num_ports, MOJO_READ_MESSAGE_FLAG_NONE)); | 147 &num_ports, MOJO_READ_MESSAGE_FLAG_NONE)); |
| 148 EXPECT_EQ(write_size, num_bytes); | 148 EXPECT_EQ(write_size, num_bytes); |
| 149 EXPECT_STREQ(kHello, read_buffer); | 149 EXPECT_STREQ(kHello, read_buffer); |
| 150 EXPECT_EQ(1, num_ports); | 150 EXPECT_EQ(1u, num_ports); |
| 151 | 151 |
| 152 | 152 |
| 153 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(server_mp3)); | 153 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(server_mp3)); |
| 154 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(client_mp3)); | 154 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(client_mp3)); |
| 155 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(server_mp2)); | 155 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(server_mp2)); |
| 156 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(client_mp2)); | 156 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(client_mp2)); |
| 157 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(server_mp)); | 157 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(server_mp)); |
| 158 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(client_mp)); | 158 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(client_mp)); |
| 159 } | 159 } |
| 160 | 160 |
| (...skipping 390 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 551 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(mp1)); | 551 EXPECT_EQ(MOJO_RESULT_OK, MojoClose(mp1)); |
| 552 } | 552 } |
| 553 } | 553 } |
| 554 | 554 |
| 555 // TODO(vtl): Test immediate write & close. | 555 // TODO(vtl): Test immediate write & close. |
| 556 // TODO(vtl): Test broken-connection cases. | 556 // TODO(vtl): Test broken-connection cases. |
| 557 | 557 |
| 558 } // namespace | 558 } // namespace |
| 559 } // namespace edk | 559 } // namespace edk |
| 560 } // namespace mojo | 560 } // namespace mojo |
| OLD | NEW |