| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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/system/core.h" | 5 #include "mojo/edk/system/core.h" |
| 6 | 6 |
| 7 #include <stdint.h> | 7 #include <stdint.h> |
| 8 | 8 |
| 9 #include <limits> | 9 #include <limits> |
| 10 | 10 |
| (...skipping 24 matching lines...) Expand all Loading... |
| 35 TEST_F(CoreTest, Basic) { | 35 TEST_F(CoreTest, Basic) { |
| 36 MockHandleInfo info; | 36 MockHandleInfo info; |
| 37 | 37 |
| 38 EXPECT_EQ(0u, info.GetCtorCallCount()); | 38 EXPECT_EQ(0u, info.GetCtorCallCount()); |
| 39 MojoHandle h = CreateMockHandle(&info); | 39 MojoHandle h = CreateMockHandle(&info); |
| 40 EXPECT_EQ(1u, info.GetCtorCallCount()); | 40 EXPECT_EQ(1u, info.GetCtorCallCount()); |
| 41 EXPECT_NE(h, MOJO_HANDLE_INVALID); | 41 EXPECT_NE(h, MOJO_HANDLE_INVALID); |
| 42 | 42 |
| 43 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); | 43 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); |
| 44 EXPECT_EQ(MOJO_RESULT_OK, | 44 EXPECT_EQ(MOJO_RESULT_OK, |
| 45 core()->WriteMessage(h, NullUserPointer(), 0, NullUserPointer(), 0, | 45 core()->WriteMessage(h, |
| 46 NullUserPointer(), |
| 47 0, |
| 48 NullUserPointer(), |
| 49 0, |
| 46 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 50 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 47 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); | 51 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); |
| 48 | 52 |
| 49 EXPECT_EQ(0u, info.GetReadMessageCallCount()); | 53 EXPECT_EQ(0u, info.GetReadMessageCallCount()); |
| 50 uint32_t num_bytes = 0; | 54 uint32_t num_bytes = 0; |
| 51 EXPECT_EQ( | 55 EXPECT_EQ(MOJO_RESULT_OK, |
| 52 MOJO_RESULT_OK, | 56 core()->ReadMessage(h, |
| 53 core()->ReadMessage(h, NullUserPointer(), MakeUserPointer(&num_bytes), | 57 NullUserPointer(), |
| 54 NullUserPointer(), NullUserPointer(), | 58 MakeUserPointer(&num_bytes), |
| 55 MOJO_READ_MESSAGE_FLAG_NONE)); | 59 NullUserPointer(), |
| 60 NullUserPointer(), |
| 61 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 56 EXPECT_EQ(1u, info.GetReadMessageCallCount()); | 62 EXPECT_EQ(1u, info.GetReadMessageCallCount()); |
| 57 EXPECT_EQ(MOJO_RESULT_OK, | 63 EXPECT_EQ(MOJO_RESULT_OK, |
| 58 core()->ReadMessage(h, NullUserPointer(), NullUserPointer(), | 64 core()->ReadMessage(h, |
| 59 NullUserPointer(), NullUserPointer(), | 65 NullUserPointer(), |
| 66 NullUserPointer(), |
| 67 NullUserPointer(), |
| 68 NullUserPointer(), |
| 60 MOJO_READ_MESSAGE_FLAG_NONE)); | 69 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 61 EXPECT_EQ(2u, info.GetReadMessageCallCount()); | 70 EXPECT_EQ(2u, info.GetReadMessageCallCount()); |
| 62 | 71 |
| 63 EXPECT_EQ(0u, info.GetWriteDataCallCount()); | 72 EXPECT_EQ(0u, info.GetWriteDataCallCount()); |
| 64 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, | 73 EXPECT_EQ( |
| 65 core()->WriteData(h, NullUserPointer(), NullUserPointer(), | 74 MOJO_RESULT_UNIMPLEMENTED, |
| 66 MOJO_WRITE_DATA_FLAG_NONE)); | 75 core()->WriteData( |
| 76 h, NullUserPointer(), NullUserPointer(), MOJO_WRITE_DATA_FLAG_NONE)); |
| 67 EXPECT_EQ(1u, info.GetWriteDataCallCount()); | 77 EXPECT_EQ(1u, info.GetWriteDataCallCount()); |
| 68 | 78 |
| 69 EXPECT_EQ(0u, info.GetBeginWriteDataCallCount()); | 79 EXPECT_EQ(0u, info.GetBeginWriteDataCallCount()); |
| 70 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, | 80 EXPECT_EQ( |
| 71 core()->BeginWriteData(h, NullUserPointer(), NullUserPointer(), | 81 MOJO_RESULT_UNIMPLEMENTED, |
| 72 MOJO_WRITE_DATA_FLAG_NONE)); | 82 core()->BeginWriteData( |
| 83 h, NullUserPointer(), NullUserPointer(), MOJO_WRITE_DATA_FLAG_NONE)); |
| 73 EXPECT_EQ(1u, info.GetBeginWriteDataCallCount()); | 84 EXPECT_EQ(1u, info.GetBeginWriteDataCallCount()); |
| 74 | 85 |
| 75 EXPECT_EQ(0u, info.GetEndWriteDataCallCount()); | 86 EXPECT_EQ(0u, info.GetEndWriteDataCallCount()); |
| 76 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, core()->EndWriteData(h, 0)); | 87 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, core()->EndWriteData(h, 0)); |
| 77 EXPECT_EQ(1u, info.GetEndWriteDataCallCount()); | 88 EXPECT_EQ(1u, info.GetEndWriteDataCallCount()); |
| 78 | 89 |
| 79 EXPECT_EQ(0u, info.GetReadDataCallCount()); | 90 EXPECT_EQ(0u, info.GetReadDataCallCount()); |
| 80 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, | 91 EXPECT_EQ( |
| 81 core()->ReadData(h, NullUserPointer(), NullUserPointer(), | 92 MOJO_RESULT_UNIMPLEMENTED, |
| 82 MOJO_READ_DATA_FLAG_NONE)); | 93 core()->ReadData( |
| 94 h, NullUserPointer(), NullUserPointer(), MOJO_READ_DATA_FLAG_NONE)); |
| 83 EXPECT_EQ(1u, info.GetReadDataCallCount()); | 95 EXPECT_EQ(1u, info.GetReadDataCallCount()); |
| 84 | 96 |
| 85 EXPECT_EQ(0u, info.GetBeginReadDataCallCount()); | 97 EXPECT_EQ(0u, info.GetBeginReadDataCallCount()); |
| 86 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, | 98 EXPECT_EQ( |
| 87 core()->BeginReadData(h, NullUserPointer(), NullUserPointer(), | 99 MOJO_RESULT_UNIMPLEMENTED, |
| 88 MOJO_READ_DATA_FLAG_NONE)); | 100 core()->BeginReadData( |
| 101 h, NullUserPointer(), NullUserPointer(), MOJO_READ_DATA_FLAG_NONE)); |
| 89 EXPECT_EQ(1u, info.GetBeginReadDataCallCount()); | 102 EXPECT_EQ(1u, info.GetBeginReadDataCallCount()); |
| 90 | 103 |
| 91 EXPECT_EQ(0u, info.GetEndReadDataCallCount()); | 104 EXPECT_EQ(0u, info.GetEndReadDataCallCount()); |
| 92 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, core()->EndReadData(h, 0)); | 105 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, core()->EndReadData(h, 0)); |
| 93 EXPECT_EQ(1u, info.GetEndReadDataCallCount()); | 106 EXPECT_EQ(1u, info.GetEndReadDataCallCount()); |
| 94 | 107 |
| 95 EXPECT_EQ(0u, info.GetAddWaiterCallCount()); | 108 EXPECT_EQ(0u, info.GetAddWaiterCallCount()); |
| 96 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 109 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
| 97 core()->Wait(h, ~MOJO_HANDLE_SIGNAL_NONE, MOJO_DEADLINE_INDEFINITE, | 110 core()->Wait(h, |
| 111 ~MOJO_HANDLE_SIGNAL_NONE, |
| 112 MOJO_DEADLINE_INDEFINITE, |
| 98 NullUserPointer())); | 113 NullUserPointer())); |
| 99 EXPECT_EQ(1u, info.GetAddWaiterCallCount()); | 114 EXPECT_EQ(1u, info.GetAddWaiterCallCount()); |
| 100 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 115 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
| 101 core()->Wait(h, ~MOJO_HANDLE_SIGNAL_NONE, 0, NullUserPointer())); | 116 core()->Wait(h, ~MOJO_HANDLE_SIGNAL_NONE, 0, NullUserPointer())); |
| 102 EXPECT_EQ(2u, info.GetAddWaiterCallCount()); | 117 EXPECT_EQ(2u, info.GetAddWaiterCallCount()); |
| 103 MojoHandleSignalsState hss = kFullMojoHandleSignalsState; | 118 MojoHandleSignalsState hss = kFullMojoHandleSignalsState; |
| 104 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 119 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
| 105 core()->Wait(h, ~MOJO_HANDLE_SIGNAL_NONE, MOJO_DEADLINE_INDEFINITE, | 120 core()->Wait(h, |
| 121 ~MOJO_HANDLE_SIGNAL_NONE, |
| 122 MOJO_DEADLINE_INDEFINITE, |
| 106 MakeUserPointer(&hss))); | 123 MakeUserPointer(&hss))); |
| 107 EXPECT_EQ(3u, info.GetAddWaiterCallCount()); | 124 EXPECT_EQ(3u, info.GetAddWaiterCallCount()); |
| 108 EXPECT_EQ(0u, hss.satisfied_signals); | 125 EXPECT_EQ(0u, hss.satisfied_signals); |
| 109 EXPECT_EQ(0u, hss.satisfiable_signals); | 126 EXPECT_EQ(0u, hss.satisfiable_signals); |
| 110 EXPECT_EQ( | 127 EXPECT_EQ( |
| 111 MOJO_RESULT_FAILED_PRECONDITION, | 128 MOJO_RESULT_FAILED_PRECONDITION, |
| 112 core()->Wait(h, ~MOJO_HANDLE_SIGNAL_NONE, 10 * 1000, NullUserPointer())); | 129 core()->Wait(h, ~MOJO_HANDLE_SIGNAL_NONE, 10 * 1000, NullUserPointer())); |
| 113 EXPECT_EQ(4u, info.GetAddWaiterCallCount()); | 130 EXPECT_EQ(4u, info.GetAddWaiterCallCount()); |
| 114 hss = kFullMojoHandleSignalsState; | 131 hss = kFullMojoHandleSignalsState; |
| 115 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 132 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
| 116 core()->Wait(h, ~MOJO_HANDLE_SIGNAL_NONE, 10 * 1000, | 133 core()->Wait( |
| 117 MakeUserPointer(&hss))); | 134 h, ~MOJO_HANDLE_SIGNAL_NONE, 10 * 1000, MakeUserPointer(&hss))); |
| 118 EXPECT_EQ(5u, info.GetAddWaiterCallCount()); | 135 EXPECT_EQ(5u, info.GetAddWaiterCallCount()); |
| 119 EXPECT_EQ(0u, hss.satisfied_signals); | 136 EXPECT_EQ(0u, hss.satisfied_signals); |
| 120 EXPECT_EQ(0u, hss.satisfiable_signals); | 137 EXPECT_EQ(0u, hss.satisfiable_signals); |
| 121 | 138 |
| 122 MojoHandleSignals handle_signals = ~MOJO_HANDLE_SIGNAL_NONE; | 139 MojoHandleSignals handle_signals = ~MOJO_HANDLE_SIGNAL_NONE; |
| 123 EXPECT_EQ( | 140 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
| 124 MOJO_RESULT_FAILED_PRECONDITION, | 141 core()->WaitMany(MakeUserPointer(&h), |
| 125 core()->WaitMany(MakeUserPointer(&h), MakeUserPointer(&handle_signals), 1, | 142 MakeUserPointer(&handle_signals), |
| 126 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), | 143 1, |
| 127 NullUserPointer())); | 144 MOJO_DEADLINE_INDEFINITE, |
| 145 NullUserPointer(), |
| 146 NullUserPointer())); |
| 128 EXPECT_EQ(6u, info.GetAddWaiterCallCount()); | 147 EXPECT_EQ(6u, info.GetAddWaiterCallCount()); |
| 129 uint32_t result_index = static_cast<uint32_t>(-1); | 148 uint32_t result_index = static_cast<uint32_t>(-1); |
| 130 EXPECT_EQ( | 149 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
| 131 MOJO_RESULT_FAILED_PRECONDITION, | 150 core()->WaitMany(MakeUserPointer(&h), |
| 132 core()->WaitMany(MakeUserPointer(&h), MakeUserPointer(&handle_signals), 1, | 151 MakeUserPointer(&handle_signals), |
| 133 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&result_index), | 152 1, |
| 134 NullUserPointer())); | 153 MOJO_DEADLINE_INDEFINITE, |
| 154 MakeUserPointer(&result_index), |
| 155 NullUserPointer())); |
| 135 EXPECT_EQ(7u, info.GetAddWaiterCallCount()); | 156 EXPECT_EQ(7u, info.GetAddWaiterCallCount()); |
| 136 EXPECT_EQ(0u, result_index); | 157 EXPECT_EQ(0u, result_index); |
| 137 hss = kFullMojoHandleSignalsState; | 158 hss = kFullMojoHandleSignalsState; |
| 138 EXPECT_EQ( | 159 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
| 139 MOJO_RESULT_FAILED_PRECONDITION, | 160 core()->WaitMany(MakeUserPointer(&h), |
| 140 core()->WaitMany(MakeUserPointer(&h), MakeUserPointer(&handle_signals), 1, | 161 MakeUserPointer(&handle_signals), |
| 141 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), | 162 1, |
| 142 MakeUserPointer(&hss))); | 163 MOJO_DEADLINE_INDEFINITE, |
| 164 NullUserPointer(), |
| 165 MakeUserPointer(&hss))); |
| 143 EXPECT_EQ(8u, info.GetAddWaiterCallCount()); | 166 EXPECT_EQ(8u, info.GetAddWaiterCallCount()); |
| 144 EXPECT_EQ(0u, hss.satisfied_signals); | 167 EXPECT_EQ(0u, hss.satisfied_signals); |
| 145 EXPECT_EQ(0u, hss.satisfiable_signals); | 168 EXPECT_EQ(0u, hss.satisfiable_signals); |
| 146 result_index = static_cast<uint32_t>(-1); | 169 result_index = static_cast<uint32_t>(-1); |
| 147 hss = kFullMojoHandleSignalsState; | 170 hss = kFullMojoHandleSignalsState; |
| 148 EXPECT_EQ( | 171 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
| 149 MOJO_RESULT_FAILED_PRECONDITION, | 172 core()->WaitMany(MakeUserPointer(&h), |
| 150 core()->WaitMany(MakeUserPointer(&h), MakeUserPointer(&handle_signals), 1, | 173 MakeUserPointer(&handle_signals), |
| 151 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&result_index), | 174 1, |
| 152 MakeUserPointer(&hss))); | 175 MOJO_DEADLINE_INDEFINITE, |
| 176 MakeUserPointer(&result_index), |
| 177 MakeUserPointer(&hss))); |
| 153 EXPECT_EQ(9u, info.GetAddWaiterCallCount()); | 178 EXPECT_EQ(9u, info.GetAddWaiterCallCount()); |
| 154 EXPECT_EQ(0u, result_index); | 179 EXPECT_EQ(0u, result_index); |
| 155 EXPECT_EQ(0u, hss.satisfied_signals); | 180 EXPECT_EQ(0u, hss.satisfied_signals); |
| 156 EXPECT_EQ(0u, hss.satisfiable_signals); | 181 EXPECT_EQ(0u, hss.satisfiable_signals); |
| 157 | 182 |
| 158 EXPECT_EQ(0u, info.GetDtorCallCount()); | 183 EXPECT_EQ(0u, info.GetDtorCallCount()); |
| 159 EXPECT_EQ(0u, info.GetCloseCallCount()); | 184 EXPECT_EQ(0u, info.GetCloseCallCount()); |
| 160 EXPECT_EQ(0u, info.GetCancelAllWaitersCallCount()); | 185 EXPECT_EQ(0u, info.GetCancelAllWaitersCallCount()); |
| 161 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); | 186 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); |
| 162 EXPECT_EQ(1u, info.GetCancelAllWaitersCallCount()); | 187 EXPECT_EQ(1u, info.GetCancelAllWaitersCallCount()); |
| (...skipping 16 matching lines...) Expand all Loading... |
| 179 MojoHandle h = CreateMockHandle(&info); | 204 MojoHandle h = CreateMockHandle(&info); |
| 180 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); | 205 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); |
| 181 EXPECT_EQ(1u, info.GetCloseCallCount()); | 206 EXPECT_EQ(1u, info.GetCloseCallCount()); |
| 182 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, core()->Close(h)); | 207 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, core()->Close(h)); |
| 183 EXPECT_EQ(1u, info.GetCloseCallCount()); | 208 EXPECT_EQ(1u, info.GetCloseCallCount()); |
| 184 } | 209 } |
| 185 | 210 |
| 186 // |Wait()|: | 211 // |Wait()|: |
| 187 { | 212 { |
| 188 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 213 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 189 core()->Wait(MOJO_HANDLE_INVALID, ~MOJO_HANDLE_SIGNAL_NONE, | 214 core()->Wait(MOJO_HANDLE_INVALID, |
| 190 MOJO_DEADLINE_INDEFINITE, NullUserPointer())); | 215 ~MOJO_HANDLE_SIGNAL_NONE, |
| 216 MOJO_DEADLINE_INDEFINITE, |
| 217 NullUserPointer())); |
| 191 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 218 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 192 core()->Wait(10, ~MOJO_HANDLE_SIGNAL_NONE, | 219 core()->Wait(10, |
| 193 MOJO_DEADLINE_INDEFINITE, NullUserPointer())); | 220 ~MOJO_HANDLE_SIGNAL_NONE, |
| 221 MOJO_DEADLINE_INDEFINITE, |
| 222 NullUserPointer())); |
| 194 | 223 |
| 195 MojoHandleSignalsState hss = kFullMojoHandleSignalsState; | 224 MojoHandleSignalsState hss = kFullMojoHandleSignalsState; |
| 196 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 225 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 197 core()->Wait(MOJO_HANDLE_INVALID, ~MOJO_HANDLE_SIGNAL_NONE, | 226 core()->Wait(MOJO_HANDLE_INVALID, |
| 198 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&hss))); | 227 ~MOJO_HANDLE_SIGNAL_NONE, |
| 228 MOJO_DEADLINE_INDEFINITE, |
| 229 MakeUserPointer(&hss))); |
| 199 // On invalid argument, it shouldn't modify the handle signals state. | 230 // On invalid argument, it shouldn't modify the handle signals state. |
| 200 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, | 231 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, |
| 201 hss.satisfied_signals); | 232 hss.satisfied_signals); |
| 202 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, | 233 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, |
| 203 hss.satisfiable_signals); | 234 hss.satisfiable_signals); |
| 204 hss = kFullMojoHandleSignalsState; | 235 hss = kFullMojoHandleSignalsState; |
| 205 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 236 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 206 core()->Wait(10, ~MOJO_HANDLE_SIGNAL_NONE, | 237 core()->Wait(10, |
| 207 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&hss))); | 238 ~MOJO_HANDLE_SIGNAL_NONE, |
| 239 MOJO_DEADLINE_INDEFINITE, |
| 240 MakeUserPointer(&hss))); |
| 208 // On invalid argument, it shouldn't modify the handle signals state. | 241 // On invalid argument, it shouldn't modify the handle signals state. |
| 209 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, | 242 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, |
| 210 hss.satisfied_signals); | 243 hss.satisfied_signals); |
| 211 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, | 244 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, |
| 212 hss.satisfiable_signals); | 245 hss.satisfiable_signals); |
| 213 } | 246 } |
| 214 | 247 |
| 215 // |WaitMany()|: | 248 // |WaitMany()|: |
| 216 { | 249 { |
| 217 MojoHandle handles[2] = {MOJO_HANDLE_INVALID, MOJO_HANDLE_INVALID}; | 250 MojoHandle handles[2] = {MOJO_HANDLE_INVALID, MOJO_HANDLE_INVALID}; |
| 218 MojoHandleSignals signals[2] = {~MOJO_HANDLE_SIGNAL_NONE, | 251 MojoHandleSignals signals[2] = {~MOJO_HANDLE_SIGNAL_NONE, |
| 219 ~MOJO_HANDLE_SIGNAL_NONE}; | 252 ~MOJO_HANDLE_SIGNAL_NONE}; |
| 220 EXPECT_EQ( | |
| 221 MOJO_RESULT_INVALID_ARGUMENT, | |
| 222 core()->WaitMany(MakeUserPointer(handles), MakeUserPointer(signals), 0, | |
| 223 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), | |
| 224 NullUserPointer())); | |
| 225 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 253 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 226 core()->WaitMany(NullUserPointer(), MakeUserPointer(signals), 0, | 254 core()->WaitMany(MakeUserPointer(handles), |
| 227 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), | 255 MakeUserPointer(signals), |
| 256 0, |
| 257 MOJO_DEADLINE_INDEFINITE, |
| 258 NullUserPointer(), |
| 259 NullUserPointer())); |
| 260 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 261 core()->WaitMany(NullUserPointer(), |
| 262 MakeUserPointer(signals), |
| 263 0, |
| 264 MOJO_DEADLINE_INDEFINITE, |
| 265 NullUserPointer(), |
| 228 NullUserPointer())); | 266 NullUserPointer())); |
| 229 // If |num_handles| is invalid, it should leave |result_index| and | 267 // If |num_handles| is invalid, it should leave |result_index| and |
| 230 // |signals_states| alone. | 268 // |signals_states| alone. |
| 231 // (We use -1 internally; make sure that doesn't leak.) | 269 // (We use -1 internally; make sure that doesn't leak.) |
| 232 uint32_t result_index = 123; | 270 uint32_t result_index = 123; |
| 233 MojoHandleSignalsState hss = kFullMojoHandleSignalsState; | 271 MojoHandleSignalsState hss = kFullMojoHandleSignalsState; |
| 234 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 272 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 235 core()->WaitMany(NullUserPointer(), MakeUserPointer(signals), 0, | 273 core()->WaitMany(NullUserPointer(), |
| 274 MakeUserPointer(signals), |
| 275 0, |
| 236 MOJO_DEADLINE_INDEFINITE, | 276 MOJO_DEADLINE_INDEFINITE, |
| 237 MakeUserPointer(&result_index), | 277 MakeUserPointer(&result_index), |
| 238 MakeUserPointer(&hss))); | 278 MakeUserPointer(&hss))); |
| 239 EXPECT_EQ(123u, result_index); | 279 EXPECT_EQ(123u, result_index); |
| 240 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, | 280 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, |
| 241 hss.satisfied_signals); | 281 hss.satisfied_signals); |
| 242 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, | 282 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, |
| 243 hss.satisfiable_signals); | 283 hss.satisfiable_signals); |
| 244 | 284 |
| 245 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 285 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 246 core()->WaitMany(MakeUserPointer(handles), NullUserPointer(), 0, | 286 core()->WaitMany(MakeUserPointer(handles), |
| 247 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), | 287 NullUserPointer(), |
| 288 0, |
| 289 MOJO_DEADLINE_INDEFINITE, |
| 290 NullUserPointer(), |
| 248 NullUserPointer())); | 291 NullUserPointer())); |
| 249 EXPECT_EQ( | 292 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 250 MOJO_RESULT_INVALID_ARGUMENT, | 293 core()->WaitMany(MakeUserPointer(handles), |
| 251 core()->WaitMany(MakeUserPointer(handles), MakeUserPointer(signals), 1, | 294 MakeUserPointer(signals), |
| 252 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), | 295 1, |
| 253 NullUserPointer())); | 296 MOJO_DEADLINE_INDEFINITE, |
| 297 NullUserPointer(), |
| 298 NullUserPointer())); |
| 254 // But if a handle is bad, then it should set |result_index| but still leave | 299 // But if a handle is bad, then it should set |result_index| but still leave |
| 255 // |signals_states| alone. | 300 // |signals_states| alone. |
| 256 result_index = static_cast<uint32_t>(-1); | 301 result_index = static_cast<uint32_t>(-1); |
| 257 hss = kFullMojoHandleSignalsState; | 302 hss = kFullMojoHandleSignalsState; |
| 258 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 303 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 259 core()->WaitMany( | 304 core()->WaitMany(MakeUserPointer(handles), |
| 260 MakeUserPointer(handles), MakeUserPointer(signals), 1, | 305 MakeUserPointer(signals), |
| 261 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&result_index), | 306 1, |
| 262 MakeUserPointer(&hss))); | 307 MOJO_DEADLINE_INDEFINITE, |
| 308 MakeUserPointer(&result_index), |
| 309 MakeUserPointer(&hss))); |
| 263 EXPECT_EQ(0u, result_index); | 310 EXPECT_EQ(0u, result_index); |
| 264 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, | 311 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, |
| 265 hss.satisfied_signals); | 312 hss.satisfied_signals); |
| 266 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, | 313 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, |
| 267 hss.satisfiable_signals); | 314 hss.satisfiable_signals); |
| 268 | 315 |
| 269 MockHandleInfo info[2]; | 316 MockHandleInfo info[2]; |
| 270 handles[0] = CreateMockHandle(&info[0]); | 317 handles[0] = CreateMockHandle(&info[0]); |
| 271 | 318 |
| 272 result_index = static_cast<uint32_t>(-1); | 319 result_index = static_cast<uint32_t>(-1); |
| 273 hss = kFullMojoHandleSignalsState; | 320 hss = kFullMojoHandleSignalsState; |
| 274 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 321 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
| 275 core()->WaitMany( | 322 core()->WaitMany(MakeUserPointer(handles), |
| 276 MakeUserPointer(handles), MakeUserPointer(signals), 1, | 323 MakeUserPointer(signals), |
| 277 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&result_index), | 324 1, |
| 278 MakeUserPointer(&hss))); | 325 MOJO_DEADLINE_INDEFINITE, |
| 326 MakeUserPointer(&result_index), |
| 327 MakeUserPointer(&hss))); |
| 279 EXPECT_EQ(0u, result_index); | 328 EXPECT_EQ(0u, result_index); |
| 280 EXPECT_EQ(0u, hss.satisfied_signals); | 329 EXPECT_EQ(0u, hss.satisfied_signals); |
| 281 EXPECT_EQ(0u, hss.satisfiable_signals); | 330 EXPECT_EQ(0u, hss.satisfiable_signals); |
| 282 | 331 |
| 283 // On invalid argument, it'll leave |signals_states| alone. | 332 // On invalid argument, it'll leave |signals_states| alone. |
| 284 result_index = static_cast<uint32_t>(-1); | 333 result_index = static_cast<uint32_t>(-1); |
| 285 hss = kFullMojoHandleSignalsState; | 334 hss = kFullMojoHandleSignalsState; |
| 286 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 335 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 287 core()->WaitMany( | 336 core()->WaitMany(MakeUserPointer(handles), |
| 288 MakeUserPointer(handles), MakeUserPointer(signals), 2, | 337 MakeUserPointer(signals), |
| 289 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&result_index), | 338 2, |
| 290 MakeUserPointer(&hss))); | 339 MOJO_DEADLINE_INDEFINITE, |
| 340 MakeUserPointer(&result_index), |
| 341 MakeUserPointer(&hss))); |
| 291 EXPECT_EQ(1u, result_index); | 342 EXPECT_EQ(1u, result_index); |
| 292 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, | 343 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, |
| 293 hss.satisfied_signals); | 344 hss.satisfied_signals); |
| 294 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, | 345 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, |
| 295 hss.satisfiable_signals); | 346 hss.satisfiable_signals); |
| 296 handles[1] = handles[0] + 1; // Invalid handle. | 347 handles[1] = handles[0] + 1; // Invalid handle. |
| 297 EXPECT_EQ( | 348 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 298 MOJO_RESULT_INVALID_ARGUMENT, | 349 core()->WaitMany(MakeUserPointer(handles), |
| 299 core()->WaitMany(MakeUserPointer(handles), MakeUserPointer(signals), 2, | 350 MakeUserPointer(signals), |
| 300 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), | 351 2, |
| 301 NullUserPointer())); | 352 MOJO_DEADLINE_INDEFINITE, |
| 353 NullUserPointer(), |
| 354 NullUserPointer())); |
| 302 handles[1] = CreateMockHandle(&info[1]); | 355 handles[1] = CreateMockHandle(&info[1]); |
| 303 EXPECT_EQ( | 356 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
| 304 MOJO_RESULT_FAILED_PRECONDITION, | 357 core()->WaitMany(MakeUserPointer(handles), |
| 305 core()->WaitMany(MakeUserPointer(handles), MakeUserPointer(signals), 2, | 358 MakeUserPointer(signals), |
| 306 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), | 359 2, |
| 307 NullUserPointer())); | 360 MOJO_DEADLINE_INDEFINITE, |
| 361 NullUserPointer(), |
| 362 NullUserPointer())); |
| 308 | 363 |
| 309 // TODO(vtl): Test one where we get "failed precondition" only for the | 364 // TODO(vtl): Test one where we get "failed precondition" only for the |
| 310 // second handle (and the first one is valid to wait on). | 365 // second handle (and the first one is valid to wait on). |
| 311 | 366 |
| 312 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(handles[0])); | 367 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(handles[0])); |
| 313 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(handles[1])); | 368 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(handles[1])); |
| 314 } | 369 } |
| 315 | 370 |
| 316 // |CreateMessagePipe()|: Nothing to check (apart from things that cause | 371 // |CreateMessagePipe()|: Nothing to check (apart from things that cause |
| 317 // death). | 372 // death). |
| 318 | 373 |
| 319 // |WriteMessage()|: | 374 // |WriteMessage()|: |
| 320 // Only check arguments checked by |Core|, namely |handle|, |handles|, and | 375 // Only check arguments checked by |Core|, namely |handle|, |handles|, and |
| 321 // |num_handles|. | 376 // |num_handles|. |
| 322 { | 377 { |
| 323 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 378 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 324 core()->WriteMessage(MOJO_HANDLE_INVALID, NullUserPointer(), 0, | 379 core()->WriteMessage(MOJO_HANDLE_INVALID, |
| 325 NullUserPointer(), 0, | 380 NullUserPointer(), |
| 381 0, |
| 382 NullUserPointer(), |
| 383 0, |
| 326 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 384 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 327 | 385 |
| 328 MockHandleInfo info; | 386 MockHandleInfo info; |
| 329 MojoHandle h = CreateMockHandle(&info); | 387 MojoHandle h = CreateMockHandle(&info); |
| 330 MojoHandle handles[2] = {MOJO_HANDLE_INVALID, MOJO_HANDLE_INVALID}; | 388 MojoHandle handles[2] = {MOJO_HANDLE_INVALID, MOJO_HANDLE_INVALID}; |
| 331 | 389 |
| 332 // Huge handle count (implausibly big on some systems -- more than can be | 390 // Huge handle count (implausibly big on some systems -- more than can be |
| 333 // stored in a 32-bit address space). | 391 // stored in a 32-bit address space). |
| 334 // Note: This may return either |MOJO_RESULT_INVALID_ARGUMENT| or | 392 // Note: This may return either |MOJO_RESULT_INVALID_ARGUMENT| or |
| 335 // |MOJO_RESULT_RESOURCE_EXHAUSTED|, depending on whether it's plausible or | 393 // |MOJO_RESULT_RESOURCE_EXHAUSTED|, depending on whether it's plausible or |
| 336 // not. | 394 // not. |
| 337 EXPECT_NE( | 395 EXPECT_NE(MOJO_RESULT_OK, |
| 338 MOJO_RESULT_OK, | 396 core()->WriteMessage(h, |
| 339 core()->WriteMessage(h, NullUserPointer(), 0, MakeUserPointer(handles), | 397 NullUserPointer(), |
| 340 std::numeric_limits<uint32_t>::max(), | 398 0, |
| 341 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 399 MakeUserPointer(handles), |
| 400 std::numeric_limits<uint32_t>::max(), |
| 401 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 342 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); | 402 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); |
| 343 | 403 |
| 344 // Huge handle count (plausibly big). | 404 // Huge handle count (plausibly big). |
| 345 EXPECT_EQ(MOJO_RESULT_RESOURCE_EXHAUSTED, | 405 EXPECT_EQ(MOJO_RESULT_RESOURCE_EXHAUSTED, |
| 346 core()->WriteMessage( | 406 core()->WriteMessage( |
| 347 h, NullUserPointer(), 0, MakeUserPointer(handles), | 407 h, |
| 408 NullUserPointer(), |
| 409 0, |
| 410 MakeUserPointer(handles), |
| 348 std::numeric_limits<uint32_t>::max() / sizeof(handles[0]), | 411 std::numeric_limits<uint32_t>::max() / sizeof(handles[0]), |
| 349 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 412 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 350 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); | 413 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); |
| 351 | 414 |
| 352 // Invalid handle in |handles|. | 415 // Invalid handle in |handles|. |
| 353 EXPECT_EQ( | 416 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 354 MOJO_RESULT_INVALID_ARGUMENT, | 417 core()->WriteMessage(h, |
| 355 core()->WriteMessage(h, NullUserPointer(), 0, MakeUserPointer(handles), | 418 NullUserPointer(), |
| 356 1, MOJO_WRITE_MESSAGE_FLAG_NONE)); | 419 0, |
| 420 MakeUserPointer(handles), |
| 421 1, |
| 422 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 357 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); | 423 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); |
| 358 | 424 |
| 359 // Two invalid handles in |handles|. | 425 // Two invalid handles in |handles|. |
| 360 EXPECT_EQ( | 426 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 361 MOJO_RESULT_INVALID_ARGUMENT, | 427 core()->WriteMessage(h, |
| 362 core()->WriteMessage(h, NullUserPointer(), 0, MakeUserPointer(handles), | 428 NullUserPointer(), |
| 363 2, MOJO_WRITE_MESSAGE_FLAG_NONE)); | 429 0, |
| 430 MakeUserPointer(handles), |
| 431 2, |
| 432 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 364 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); | 433 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); |
| 365 | 434 |
| 366 // Can't send a handle over itself. | 435 // Can't send a handle over itself. |
| 367 handles[0] = h; | 436 handles[0] = h; |
| 368 EXPECT_EQ( | 437 EXPECT_EQ(MOJO_RESULT_BUSY, |
| 369 MOJO_RESULT_BUSY, | 438 core()->WriteMessage(h, |
| 370 core()->WriteMessage(h, NullUserPointer(), 0, MakeUserPointer(handles), | 439 NullUserPointer(), |
| 371 1, MOJO_WRITE_MESSAGE_FLAG_NONE)); | 440 0, |
| 441 MakeUserPointer(handles), |
| 442 1, |
| 443 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 372 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); | 444 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); |
| 373 | 445 |
| 374 MockHandleInfo info2; | 446 MockHandleInfo info2; |
| 375 MojoHandle h2 = CreateMockHandle(&info2); | 447 MojoHandle h2 = CreateMockHandle(&info2); |
| 376 | 448 |
| 377 // This is "okay", but |MockDispatcher| doesn't implement it. | 449 // This is "okay", but |MockDispatcher| doesn't implement it. |
| 378 handles[0] = h2; | 450 handles[0] = h2; |
| 379 EXPECT_EQ( | 451 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, |
| 380 MOJO_RESULT_UNIMPLEMENTED, | 452 core()->WriteMessage(h, |
| 381 core()->WriteMessage(h, NullUserPointer(), 0, MakeUserPointer(handles), | 453 NullUserPointer(), |
| 382 1, MOJO_WRITE_MESSAGE_FLAG_NONE)); | 454 0, |
| 455 MakeUserPointer(handles), |
| 456 1, |
| 457 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 383 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); | 458 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); |
| 384 | 459 |
| 385 // One of the |handles| is still invalid. | 460 // One of the |handles| is still invalid. |
| 386 EXPECT_EQ( | 461 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 387 MOJO_RESULT_INVALID_ARGUMENT, | 462 core()->WriteMessage(h, |
| 388 core()->WriteMessage(h, NullUserPointer(), 0, MakeUserPointer(handles), | 463 NullUserPointer(), |
| 389 2, MOJO_WRITE_MESSAGE_FLAG_NONE)); | 464 0, |
| 465 MakeUserPointer(handles), |
| 466 2, |
| 467 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 390 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); | 468 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); |
| 391 | 469 |
| 392 // One of the |handles| is the same as |handle|. | 470 // One of the |handles| is the same as |handle|. |
| 393 handles[1] = h; | 471 handles[1] = h; |
| 394 EXPECT_EQ( | 472 EXPECT_EQ(MOJO_RESULT_BUSY, |
| 395 MOJO_RESULT_BUSY, | 473 core()->WriteMessage(h, |
| 396 core()->WriteMessage(h, NullUserPointer(), 0, MakeUserPointer(handles), | 474 NullUserPointer(), |
| 397 2, MOJO_WRITE_MESSAGE_FLAG_NONE)); | 475 0, |
| 476 MakeUserPointer(handles), |
| 477 2, |
| 478 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 398 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); | 479 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); |
| 399 | 480 |
| 400 // Can't send a handle twice in the same message. | 481 // Can't send a handle twice in the same message. |
| 401 handles[1] = h2; | 482 handles[1] = h2; |
| 402 EXPECT_EQ( | 483 EXPECT_EQ(MOJO_RESULT_BUSY, |
| 403 MOJO_RESULT_BUSY, | 484 core()->WriteMessage(h, |
| 404 core()->WriteMessage(h, NullUserPointer(), 0, MakeUserPointer(handles), | 485 NullUserPointer(), |
| 405 2, MOJO_WRITE_MESSAGE_FLAG_NONE)); | 486 0, |
| 487 MakeUserPointer(handles), |
| 488 2, |
| 489 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 406 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); | 490 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); |
| 407 | 491 |
| 408 // Note: Since we never successfully sent anything with it, |h2| should | 492 // Note: Since we never successfully sent anything with it, |h2| should |
| 409 // still be valid. | 493 // still be valid. |
| 410 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h2)); | 494 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h2)); |
| 411 | 495 |
| 412 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); | 496 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); |
| 413 } | 497 } |
| 414 | 498 |
| 415 // |ReadMessage()|: | 499 // |ReadMessage()|: |
| 416 // Only check arguments checked by |Core|, namely |handle|, |handles|, and | 500 // Only check arguments checked by |Core|, namely |handle|, |handles|, and |
| 417 // |num_handles|. | 501 // |num_handles|. |
| 418 { | 502 { |
| 419 EXPECT_EQ( | 503 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 420 MOJO_RESULT_INVALID_ARGUMENT, | 504 core()->ReadMessage(MOJO_HANDLE_INVALID, |
| 421 core()->ReadMessage(MOJO_HANDLE_INVALID, NullUserPointer(), | 505 NullUserPointer(), |
| 422 NullUserPointer(), NullUserPointer(), | 506 NullUserPointer(), |
| 423 NullUserPointer(), MOJO_READ_MESSAGE_FLAG_NONE)); | 507 NullUserPointer(), |
| 508 NullUserPointer(), |
| 509 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 424 | 510 |
| 425 MockHandleInfo info; | 511 MockHandleInfo info; |
| 426 MojoHandle h = CreateMockHandle(&info); | 512 MojoHandle h = CreateMockHandle(&info); |
| 427 | 513 |
| 428 // Okay. | 514 // Okay. |
| 429 uint32_t handle_count = 0; | 515 uint32_t handle_count = 0; |
| 430 EXPECT_EQ(MOJO_RESULT_OK, | 516 EXPECT_EQ(MOJO_RESULT_OK, |
| 431 core()->ReadMessage( | 517 core()->ReadMessage(h, |
| 432 h, NullUserPointer(), NullUserPointer(), NullUserPointer(), | 518 NullUserPointer(), |
| 433 MakeUserPointer(&handle_count), MOJO_READ_MESSAGE_FLAG_NONE)); | 519 NullUserPointer(), |
| 520 NullUserPointer(), |
| 521 MakeUserPointer(&handle_count), |
| 522 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 434 // Checked by |Core|, shouldn't go through to the dispatcher. | 523 // Checked by |Core|, shouldn't go through to the dispatcher. |
| 435 EXPECT_EQ(1u, info.GetReadMessageCallCount()); | 524 EXPECT_EQ(1u, info.GetReadMessageCallCount()); |
| 436 | 525 |
| 437 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); | 526 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); |
| 438 } | 527 } |
| 439 } | 528 } |
| 440 | 529 |
| 441 // These test invalid arguments that should cause death if we're being paranoid | 530 // These test invalid arguments that should cause death if we're being paranoid |
| 442 // about checking arguments (which we would want to do if, e.g., we were in a | 531 // about checking arguments (which we would want to do if, e.g., we were in a |
| 443 // true "kernel" situation, but we might not want to do otherwise for | 532 // true "kernel" situation, but we might not want to do otherwise for |
| 444 // performance reasons). Probably blatant errors like passing in null pointers | 533 // performance reasons). Probably blatant errors like passing in null pointers |
| 445 // (for required pointer arguments) will still cause death, but perhaps not | 534 // (for required pointer arguments) will still cause death, but perhaps not |
| 446 // predictably. | 535 // predictably. |
| 447 TEST_F(CoreTest, InvalidArgumentsDeath) { | 536 TEST_F(CoreTest, InvalidArgumentsDeath) { |
| 448 const char kMemoryCheckFailedRegex[] = "Check failed"; | 537 const char kMemoryCheckFailedRegex[] = "Check failed"; |
| 449 | 538 |
| 450 // |WaitMany()|: | 539 // |WaitMany()|: |
| 451 { | 540 { |
| 452 MojoHandle handle = MOJO_HANDLE_INVALID; | 541 MojoHandle handle = MOJO_HANDLE_INVALID; |
| 453 MojoHandleSignals signals = ~MOJO_HANDLE_SIGNAL_NONE; | 542 MojoHandleSignals signals = ~MOJO_HANDLE_SIGNAL_NONE; |
| 454 EXPECT_DEATH_IF_SUPPORTED( | 543 EXPECT_DEATH_IF_SUPPORTED(core()->WaitMany(NullUserPointer(), |
| 455 core()->WaitMany(NullUserPointer(), MakeUserPointer(&signals), 1, | 544 MakeUserPointer(&signals), |
| 456 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), | 545 1, |
| 457 NullUserPointer()), | 546 MOJO_DEADLINE_INDEFINITE, |
| 458 kMemoryCheckFailedRegex); | 547 NullUserPointer(), |
| 459 EXPECT_DEATH_IF_SUPPORTED( | 548 NullUserPointer()), |
| 460 core()->WaitMany(MakeUserPointer(&handle), NullUserPointer(), 1, | 549 kMemoryCheckFailedRegex); |
| 461 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), | 550 EXPECT_DEATH_IF_SUPPORTED(core()->WaitMany(MakeUserPointer(&handle), |
| 462 NullUserPointer()), | 551 NullUserPointer(), |
| 463 kMemoryCheckFailedRegex); | 552 1, |
| 553 MOJO_DEADLINE_INDEFINITE, |
| 554 NullUserPointer(), |
| 555 NullUserPointer()), |
| 556 kMemoryCheckFailedRegex); |
| 464 // TODO(vtl): |result_index| and |signals_states| are optional. Test them | 557 // TODO(vtl): |result_index| and |signals_states| are optional. Test them |
| 465 // with non-null invalid pointers? | 558 // with non-null invalid pointers? |
| 466 } | 559 } |
| 467 | 560 |
| 468 // |CreateMessagePipe()|: | 561 // |CreateMessagePipe()|: |
| 469 { | 562 { |
| 470 MojoHandle h; | 563 MojoHandle h; |
| 471 EXPECT_DEATH_IF_SUPPORTED( | 564 EXPECT_DEATH_IF_SUPPORTED( |
| 472 core()->CreateMessagePipe(NullUserPointer(), NullUserPointer(), | 565 core()->CreateMessagePipe( |
| 473 NullUserPointer()), | 566 NullUserPointer(), NullUserPointer(), NullUserPointer()), |
| 474 kMemoryCheckFailedRegex); | 567 kMemoryCheckFailedRegex); |
| 475 EXPECT_DEATH_IF_SUPPORTED( | 568 EXPECT_DEATH_IF_SUPPORTED( |
| 476 core()->CreateMessagePipe(NullUserPointer(), MakeUserPointer(&h), | 569 core()->CreateMessagePipe( |
| 477 NullUserPointer()), | 570 NullUserPointer(), MakeUserPointer(&h), NullUserPointer()), |
| 478 kMemoryCheckFailedRegex); | 571 kMemoryCheckFailedRegex); |
| 479 EXPECT_DEATH_IF_SUPPORTED( | 572 EXPECT_DEATH_IF_SUPPORTED( |
| 480 core()->CreateMessagePipe(NullUserPointer(), NullUserPointer(), | 573 core()->CreateMessagePipe( |
| 481 MakeUserPointer(&h)), | 574 NullUserPointer(), NullUserPointer(), MakeUserPointer(&h)), |
| 482 kMemoryCheckFailedRegex); | 575 kMemoryCheckFailedRegex); |
| 483 } | 576 } |
| 484 | 577 |
| 485 // |WriteMessage()|: | 578 // |WriteMessage()|: |
| 486 // Only check arguments checked by |Core|, namely |handle|, |handles|, and | 579 // Only check arguments checked by |Core|, namely |handle|, |handles|, and |
| 487 // |num_handles|. | 580 // |num_handles|. |
| 488 { | 581 { |
| 489 MockHandleInfo info; | 582 MockHandleInfo info; |
| 490 MojoHandle h = CreateMockHandle(&info); | 583 MojoHandle h = CreateMockHandle(&info); |
| 491 | 584 |
| 492 // Null |handles| with nonzero |num_handles|. | 585 // Null |handles| with nonzero |num_handles|. |
| 493 EXPECT_DEATH_IF_SUPPORTED( | 586 EXPECT_DEATH_IF_SUPPORTED( |
| 494 core()->WriteMessage(h, NullUserPointer(), 0, NullUserPointer(), 1, | 587 core()->WriteMessage(h, |
| 588 NullUserPointer(), |
| 589 0, |
| 590 NullUserPointer(), |
| 591 1, |
| 495 MOJO_WRITE_MESSAGE_FLAG_NONE), | 592 MOJO_WRITE_MESSAGE_FLAG_NONE), |
| 496 kMemoryCheckFailedRegex); | 593 kMemoryCheckFailedRegex); |
| 497 | 594 |
| 498 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); | 595 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); |
| 499 } | 596 } |
| 500 | 597 |
| 501 // |ReadMessage()|: | 598 // |ReadMessage()|: |
| 502 // Only check arguments checked by |Core|, namely |handle|, |handles|, and | 599 // Only check arguments checked by |Core|, namely |handle|, |handles|, and |
| 503 // |num_handles|. | 600 // |num_handles|. |
| 504 { | 601 { |
| 505 MockHandleInfo info; | 602 MockHandleInfo info; |
| 506 MojoHandle h = CreateMockHandle(&info); | 603 MojoHandle h = CreateMockHandle(&info); |
| 507 | 604 |
| 508 uint32_t handle_count = 1; | 605 uint32_t handle_count = 1; |
| 509 EXPECT_DEATH_IF_SUPPORTED( | 606 EXPECT_DEATH_IF_SUPPORTED( |
| 510 core()->ReadMessage(h, NullUserPointer(), NullUserPointer(), | 607 core()->ReadMessage(h, |
| 511 NullUserPointer(), MakeUserPointer(&handle_count), | 608 NullUserPointer(), |
| 609 NullUserPointer(), |
| 610 NullUserPointer(), |
| 611 MakeUserPointer(&handle_count), |
| 512 MOJO_READ_MESSAGE_FLAG_NONE), | 612 MOJO_READ_MESSAGE_FLAG_NONE), |
| 513 kMemoryCheckFailedRegex); | 613 kMemoryCheckFailedRegex); |
| 514 | 614 |
| 515 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); | 615 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); |
| 516 } | 616 } |
| 517 } | 617 } |
| 518 | 618 |
| 519 // TODO(vtl): test |Wait()| and |WaitMany()| properly | 619 // TODO(vtl): test |Wait()| and |WaitMany()| properly |
| 520 // - including |WaitMany()| with the same handle more than once (with | 620 // - including |WaitMany()| with the same handle more than once (with |
| 521 // same/different signals) | 621 // same/different signals) |
| 522 | 622 |
| 523 TEST_F(CoreTest, MessagePipe) { | 623 TEST_F(CoreTest, MessagePipe) { |
| 524 MojoHandle h[2]; | 624 MojoHandle h[2]; |
| 525 MojoHandleSignalsState hss[2]; | 625 MojoHandleSignalsState hss[2]; |
| 526 uint32_t result_index; | 626 uint32_t result_index; |
| 527 | 627 |
| 528 EXPECT_EQ(MOJO_RESULT_OK, | 628 EXPECT_EQ( |
| 529 core()->CreateMessagePipe(NullUserPointer(), MakeUserPointer(&h[0]), | 629 MOJO_RESULT_OK, |
| 530 MakeUserPointer(&h[1]))); | 630 core()->CreateMessagePipe( |
| 631 NullUserPointer(), MakeUserPointer(&h[0]), MakeUserPointer(&h[1]))); |
| 531 // Should get two distinct, valid handles. | 632 // Should get two distinct, valid handles. |
| 532 EXPECT_NE(h[0], MOJO_HANDLE_INVALID); | 633 EXPECT_NE(h[0], MOJO_HANDLE_INVALID); |
| 533 EXPECT_NE(h[1], MOJO_HANDLE_INVALID); | 634 EXPECT_NE(h[1], MOJO_HANDLE_INVALID); |
| 534 EXPECT_NE(h[0], h[1]); | 635 EXPECT_NE(h[0], h[1]); |
| 535 | 636 |
| 536 // Neither should be readable. | 637 // Neither should be readable. |
| 537 MojoHandleSignals signals[2] = {MOJO_HANDLE_SIGNAL_READABLE, | 638 MojoHandleSignals signals[2] = {MOJO_HANDLE_SIGNAL_READABLE, |
| 538 MOJO_HANDLE_SIGNAL_READABLE}; | 639 MOJO_HANDLE_SIGNAL_READABLE}; |
| 539 result_index = static_cast<uint32_t>(-1); | 640 result_index = static_cast<uint32_t>(-1); |
| 540 hss[0] = kEmptyMojoHandleSignalsState; | 641 hss[0] = kEmptyMojoHandleSignalsState; |
| 541 hss[1] = kEmptyMojoHandleSignalsState; | 642 hss[1] = kEmptyMojoHandleSignalsState; |
| 542 EXPECT_EQ( | 643 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, |
| 543 MOJO_RESULT_DEADLINE_EXCEEDED, | 644 core()->WaitMany(MakeUserPointer(h), |
| 544 core()->WaitMany(MakeUserPointer(h), MakeUserPointer(signals), 2, 0, | 645 MakeUserPointer(signals), |
| 545 MakeUserPointer(&result_index), MakeUserPointer(hss))); | 646 2, |
| 647 0, |
| 648 MakeUserPointer(&result_index), |
| 649 MakeUserPointer(hss))); |
| 546 EXPECT_EQ(static_cast<uint32_t>(-1), result_index); | 650 EXPECT_EQ(static_cast<uint32_t>(-1), result_index); |
| 547 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); | 651 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); |
| 548 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 652 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 549 hss[0].satisfiable_signals); | 653 hss[0].satisfiable_signals); |
| 550 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[1].satisfied_signals); | 654 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[1].satisfied_signals); |
| 551 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 655 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 552 hss[1].satisfiable_signals); | 656 hss[1].satisfiable_signals); |
| 553 | 657 |
| 554 // Try to read anyway. | 658 // Try to read anyway. |
| 555 char buffer[1] = {'a'}; | 659 char buffer[1] = {'a'}; |
| 556 uint32_t buffer_size = 1; | 660 uint32_t buffer_size = 1; |
| 557 EXPECT_EQ( | 661 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT, |
| 558 MOJO_RESULT_SHOULD_WAIT, | 662 core()->ReadMessage(h[0], |
| 559 core()->ReadMessage(h[0], UserPointer<void>(buffer), | 663 UserPointer<void>(buffer), |
| 560 MakeUserPointer(&buffer_size), NullUserPointer(), | 664 MakeUserPointer(&buffer_size), |
| 561 NullUserPointer(), MOJO_READ_MESSAGE_FLAG_NONE)); | 665 NullUserPointer(), |
| 666 NullUserPointer(), |
| 667 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 562 // Check that it left its inputs alone. | 668 // Check that it left its inputs alone. |
| 563 EXPECT_EQ('a', buffer[0]); | 669 EXPECT_EQ('a', buffer[0]); |
| 564 EXPECT_EQ(1u, buffer_size); | 670 EXPECT_EQ(1u, buffer_size); |
| 565 | 671 |
| 566 // Both should be writable. | 672 // Both should be writable. |
| 567 hss[0] = kEmptyMojoHandleSignalsState; | 673 hss[0] = kEmptyMojoHandleSignalsState; |
| 568 EXPECT_EQ(MOJO_RESULT_OK, core()->Wait(h[0], MOJO_HANDLE_SIGNAL_WRITABLE, | 674 EXPECT_EQ(MOJO_RESULT_OK, |
| 569 1000000000, MakeUserPointer(&hss[0]))); | 675 core()->Wait(h[0], |
| 676 MOJO_HANDLE_SIGNAL_WRITABLE, |
| 677 1000000000, |
| 678 MakeUserPointer(&hss[0]))); |
| 570 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); | 679 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); |
| 571 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 680 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 572 hss[0].satisfiable_signals); | 681 hss[0].satisfiable_signals); |
| 573 hss[0] = kEmptyMojoHandleSignalsState; | 682 hss[0] = kEmptyMojoHandleSignalsState; |
| 574 EXPECT_EQ(MOJO_RESULT_OK, core()->Wait(h[1], MOJO_HANDLE_SIGNAL_WRITABLE, | 683 EXPECT_EQ(MOJO_RESULT_OK, |
| 575 1000000000, MakeUserPointer(&hss[0]))); | 684 core()->Wait(h[1], |
| 685 MOJO_HANDLE_SIGNAL_WRITABLE, |
| 686 1000000000, |
| 687 MakeUserPointer(&hss[0]))); |
| 576 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); | 688 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); |
| 577 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 689 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 578 hss[0].satisfiable_signals); | 690 hss[0].satisfiable_signals); |
| 579 | 691 |
| 580 // Also check that |h[1]| is writable using |WaitMany()|. | 692 // Also check that |h[1]| is writable using |WaitMany()|. |
| 581 signals[0] = MOJO_HANDLE_SIGNAL_READABLE; | 693 signals[0] = MOJO_HANDLE_SIGNAL_READABLE; |
| 582 signals[1] = MOJO_HANDLE_SIGNAL_WRITABLE; | 694 signals[1] = MOJO_HANDLE_SIGNAL_WRITABLE; |
| 583 result_index = static_cast<uint32_t>(-1); | 695 result_index = static_cast<uint32_t>(-1); |
| 584 hss[0] = kEmptyMojoHandleSignalsState; | 696 hss[0] = kEmptyMojoHandleSignalsState; |
| 585 hss[1] = kEmptyMojoHandleSignalsState; | 697 hss[1] = kEmptyMojoHandleSignalsState; |
| 586 EXPECT_EQ( | 698 EXPECT_EQ(MOJO_RESULT_OK, |
| 587 MOJO_RESULT_OK, | 699 core()->WaitMany(MakeUserPointer(h), |
| 588 core()->WaitMany(MakeUserPointer(h), MakeUserPointer(signals), 2, | 700 MakeUserPointer(signals), |
| 589 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&result_index), | 701 2, |
| 590 MakeUserPointer(hss))); | 702 MOJO_DEADLINE_INDEFINITE, |
| 703 MakeUserPointer(&result_index), |
| 704 MakeUserPointer(hss))); |
| 591 EXPECT_EQ(1u, result_index); | 705 EXPECT_EQ(1u, result_index); |
| 592 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); | 706 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); |
| 593 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 707 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 594 hss[0].satisfiable_signals); | 708 hss[0].satisfiable_signals); |
| 595 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[1].satisfied_signals); | 709 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[1].satisfied_signals); |
| 596 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 710 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 597 hss[1].satisfiable_signals); | 711 hss[1].satisfiable_signals); |
| 598 | 712 |
| 599 // Write to |h[1]|. | 713 // Write to |h[1]|. |
| 600 buffer[0] = 'b'; | 714 buffer[0] = 'b'; |
| 601 EXPECT_EQ( | 715 EXPECT_EQ(MOJO_RESULT_OK, |
| 602 MOJO_RESULT_OK, | 716 core()->WriteMessage(h[1], |
| 603 core()->WriteMessage(h[1], UserPointer<const void>(buffer), 1, | 717 UserPointer<const void>(buffer), |
| 604 NullUserPointer(), 0, MOJO_WRITE_MESSAGE_FLAG_NONE)); | 718 1, |
| 719 NullUserPointer(), |
| 720 0, |
| 721 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 605 | 722 |
| 606 // Check that |h[0]| is now readable. | 723 // Check that |h[0]| is now readable. |
| 607 signals[0] = MOJO_HANDLE_SIGNAL_READABLE; | 724 signals[0] = MOJO_HANDLE_SIGNAL_READABLE; |
| 608 signals[1] = MOJO_HANDLE_SIGNAL_READABLE; | 725 signals[1] = MOJO_HANDLE_SIGNAL_READABLE; |
| 609 result_index = static_cast<uint32_t>(-1); | 726 result_index = static_cast<uint32_t>(-1); |
| 610 hss[0] = kEmptyMojoHandleSignalsState; | 727 hss[0] = kEmptyMojoHandleSignalsState; |
| 611 hss[1] = kEmptyMojoHandleSignalsState; | 728 hss[1] = kEmptyMojoHandleSignalsState; |
| 612 EXPECT_EQ( | 729 EXPECT_EQ(MOJO_RESULT_OK, |
| 613 MOJO_RESULT_OK, | 730 core()->WaitMany(MakeUserPointer(h), |
| 614 core()->WaitMany(MakeUserPointer(h), MakeUserPointer(signals), 2, | 731 MakeUserPointer(signals), |
| 615 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&result_index), | 732 2, |
| 616 MakeUserPointer(hss))); | 733 MOJO_DEADLINE_INDEFINITE, |
| 734 MakeUserPointer(&result_index), |
| 735 MakeUserPointer(hss))); |
| 617 EXPECT_EQ(0u, result_index); | 736 EXPECT_EQ(0u, result_index); |
| 618 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 737 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 619 hss[0].satisfied_signals); | 738 hss[0].satisfied_signals); |
| 620 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 739 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 621 hss[0].satisfiable_signals); | 740 hss[0].satisfiable_signals); |
| 622 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[1].satisfied_signals); | 741 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[1].satisfied_signals); |
| 623 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 742 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 624 hss[1].satisfiable_signals); | 743 hss[1].satisfiable_signals); |
| 625 | 744 |
| 626 // Read from |h[0]|. | 745 // Read from |h[0]|. |
| 627 // First, get only the size. | 746 // First, get only the size. |
| 628 buffer_size = 0; | 747 buffer_size = 0; |
| 629 EXPECT_EQ( | 748 EXPECT_EQ(MOJO_RESULT_RESOURCE_EXHAUSTED, |
| 630 MOJO_RESULT_RESOURCE_EXHAUSTED, | 749 core()->ReadMessage(h[0], |
| 631 core()->ReadMessage(h[0], NullUserPointer(), | 750 NullUserPointer(), |
| 632 MakeUserPointer(&buffer_size), NullUserPointer(), | 751 MakeUserPointer(&buffer_size), |
| 633 NullUserPointer(), MOJO_READ_MESSAGE_FLAG_NONE)); | 752 NullUserPointer(), |
| 753 NullUserPointer(), |
| 754 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 634 EXPECT_EQ(1u, buffer_size); | 755 EXPECT_EQ(1u, buffer_size); |
| 635 // Then actually read it. | 756 // Then actually read it. |
| 636 buffer[0] = 'c'; | 757 buffer[0] = 'c'; |
| 637 buffer_size = 1; | 758 buffer_size = 1; |
| 638 EXPECT_EQ( | 759 EXPECT_EQ(MOJO_RESULT_OK, |
| 639 MOJO_RESULT_OK, | 760 core()->ReadMessage(h[0], |
| 640 core()->ReadMessage(h[0], UserPointer<void>(buffer), | 761 UserPointer<void>(buffer), |
| 641 MakeUserPointer(&buffer_size), NullUserPointer(), | 762 MakeUserPointer(&buffer_size), |
| 642 NullUserPointer(), MOJO_READ_MESSAGE_FLAG_NONE)); | 763 NullUserPointer(), |
| 764 NullUserPointer(), |
| 765 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 643 EXPECT_EQ('b', buffer[0]); | 766 EXPECT_EQ('b', buffer[0]); |
| 644 EXPECT_EQ(1u, buffer_size); | 767 EXPECT_EQ(1u, buffer_size); |
| 645 | 768 |
| 646 // |h[0]| should no longer be readable. | 769 // |h[0]| should no longer be readable. |
| 647 hss[0] = kEmptyMojoHandleSignalsState; | 770 hss[0] = kEmptyMojoHandleSignalsState; |
| 648 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, | 771 EXPECT_EQ( |
| 649 core()->Wait(h[0], MOJO_HANDLE_SIGNAL_READABLE, 0, | 772 MOJO_RESULT_DEADLINE_EXCEEDED, |
| 650 MakeUserPointer(&hss[0]))); | 773 core()->Wait( |
| 774 h[0], MOJO_HANDLE_SIGNAL_READABLE, 0, MakeUserPointer(&hss[0]))); |
| 651 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); | 775 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); |
| 652 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 776 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 653 hss[0].satisfiable_signals); | 777 hss[0].satisfiable_signals); |
| 654 | 778 |
| 655 // Write to |h[0]|. | 779 // Write to |h[0]|. |
| 656 buffer[0] = 'd'; | 780 buffer[0] = 'd'; |
| 657 EXPECT_EQ( | 781 EXPECT_EQ(MOJO_RESULT_OK, |
| 658 MOJO_RESULT_OK, | 782 core()->WriteMessage(h[0], |
| 659 core()->WriteMessage(h[0], UserPointer<const void>(buffer), 1, | 783 UserPointer<const void>(buffer), |
| 660 NullUserPointer(), 0, MOJO_WRITE_MESSAGE_FLAG_NONE)); | 784 1, |
| 785 NullUserPointer(), |
| 786 0, |
| 787 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 661 | 788 |
| 662 // Close |h[0]|. | 789 // Close |h[0]|. |
| 663 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h[0])); | 790 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h[0])); |
| 664 | 791 |
| 665 // Check that |h[1]| is no longer writable (and will never be). | 792 // Check that |h[1]| is no longer writable (and will never be). |
| 666 hss[0] = kEmptyMojoHandleSignalsState; | 793 hss[0] = kEmptyMojoHandleSignalsState; |
| 667 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 794 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
| 668 core()->Wait(h[1], MOJO_HANDLE_SIGNAL_WRITABLE, 1000000000, | 795 core()->Wait(h[1], |
| 796 MOJO_HANDLE_SIGNAL_WRITABLE, |
| 797 1000000000, |
| 669 MakeUserPointer(&hss[0]))); | 798 MakeUserPointer(&hss[0]))); |
| 670 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss[0].satisfied_signals); | 799 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss[0].satisfied_signals); |
| 671 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss[0].satisfiable_signals); | 800 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss[0].satisfiable_signals); |
| 672 | 801 |
| 673 // Check that |h[1]| is still readable (for the moment). | 802 // Check that |h[1]| is still readable (for the moment). |
| 674 hss[0] = kEmptyMojoHandleSignalsState; | 803 hss[0] = kEmptyMojoHandleSignalsState; |
| 675 EXPECT_EQ(MOJO_RESULT_OK, core()->Wait(h[1], MOJO_HANDLE_SIGNAL_READABLE, | 804 EXPECT_EQ(MOJO_RESULT_OK, |
| 676 1000000000, MakeUserPointer(&hss[0]))); | 805 core()->Wait(h[1], |
| 806 MOJO_HANDLE_SIGNAL_READABLE, |
| 807 1000000000, |
| 808 MakeUserPointer(&hss[0]))); |
| 677 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss[0].satisfied_signals); | 809 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss[0].satisfied_signals); |
| 678 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss[0].satisfiable_signals); | 810 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss[0].satisfiable_signals); |
| 679 | 811 |
| 680 // Discard a message from |h[1]|. | 812 // Discard a message from |h[1]|. |
| 681 EXPECT_EQ(MOJO_RESULT_RESOURCE_EXHAUSTED, | 813 EXPECT_EQ(MOJO_RESULT_RESOURCE_EXHAUSTED, |
| 682 core()->ReadMessage(h[1], NullUserPointer(), NullUserPointer(), | 814 core()->ReadMessage(h[1], |
| 683 NullUserPointer(), NullUserPointer(), | 815 NullUserPointer(), |
| 816 NullUserPointer(), |
| 817 NullUserPointer(), |
| 818 NullUserPointer(), |
| 684 MOJO_READ_MESSAGE_FLAG_MAY_DISCARD)); | 819 MOJO_READ_MESSAGE_FLAG_MAY_DISCARD)); |
| 685 | 820 |
| 686 // |h[1]| is no longer readable (and will never be). | 821 // |h[1]| is no longer readable (and will never be). |
| 687 hss[0] = kFullMojoHandleSignalsState; | 822 hss[0] = kFullMojoHandleSignalsState; |
| 688 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 823 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
| 689 core()->Wait(h[1], MOJO_HANDLE_SIGNAL_READABLE, 1000000000, | 824 core()->Wait(h[1], |
| 825 MOJO_HANDLE_SIGNAL_READABLE, |
| 826 1000000000, |
| 690 MakeUserPointer(&hss[0]))); | 827 MakeUserPointer(&hss[0]))); |
| 691 EXPECT_EQ(0u, hss[0].satisfied_signals); | 828 EXPECT_EQ(0u, hss[0].satisfied_signals); |
| 692 EXPECT_EQ(0u, hss[0].satisfiable_signals); | 829 EXPECT_EQ(0u, hss[0].satisfiable_signals); |
| 693 | 830 |
| 694 // Try writing to |h[1]|. | 831 // Try writing to |h[1]|. |
| 695 buffer[0] = 'e'; | 832 buffer[0] = 'e'; |
| 696 EXPECT_EQ( | 833 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
| 697 MOJO_RESULT_FAILED_PRECONDITION, | 834 core()->WriteMessage(h[1], |
| 698 core()->WriteMessage(h[1], UserPointer<const void>(buffer), 1, | 835 UserPointer<const void>(buffer), |
| 699 NullUserPointer(), 0, MOJO_WRITE_MESSAGE_FLAG_NONE)); | 836 1, |
| 837 NullUserPointer(), |
| 838 0, |
| 839 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 700 | 840 |
| 701 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h[1])); | 841 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h[1])); |
| 702 } | 842 } |
| 703 | 843 |
| 704 // Tests passing a message pipe handle. | 844 // Tests passing a message pipe handle. |
| 705 TEST_F(CoreTest, MessagePipeBasicLocalHandlePassing1) { | 845 TEST_F(CoreTest, MessagePipeBasicLocalHandlePassing1) { |
| 706 const char kHello[] = "hello"; | 846 const char kHello[] = "hello"; |
| 707 const uint32_t kHelloSize = static_cast<uint32_t>(sizeof(kHello)); | 847 const uint32_t kHelloSize = static_cast<uint32_t>(sizeof(kHello)); |
| 708 const char kWorld[] = "world!!!"; | 848 const char kWorld[] = "world!!!"; |
| 709 const uint32_t kWorldSize = static_cast<uint32_t>(sizeof(kWorld)); | 849 const uint32_t kWorldSize = static_cast<uint32_t>(sizeof(kWorld)); |
| 710 char buffer[100]; | 850 char buffer[100]; |
| 711 const uint32_t kBufferSize = static_cast<uint32_t>(sizeof(buffer)); | 851 const uint32_t kBufferSize = static_cast<uint32_t>(sizeof(buffer)); |
| 712 uint32_t num_bytes; | 852 uint32_t num_bytes; |
| 713 MojoHandle handles[10]; | 853 MojoHandle handles[10]; |
| 714 uint32_t num_handles; | 854 uint32_t num_handles; |
| 715 MojoHandleSignalsState hss; | 855 MojoHandleSignalsState hss; |
| 716 MojoHandle h_received; | 856 MojoHandle h_received; |
| 717 | 857 |
| 718 MojoHandle h_passing[2]; | 858 MojoHandle h_passing[2]; |
| 719 EXPECT_EQ(MOJO_RESULT_OK, | 859 EXPECT_EQ(MOJO_RESULT_OK, |
| 720 core()->CreateMessagePipe(NullUserPointer(), | 860 core()->CreateMessagePipe(NullUserPointer(), |
| 721 MakeUserPointer(&h_passing[0]), | 861 MakeUserPointer(&h_passing[0]), |
| 722 MakeUserPointer(&h_passing[1]))); | 862 MakeUserPointer(&h_passing[1]))); |
| 723 | 863 |
| 724 // Make sure that |h_passing[]| work properly. | 864 // Make sure that |h_passing[]| work properly. |
| 725 EXPECT_EQ(MOJO_RESULT_OK, | 865 EXPECT_EQ(MOJO_RESULT_OK, |
| 726 core()->WriteMessage(h_passing[0], UserPointer<const void>(kHello), | 866 core()->WriteMessage(h_passing[0], |
| 727 kHelloSize, NullUserPointer(), 0, | 867 UserPointer<const void>(kHello), |
| 868 kHelloSize, |
| 869 NullUserPointer(), |
| 870 0, |
| 728 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 871 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 729 hss = kEmptyMojoHandleSignalsState; | 872 hss = kEmptyMojoHandleSignalsState; |
| 730 EXPECT_EQ(MOJO_RESULT_OK, | 873 EXPECT_EQ(MOJO_RESULT_OK, |
| 731 core()->Wait(h_passing[1], MOJO_HANDLE_SIGNAL_READABLE, 1000000000, | 874 core()->Wait(h_passing[1], |
| 875 MOJO_HANDLE_SIGNAL_READABLE, |
| 876 1000000000, |
| 732 MakeUserPointer(&hss))); | 877 MakeUserPointer(&hss))); |
| 733 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 878 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 734 hss.satisfied_signals); | 879 hss.satisfied_signals); |
| 735 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 880 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 736 hss.satisfiable_signals); | 881 hss.satisfiable_signals); |
| 737 num_bytes = kBufferSize; | 882 num_bytes = kBufferSize; |
| 738 num_handles = arraysize(handles); | 883 num_handles = arraysize(handles); |
| 739 EXPECT_EQ(MOJO_RESULT_OK, | 884 EXPECT_EQ(MOJO_RESULT_OK, |
| 740 core()->ReadMessage( | 885 core()->ReadMessage(h_passing[1], |
| 741 h_passing[1], UserPointer<void>(buffer), | 886 UserPointer<void>(buffer), |
| 742 MakeUserPointer(&num_bytes), MakeUserPointer(handles), | 887 MakeUserPointer(&num_bytes), |
| 743 MakeUserPointer(&num_handles), MOJO_READ_MESSAGE_FLAG_NONE)); | 888 MakeUserPointer(handles), |
| 889 MakeUserPointer(&num_handles), |
| 890 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 744 EXPECT_EQ(kHelloSize, num_bytes); | 891 EXPECT_EQ(kHelloSize, num_bytes); |
| 745 EXPECT_STREQ(kHello, buffer); | 892 EXPECT_STREQ(kHello, buffer); |
| 746 EXPECT_EQ(0u, num_handles); | 893 EXPECT_EQ(0u, num_handles); |
| 747 | 894 |
| 748 // Make sure that you can't pass either of the message pipe's handles over | 895 // Make sure that you can't pass either of the message pipe's handles over |
| 749 // itself. | 896 // itself. |
| 750 EXPECT_EQ(MOJO_RESULT_BUSY, | 897 EXPECT_EQ(MOJO_RESULT_BUSY, |
| 751 core()->WriteMessage(h_passing[0], UserPointer<const void>(kHello), | 898 core()->WriteMessage(h_passing[0], |
| 752 kHelloSize, MakeUserPointer(&h_passing[0]), 1, | 899 UserPointer<const void>(kHello), |
| 900 kHelloSize, |
| 901 MakeUserPointer(&h_passing[0]), |
| 902 1, |
| 753 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 903 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 754 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 904 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 755 core()->WriteMessage(h_passing[0], UserPointer<const void>(kHello), | 905 core()->WriteMessage(h_passing[0], |
| 756 kHelloSize, MakeUserPointer(&h_passing[1]), 1, | 906 UserPointer<const void>(kHello), |
| 907 kHelloSize, |
| 908 MakeUserPointer(&h_passing[1]), |
| 909 1, |
| 757 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 910 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 758 | 911 |
| 759 MojoHandle h_passed[2]; | 912 MojoHandle h_passed[2]; |
| 760 EXPECT_EQ(MOJO_RESULT_OK, | 913 EXPECT_EQ(MOJO_RESULT_OK, |
| 761 core()->CreateMessagePipe(NullUserPointer(), | 914 core()->CreateMessagePipe(NullUserPointer(), |
| 762 MakeUserPointer(&h_passed[0]), | 915 MakeUserPointer(&h_passed[0]), |
| 763 MakeUserPointer(&h_passed[1]))); | 916 MakeUserPointer(&h_passed[1]))); |
| 764 | 917 |
| 765 // Make sure that |h_passed[]| work properly. | 918 // Make sure that |h_passed[]| work properly. |
| 766 EXPECT_EQ(MOJO_RESULT_OK, | 919 EXPECT_EQ(MOJO_RESULT_OK, |
| 767 core()->WriteMessage(h_passed[0], UserPointer<const void>(kHello), | 920 core()->WriteMessage(h_passed[0], |
| 768 kHelloSize, NullUserPointer(), 0, | 921 UserPointer<const void>(kHello), |
| 922 kHelloSize, |
| 923 NullUserPointer(), |
| 924 0, |
| 769 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 925 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 770 hss = kEmptyMojoHandleSignalsState; | 926 hss = kEmptyMojoHandleSignalsState; |
| 771 EXPECT_EQ(MOJO_RESULT_OK, | 927 EXPECT_EQ(MOJO_RESULT_OK, |
| 772 core()->Wait(h_passed[1], MOJO_HANDLE_SIGNAL_READABLE, 1000000000, | 928 core()->Wait(h_passed[1], |
| 929 MOJO_HANDLE_SIGNAL_READABLE, |
| 930 1000000000, |
| 773 MakeUserPointer(&hss))); | 931 MakeUserPointer(&hss))); |
| 774 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 932 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 775 hss.satisfied_signals); | 933 hss.satisfied_signals); |
| 776 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 934 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 777 hss.satisfiable_signals); | 935 hss.satisfiable_signals); |
| 778 num_bytes = kBufferSize; | 936 num_bytes = kBufferSize; |
| 779 num_handles = arraysize(handles); | 937 num_handles = arraysize(handles); |
| 780 EXPECT_EQ(MOJO_RESULT_OK, | 938 EXPECT_EQ(MOJO_RESULT_OK, |
| 781 core()->ReadMessage( | 939 core()->ReadMessage(h_passed[1], |
| 782 h_passed[1], UserPointer<void>(buffer), | 940 UserPointer<void>(buffer), |
| 783 MakeUserPointer(&num_bytes), MakeUserPointer(handles), | 941 MakeUserPointer(&num_bytes), |
| 784 MakeUserPointer(&num_handles), MOJO_READ_MESSAGE_FLAG_NONE)); | 942 MakeUserPointer(handles), |
| 943 MakeUserPointer(&num_handles), |
| 944 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 785 EXPECT_EQ(kHelloSize, num_bytes); | 945 EXPECT_EQ(kHelloSize, num_bytes); |
| 786 EXPECT_STREQ(kHello, buffer); | 946 EXPECT_STREQ(kHello, buffer); |
| 787 EXPECT_EQ(0u, num_handles); | 947 EXPECT_EQ(0u, num_handles); |
| 788 | 948 |
| 789 // Send |h_passed[1]| from |h_passing[0]| to |h_passing[1]|. | 949 // Send |h_passed[1]| from |h_passing[0]| to |h_passing[1]|. |
| 790 EXPECT_EQ(MOJO_RESULT_OK, | 950 EXPECT_EQ(MOJO_RESULT_OK, |
| 791 core()->WriteMessage(h_passing[0], UserPointer<const void>(kWorld), | 951 core()->WriteMessage(h_passing[0], |
| 792 kWorldSize, MakeUserPointer(&h_passed[1]), 1, | 952 UserPointer<const void>(kWorld), |
| 953 kWorldSize, |
| 954 MakeUserPointer(&h_passed[1]), |
| 955 1, |
| 793 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 956 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 794 hss = kEmptyMojoHandleSignalsState; | 957 hss = kEmptyMojoHandleSignalsState; |
| 795 EXPECT_EQ(MOJO_RESULT_OK, | 958 EXPECT_EQ(MOJO_RESULT_OK, |
| 796 core()->Wait(h_passing[1], MOJO_HANDLE_SIGNAL_READABLE, 1000000000, | 959 core()->Wait(h_passing[1], |
| 960 MOJO_HANDLE_SIGNAL_READABLE, |
| 961 1000000000, |
| 797 MakeUserPointer(&hss))); | 962 MakeUserPointer(&hss))); |
| 798 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 963 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 799 hss.satisfied_signals); | 964 hss.satisfied_signals); |
| 800 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 965 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 801 hss.satisfiable_signals); | 966 hss.satisfiable_signals); |
| 802 num_bytes = kBufferSize; | 967 num_bytes = kBufferSize; |
| 803 num_handles = arraysize(handles); | 968 num_handles = arraysize(handles); |
| 804 EXPECT_EQ(MOJO_RESULT_OK, | 969 EXPECT_EQ(MOJO_RESULT_OK, |
| 805 core()->ReadMessage( | 970 core()->ReadMessage(h_passing[1], |
| 806 h_passing[1], UserPointer<void>(buffer), | 971 UserPointer<void>(buffer), |
| 807 MakeUserPointer(&num_bytes), MakeUserPointer(handles), | 972 MakeUserPointer(&num_bytes), |
| 808 MakeUserPointer(&num_handles), MOJO_READ_MESSAGE_FLAG_NONE)); | 973 MakeUserPointer(handles), |
| 974 MakeUserPointer(&num_handles), |
| 975 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 809 EXPECT_EQ(kWorldSize, num_bytes); | 976 EXPECT_EQ(kWorldSize, num_bytes); |
| 810 EXPECT_STREQ(kWorld, buffer); | 977 EXPECT_STREQ(kWorld, buffer); |
| 811 EXPECT_EQ(1u, num_handles); | 978 EXPECT_EQ(1u, num_handles); |
| 812 h_received = handles[0]; | 979 h_received = handles[0]; |
| 813 EXPECT_NE(h_received, MOJO_HANDLE_INVALID); | 980 EXPECT_NE(h_received, MOJO_HANDLE_INVALID); |
| 814 EXPECT_NE(h_received, h_passing[0]); | 981 EXPECT_NE(h_received, h_passing[0]); |
| 815 EXPECT_NE(h_received, h_passing[1]); | 982 EXPECT_NE(h_received, h_passing[1]); |
| 816 EXPECT_NE(h_received, h_passed[0]); | 983 EXPECT_NE(h_received, h_passed[0]); |
| 817 | 984 |
| 818 // Note: We rely on the Mojo system not re-using handle values very often. | 985 // Note: We rely on the Mojo system not re-using handle values very often. |
| 819 EXPECT_NE(h_received, h_passed[1]); | 986 EXPECT_NE(h_received, h_passed[1]); |
| 820 | 987 |
| 821 // |h_passed[1]| should no longer be valid; check that trying to close it | 988 // |h_passed[1]| should no longer be valid; check that trying to close it |
| 822 // fails. See above note. | 989 // fails. See above note. |
| 823 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, core()->Close(h_passed[1])); | 990 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, core()->Close(h_passed[1])); |
| 824 | 991 |
| 825 // Write to |h_passed[0]|. Should receive on |h_received|. | 992 // Write to |h_passed[0]|. Should receive on |h_received|. |
| 826 EXPECT_EQ(MOJO_RESULT_OK, | 993 EXPECT_EQ(MOJO_RESULT_OK, |
| 827 core()->WriteMessage(h_passed[0], UserPointer<const void>(kHello), | 994 core()->WriteMessage(h_passed[0], |
| 828 kHelloSize, NullUserPointer(), 0, | 995 UserPointer<const void>(kHello), |
| 996 kHelloSize, |
| 997 NullUserPointer(), |
| 998 0, |
| 829 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 999 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 830 hss = kEmptyMojoHandleSignalsState; | 1000 hss = kEmptyMojoHandleSignalsState; |
| 831 EXPECT_EQ(MOJO_RESULT_OK, | 1001 EXPECT_EQ(MOJO_RESULT_OK, |
| 832 core()->Wait(h_received, MOJO_HANDLE_SIGNAL_READABLE, 1000000000, | 1002 core()->Wait(h_received, |
| 1003 MOJO_HANDLE_SIGNAL_READABLE, |
| 1004 1000000000, |
| 833 MakeUserPointer(&hss))); | 1005 MakeUserPointer(&hss))); |
| 834 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1006 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 835 hss.satisfied_signals); | 1007 hss.satisfied_signals); |
| 836 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1008 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 837 hss.satisfiable_signals); | 1009 hss.satisfiable_signals); |
| 838 num_bytes = kBufferSize; | 1010 num_bytes = kBufferSize; |
| 839 num_handles = arraysize(handles); | 1011 num_handles = arraysize(handles); |
| 840 EXPECT_EQ(MOJO_RESULT_OK, | 1012 EXPECT_EQ(MOJO_RESULT_OK, |
| 841 core()->ReadMessage( | 1013 core()->ReadMessage(h_received, |
| 842 h_received, UserPointer<void>(buffer), | 1014 UserPointer<void>(buffer), |
| 843 MakeUserPointer(&num_bytes), MakeUserPointer(handles), | 1015 MakeUserPointer(&num_bytes), |
| 844 MakeUserPointer(&num_handles), MOJO_READ_MESSAGE_FLAG_NONE)); | 1016 MakeUserPointer(handles), |
| 1017 MakeUserPointer(&num_handles), |
| 1018 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 845 EXPECT_EQ(kHelloSize, num_bytes); | 1019 EXPECT_EQ(kHelloSize, num_bytes); |
| 846 EXPECT_STREQ(kHello, buffer); | 1020 EXPECT_STREQ(kHello, buffer); |
| 847 EXPECT_EQ(0u, num_handles); | 1021 EXPECT_EQ(0u, num_handles); |
| 848 | 1022 |
| 849 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passing[0])); | 1023 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passing[0])); |
| 850 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passing[1])); | 1024 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passing[1])); |
| 851 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passed[0])); | 1025 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passed[0])); |
| 852 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_received)); | 1026 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_received)); |
| 853 } | 1027 } |
| 854 | 1028 |
| 855 TEST_F(CoreTest, DataPipe) { | 1029 TEST_F(CoreTest, DataPipe) { |
| 856 MojoHandle ph, ch; // p is for producer and c is for consumer. | 1030 MojoHandle ph, ch; // p is for producer and c is for consumer. |
| 857 MojoHandleSignalsState hss; | 1031 MojoHandleSignalsState hss; |
| 858 | 1032 |
| 859 EXPECT_EQ(MOJO_RESULT_OK, | 1033 EXPECT_EQ(MOJO_RESULT_OK, |
| 860 core()->CreateDataPipe(NullUserPointer(), MakeUserPointer(&ph), | 1034 core()->CreateDataPipe( |
| 861 MakeUserPointer(&ch))); | 1035 NullUserPointer(), MakeUserPointer(&ph), MakeUserPointer(&ch))); |
| 862 // Should get two distinct, valid handles. | 1036 // Should get two distinct, valid handles. |
| 863 EXPECT_NE(ph, MOJO_HANDLE_INVALID); | 1037 EXPECT_NE(ph, MOJO_HANDLE_INVALID); |
| 864 EXPECT_NE(ch, MOJO_HANDLE_INVALID); | 1038 EXPECT_NE(ch, MOJO_HANDLE_INVALID); |
| 865 EXPECT_NE(ph, ch); | 1039 EXPECT_NE(ph, ch); |
| 866 | 1040 |
| 867 // Producer should be never-readable, but already writable. | 1041 // Producer should be never-readable, but already writable. |
| 868 hss = kEmptyMojoHandleSignalsState; | 1042 hss = kEmptyMojoHandleSignalsState; |
| 869 EXPECT_EQ( | 1043 EXPECT_EQ( |
| 870 MOJO_RESULT_FAILED_PRECONDITION, | 1044 MOJO_RESULT_FAILED_PRECONDITION, |
| 871 core()->Wait(ph, MOJO_HANDLE_SIGNAL_READABLE, 0, MakeUserPointer(&hss))); | 1045 core()->Wait(ph, MOJO_HANDLE_SIGNAL_READABLE, 0, MakeUserPointer(&hss))); |
| 872 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); | 1046 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); |
| 873 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); | 1047 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); |
| 874 hss = kEmptyMojoHandleSignalsState; | 1048 hss = kEmptyMojoHandleSignalsState; |
| 875 EXPECT_EQ(MOJO_RESULT_OK, core()->Wait(ph, MOJO_HANDLE_SIGNAL_WRITABLE, 0, | 1049 EXPECT_EQ( |
| 876 MakeUserPointer(&hss))); | 1050 MOJO_RESULT_OK, |
| 1051 core()->Wait(ph, MOJO_HANDLE_SIGNAL_WRITABLE, 0, MakeUserPointer(&hss))); |
| 877 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); | 1052 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); |
| 878 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); | 1053 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); |
| 879 | 1054 |
| 880 // Consumer should be never-writable, and not yet readable. | 1055 // Consumer should be never-writable, and not yet readable. |
| 881 hss = kFullMojoHandleSignalsState; | 1056 hss = kFullMojoHandleSignalsState; |
| 882 EXPECT_EQ( | 1057 EXPECT_EQ( |
| 883 MOJO_RESULT_FAILED_PRECONDITION, | 1058 MOJO_RESULT_FAILED_PRECONDITION, |
| 884 core()->Wait(ch, MOJO_HANDLE_SIGNAL_WRITABLE, 0, MakeUserPointer(&hss))); | 1059 core()->Wait(ch, MOJO_HANDLE_SIGNAL_WRITABLE, 0, MakeUserPointer(&hss))); |
| 885 EXPECT_EQ(0u, hss.satisfied_signals); | 1060 EXPECT_EQ(0u, hss.satisfied_signals); |
| 886 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 1061 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
| 887 hss = kFullMojoHandleSignalsState; | 1062 hss = kFullMojoHandleSignalsState; |
| 888 EXPECT_EQ( | 1063 EXPECT_EQ( |
| 889 MOJO_RESULT_DEADLINE_EXCEEDED, | 1064 MOJO_RESULT_DEADLINE_EXCEEDED, |
| 890 core()->Wait(ch, MOJO_HANDLE_SIGNAL_READABLE, 0, MakeUserPointer(&hss))); | 1065 core()->Wait(ch, MOJO_HANDLE_SIGNAL_READABLE, 0, MakeUserPointer(&hss))); |
| 891 EXPECT_EQ(0u, hss.satisfied_signals); | 1066 EXPECT_EQ(0u, hss.satisfied_signals); |
| 892 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 1067 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
| 893 | 1068 |
| 894 // Write. | 1069 // Write. |
| 895 char elements[2] = {'A', 'B'}; | 1070 char elements[2] = {'A', 'B'}; |
| 896 uint32_t num_bytes = 2u; | 1071 uint32_t num_bytes = 2u; |
| 897 EXPECT_EQ(MOJO_RESULT_OK, | 1072 EXPECT_EQ(MOJO_RESULT_OK, |
| 898 core()->WriteData(ph, UserPointer<const void>(elements), | 1073 core()->WriteData(ph, |
| 1074 UserPointer<const void>(elements), |
| 899 MakeUserPointer(&num_bytes), | 1075 MakeUserPointer(&num_bytes), |
| 900 MOJO_WRITE_DATA_FLAG_NONE)); | 1076 MOJO_WRITE_DATA_FLAG_NONE)); |
| 901 EXPECT_EQ(2u, num_bytes); | 1077 EXPECT_EQ(2u, num_bytes); |
| 902 | 1078 |
| 903 // Consumer should now be readable. | 1079 // Consumer should now be readable. |
| 904 hss = kEmptyMojoHandleSignalsState; | 1080 hss = kEmptyMojoHandleSignalsState; |
| 905 EXPECT_EQ(MOJO_RESULT_OK, core()->Wait(ch, MOJO_HANDLE_SIGNAL_READABLE, 0, | 1081 EXPECT_EQ( |
| 906 MakeUserPointer(&hss))); | 1082 MOJO_RESULT_OK, |
| 1083 core()->Wait(ch, MOJO_HANDLE_SIGNAL_READABLE, 0, MakeUserPointer(&hss))); |
| 907 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); | 1084 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); |
| 908 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 1085 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
| 909 | 1086 |
| 910 // Peek one character. | 1087 // Peek one character. |
| 911 elements[0] = -1; | 1088 elements[0] = -1; |
| 912 elements[1] = -1; | 1089 elements[1] = -1; |
| 913 num_bytes = 1u; | 1090 num_bytes = 1u; |
| 914 EXPECT_EQ(MOJO_RESULT_OK, | 1091 EXPECT_EQ(MOJO_RESULT_OK, |
| 915 core()->ReadData( | 1092 core()->ReadData( |
| 916 ch, UserPointer<void>(elements), MakeUserPointer(&num_bytes), | 1093 ch, |
| 1094 UserPointer<void>(elements), |
| 1095 MakeUserPointer(&num_bytes), |
| 917 MOJO_READ_DATA_FLAG_NONE | MOJO_READ_DATA_FLAG_PEEK)); | 1096 MOJO_READ_DATA_FLAG_NONE | MOJO_READ_DATA_FLAG_PEEK)); |
| 918 EXPECT_EQ('A', elements[0]); | 1097 EXPECT_EQ('A', elements[0]); |
| 919 EXPECT_EQ(-1, elements[1]); | 1098 EXPECT_EQ(-1, elements[1]); |
| 920 | 1099 |
| 921 // Read one character. | 1100 // Read one character. |
| 922 elements[0] = -1; | 1101 elements[0] = -1; |
| 923 elements[1] = -1; | 1102 elements[1] = -1; |
| 924 num_bytes = 1u; | 1103 num_bytes = 1u; |
| 925 EXPECT_EQ(MOJO_RESULT_OK, core()->ReadData(ch, UserPointer<void>(elements), | 1104 EXPECT_EQ(MOJO_RESULT_OK, |
| 926 MakeUserPointer(&num_bytes), | 1105 core()->ReadData(ch, |
| 927 MOJO_READ_DATA_FLAG_NONE)); | 1106 UserPointer<void>(elements), |
| 1107 MakeUserPointer(&num_bytes), |
| 1108 MOJO_READ_DATA_FLAG_NONE)); |
| 928 EXPECT_EQ('A', elements[0]); | 1109 EXPECT_EQ('A', elements[0]); |
| 929 EXPECT_EQ(-1, elements[1]); | 1110 EXPECT_EQ(-1, elements[1]); |
| 930 | 1111 |
| 931 // Two-phase write. | 1112 // Two-phase write. |
| 932 void* write_ptr = nullptr; | 1113 void* write_ptr = nullptr; |
| 933 num_bytes = 0u; | 1114 num_bytes = 0u; |
| 934 ASSERT_EQ(MOJO_RESULT_OK, | 1115 ASSERT_EQ(MOJO_RESULT_OK, |
| 935 core()->BeginWriteData(ph, MakeUserPointer(&write_ptr), | 1116 core()->BeginWriteData(ph, |
| 1117 MakeUserPointer(&write_ptr), |
| 936 MakeUserPointer(&num_bytes), | 1118 MakeUserPointer(&num_bytes), |
| 937 MOJO_WRITE_DATA_FLAG_NONE)); | 1119 MOJO_WRITE_DATA_FLAG_NONE)); |
| 938 // We count on the default options providing a decent buffer size. | 1120 // We count on the default options providing a decent buffer size. |
| 939 ASSERT_GE(num_bytes, 3u); | 1121 ASSERT_GE(num_bytes, 3u); |
| 940 | 1122 |
| 941 // Trying to do a normal write during a two-phase write should fail. | 1123 // Trying to do a normal write during a two-phase write should fail. |
| 942 elements[0] = 'X'; | 1124 elements[0] = 'X'; |
| 943 num_bytes = 1u; | 1125 num_bytes = 1u; |
| 944 EXPECT_EQ(MOJO_RESULT_BUSY, | 1126 EXPECT_EQ(MOJO_RESULT_BUSY, |
| 945 core()->WriteData(ph, UserPointer<const void>(elements), | 1127 core()->WriteData(ph, |
| 1128 UserPointer<const void>(elements), |
| 946 MakeUserPointer(&num_bytes), | 1129 MakeUserPointer(&num_bytes), |
| 947 MOJO_WRITE_DATA_FLAG_NONE)); | 1130 MOJO_WRITE_DATA_FLAG_NONE)); |
| 948 | 1131 |
| 949 // Actually write the data, and complete it now. | 1132 // Actually write the data, and complete it now. |
| 950 static_cast<char*>(write_ptr)[0] = 'C'; | 1133 static_cast<char*>(write_ptr)[0] = 'C'; |
| 951 static_cast<char*>(write_ptr)[1] = 'D'; | 1134 static_cast<char*>(write_ptr)[1] = 'D'; |
| 952 static_cast<char*>(write_ptr)[2] = 'E'; | 1135 static_cast<char*>(write_ptr)[2] = 'E'; |
| 953 EXPECT_EQ(MOJO_RESULT_OK, core()->EndWriteData(ph, 3u)); | 1136 EXPECT_EQ(MOJO_RESULT_OK, core()->EndWriteData(ph, 3u)); |
| 954 | 1137 |
| 955 // Query how much data we have. | 1138 // Query how much data we have. |
| 956 num_bytes = 0; | 1139 num_bytes = 0; |
| 957 EXPECT_EQ(MOJO_RESULT_OK, | 1140 EXPECT_EQ(MOJO_RESULT_OK, |
| 958 core()->ReadData(ch, NullUserPointer(), MakeUserPointer(&num_bytes), | 1141 core()->ReadData(ch, |
| 1142 NullUserPointer(), |
| 1143 MakeUserPointer(&num_bytes), |
| 959 MOJO_READ_DATA_FLAG_QUERY)); | 1144 MOJO_READ_DATA_FLAG_QUERY)); |
| 960 EXPECT_EQ(4u, num_bytes); | 1145 EXPECT_EQ(4u, num_bytes); |
| 961 | 1146 |
| 962 // Try to query with peek. Should fail. | 1147 // Try to query with peek. Should fail. |
| 963 num_bytes = 0; | 1148 num_bytes = 0; |
| 964 EXPECT_EQ( | 1149 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 965 MOJO_RESULT_INVALID_ARGUMENT, | 1150 core()->ReadData( |
| 966 core()->ReadData(ch, NullUserPointer(), MakeUserPointer(&num_bytes), | 1151 ch, |
| 967 MOJO_READ_DATA_FLAG_QUERY | MOJO_READ_DATA_FLAG_PEEK)); | 1152 NullUserPointer(), |
| 1153 MakeUserPointer(&num_bytes), |
| 1154 MOJO_READ_DATA_FLAG_QUERY | MOJO_READ_DATA_FLAG_PEEK)); |
| 968 EXPECT_EQ(0u, num_bytes); | 1155 EXPECT_EQ(0u, num_bytes); |
| 969 | 1156 |
| 970 // Try to discard ten characters, in all-or-none mode. Should fail. | 1157 // Try to discard ten characters, in all-or-none mode. Should fail. |
| 971 num_bytes = 10; | 1158 num_bytes = 10; |
| 972 EXPECT_EQ(MOJO_RESULT_OUT_OF_RANGE, | 1159 EXPECT_EQ(MOJO_RESULT_OUT_OF_RANGE, |
| 973 core()->ReadData( | 1160 core()->ReadData( |
| 974 ch, NullUserPointer(), MakeUserPointer(&num_bytes), | 1161 ch, |
| 1162 NullUserPointer(), |
| 1163 MakeUserPointer(&num_bytes), |
| 975 MOJO_READ_DATA_FLAG_DISCARD | MOJO_READ_DATA_FLAG_ALL_OR_NONE)); | 1164 MOJO_READ_DATA_FLAG_DISCARD | MOJO_READ_DATA_FLAG_ALL_OR_NONE)); |
| 976 | 1165 |
| 977 // Try to discard two characters, in peek mode. Should fail. | 1166 // Try to discard two characters, in peek mode. Should fail. |
| 978 num_bytes = 2; | 1167 num_bytes = 2; |
| 979 EXPECT_EQ( | 1168 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 980 MOJO_RESULT_INVALID_ARGUMENT, | 1169 core()->ReadData( |
| 981 core()->ReadData(ch, NullUserPointer(), MakeUserPointer(&num_bytes), | 1170 ch, |
| 982 MOJO_READ_DATA_FLAG_DISCARD | MOJO_READ_DATA_FLAG_PEEK)); | 1171 NullUserPointer(), |
| 1172 MakeUserPointer(&num_bytes), |
| 1173 MOJO_READ_DATA_FLAG_DISCARD | MOJO_READ_DATA_FLAG_PEEK)); |
| 983 | 1174 |
| 984 // Discard two characters. | 1175 // Discard two characters. |
| 985 num_bytes = 2; | 1176 num_bytes = 2; |
| 986 EXPECT_EQ(MOJO_RESULT_OK, | 1177 EXPECT_EQ(MOJO_RESULT_OK, |
| 987 core()->ReadData( | 1178 core()->ReadData( |
| 988 ch, NullUserPointer(), MakeUserPointer(&num_bytes), | 1179 ch, |
| 1180 NullUserPointer(), |
| 1181 MakeUserPointer(&num_bytes), |
| 989 MOJO_READ_DATA_FLAG_DISCARD | MOJO_READ_DATA_FLAG_ALL_OR_NONE)); | 1182 MOJO_READ_DATA_FLAG_DISCARD | MOJO_READ_DATA_FLAG_ALL_OR_NONE)); |
| 990 | 1183 |
| 991 // Try a two-phase read of the remaining two bytes with peek. Should fail. | 1184 // Try a two-phase read of the remaining two bytes with peek. Should fail. |
| 992 const void* read_ptr = nullptr; | 1185 const void* read_ptr = nullptr; |
| 993 num_bytes = 2; | 1186 num_bytes = 2; |
| 994 ASSERT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 1187 ASSERT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
| 995 core()->BeginReadData(ch, MakeUserPointer(&read_ptr), | 1188 core()->BeginReadData(ch, |
| 1189 MakeUserPointer(&read_ptr), |
| 996 MakeUserPointer(&num_bytes), | 1190 MakeUserPointer(&num_bytes), |
| 997 MOJO_READ_DATA_FLAG_PEEK)); | 1191 MOJO_READ_DATA_FLAG_PEEK)); |
| 998 | 1192 |
| 999 // Read the remaining two characters, in two-phase mode (all-or-none). | 1193 // Read the remaining two characters, in two-phase mode (all-or-none). |
| 1000 num_bytes = 2; | 1194 num_bytes = 2; |
| 1001 ASSERT_EQ(MOJO_RESULT_OK, | 1195 ASSERT_EQ(MOJO_RESULT_OK, |
| 1002 core()->BeginReadData(ch, MakeUserPointer(&read_ptr), | 1196 core()->BeginReadData(ch, |
| 1197 MakeUserPointer(&read_ptr), |
| 1003 MakeUserPointer(&num_bytes), | 1198 MakeUserPointer(&num_bytes), |
| 1004 MOJO_READ_DATA_FLAG_ALL_OR_NONE)); | 1199 MOJO_READ_DATA_FLAG_ALL_OR_NONE)); |
| 1005 // Note: Count on still being able to do the contiguous read here. | 1200 // Note: Count on still being able to do the contiguous read here. |
| 1006 ASSERT_EQ(2u, num_bytes); | 1201 ASSERT_EQ(2u, num_bytes); |
| 1007 | 1202 |
| 1008 // Discarding right now should fail. | 1203 // Discarding right now should fail. |
| 1009 num_bytes = 1; | 1204 num_bytes = 1; |
| 1010 EXPECT_EQ(MOJO_RESULT_BUSY, | 1205 EXPECT_EQ(MOJO_RESULT_BUSY, |
| 1011 core()->ReadData(ch, NullUserPointer(), MakeUserPointer(&num_bytes), | 1206 core()->ReadData(ch, |
| 1207 NullUserPointer(), |
| 1208 MakeUserPointer(&num_bytes), |
| 1012 MOJO_READ_DATA_FLAG_DISCARD)); | 1209 MOJO_READ_DATA_FLAG_DISCARD)); |
| 1013 | 1210 |
| 1014 // Actually check our data and end the two-phase read. | 1211 // Actually check our data and end the two-phase read. |
| 1015 EXPECT_EQ('D', static_cast<const char*>(read_ptr)[0]); | 1212 EXPECT_EQ('D', static_cast<const char*>(read_ptr)[0]); |
| 1016 EXPECT_EQ('E', static_cast<const char*>(read_ptr)[1]); | 1213 EXPECT_EQ('E', static_cast<const char*>(read_ptr)[1]); |
| 1017 EXPECT_EQ(MOJO_RESULT_OK, core()->EndReadData(ch, 2u)); | 1214 EXPECT_EQ(MOJO_RESULT_OK, core()->EndReadData(ch, 2u)); |
| 1018 | 1215 |
| 1019 // Consumer should now be no longer readable. | 1216 // Consumer should now be no longer readable. |
| 1020 hss = kFullMojoHandleSignalsState; | 1217 hss = kFullMojoHandleSignalsState; |
| 1021 EXPECT_EQ( | 1218 EXPECT_EQ( |
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1054 MojoHandleSignalsState hss; | 1251 MojoHandleSignalsState hss; |
| 1055 | 1252 |
| 1056 MojoHandle h_passing[2]; | 1253 MojoHandle h_passing[2]; |
| 1057 EXPECT_EQ(MOJO_RESULT_OK, | 1254 EXPECT_EQ(MOJO_RESULT_OK, |
| 1058 core()->CreateMessagePipe(NullUserPointer(), | 1255 core()->CreateMessagePipe(NullUserPointer(), |
| 1059 MakeUserPointer(&h_passing[0]), | 1256 MakeUserPointer(&h_passing[0]), |
| 1060 MakeUserPointer(&h_passing[1]))); | 1257 MakeUserPointer(&h_passing[1]))); |
| 1061 | 1258 |
| 1062 MojoHandle ph, ch; | 1259 MojoHandle ph, ch; |
| 1063 EXPECT_EQ(MOJO_RESULT_OK, | 1260 EXPECT_EQ(MOJO_RESULT_OK, |
| 1064 core()->CreateDataPipe(NullUserPointer(), MakeUserPointer(&ph), | 1261 core()->CreateDataPipe( |
| 1065 MakeUserPointer(&ch))); | 1262 NullUserPointer(), MakeUserPointer(&ph), MakeUserPointer(&ch))); |
| 1066 | 1263 |
| 1067 // Send |ch| from |h_passing[0]| to |h_passing[1]|. | 1264 // Send |ch| from |h_passing[0]| to |h_passing[1]|. |
| 1068 EXPECT_EQ(MOJO_RESULT_OK, | 1265 EXPECT_EQ(MOJO_RESULT_OK, |
| 1069 core()->WriteMessage(h_passing[0], UserPointer<const void>(kHello), | 1266 core()->WriteMessage(h_passing[0], |
| 1070 kHelloSize, MakeUserPointer(&ch), 1, | 1267 UserPointer<const void>(kHello), |
| 1268 kHelloSize, |
| 1269 MakeUserPointer(&ch), |
| 1270 1, |
| 1071 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 1271 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 1072 hss = kEmptyMojoHandleSignalsState; | 1272 hss = kEmptyMojoHandleSignalsState; |
| 1073 EXPECT_EQ(MOJO_RESULT_OK, | 1273 EXPECT_EQ(MOJO_RESULT_OK, |
| 1074 core()->Wait(h_passing[1], MOJO_HANDLE_SIGNAL_READABLE, 1000000000, | 1274 core()->Wait(h_passing[1], |
| 1275 MOJO_HANDLE_SIGNAL_READABLE, |
| 1276 1000000000, |
| 1075 MakeUserPointer(&hss))); | 1277 MakeUserPointer(&hss))); |
| 1076 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1278 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 1077 hss.satisfied_signals); | 1279 hss.satisfied_signals); |
| 1078 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1280 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 1079 hss.satisfiable_signals); | 1281 hss.satisfiable_signals); |
| 1080 num_bytes = kBufferSize; | 1282 num_bytes = kBufferSize; |
| 1081 num_handles = arraysize(handles); | 1283 num_handles = arraysize(handles); |
| 1082 EXPECT_EQ(MOJO_RESULT_OK, | 1284 EXPECT_EQ(MOJO_RESULT_OK, |
| 1083 core()->ReadMessage( | 1285 core()->ReadMessage(h_passing[1], |
| 1084 h_passing[1], UserPointer<void>(buffer), | 1286 UserPointer<void>(buffer), |
| 1085 MakeUserPointer(&num_bytes), MakeUserPointer(handles), | 1287 MakeUserPointer(&num_bytes), |
| 1086 MakeUserPointer(&num_handles), MOJO_READ_MESSAGE_FLAG_NONE)); | 1288 MakeUserPointer(handles), |
| 1289 MakeUserPointer(&num_handles), |
| 1290 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 1087 EXPECT_EQ(kHelloSize, num_bytes); | 1291 EXPECT_EQ(kHelloSize, num_bytes); |
| 1088 EXPECT_STREQ(kHello, buffer); | 1292 EXPECT_STREQ(kHello, buffer); |
| 1089 EXPECT_EQ(1u, num_handles); | 1293 EXPECT_EQ(1u, num_handles); |
| 1090 MojoHandle ch_received = handles[0]; | 1294 MojoHandle ch_received = handles[0]; |
| 1091 EXPECT_NE(ch_received, MOJO_HANDLE_INVALID); | 1295 EXPECT_NE(ch_received, MOJO_HANDLE_INVALID); |
| 1092 EXPECT_NE(ch_received, h_passing[0]); | 1296 EXPECT_NE(ch_received, h_passing[0]); |
| 1093 EXPECT_NE(ch_received, h_passing[1]); | 1297 EXPECT_NE(ch_received, h_passing[1]); |
| 1094 EXPECT_NE(ch_received, ph); | 1298 EXPECT_NE(ch_received, ph); |
| 1095 | 1299 |
| 1096 // Note: We rely on the Mojo system not re-using handle values very often. | 1300 // Note: We rely on the Mojo system not re-using handle values very often. |
| 1097 EXPECT_NE(ch_received, ch); | 1301 EXPECT_NE(ch_received, ch); |
| 1098 | 1302 |
| 1099 // |ch| should no longer be valid; check that trying to close it fails. See | 1303 // |ch| should no longer be valid; check that trying to close it fails. See |
| 1100 // above note. | 1304 // above note. |
| 1101 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, core()->Close(ch)); | 1305 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, core()->Close(ch)); |
| 1102 | 1306 |
| 1103 // Write to |ph|. Should receive on |ch_received|. | 1307 // Write to |ph|. Should receive on |ch_received|. |
| 1104 num_bytes = kWorldSize; | 1308 num_bytes = kWorldSize; |
| 1105 EXPECT_EQ(MOJO_RESULT_OK, | 1309 EXPECT_EQ(MOJO_RESULT_OK, |
| 1106 core()->WriteData(ph, UserPointer<const void>(kWorld), | 1310 core()->WriteData(ph, |
| 1311 UserPointer<const void>(kWorld), |
| 1107 MakeUserPointer(&num_bytes), | 1312 MakeUserPointer(&num_bytes), |
| 1108 MOJO_WRITE_DATA_FLAG_ALL_OR_NONE)); | 1313 MOJO_WRITE_DATA_FLAG_ALL_OR_NONE)); |
| 1109 hss = kEmptyMojoHandleSignalsState; | 1314 hss = kEmptyMojoHandleSignalsState; |
| 1110 EXPECT_EQ(MOJO_RESULT_OK, | 1315 EXPECT_EQ(MOJO_RESULT_OK, |
| 1111 core()->Wait(ch_received, MOJO_HANDLE_SIGNAL_READABLE, 1000000000, | 1316 core()->Wait(ch_received, |
| 1317 MOJO_HANDLE_SIGNAL_READABLE, |
| 1318 1000000000, |
| 1112 MakeUserPointer(&hss))); | 1319 MakeUserPointer(&hss))); |
| 1113 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); | 1320 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); |
| 1114 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 1321 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
| 1115 num_bytes = kBufferSize; | 1322 num_bytes = kBufferSize; |
| 1116 EXPECT_EQ(MOJO_RESULT_OK, | 1323 EXPECT_EQ(MOJO_RESULT_OK, |
| 1117 core()->ReadData(ch_received, UserPointer<void>(buffer), | 1324 core()->ReadData(ch_received, |
| 1325 UserPointer<void>(buffer), |
| 1118 MakeUserPointer(&num_bytes), | 1326 MakeUserPointer(&num_bytes), |
| 1119 MOJO_READ_MESSAGE_FLAG_NONE)); | 1327 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 1120 EXPECT_EQ(kWorldSize, num_bytes); | 1328 EXPECT_EQ(kWorldSize, num_bytes); |
| 1121 EXPECT_STREQ(kWorld, buffer); | 1329 EXPECT_STREQ(kWorld, buffer); |
| 1122 | 1330 |
| 1123 // Now pass |ph| in the same direction. | 1331 // Now pass |ph| in the same direction. |
| 1124 EXPECT_EQ(MOJO_RESULT_OK, | 1332 EXPECT_EQ(MOJO_RESULT_OK, |
| 1125 core()->WriteMessage(h_passing[0], UserPointer<const void>(kWorld), | 1333 core()->WriteMessage(h_passing[0], |
| 1126 kWorldSize, MakeUserPointer(&ph), 1, | 1334 UserPointer<const void>(kWorld), |
| 1335 kWorldSize, |
| 1336 MakeUserPointer(&ph), |
| 1337 1, |
| 1127 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 1338 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 1128 hss = kEmptyMojoHandleSignalsState; | 1339 hss = kEmptyMojoHandleSignalsState; |
| 1129 EXPECT_EQ(MOJO_RESULT_OK, | 1340 EXPECT_EQ(MOJO_RESULT_OK, |
| 1130 core()->Wait(h_passing[1], MOJO_HANDLE_SIGNAL_READABLE, 1000000000, | 1341 core()->Wait(h_passing[1], |
| 1342 MOJO_HANDLE_SIGNAL_READABLE, |
| 1343 1000000000, |
| 1131 MakeUserPointer(&hss))); | 1344 MakeUserPointer(&hss))); |
| 1132 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1345 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 1133 hss.satisfied_signals); | 1346 hss.satisfied_signals); |
| 1134 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1347 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 1135 hss.satisfiable_signals); | 1348 hss.satisfiable_signals); |
| 1136 num_bytes = kBufferSize; | 1349 num_bytes = kBufferSize; |
| 1137 num_handles = arraysize(handles); | 1350 num_handles = arraysize(handles); |
| 1138 EXPECT_EQ(MOJO_RESULT_OK, | 1351 EXPECT_EQ(MOJO_RESULT_OK, |
| 1139 core()->ReadMessage( | 1352 core()->ReadMessage(h_passing[1], |
| 1140 h_passing[1], UserPointer<void>(buffer), | 1353 UserPointer<void>(buffer), |
| 1141 MakeUserPointer(&num_bytes), MakeUserPointer(handles), | 1354 MakeUserPointer(&num_bytes), |
| 1142 MakeUserPointer(&num_handles), MOJO_READ_MESSAGE_FLAG_NONE)); | 1355 MakeUserPointer(handles), |
| 1356 MakeUserPointer(&num_handles), |
| 1357 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 1143 EXPECT_EQ(kWorldSize, num_bytes); | 1358 EXPECT_EQ(kWorldSize, num_bytes); |
| 1144 EXPECT_STREQ(kWorld, buffer); | 1359 EXPECT_STREQ(kWorld, buffer); |
| 1145 EXPECT_EQ(1u, num_handles); | 1360 EXPECT_EQ(1u, num_handles); |
| 1146 MojoHandle ph_received = handles[0]; | 1361 MojoHandle ph_received = handles[0]; |
| 1147 EXPECT_NE(ph_received, MOJO_HANDLE_INVALID); | 1362 EXPECT_NE(ph_received, MOJO_HANDLE_INVALID); |
| 1148 EXPECT_NE(ph_received, h_passing[0]); | 1363 EXPECT_NE(ph_received, h_passing[0]); |
| 1149 EXPECT_NE(ph_received, h_passing[1]); | 1364 EXPECT_NE(ph_received, h_passing[1]); |
| 1150 EXPECT_NE(ph_received, ch_received); | 1365 EXPECT_NE(ph_received, ch_received); |
| 1151 | 1366 |
| 1152 // Again, rely on the Mojo system not re-using handle values very often. | 1367 // Again, rely on the Mojo system not re-using handle values very often. |
| 1153 EXPECT_NE(ph_received, ph); | 1368 EXPECT_NE(ph_received, ph); |
| 1154 | 1369 |
| 1155 // |ph| should no longer be valid; check that trying to close it fails. See | 1370 // |ph| should no longer be valid; check that trying to close it fails. See |
| 1156 // above note. | 1371 // above note. |
| 1157 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, core()->Close(ph)); | 1372 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, core()->Close(ph)); |
| 1158 | 1373 |
| 1159 // Write to |ph_received|. Should receive on |ch_received|. | 1374 // Write to |ph_received|. Should receive on |ch_received|. |
| 1160 num_bytes = kHelloSize; | 1375 num_bytes = kHelloSize; |
| 1161 EXPECT_EQ(MOJO_RESULT_OK, | 1376 EXPECT_EQ(MOJO_RESULT_OK, |
| 1162 core()->WriteData(ph_received, UserPointer<const void>(kHello), | 1377 core()->WriteData(ph_received, |
| 1378 UserPointer<const void>(kHello), |
| 1163 MakeUserPointer(&num_bytes), | 1379 MakeUserPointer(&num_bytes), |
| 1164 MOJO_WRITE_DATA_FLAG_ALL_OR_NONE)); | 1380 MOJO_WRITE_DATA_FLAG_ALL_OR_NONE)); |
| 1165 hss = kEmptyMojoHandleSignalsState; | 1381 hss = kEmptyMojoHandleSignalsState; |
| 1166 EXPECT_EQ(MOJO_RESULT_OK, | 1382 EXPECT_EQ(MOJO_RESULT_OK, |
| 1167 core()->Wait(ch_received, MOJO_HANDLE_SIGNAL_READABLE, 1000000000, | 1383 core()->Wait(ch_received, |
| 1384 MOJO_HANDLE_SIGNAL_READABLE, |
| 1385 1000000000, |
| 1168 MakeUserPointer(&hss))); | 1386 MakeUserPointer(&hss))); |
| 1169 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); | 1387 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); |
| 1170 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 1388 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
| 1171 num_bytes = kBufferSize; | 1389 num_bytes = kBufferSize; |
| 1172 EXPECT_EQ(MOJO_RESULT_OK, | 1390 EXPECT_EQ(MOJO_RESULT_OK, |
| 1173 core()->ReadData(ch_received, UserPointer<void>(buffer), | 1391 core()->ReadData(ch_received, |
| 1392 UserPointer<void>(buffer), |
| 1174 MakeUserPointer(&num_bytes), | 1393 MakeUserPointer(&num_bytes), |
| 1175 MOJO_READ_MESSAGE_FLAG_NONE)); | 1394 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 1176 EXPECT_EQ(kHelloSize, num_bytes); | 1395 EXPECT_EQ(kHelloSize, num_bytes); |
| 1177 EXPECT_STREQ(kHello, buffer); | 1396 EXPECT_STREQ(kHello, buffer); |
| 1178 | 1397 |
| 1179 ph = ph_received; | 1398 ph = ph_received; |
| 1180 ph_received = MOJO_HANDLE_INVALID; | 1399 ph_received = MOJO_HANDLE_INVALID; |
| 1181 ch = ch_received; | 1400 ch = ch_received; |
| 1182 ch_received = MOJO_HANDLE_INVALID; | 1401 ch_received = MOJO_HANDLE_INVALID; |
| 1183 | 1402 |
| 1184 // Make sure that |ph| can't be sent if it's in a two-phase write. | 1403 // Make sure that |ph| can't be sent if it's in a two-phase write. |
| 1185 void* write_ptr = nullptr; | 1404 void* write_ptr = nullptr; |
| 1186 num_bytes = 0; | 1405 num_bytes = 0; |
| 1187 ASSERT_EQ(MOJO_RESULT_OK, | 1406 ASSERT_EQ(MOJO_RESULT_OK, |
| 1188 core()->BeginWriteData(ph, MakeUserPointer(&write_ptr), | 1407 core()->BeginWriteData(ph, |
| 1408 MakeUserPointer(&write_ptr), |
| 1189 MakeUserPointer(&num_bytes), | 1409 MakeUserPointer(&num_bytes), |
| 1190 MOJO_WRITE_DATA_FLAG_NONE)); | 1410 MOJO_WRITE_DATA_FLAG_NONE)); |
| 1191 ASSERT_GE(num_bytes, 1u); | 1411 ASSERT_GE(num_bytes, 1u); |
| 1192 EXPECT_EQ(MOJO_RESULT_BUSY, | 1412 EXPECT_EQ(MOJO_RESULT_BUSY, |
| 1193 core()->WriteMessage(h_passing[0], UserPointer<const void>(kHello), | 1413 core()->WriteMessage(h_passing[0], |
| 1194 kHelloSize, MakeUserPointer(&ph), 1, | 1414 UserPointer<const void>(kHello), |
| 1415 kHelloSize, |
| 1416 MakeUserPointer(&ph), |
| 1417 1, |
| 1195 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 1418 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 1196 | 1419 |
| 1197 // But |ch| can, even if |ph| is in a two-phase write. | 1420 // But |ch| can, even if |ph| is in a two-phase write. |
| 1198 EXPECT_EQ(MOJO_RESULT_OK, | 1421 EXPECT_EQ(MOJO_RESULT_OK, |
| 1199 core()->WriteMessage(h_passing[0], UserPointer<const void>(kHello), | 1422 core()->WriteMessage(h_passing[0], |
| 1200 kHelloSize, MakeUserPointer(&ch), 1, | 1423 UserPointer<const void>(kHello), |
| 1424 kHelloSize, |
| 1425 MakeUserPointer(&ch), |
| 1426 1, |
| 1201 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 1427 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 1202 ch = MOJO_HANDLE_INVALID; | 1428 ch = MOJO_HANDLE_INVALID; |
| 1203 EXPECT_EQ(MOJO_RESULT_OK, | 1429 EXPECT_EQ(MOJO_RESULT_OK, |
| 1204 core()->Wait(h_passing[1], MOJO_HANDLE_SIGNAL_READABLE, 1000000000, | 1430 core()->Wait(h_passing[1], |
| 1431 MOJO_HANDLE_SIGNAL_READABLE, |
| 1432 1000000000, |
| 1205 NullUserPointer())); | 1433 NullUserPointer())); |
| 1206 num_bytes = kBufferSize; | 1434 num_bytes = kBufferSize; |
| 1207 num_handles = arraysize(handles); | 1435 num_handles = arraysize(handles); |
| 1208 EXPECT_EQ(MOJO_RESULT_OK, | 1436 EXPECT_EQ(MOJO_RESULT_OK, |
| 1209 core()->ReadMessage( | 1437 core()->ReadMessage(h_passing[1], |
| 1210 h_passing[1], UserPointer<void>(buffer), | 1438 UserPointer<void>(buffer), |
| 1211 MakeUserPointer(&num_bytes), MakeUserPointer(handles), | 1439 MakeUserPointer(&num_bytes), |
| 1212 MakeUserPointer(&num_handles), MOJO_READ_MESSAGE_FLAG_NONE)); | 1440 MakeUserPointer(handles), |
| 1441 MakeUserPointer(&num_handles), |
| 1442 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 1213 EXPECT_EQ(kHelloSize, num_bytes); | 1443 EXPECT_EQ(kHelloSize, num_bytes); |
| 1214 EXPECT_STREQ(kHello, buffer); | 1444 EXPECT_STREQ(kHello, buffer); |
| 1215 EXPECT_EQ(1u, num_handles); | 1445 EXPECT_EQ(1u, num_handles); |
| 1216 ch = handles[0]; | 1446 ch = handles[0]; |
| 1217 EXPECT_NE(ch, MOJO_HANDLE_INVALID); | 1447 EXPECT_NE(ch, MOJO_HANDLE_INVALID); |
| 1218 | 1448 |
| 1219 // Complete the two-phase write. | 1449 // Complete the two-phase write. |
| 1220 static_cast<char*>(write_ptr)[0] = 'x'; | 1450 static_cast<char*>(write_ptr)[0] = 'x'; |
| 1221 EXPECT_EQ(MOJO_RESULT_OK, core()->EndWriteData(ph, 1)); | 1451 EXPECT_EQ(MOJO_RESULT_OK, core()->EndWriteData(ph, 1)); |
| 1222 | 1452 |
| 1223 // Wait for |ch| to be readable. | 1453 // Wait for |ch| to be readable. |
| 1224 hss = kEmptyMojoHandleSignalsState; | 1454 hss = kEmptyMojoHandleSignalsState; |
| 1225 EXPECT_EQ(MOJO_RESULT_OK, core()->Wait(ch, MOJO_HANDLE_SIGNAL_READABLE, | 1455 EXPECT_EQ( |
| 1226 1000000000, MakeUserPointer(&hss))); | 1456 MOJO_RESULT_OK, |
| 1457 core()->Wait( |
| 1458 ch, MOJO_HANDLE_SIGNAL_READABLE, 1000000000, MakeUserPointer(&hss))); |
| 1227 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); | 1459 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); |
| 1228 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 1460 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
| 1229 | 1461 |
| 1230 // Make sure that |ch| can't be sent if it's in a two-phase read. | 1462 // Make sure that |ch| can't be sent if it's in a two-phase read. |
| 1231 const void* read_ptr = nullptr; | 1463 const void* read_ptr = nullptr; |
| 1232 num_bytes = 1; | 1464 num_bytes = 1; |
| 1233 ASSERT_EQ(MOJO_RESULT_OK, | 1465 ASSERT_EQ(MOJO_RESULT_OK, |
| 1234 core()->BeginReadData(ch, MakeUserPointer(&read_ptr), | 1466 core()->BeginReadData(ch, |
| 1467 MakeUserPointer(&read_ptr), |
| 1235 MakeUserPointer(&num_bytes), | 1468 MakeUserPointer(&num_bytes), |
| 1236 MOJO_READ_DATA_FLAG_ALL_OR_NONE)); | 1469 MOJO_READ_DATA_FLAG_ALL_OR_NONE)); |
| 1237 EXPECT_EQ(MOJO_RESULT_BUSY, | 1470 EXPECT_EQ(MOJO_RESULT_BUSY, |
| 1238 core()->WriteMessage(h_passing[0], UserPointer<const void>(kHello), | 1471 core()->WriteMessage(h_passing[0], |
| 1239 kHelloSize, MakeUserPointer(&ch), 1, | 1472 UserPointer<const void>(kHello), |
| 1473 kHelloSize, |
| 1474 MakeUserPointer(&ch), |
| 1475 1, |
| 1240 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 1476 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 1241 | 1477 |
| 1242 // But |ph| can, even if |ch| is in a two-phase read. | 1478 // But |ph| can, even if |ch| is in a two-phase read. |
| 1243 EXPECT_EQ(MOJO_RESULT_OK, | 1479 EXPECT_EQ(MOJO_RESULT_OK, |
| 1244 core()->WriteMessage(h_passing[0], UserPointer<const void>(kWorld), | 1480 core()->WriteMessage(h_passing[0], |
| 1245 kWorldSize, MakeUserPointer(&ph), 1, | 1481 UserPointer<const void>(kWorld), |
| 1482 kWorldSize, |
| 1483 MakeUserPointer(&ph), |
| 1484 1, |
| 1246 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 1485 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
| 1247 ph = MOJO_HANDLE_INVALID; | 1486 ph = MOJO_HANDLE_INVALID; |
| 1248 hss = kEmptyMojoHandleSignalsState; | 1487 hss = kEmptyMojoHandleSignalsState; |
| 1249 EXPECT_EQ(MOJO_RESULT_OK, | 1488 EXPECT_EQ(MOJO_RESULT_OK, |
| 1250 core()->Wait(h_passing[1], MOJO_HANDLE_SIGNAL_READABLE, 1000000000, | 1489 core()->Wait(h_passing[1], |
| 1490 MOJO_HANDLE_SIGNAL_READABLE, |
| 1491 1000000000, |
| 1251 MakeUserPointer(&hss))); | 1492 MakeUserPointer(&hss))); |
| 1252 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1493 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 1253 hss.satisfied_signals); | 1494 hss.satisfied_signals); |
| 1254 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1495 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
| 1255 hss.satisfiable_signals); | 1496 hss.satisfiable_signals); |
| 1256 num_bytes = kBufferSize; | 1497 num_bytes = kBufferSize; |
| 1257 num_handles = arraysize(handles); | 1498 num_handles = arraysize(handles); |
| 1258 EXPECT_EQ(MOJO_RESULT_OK, | 1499 EXPECT_EQ(MOJO_RESULT_OK, |
| 1259 core()->ReadMessage( | 1500 core()->ReadMessage(h_passing[1], |
| 1260 h_passing[1], UserPointer<void>(buffer), | 1501 UserPointer<void>(buffer), |
| 1261 MakeUserPointer(&num_bytes), MakeUserPointer(handles), | 1502 MakeUserPointer(&num_bytes), |
| 1262 MakeUserPointer(&num_handles), MOJO_READ_MESSAGE_FLAG_NONE)); | 1503 MakeUserPointer(handles), |
| 1504 MakeUserPointer(&num_handles), |
| 1505 MOJO_READ_MESSAGE_FLAG_NONE)); |
| 1263 EXPECT_EQ(kWorldSize, num_bytes); | 1506 EXPECT_EQ(kWorldSize, num_bytes); |
| 1264 EXPECT_STREQ(kWorld, buffer); | 1507 EXPECT_STREQ(kWorld, buffer); |
| 1265 EXPECT_EQ(1u, num_handles); | 1508 EXPECT_EQ(1u, num_handles); |
| 1266 ph = handles[0]; | 1509 ph = handles[0]; |
| 1267 EXPECT_NE(ph, MOJO_HANDLE_INVALID); | 1510 EXPECT_NE(ph, MOJO_HANDLE_INVALID); |
| 1268 | 1511 |
| 1269 // Complete the two-phase read. | 1512 // Complete the two-phase read. |
| 1270 EXPECT_EQ('x', static_cast<const char*>(read_ptr)[0]); | 1513 EXPECT_EQ('x', static_cast<const char*>(read_ptr)[0]); |
| 1271 EXPECT_EQ(MOJO_RESULT_OK, core()->EndReadData(ch, 1)); | 1514 EXPECT_EQ(MOJO_RESULT_OK, core()->EndReadData(ch, 1)); |
| 1272 | 1515 |
| 1273 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passing[0])); | 1516 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passing[0])); |
| 1274 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passing[1])); | 1517 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passing[1])); |
| 1275 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(ph)); | 1518 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(ph)); |
| 1276 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(ch)); | 1519 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(ch)); |
| 1277 } | 1520 } |
| 1278 | 1521 |
| 1279 // TODO(vtl): Test |DuplicateBufferHandle()| and |MapBuffer()|. | 1522 // TODO(vtl): Test |DuplicateBufferHandle()| and |MapBuffer()|. |
| 1280 | 1523 |
| 1281 } // namespace | 1524 } // namespace |
| 1282 } // namespace system | 1525 } // namespace system |
| 1283 } // namespace mojo | 1526 } // namespace mojo |
| OLD | NEW |