OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include <stdint.h> | 5 #include <stdint.h> |
6 #include <stdio.h> | 6 #include <stdio.h> |
7 #include <string.h> | 7 #include <string.h> |
8 | 8 |
9 #include <vector> | 9 #include <vector> |
10 | 10 |
(...skipping 91 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
102 embedder::PlatformChannelPair channel_pair; | 102 embedder::PlatformChannelPair channel_pair; |
103 platform_handles_[0] = channel_pair.PassServerHandle(); | 103 platform_handles_[0] = channel_pair.PassServerHandle(); |
104 platform_handles_[1] = channel_pair.PassClientHandle(); | 104 platform_handles_[1] = channel_pair.PassClientHandle(); |
105 } | 105 } |
106 | 106 |
107 void TearDownOnIOThread() { | 107 void TearDownOnIOThread() { |
108 CHECK_EQ(base::MessageLoop::current(), io_thread()->message_loop()); | 108 CHECK_EQ(base::MessageLoop::current(), io_thread()->message_loop()); |
109 | 109 |
110 if (channels_[0].get()) { | 110 if (channels_[0].get()) { |
111 channels_[0]->Shutdown(); | 111 channels_[0]->Shutdown(); |
112 channels_[0] = NULL; | 112 channels_[0] = nullptr; |
113 } | 113 } |
114 if (channels_[1].get()) { | 114 if (channels_[1].get()) { |
115 channels_[1]->Shutdown(); | 115 channels_[1]->Shutdown(); |
116 channels_[1] = NULL; | 116 channels_[1] = nullptr; |
117 } | 117 } |
118 } | 118 } |
119 | 119 |
120 void CreateAndInitChannel(unsigned channel_index) { | 120 void CreateAndInitChannel(unsigned channel_index) { |
121 CHECK_EQ(base::MessageLoop::current(), io_thread()->message_loop()); | 121 CHECK_EQ(base::MessageLoop::current(), io_thread()->message_loop()); |
122 CHECK(channel_index == 0 || channel_index == 1); | 122 CHECK(channel_index == 0 || channel_index == 1); |
123 CHECK(!channels_[channel_index].get()); | 123 CHECK(!channels_[channel_index].get()); |
124 | 124 |
125 channels_[channel_index] = new Channel(&platform_support_); | 125 channels_[channel_index] = new Channel(&platform_support_); |
126 CHECK(channels_[channel_index]->Init( | 126 CHECK(channels_[channel_index]->Init( |
(...skipping 64 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
191 scoped_refptr<MessagePipe> mp0(MessagePipe::CreateLocalProxy(&ep0)); | 191 scoped_refptr<MessagePipe> mp0(MessagePipe::CreateLocalProxy(&ep0)); |
192 scoped_refptr<ChannelEndpoint> ep1; | 192 scoped_refptr<ChannelEndpoint> ep1; |
193 scoped_refptr<MessagePipe> mp1(MessagePipe::CreateProxyLocal(&ep1)); | 193 scoped_refptr<MessagePipe> mp1(MessagePipe::CreateProxyLocal(&ep1)); |
194 ConnectChannelEndpoints(ep0, ep1); | 194 ConnectChannelEndpoints(ep0, ep1); |
195 | 195 |
196 // Write in one direction: MP 0, port 0 -> ... -> MP 1, port 1. | 196 // Write in one direction: MP 0, port 0 -> ... -> MP 1, port 1. |
197 | 197 |
198 // Prepare to wait on MP 1, port 1. (Add the waiter now. Otherwise, if we do | 198 // Prepare to wait on MP 1, port 1. (Add the waiter now. Otherwise, if we do |
199 // it later, it might already be readable.) | 199 // it later, it might already be readable.) |
200 waiter.Init(); | 200 waiter.Init(); |
201 ASSERT_EQ(MOJO_RESULT_OK, | 201 ASSERT_EQ( |
202 mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, NULL)); | 202 MOJO_RESULT_OK, |
| 203 mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr)); |
203 | 204 |
204 // Write to MP 0, port 0. | 205 // Write to MP 0, port 0. |
205 EXPECT_EQ(MOJO_RESULT_OK, | 206 EXPECT_EQ(MOJO_RESULT_OK, |
206 mp0->WriteMessage(0, | 207 mp0->WriteMessage(0, |
207 UserPointer<const void>(kHello), | 208 UserPointer<const void>(kHello), |
208 sizeof(kHello), | 209 sizeof(kHello), |
209 NULL, | 210 nullptr, |
210 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 211 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
211 | 212 |
212 // Wait. | 213 // Wait. |
213 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); | 214 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); |
214 EXPECT_EQ(123u, context); | 215 EXPECT_EQ(123u, context); |
215 hss = HandleSignalsState(); | 216 hss = HandleSignalsState(); |
216 mp1->RemoveWaiter(1, &waiter, &hss); | 217 mp1->RemoveWaiter(1, &waiter, &hss); |
217 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 218 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
218 hss.satisfied_signals); | 219 hss.satisfied_signals); |
219 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 220 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
220 hss.satisfiable_signals); | 221 hss.satisfiable_signals); |
221 | 222 |
222 // Read from MP 1, port 1. | 223 // Read from MP 1, port 1. |
223 EXPECT_EQ(MOJO_RESULT_OK, | 224 EXPECT_EQ(MOJO_RESULT_OK, |
224 mp1->ReadMessage(1, | 225 mp1->ReadMessage(1, |
225 UserPointer<void>(buffer), | 226 UserPointer<void>(buffer), |
226 MakeUserPointer(&buffer_size), | 227 MakeUserPointer(&buffer_size), |
227 NULL, | 228 nullptr, |
228 NULL, | 229 nullptr, |
229 MOJO_READ_MESSAGE_FLAG_NONE)); | 230 MOJO_READ_MESSAGE_FLAG_NONE)); |
230 EXPECT_EQ(sizeof(kHello), static_cast<size_t>(buffer_size)); | 231 EXPECT_EQ(sizeof(kHello), static_cast<size_t>(buffer_size)); |
231 EXPECT_STREQ(kHello, buffer); | 232 EXPECT_STREQ(kHello, buffer); |
232 | 233 |
233 // Write in the other direction: MP 1, port 1 -> ... -> MP 0, port 0. | 234 // Write in the other direction: MP 1, port 1 -> ... -> MP 0, port 0. |
234 | 235 |
235 waiter.Init(); | 236 waiter.Init(); |
236 ASSERT_EQ(MOJO_RESULT_OK, | 237 ASSERT_EQ( |
237 mp0->AddWaiter(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 456, NULL)); | 238 MOJO_RESULT_OK, |
| 239 mp0->AddWaiter(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 456, nullptr)); |
238 | 240 |
239 EXPECT_EQ(MOJO_RESULT_OK, | 241 EXPECT_EQ(MOJO_RESULT_OK, |
240 mp1->WriteMessage(1, | 242 mp1->WriteMessage(1, |
241 UserPointer<const void>(kWorld), | 243 UserPointer<const void>(kWorld), |
242 sizeof(kWorld), | 244 sizeof(kWorld), |
243 NULL, | 245 nullptr, |
244 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 246 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
245 | 247 |
246 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); | 248 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); |
247 EXPECT_EQ(456u, context); | 249 EXPECT_EQ(456u, context); |
248 hss = HandleSignalsState(); | 250 hss = HandleSignalsState(); |
249 mp0->RemoveWaiter(0, &waiter, &hss); | 251 mp0->RemoveWaiter(0, &waiter, &hss); |
250 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 252 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
251 hss.satisfied_signals); | 253 hss.satisfied_signals); |
252 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 254 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
253 hss.satisfiable_signals); | 255 hss.satisfiable_signals); |
254 | 256 |
255 buffer_size = static_cast<uint32_t>(sizeof(buffer)); | 257 buffer_size = static_cast<uint32_t>(sizeof(buffer)); |
256 EXPECT_EQ(MOJO_RESULT_OK, | 258 EXPECT_EQ(MOJO_RESULT_OK, |
257 mp0->ReadMessage(0, | 259 mp0->ReadMessage(0, |
258 UserPointer<void>(buffer), | 260 UserPointer<void>(buffer), |
259 MakeUserPointer(&buffer_size), | 261 MakeUserPointer(&buffer_size), |
260 NULL, | 262 nullptr, |
261 NULL, | 263 nullptr, |
262 MOJO_READ_MESSAGE_FLAG_NONE)); | 264 MOJO_READ_MESSAGE_FLAG_NONE)); |
263 EXPECT_EQ(sizeof(kWorld), static_cast<size_t>(buffer_size)); | 265 EXPECT_EQ(sizeof(kWorld), static_cast<size_t>(buffer_size)); |
264 EXPECT_STREQ(kWorld, buffer); | 266 EXPECT_STREQ(kWorld, buffer); |
265 | 267 |
266 // Close MP 0, port 0. | 268 // Close MP 0, port 0. |
267 mp0->Close(0); | 269 mp0->Close(0); |
268 | 270 |
269 // Try to wait for MP 1, port 1 to become readable. This will eventually fail | 271 // Try to wait for MP 1, port 1 to become readable. This will eventually fail |
270 // when it realizes that MP 0, port 0 has been closed. (It may also fail | 272 // when it realizes that MP 0, port 0 has been closed. (It may also fail |
271 // immediately.) | 273 // immediately.) |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
308 | 310 |
309 scoped_refptr<ChannelEndpoint> ep2; | 311 scoped_refptr<ChannelEndpoint> ep2; |
310 scoped_refptr<MessagePipe> mp2(MessagePipe::CreateLocalProxy(&ep2)); | 312 scoped_refptr<MessagePipe> mp2(MessagePipe::CreateLocalProxy(&ep2)); |
311 scoped_refptr<ChannelEndpoint> ep3; | 313 scoped_refptr<ChannelEndpoint> ep3; |
312 scoped_refptr<MessagePipe> mp3(MessagePipe::CreateProxyLocal(&ep3)); | 314 scoped_refptr<MessagePipe> mp3(MessagePipe::CreateProxyLocal(&ep3)); |
313 ConnectChannelEndpoints(ep2, ep3); | 315 ConnectChannelEndpoints(ep2, ep3); |
314 | 316 |
315 // Write: MP 2, port 0 -> MP 3, port 1. | 317 // Write: MP 2, port 0 -> MP 3, port 1. |
316 | 318 |
317 waiter.Init(); | 319 waiter.Init(); |
318 ASSERT_EQ(MOJO_RESULT_OK, | 320 ASSERT_EQ( |
319 mp3->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 789, NULL)); | 321 MOJO_RESULT_OK, |
| 322 mp3->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 789, nullptr)); |
320 | 323 |
321 EXPECT_EQ(MOJO_RESULT_OK, | 324 EXPECT_EQ(MOJO_RESULT_OK, |
322 mp2->WriteMessage(0, | 325 mp2->WriteMessage(0, |
323 UserPointer<const void>(kHello), | 326 UserPointer<const void>(kHello), |
324 sizeof(kHello), | 327 sizeof(kHello), |
325 NULL, | 328 nullptr, |
326 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 329 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
327 | 330 |
328 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); | 331 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); |
329 EXPECT_EQ(789u, context); | 332 EXPECT_EQ(789u, context); |
330 hss = HandleSignalsState(); | 333 hss = HandleSignalsState(); |
331 mp3->RemoveWaiter(1, &waiter, &hss); | 334 mp3->RemoveWaiter(1, &waiter, &hss); |
332 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 335 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
333 hss.satisfied_signals); | 336 hss.satisfied_signals); |
334 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 337 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
335 hss.satisfiable_signals); | 338 hss.satisfiable_signals); |
336 | 339 |
337 // Make sure there's nothing on MP 0, port 0 or MP 1, port 1 or MP 2, port 0. | 340 // Make sure there's nothing on MP 0, port 0 or MP 1, port 1 or MP 2, port 0. |
338 buffer_size = static_cast<uint32_t>(sizeof(buffer)); | 341 buffer_size = static_cast<uint32_t>(sizeof(buffer)); |
339 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT, | 342 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT, |
340 mp0->ReadMessage(0, | 343 mp0->ReadMessage(0, |
341 UserPointer<void>(buffer), | 344 UserPointer<void>(buffer), |
342 MakeUserPointer(&buffer_size), | 345 MakeUserPointer(&buffer_size), |
343 NULL, | 346 nullptr, |
344 NULL, | 347 nullptr, |
345 MOJO_READ_MESSAGE_FLAG_NONE)); | 348 MOJO_READ_MESSAGE_FLAG_NONE)); |
346 buffer_size = static_cast<uint32_t>(sizeof(buffer)); | 349 buffer_size = static_cast<uint32_t>(sizeof(buffer)); |
347 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT, | 350 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT, |
348 mp1->ReadMessage(1, | 351 mp1->ReadMessage(1, |
349 UserPointer<void>(buffer), | 352 UserPointer<void>(buffer), |
350 MakeUserPointer(&buffer_size), | 353 MakeUserPointer(&buffer_size), |
351 NULL, | 354 nullptr, |
352 NULL, | 355 nullptr, |
353 MOJO_READ_MESSAGE_FLAG_NONE)); | 356 MOJO_READ_MESSAGE_FLAG_NONE)); |
354 buffer_size = static_cast<uint32_t>(sizeof(buffer)); | 357 buffer_size = static_cast<uint32_t>(sizeof(buffer)); |
355 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT, | 358 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT, |
356 mp2->ReadMessage(0, | 359 mp2->ReadMessage(0, |
357 UserPointer<void>(buffer), | 360 UserPointer<void>(buffer), |
358 MakeUserPointer(&buffer_size), | 361 MakeUserPointer(&buffer_size), |
359 NULL, | 362 nullptr, |
360 NULL, | 363 nullptr, |
361 MOJO_READ_MESSAGE_FLAG_NONE)); | 364 MOJO_READ_MESSAGE_FLAG_NONE)); |
362 | 365 |
363 // Read from MP 3, port 1. | 366 // Read from MP 3, port 1. |
364 buffer_size = static_cast<uint32_t>(sizeof(buffer)); | 367 buffer_size = static_cast<uint32_t>(sizeof(buffer)); |
365 EXPECT_EQ(MOJO_RESULT_OK, | 368 EXPECT_EQ(MOJO_RESULT_OK, |
366 mp3->ReadMessage(1, | 369 mp3->ReadMessage(1, |
367 UserPointer<void>(buffer), | 370 UserPointer<void>(buffer), |
368 MakeUserPointer(&buffer_size), | 371 MakeUserPointer(&buffer_size), |
369 NULL, | 372 nullptr, |
370 NULL, | 373 nullptr, |
371 MOJO_READ_MESSAGE_FLAG_NONE)); | 374 MOJO_READ_MESSAGE_FLAG_NONE)); |
372 EXPECT_EQ(sizeof(kHello), static_cast<size_t>(buffer_size)); | 375 EXPECT_EQ(sizeof(kHello), static_cast<size_t>(buffer_size)); |
373 EXPECT_STREQ(kHello, buffer); | 376 EXPECT_STREQ(kHello, buffer); |
374 | 377 |
375 // Write: MP 0, port 0 -> MP 1, port 1 again. | 378 // Write: MP 0, port 0 -> MP 1, port 1 again. |
376 | 379 |
377 waiter.Init(); | 380 waiter.Init(); |
378 ASSERT_EQ(MOJO_RESULT_OK, | 381 ASSERT_EQ( |
379 mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, NULL)); | 382 MOJO_RESULT_OK, |
| 383 mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr)); |
380 | 384 |
381 EXPECT_EQ(MOJO_RESULT_OK, | 385 EXPECT_EQ(MOJO_RESULT_OK, |
382 mp0->WriteMessage(0, | 386 mp0->WriteMessage(0, |
383 UserPointer<const void>(kWorld), | 387 UserPointer<const void>(kWorld), |
384 sizeof(kWorld), | 388 sizeof(kWorld), |
385 NULL, | 389 nullptr, |
386 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 390 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
387 | 391 |
388 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); | 392 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); |
389 EXPECT_EQ(123u, context); | 393 EXPECT_EQ(123u, context); |
390 hss = HandleSignalsState(); | 394 hss = HandleSignalsState(); |
391 mp1->RemoveWaiter(1, &waiter, &hss); | 395 mp1->RemoveWaiter(1, &waiter, &hss); |
392 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 396 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
393 hss.satisfied_signals); | 397 hss.satisfied_signals); |
394 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 398 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
395 hss.satisfiable_signals); | 399 hss.satisfiable_signals); |
396 | 400 |
397 // Make sure there's nothing on the other ports. | 401 // Make sure there's nothing on the other ports. |
398 buffer_size = static_cast<uint32_t>(sizeof(buffer)); | 402 buffer_size = static_cast<uint32_t>(sizeof(buffer)); |
399 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT, | 403 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT, |
400 mp0->ReadMessage(0, | 404 mp0->ReadMessage(0, |
401 UserPointer<void>(buffer), | 405 UserPointer<void>(buffer), |
402 MakeUserPointer(&buffer_size), | 406 MakeUserPointer(&buffer_size), |
403 NULL, | 407 nullptr, |
404 NULL, | 408 nullptr, |
405 MOJO_READ_MESSAGE_FLAG_NONE)); | 409 MOJO_READ_MESSAGE_FLAG_NONE)); |
406 buffer_size = static_cast<uint32_t>(sizeof(buffer)); | 410 buffer_size = static_cast<uint32_t>(sizeof(buffer)); |
407 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT, | 411 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT, |
408 mp2->ReadMessage(0, | 412 mp2->ReadMessage(0, |
409 UserPointer<void>(buffer), | 413 UserPointer<void>(buffer), |
410 MakeUserPointer(&buffer_size), | 414 MakeUserPointer(&buffer_size), |
411 NULL, | 415 nullptr, |
412 NULL, | 416 nullptr, |
413 MOJO_READ_MESSAGE_FLAG_NONE)); | 417 MOJO_READ_MESSAGE_FLAG_NONE)); |
414 buffer_size = static_cast<uint32_t>(sizeof(buffer)); | 418 buffer_size = static_cast<uint32_t>(sizeof(buffer)); |
415 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT, | 419 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT, |
416 mp3->ReadMessage(1, | 420 mp3->ReadMessage(1, |
417 UserPointer<void>(buffer), | 421 UserPointer<void>(buffer), |
418 MakeUserPointer(&buffer_size), | 422 MakeUserPointer(&buffer_size), |
419 NULL, | 423 nullptr, |
420 NULL, | 424 nullptr, |
421 MOJO_READ_MESSAGE_FLAG_NONE)); | 425 MOJO_READ_MESSAGE_FLAG_NONE)); |
422 | 426 |
423 buffer_size = static_cast<uint32_t>(sizeof(buffer)); | 427 buffer_size = static_cast<uint32_t>(sizeof(buffer)); |
424 EXPECT_EQ(MOJO_RESULT_OK, | 428 EXPECT_EQ(MOJO_RESULT_OK, |
425 mp1->ReadMessage(1, | 429 mp1->ReadMessage(1, |
426 UserPointer<void>(buffer), | 430 UserPointer<void>(buffer), |
427 MakeUserPointer(&buffer_size), | 431 MakeUserPointer(&buffer_size), |
428 NULL, | 432 nullptr, |
429 NULL, | 433 nullptr, |
430 MOJO_READ_MESSAGE_FLAG_NONE)); | 434 MOJO_READ_MESSAGE_FLAG_NONE)); |
431 EXPECT_EQ(sizeof(kWorld), static_cast<size_t>(buffer_size)); | 435 EXPECT_EQ(sizeof(kWorld), static_cast<size_t>(buffer_size)); |
432 EXPECT_STREQ(kWorld, buffer); | 436 EXPECT_STREQ(kWorld, buffer); |
433 | 437 |
434 mp0->Close(0); | 438 mp0->Close(0); |
435 mp1->Close(1); | 439 mp1->Close(1); |
436 mp2->Close(0); | 440 mp2->Close(0); |
437 mp3->Close(1); | 441 mp3->Close(1); |
438 } | 442 } |
439 | 443 |
(...skipping 10 matching lines...) Expand all Loading... |
450 // MP 0, port 0 and MP 1, port 1 as the "user-facing" endpoints. | 454 // MP 0, port 0 and MP 1, port 1 as the "user-facing" endpoints. |
451 | 455 |
452 scoped_refptr<ChannelEndpoint> ep0; | 456 scoped_refptr<ChannelEndpoint> ep0; |
453 scoped_refptr<MessagePipe> mp0(MessagePipe::CreateLocalProxy(&ep0)); | 457 scoped_refptr<MessagePipe> mp0(MessagePipe::CreateLocalProxy(&ep0)); |
454 | 458 |
455 // Write to MP 0, port 0. | 459 // Write to MP 0, port 0. |
456 EXPECT_EQ(MOJO_RESULT_OK, | 460 EXPECT_EQ(MOJO_RESULT_OK, |
457 mp0->WriteMessage(0, | 461 mp0->WriteMessage(0, |
458 UserPointer<const void>(kHello), | 462 UserPointer<const void>(kHello), |
459 sizeof(kHello), | 463 sizeof(kHello), |
460 NULL, | 464 nullptr, |
461 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 465 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
462 | 466 |
463 BootstrapChannelEndpointNoWait(0, ep0); | 467 BootstrapChannelEndpointNoWait(0, ep0); |
464 | 468 |
465 // Close MP 0, port 0 before channel 1 is even connected. | 469 // Close MP 0, port 0 before channel 1 is even connected. |
466 mp0->Close(0); | 470 mp0->Close(0); |
467 | 471 |
468 scoped_refptr<ChannelEndpoint> ep1; | 472 scoped_refptr<ChannelEndpoint> ep1; |
469 scoped_refptr<MessagePipe> mp1(MessagePipe::CreateProxyLocal(&ep1)); | 473 scoped_refptr<MessagePipe> mp1(MessagePipe::CreateProxyLocal(&ep1)); |
470 | 474 |
471 // Prepare to wait on MP 1, port 1. (Add the waiter now. Otherwise, if we do | 475 // Prepare to wait on MP 1, port 1. (Add the waiter now. Otherwise, if we do |
472 // it later, it might already be readable.) | 476 // it later, it might already be readable.) |
473 waiter.Init(); | 477 waiter.Init(); |
474 ASSERT_EQ(MOJO_RESULT_OK, | 478 ASSERT_EQ( |
475 mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, NULL)); | 479 MOJO_RESULT_OK, |
| 480 mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr)); |
476 | 481 |
477 BootstrapChannelEndpointNoWait(1, ep1); | 482 BootstrapChannelEndpointNoWait(1, ep1); |
478 | 483 |
479 // Wait. | 484 // Wait. |
480 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); | 485 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); |
481 EXPECT_EQ(123u, context); | 486 EXPECT_EQ(123u, context); |
482 hss = HandleSignalsState(); | 487 hss = HandleSignalsState(); |
483 // Note: MP 1, port 1 should definitely should be readable, but it may or may | 488 // Note: MP 1, port 1 should definitely should be readable, but it may or may |
484 // not appear as writable (there's a race, and it may not have noticed that | 489 // not appear as writable (there's a race, and it may not have noticed that |
485 // the other side was closed yet -- e.g., inserting a sleep here would make it | 490 // the other side was closed yet -- e.g., inserting a sleep here would make it |
486 // much more likely to notice that it's no longer writable). | 491 // much more likely to notice that it's no longer writable). |
487 mp1->RemoveWaiter(1, &waiter, &hss); | 492 mp1->RemoveWaiter(1, &waiter, &hss); |
488 EXPECT_TRUE((hss.satisfied_signals & MOJO_HANDLE_SIGNAL_READABLE)); | 493 EXPECT_TRUE((hss.satisfied_signals & MOJO_HANDLE_SIGNAL_READABLE)); |
489 EXPECT_TRUE((hss.satisfiable_signals & MOJO_HANDLE_SIGNAL_READABLE)); | 494 EXPECT_TRUE((hss.satisfiable_signals & MOJO_HANDLE_SIGNAL_READABLE)); |
490 | 495 |
491 // Read from MP 1, port 1. | 496 // Read from MP 1, port 1. |
492 EXPECT_EQ(MOJO_RESULT_OK, | 497 EXPECT_EQ(MOJO_RESULT_OK, |
493 mp1->ReadMessage(1, | 498 mp1->ReadMessage(1, |
494 UserPointer<void>(buffer), | 499 UserPointer<void>(buffer), |
495 MakeUserPointer(&buffer_size), | 500 MakeUserPointer(&buffer_size), |
496 NULL, | 501 nullptr, |
497 NULL, | 502 nullptr, |
498 MOJO_READ_MESSAGE_FLAG_NONE)); | 503 MOJO_READ_MESSAGE_FLAG_NONE)); |
499 EXPECT_EQ(sizeof(kHello), static_cast<size_t>(buffer_size)); | 504 EXPECT_EQ(sizeof(kHello), static_cast<size_t>(buffer_size)); |
500 EXPECT_STREQ(kHello, buffer); | 505 EXPECT_STREQ(kHello, buffer); |
501 | 506 |
502 // And MP 1, port 1. | 507 // And MP 1, port 1. |
503 mp1->Close(1); | 508 mp1->Close(1); |
504 } | 509 } |
505 | 510 |
506 TEST_F(RemoteMessagePipeTest, HandlePassing) { | 511 TEST_F(RemoteMessagePipeTest, HandlePassing) { |
507 static const char kHello[] = "hello"; | 512 static const char kHello[] = "hello"; |
508 Waiter waiter; | 513 Waiter waiter; |
509 HandleSignalsState hss; | 514 HandleSignalsState hss; |
510 uint32_t context = 0; | 515 uint32_t context = 0; |
511 | 516 |
512 scoped_refptr<ChannelEndpoint> ep0; | 517 scoped_refptr<ChannelEndpoint> ep0; |
513 scoped_refptr<MessagePipe> mp0(MessagePipe::CreateLocalProxy(&ep0)); | 518 scoped_refptr<MessagePipe> mp0(MessagePipe::CreateLocalProxy(&ep0)); |
514 scoped_refptr<ChannelEndpoint> ep1; | 519 scoped_refptr<ChannelEndpoint> ep1; |
515 scoped_refptr<MessagePipe> mp1(MessagePipe::CreateProxyLocal(&ep1)); | 520 scoped_refptr<MessagePipe> mp1(MessagePipe::CreateProxyLocal(&ep1)); |
516 ConnectChannelEndpoints(ep0, ep1); | 521 ConnectChannelEndpoints(ep0, ep1); |
517 | 522 |
518 // We'll try to pass this dispatcher. | 523 // We'll try to pass this dispatcher. |
519 scoped_refptr<MessagePipeDispatcher> dispatcher( | 524 scoped_refptr<MessagePipeDispatcher> dispatcher( |
520 new MessagePipeDispatcher(MessagePipeDispatcher::kDefaultCreateOptions)); | 525 new MessagePipeDispatcher(MessagePipeDispatcher::kDefaultCreateOptions)); |
521 scoped_refptr<MessagePipe> local_mp(MessagePipe::CreateLocalLocal()); | 526 scoped_refptr<MessagePipe> local_mp(MessagePipe::CreateLocalLocal()); |
522 dispatcher->Init(local_mp, 0); | 527 dispatcher->Init(local_mp, 0); |
523 | 528 |
524 // Prepare to wait on MP 1, port 1. (Add the waiter now. Otherwise, if we do | 529 // Prepare to wait on MP 1, port 1. (Add the waiter now. Otherwise, if we do |
525 // it later, it might already be readable.) | 530 // it later, it might already be readable.) |
526 waiter.Init(); | 531 waiter.Init(); |
527 ASSERT_EQ(MOJO_RESULT_OK, | 532 ASSERT_EQ( |
528 mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, NULL)); | 533 MOJO_RESULT_OK, |
| 534 mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr)); |
529 | 535 |
530 // Write to MP 0, port 0. | 536 // Write to MP 0, port 0. |
531 { | 537 { |
532 DispatcherTransport transport( | 538 DispatcherTransport transport( |
533 test::DispatcherTryStartTransport(dispatcher.get())); | 539 test::DispatcherTryStartTransport(dispatcher.get())); |
534 EXPECT_TRUE(transport.is_valid()); | 540 EXPECT_TRUE(transport.is_valid()); |
535 | 541 |
536 std::vector<DispatcherTransport> transports; | 542 std::vector<DispatcherTransport> transports; |
537 transports.push_back(transport); | 543 transports.push_back(transport); |
538 EXPECT_EQ(MOJO_RESULT_OK, | 544 EXPECT_EQ(MOJO_RESULT_OK, |
539 mp0->WriteMessage(0, | 545 mp0->WriteMessage(0, |
540 UserPointer<const void>(kHello), | 546 UserPointer<const void>(kHello), |
541 sizeof(kHello), | 547 sizeof(kHello), |
542 &transports, | 548 &transports, |
543 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 549 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
544 transport.End(); | 550 transport.End(); |
545 | 551 |
546 // |dispatcher| should have been closed. This is |DCHECK()|ed when the | 552 // |dispatcher| should have been closed. This is |DCHECK()|ed when the |
547 // |dispatcher| is destroyed. | 553 // |dispatcher| is destroyed. |
548 EXPECT_TRUE(dispatcher->HasOneRef()); | 554 EXPECT_TRUE(dispatcher->HasOneRef()); |
549 dispatcher = NULL; | 555 dispatcher = nullptr; |
550 } | 556 } |
551 | 557 |
552 // Wait. | 558 // Wait. |
553 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); | 559 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); |
554 EXPECT_EQ(123u, context); | 560 EXPECT_EQ(123u, context); |
555 hss = HandleSignalsState(); | 561 hss = HandleSignalsState(); |
556 mp1->RemoveWaiter(1, &waiter, &hss); | 562 mp1->RemoveWaiter(1, &waiter, &hss); |
557 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 563 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
558 hss.satisfied_signals); | 564 hss.satisfied_signals); |
559 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 565 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
(...skipping 16 matching lines...) Expand all Loading... |
576 EXPECT_EQ(1u, read_dispatchers.size()); | 582 EXPECT_EQ(1u, read_dispatchers.size()); |
577 EXPECT_EQ(1u, read_num_dispatchers); | 583 EXPECT_EQ(1u, read_num_dispatchers); |
578 ASSERT_TRUE(read_dispatchers[0].get()); | 584 ASSERT_TRUE(read_dispatchers[0].get()); |
579 EXPECT_TRUE(read_dispatchers[0]->HasOneRef()); | 585 EXPECT_TRUE(read_dispatchers[0]->HasOneRef()); |
580 | 586 |
581 EXPECT_EQ(Dispatcher::kTypeMessagePipe, read_dispatchers[0]->GetType()); | 587 EXPECT_EQ(Dispatcher::kTypeMessagePipe, read_dispatchers[0]->GetType()); |
582 dispatcher = static_cast<MessagePipeDispatcher*>(read_dispatchers[0].get()); | 588 dispatcher = static_cast<MessagePipeDispatcher*>(read_dispatchers[0].get()); |
583 | 589 |
584 // Add the waiter now, before it becomes readable to avoid a race. | 590 // Add the waiter now, before it becomes readable to avoid a race. |
585 waiter.Init(); | 591 waiter.Init(); |
586 ASSERT_EQ( | 592 ASSERT_EQ(MOJO_RESULT_OK, |
587 MOJO_RESULT_OK, | 593 dispatcher->AddWaiter( |
588 dispatcher->AddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 456, NULL)); | 594 &waiter, MOJO_HANDLE_SIGNAL_READABLE, 456, nullptr)); |
589 | 595 |
590 // Write to "local_mp", port 1. | 596 // Write to "local_mp", port 1. |
591 EXPECT_EQ(MOJO_RESULT_OK, | 597 EXPECT_EQ(MOJO_RESULT_OK, |
592 local_mp->WriteMessage(1, | 598 local_mp->WriteMessage(1, |
593 UserPointer<const void>(kHello), | 599 UserPointer<const void>(kHello), |
594 sizeof(kHello), | 600 sizeof(kHello), |
595 NULL, | 601 nullptr, |
596 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 602 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
597 | 603 |
598 // TODO(vtl): FIXME -- We (racily) crash if I close |dispatcher| immediately | 604 // TODO(vtl): FIXME -- We (racily) crash if I close |dispatcher| immediately |
599 // here. (We don't crash if I sleep and then close.) | 605 // here. (We don't crash if I sleep and then close.) |
600 | 606 |
601 // Wait for the dispatcher to become readable. | 607 // Wait for the dispatcher to become readable. |
602 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); | 608 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); |
603 EXPECT_EQ(456u, context); | 609 EXPECT_EQ(456u, context); |
604 hss = HandleSignalsState(); | 610 hss = HandleSignalsState(); |
605 dispatcher->RemoveWaiter(&waiter, &hss); | 611 dispatcher->RemoveWaiter(&waiter, &hss); |
606 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 612 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
607 hss.satisfied_signals); | 613 hss.satisfied_signals); |
608 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 614 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
609 hss.satisfiable_signals); | 615 hss.satisfiable_signals); |
610 | 616 |
611 // Read from the dispatcher. | 617 // Read from the dispatcher. |
612 memset(read_buffer, 0, sizeof(read_buffer)); | 618 memset(read_buffer, 0, sizeof(read_buffer)); |
613 read_buffer_size = static_cast<uint32_t>(sizeof(read_buffer)); | 619 read_buffer_size = static_cast<uint32_t>(sizeof(read_buffer)); |
614 EXPECT_EQ(MOJO_RESULT_OK, | 620 EXPECT_EQ(MOJO_RESULT_OK, |
615 dispatcher->ReadMessage(UserPointer<void>(read_buffer), | 621 dispatcher->ReadMessage(UserPointer<void>(read_buffer), |
616 MakeUserPointer(&read_buffer_size), | 622 MakeUserPointer(&read_buffer_size), |
617 0, | 623 0, |
618 NULL, | 624 nullptr, |
619 MOJO_READ_MESSAGE_FLAG_NONE)); | 625 MOJO_READ_MESSAGE_FLAG_NONE)); |
620 EXPECT_EQ(sizeof(kHello), static_cast<size_t>(read_buffer_size)); | 626 EXPECT_EQ(sizeof(kHello), static_cast<size_t>(read_buffer_size)); |
621 EXPECT_STREQ(kHello, read_buffer); | 627 EXPECT_STREQ(kHello, read_buffer); |
622 | 628 |
623 // Prepare to wait on "local_mp", port 1. | 629 // Prepare to wait on "local_mp", port 1. |
624 waiter.Init(); | 630 waiter.Init(); |
625 ASSERT_EQ( | 631 ASSERT_EQ(MOJO_RESULT_OK, |
626 MOJO_RESULT_OK, | 632 local_mp->AddWaiter( |
627 local_mp->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 789, NULL)); | 633 1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 789, nullptr)); |
628 | 634 |
629 // Write to the dispatcher. | 635 // Write to the dispatcher. |
630 EXPECT_EQ(MOJO_RESULT_OK, | 636 EXPECT_EQ(MOJO_RESULT_OK, |
631 dispatcher->WriteMessage(UserPointer<const void>(kHello), | 637 dispatcher->WriteMessage(UserPointer<const void>(kHello), |
632 sizeof(kHello), | 638 sizeof(kHello), |
633 NULL, | 639 nullptr, |
634 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 640 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
635 | 641 |
636 // Wait. | 642 // Wait. |
637 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); | 643 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); |
638 EXPECT_EQ(789u, context); | 644 EXPECT_EQ(789u, context); |
639 hss = HandleSignalsState(); | 645 hss = HandleSignalsState(); |
640 local_mp->RemoveWaiter(1, &waiter, &hss); | 646 local_mp->RemoveWaiter(1, &waiter, &hss); |
641 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 647 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
642 hss.satisfied_signals); | 648 hss.satisfied_signals); |
643 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 649 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
644 hss.satisfiable_signals); | 650 hss.satisfiable_signals); |
645 | 651 |
646 // Read from "local_mp", port 1. | 652 // Read from "local_mp", port 1. |
647 memset(read_buffer, 0, sizeof(read_buffer)); | 653 memset(read_buffer, 0, sizeof(read_buffer)); |
648 read_buffer_size = static_cast<uint32_t>(sizeof(read_buffer)); | 654 read_buffer_size = static_cast<uint32_t>(sizeof(read_buffer)); |
649 EXPECT_EQ(MOJO_RESULT_OK, | 655 EXPECT_EQ(MOJO_RESULT_OK, |
650 local_mp->ReadMessage(1, | 656 local_mp->ReadMessage(1, |
651 UserPointer<void>(read_buffer), | 657 UserPointer<void>(read_buffer), |
652 MakeUserPointer(&read_buffer_size), | 658 MakeUserPointer(&read_buffer_size), |
653 NULL, | 659 nullptr, |
654 NULL, | 660 nullptr, |
655 MOJO_READ_MESSAGE_FLAG_NONE)); | 661 MOJO_READ_MESSAGE_FLAG_NONE)); |
656 EXPECT_EQ(sizeof(kHello), static_cast<size_t>(read_buffer_size)); | 662 EXPECT_EQ(sizeof(kHello), static_cast<size_t>(read_buffer_size)); |
657 EXPECT_STREQ(kHello, read_buffer); | 663 EXPECT_STREQ(kHello, read_buffer); |
658 | 664 |
659 // TODO(vtl): Also test that messages queued up before the handle was sent are | 665 // TODO(vtl): Also test that messages queued up before the handle was sent are |
660 // delivered properly. | 666 // delivered properly. |
661 | 667 |
662 // Close everything that belongs to us. | 668 // Close everything that belongs to us. |
663 mp0->Close(0); | 669 mp0->Close(0); |
664 mp1->Close(1); | 670 mp1->Close(1); |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
703 ASSERT_TRUE(mapping0); | 709 ASSERT_TRUE(mapping0); |
704 ASSERT_TRUE(mapping0->GetBase()); | 710 ASSERT_TRUE(mapping0->GetBase()); |
705 ASSERT_EQ(100u, mapping0->GetLength()); | 711 ASSERT_EQ(100u, mapping0->GetLength()); |
706 static_cast<char*>(mapping0->GetBase())[0] = 'A'; | 712 static_cast<char*>(mapping0->GetBase())[0] = 'A'; |
707 static_cast<char*>(mapping0->GetBase())[50] = 'B'; | 713 static_cast<char*>(mapping0->GetBase())[50] = 'B'; |
708 static_cast<char*>(mapping0->GetBase())[99] = 'C'; | 714 static_cast<char*>(mapping0->GetBase())[99] = 'C'; |
709 | 715 |
710 // Prepare to wait on MP 1, port 1. (Add the waiter now. Otherwise, if we do | 716 // Prepare to wait on MP 1, port 1. (Add the waiter now. Otherwise, if we do |
711 // it later, it might already be readable.) | 717 // it later, it might already be readable.) |
712 waiter.Init(); | 718 waiter.Init(); |
713 ASSERT_EQ(MOJO_RESULT_OK, | 719 ASSERT_EQ( |
714 mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, NULL)); | 720 MOJO_RESULT_OK, |
| 721 mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr)); |
715 | 722 |
716 // Write to MP 0, port 0. | 723 // Write to MP 0, port 0. |
717 { | 724 { |
718 DispatcherTransport transport( | 725 DispatcherTransport transport( |
719 test::DispatcherTryStartTransport(dispatcher.get())); | 726 test::DispatcherTryStartTransport(dispatcher.get())); |
720 EXPECT_TRUE(transport.is_valid()); | 727 EXPECT_TRUE(transport.is_valid()); |
721 | 728 |
722 std::vector<DispatcherTransport> transports; | 729 std::vector<DispatcherTransport> transports; |
723 transports.push_back(transport); | 730 transports.push_back(transport); |
724 EXPECT_EQ(MOJO_RESULT_OK, | 731 EXPECT_EQ(MOJO_RESULT_OK, |
725 mp0->WriteMessage(0, | 732 mp0->WriteMessage(0, |
726 UserPointer<const void>(kHello), | 733 UserPointer<const void>(kHello), |
727 sizeof(kHello), | 734 sizeof(kHello), |
728 &transports, | 735 &transports, |
729 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 736 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
730 transport.End(); | 737 transport.End(); |
731 | 738 |
732 // |dispatcher| should have been closed. This is |DCHECK()|ed when the | 739 // |dispatcher| should have been closed. This is |DCHECK()|ed when the |
733 // |dispatcher| is destroyed. | 740 // |dispatcher| is destroyed. |
734 EXPECT_TRUE(dispatcher->HasOneRef()); | 741 EXPECT_TRUE(dispatcher->HasOneRef()); |
735 dispatcher = NULL; | 742 dispatcher = nullptr; |
736 } | 743 } |
737 | 744 |
738 // Wait. | 745 // Wait. |
739 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); | 746 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); |
740 EXPECT_EQ(123u, context); | 747 EXPECT_EQ(123u, context); |
741 hss = HandleSignalsState(); | 748 hss = HandleSignalsState(); |
742 mp1->RemoveWaiter(1, &waiter, &hss); | 749 mp1->RemoveWaiter(1, &waiter, &hss); |
743 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 750 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
744 hss.satisfied_signals); | 751 hss.satisfied_signals); |
745 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 752 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
(...skipping 81 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
827 EXPECT_EQ(sizeof(kHello), fwrite(kHello, 1, sizeof(kHello), fp.get())); | 834 EXPECT_EQ(sizeof(kHello), fwrite(kHello, 1, sizeof(kHello), fp.get())); |
828 // We'll try to pass this dispatcher, which will cause a |PlatformHandle| to | 835 // We'll try to pass this dispatcher, which will cause a |PlatformHandle| to |
829 // be passed. | 836 // be passed. |
830 scoped_refptr<PlatformHandleDispatcher> dispatcher( | 837 scoped_refptr<PlatformHandleDispatcher> dispatcher( |
831 new PlatformHandleDispatcher( | 838 new PlatformHandleDispatcher( |
832 mojo::test::PlatformHandleFromFILE(fp.Pass()))); | 839 mojo::test::PlatformHandleFromFILE(fp.Pass()))); |
833 | 840 |
834 // Prepare to wait on MP 1, port 1. (Add the waiter now. Otherwise, if we do | 841 // Prepare to wait on MP 1, port 1. (Add the waiter now. Otherwise, if we do |
835 // it later, it might already be readable.) | 842 // it later, it might already be readable.) |
836 waiter.Init(); | 843 waiter.Init(); |
837 ASSERT_EQ(MOJO_RESULT_OK, | 844 ASSERT_EQ( |
838 mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, NULL)); | 845 MOJO_RESULT_OK, |
| 846 mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr)); |
839 | 847 |
840 // Write to MP 0, port 0. | 848 // Write to MP 0, port 0. |
841 { | 849 { |
842 DispatcherTransport transport( | 850 DispatcherTransport transport( |
843 test::DispatcherTryStartTransport(dispatcher.get())); | 851 test::DispatcherTryStartTransport(dispatcher.get())); |
844 EXPECT_TRUE(transport.is_valid()); | 852 EXPECT_TRUE(transport.is_valid()); |
845 | 853 |
846 std::vector<DispatcherTransport> transports; | 854 std::vector<DispatcherTransport> transports; |
847 transports.push_back(transport); | 855 transports.push_back(transport); |
848 EXPECT_EQ(MOJO_RESULT_OK, | 856 EXPECT_EQ(MOJO_RESULT_OK, |
849 mp0->WriteMessage(0, | 857 mp0->WriteMessage(0, |
850 UserPointer<const void>(kWorld), | 858 UserPointer<const void>(kWorld), |
851 sizeof(kWorld), | 859 sizeof(kWorld), |
852 &transports, | 860 &transports, |
853 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 861 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
854 transport.End(); | 862 transport.End(); |
855 | 863 |
856 // |dispatcher| should have been closed. This is |DCHECK()|ed when the | 864 // |dispatcher| should have been closed. This is |DCHECK()|ed when the |
857 // |dispatcher| is destroyed. | 865 // |dispatcher| is destroyed. |
858 EXPECT_TRUE(dispatcher->HasOneRef()); | 866 EXPECT_TRUE(dispatcher->HasOneRef()); |
859 dispatcher = NULL; | 867 dispatcher = nullptr; |
860 } | 868 } |
861 | 869 |
862 // Wait. | 870 // Wait. |
863 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); | 871 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); |
864 EXPECT_EQ(123u, context); | 872 EXPECT_EQ(123u, context); |
865 hss = HandleSignalsState(); | 873 hss = HandleSignalsState(); |
866 mp1->RemoveWaiter(1, &waiter, &hss); | 874 mp1->RemoveWaiter(1, &waiter, &hss); |
867 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 875 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
868 hss.satisfied_signals); | 876 hss.satisfied_signals); |
869 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 877 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
(...skipping 98 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
968 | 976 |
969 // We'll try to pass this dispatcher. | 977 // We'll try to pass this dispatcher. |
970 scoped_refptr<MessagePipeDispatcher> dispatcher( | 978 scoped_refptr<MessagePipeDispatcher> dispatcher( |
971 new MessagePipeDispatcher(MessagePipeDispatcher::kDefaultCreateOptions)); | 979 new MessagePipeDispatcher(MessagePipeDispatcher::kDefaultCreateOptions)); |
972 scoped_refptr<MessagePipe> local_mp(MessagePipe::CreateLocalLocal()); | 980 scoped_refptr<MessagePipe> local_mp(MessagePipe::CreateLocalLocal()); |
973 dispatcher->Init(local_mp, 0); | 981 dispatcher->Init(local_mp, 0); |
974 | 982 |
975 // Prepare to wait on MP 1, port 1. (Add the waiter now. Otherwise, if we do | 983 // Prepare to wait on MP 1, port 1. (Add the waiter now. Otherwise, if we do |
976 // it later, it might already be readable.) | 984 // it later, it might already be readable.) |
977 waiter.Init(); | 985 waiter.Init(); |
978 ASSERT_EQ(MOJO_RESULT_OK, | 986 ASSERT_EQ( |
979 mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, NULL)); | 987 MOJO_RESULT_OK, |
| 988 mp1->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr)); |
980 | 989 |
981 // Write to MP 0, port 0. | 990 // Write to MP 0, port 0. |
982 { | 991 { |
983 DispatcherTransport transport( | 992 DispatcherTransport transport( |
984 test::DispatcherTryStartTransport(dispatcher.get())); | 993 test::DispatcherTryStartTransport(dispatcher.get())); |
985 EXPECT_TRUE(transport.is_valid()); | 994 EXPECT_TRUE(transport.is_valid()); |
986 | 995 |
987 std::vector<DispatcherTransport> transports; | 996 std::vector<DispatcherTransport> transports; |
988 transports.push_back(transport); | 997 transports.push_back(transport); |
989 EXPECT_EQ(MOJO_RESULT_OK, | 998 EXPECT_EQ(MOJO_RESULT_OK, |
990 mp0->WriteMessage(0, | 999 mp0->WriteMessage(0, |
991 UserPointer<const void>(kHello), | 1000 UserPointer<const void>(kHello), |
992 sizeof(kHello), | 1001 sizeof(kHello), |
993 &transports, | 1002 &transports, |
994 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 1003 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
995 transport.End(); | 1004 transport.End(); |
996 | 1005 |
997 // |dispatcher| should have been closed. This is |DCHECK()|ed when the | 1006 // |dispatcher| should have been closed. This is |DCHECK()|ed when the |
998 // |dispatcher| is destroyed. | 1007 // |dispatcher| is destroyed. |
999 EXPECT_TRUE(dispatcher->HasOneRef()); | 1008 EXPECT_TRUE(dispatcher->HasOneRef()); |
1000 dispatcher = NULL; | 1009 dispatcher = nullptr; |
1001 } | 1010 } |
1002 | 1011 |
1003 // Wait. | 1012 // Wait. |
1004 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); | 1013 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); |
1005 EXPECT_EQ(123u, context); | 1014 EXPECT_EQ(123u, context); |
1006 hss = HandleSignalsState(); | 1015 hss = HandleSignalsState(); |
1007 mp1->RemoveWaiter(1, &waiter, &hss); | 1016 mp1->RemoveWaiter(1, &waiter, &hss); |
1008 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1017 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
1009 hss.satisfied_signals); | 1018 hss.satisfied_signals); |
1010 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1019 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
(...skipping 20 matching lines...) Expand all Loading... |
1031 | 1040 |
1032 EXPECT_EQ(Dispatcher::kTypeMessagePipe, read_dispatchers[0]->GetType()); | 1041 EXPECT_EQ(Dispatcher::kTypeMessagePipe, read_dispatchers[0]->GetType()); |
1033 dispatcher = static_cast<MessagePipeDispatcher*>(read_dispatchers[0].get()); | 1042 dispatcher = static_cast<MessagePipeDispatcher*>(read_dispatchers[0].get()); |
1034 read_dispatchers.clear(); | 1043 read_dispatchers.clear(); |
1035 | 1044 |
1036 // Now pass it back. | 1045 // Now pass it back. |
1037 | 1046 |
1038 // Prepare to wait on MP 0, port 0. (Add the waiter now. Otherwise, if we do | 1047 // Prepare to wait on MP 0, port 0. (Add the waiter now. Otherwise, if we do |
1039 // it later, it might already be readable.) | 1048 // it later, it might already be readable.) |
1040 waiter.Init(); | 1049 waiter.Init(); |
1041 ASSERT_EQ(MOJO_RESULT_OK, | 1050 ASSERT_EQ( |
1042 mp0->AddWaiter(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 456, NULL)); | 1051 MOJO_RESULT_OK, |
| 1052 mp0->AddWaiter(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 456, nullptr)); |
1043 | 1053 |
1044 // Write to MP 1, port 1. | 1054 // Write to MP 1, port 1. |
1045 { | 1055 { |
1046 DispatcherTransport transport( | 1056 DispatcherTransport transport( |
1047 test::DispatcherTryStartTransport(dispatcher.get())); | 1057 test::DispatcherTryStartTransport(dispatcher.get())); |
1048 EXPECT_TRUE(transport.is_valid()); | 1058 EXPECT_TRUE(transport.is_valid()); |
1049 | 1059 |
1050 std::vector<DispatcherTransport> transports; | 1060 std::vector<DispatcherTransport> transports; |
1051 transports.push_back(transport); | 1061 transports.push_back(transport); |
1052 EXPECT_EQ(MOJO_RESULT_OK, | 1062 EXPECT_EQ(MOJO_RESULT_OK, |
1053 mp1->WriteMessage(1, | 1063 mp1->WriteMessage(1, |
1054 UserPointer<const void>(kWorld), | 1064 UserPointer<const void>(kWorld), |
1055 sizeof(kWorld), | 1065 sizeof(kWorld), |
1056 &transports, | 1066 &transports, |
1057 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 1067 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
1058 transport.End(); | 1068 transport.End(); |
1059 | 1069 |
1060 // |dispatcher| should have been closed. This is |DCHECK()|ed when the | 1070 // |dispatcher| should have been closed. This is |DCHECK()|ed when the |
1061 // |dispatcher| is destroyed. | 1071 // |dispatcher| is destroyed. |
1062 EXPECT_TRUE(dispatcher->HasOneRef()); | 1072 EXPECT_TRUE(dispatcher->HasOneRef()); |
1063 dispatcher = NULL; | 1073 dispatcher = nullptr; |
1064 } | 1074 } |
1065 | 1075 |
1066 // Wait. | 1076 // Wait. |
1067 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); | 1077 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); |
1068 EXPECT_EQ(456u, context); | 1078 EXPECT_EQ(456u, context); |
1069 hss = HandleSignalsState(); | 1079 hss = HandleSignalsState(); |
1070 mp0->RemoveWaiter(0, &waiter, &hss); | 1080 mp0->RemoveWaiter(0, &waiter, &hss); |
1071 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1081 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
1072 hss.satisfied_signals); | 1082 hss.satisfied_signals); |
1073 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1083 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
(...skipping 15 matching lines...) Expand all Loading... |
1089 EXPECT_EQ(1u, read_num_dispatchers); | 1099 EXPECT_EQ(1u, read_num_dispatchers); |
1090 ASSERT_TRUE(read_dispatchers[0].get()); | 1100 ASSERT_TRUE(read_dispatchers[0].get()); |
1091 EXPECT_TRUE(read_dispatchers[0]->HasOneRef()); | 1101 EXPECT_TRUE(read_dispatchers[0]->HasOneRef()); |
1092 | 1102 |
1093 EXPECT_EQ(Dispatcher::kTypeMessagePipe, read_dispatchers[0]->GetType()); | 1103 EXPECT_EQ(Dispatcher::kTypeMessagePipe, read_dispatchers[0]->GetType()); |
1094 dispatcher = static_cast<MessagePipeDispatcher*>(read_dispatchers[0].get()); | 1104 dispatcher = static_cast<MessagePipeDispatcher*>(read_dispatchers[0].get()); |
1095 read_dispatchers.clear(); | 1105 read_dispatchers.clear(); |
1096 | 1106 |
1097 // Add the waiter now, before it becomes readable to avoid a race. | 1107 // Add the waiter now, before it becomes readable to avoid a race. |
1098 waiter.Init(); | 1108 waiter.Init(); |
1099 ASSERT_EQ( | 1109 ASSERT_EQ(MOJO_RESULT_OK, |
1100 MOJO_RESULT_OK, | 1110 dispatcher->AddWaiter( |
1101 dispatcher->AddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 789, NULL)); | 1111 &waiter, MOJO_HANDLE_SIGNAL_READABLE, 789, nullptr)); |
1102 | 1112 |
1103 // Write to "local_mp", port 1. | 1113 // Write to "local_mp", port 1. |
1104 EXPECT_EQ(MOJO_RESULT_OK, | 1114 EXPECT_EQ(MOJO_RESULT_OK, |
1105 local_mp->WriteMessage(1, | 1115 local_mp->WriteMessage(1, |
1106 UserPointer<const void>(kHello), | 1116 UserPointer<const void>(kHello), |
1107 sizeof(kHello), | 1117 sizeof(kHello), |
1108 NULL, | 1118 nullptr, |
1109 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 1119 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
1110 | 1120 |
1111 // Wait for the dispatcher to become readable. | 1121 // Wait for the dispatcher to become readable. |
1112 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); | 1122 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); |
1113 EXPECT_EQ(789u, context); | 1123 EXPECT_EQ(789u, context); |
1114 hss = HandleSignalsState(); | 1124 hss = HandleSignalsState(); |
1115 dispatcher->RemoveWaiter(&waiter, &hss); | 1125 dispatcher->RemoveWaiter(&waiter, &hss); |
1116 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1126 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
1117 hss.satisfied_signals); | 1127 hss.satisfied_signals); |
1118 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1128 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
1119 hss.satisfiable_signals); | 1129 hss.satisfiable_signals); |
1120 | 1130 |
1121 // Read from the dispatcher. | 1131 // Read from the dispatcher. |
1122 memset(read_buffer, 0, sizeof(read_buffer)); | 1132 memset(read_buffer, 0, sizeof(read_buffer)); |
1123 read_buffer_size = static_cast<uint32_t>(sizeof(read_buffer)); | 1133 read_buffer_size = static_cast<uint32_t>(sizeof(read_buffer)); |
1124 EXPECT_EQ(MOJO_RESULT_OK, | 1134 EXPECT_EQ(MOJO_RESULT_OK, |
1125 dispatcher->ReadMessage(UserPointer<void>(read_buffer), | 1135 dispatcher->ReadMessage(UserPointer<void>(read_buffer), |
1126 MakeUserPointer(&read_buffer_size), | 1136 MakeUserPointer(&read_buffer_size), |
1127 0, | 1137 0, |
1128 NULL, | 1138 nullptr, |
1129 MOJO_READ_MESSAGE_FLAG_NONE)); | 1139 MOJO_READ_MESSAGE_FLAG_NONE)); |
1130 EXPECT_EQ(sizeof(kHello), static_cast<size_t>(read_buffer_size)); | 1140 EXPECT_EQ(sizeof(kHello), static_cast<size_t>(read_buffer_size)); |
1131 EXPECT_STREQ(kHello, read_buffer); | 1141 EXPECT_STREQ(kHello, read_buffer); |
1132 | 1142 |
1133 // Prepare to wait on "local_mp", port 1. | 1143 // Prepare to wait on "local_mp", port 1. |
1134 waiter.Init(); | 1144 waiter.Init(); |
1135 ASSERT_EQ( | 1145 ASSERT_EQ(MOJO_RESULT_OK, |
1136 MOJO_RESULT_OK, | 1146 local_mp->AddWaiter( |
1137 local_mp->AddWaiter(1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 789, NULL)); | 1147 1, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 789, nullptr)); |
1138 | 1148 |
1139 // Write to the dispatcher. | 1149 // Write to the dispatcher. |
1140 EXPECT_EQ(MOJO_RESULT_OK, | 1150 EXPECT_EQ(MOJO_RESULT_OK, |
1141 dispatcher->WriteMessage(UserPointer<const void>(kHello), | 1151 dispatcher->WriteMessage(UserPointer<const void>(kHello), |
1142 sizeof(kHello), | 1152 sizeof(kHello), |
1143 NULL, | 1153 nullptr, |
1144 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 1154 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
1145 | 1155 |
1146 // Wait. | 1156 // Wait. |
1147 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); | 1157 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(MOJO_DEADLINE_INDEFINITE, &context)); |
1148 EXPECT_EQ(789u, context); | 1158 EXPECT_EQ(789u, context); |
1149 hss = HandleSignalsState(); | 1159 hss = HandleSignalsState(); |
1150 local_mp->RemoveWaiter(1, &waiter, &hss); | 1160 local_mp->RemoveWaiter(1, &waiter, &hss); |
1151 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1161 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
1152 hss.satisfied_signals); | 1162 hss.satisfied_signals); |
1153 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1163 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
1154 hss.satisfiable_signals); | 1164 hss.satisfiable_signals); |
1155 | 1165 |
1156 // Read from "local_mp", port 1. | 1166 // Read from "local_mp", port 1. |
1157 memset(read_buffer, 0, sizeof(read_buffer)); | 1167 memset(read_buffer, 0, sizeof(read_buffer)); |
1158 read_buffer_size = static_cast<uint32_t>(sizeof(read_buffer)); | 1168 read_buffer_size = static_cast<uint32_t>(sizeof(read_buffer)); |
1159 EXPECT_EQ(MOJO_RESULT_OK, | 1169 EXPECT_EQ(MOJO_RESULT_OK, |
1160 local_mp->ReadMessage(1, | 1170 local_mp->ReadMessage(1, |
1161 UserPointer<void>(read_buffer), | 1171 UserPointer<void>(read_buffer), |
1162 MakeUserPointer(&read_buffer_size), | 1172 MakeUserPointer(&read_buffer_size), |
1163 NULL, | 1173 nullptr, |
1164 NULL, | 1174 nullptr, |
1165 MOJO_READ_MESSAGE_FLAG_NONE)); | 1175 MOJO_READ_MESSAGE_FLAG_NONE)); |
1166 EXPECT_EQ(sizeof(kHello), static_cast<size_t>(read_buffer_size)); | 1176 EXPECT_EQ(sizeof(kHello), static_cast<size_t>(read_buffer_size)); |
1167 EXPECT_STREQ(kHello, read_buffer); | 1177 EXPECT_STREQ(kHello, read_buffer); |
1168 | 1178 |
1169 // TODO(vtl): Also test the cases where messages are written and read (at | 1179 // TODO(vtl): Also test the cases where messages are written and read (at |
1170 // various points) on the message pipe being passed around. | 1180 // various points) on the message pipe being passed around. |
1171 | 1181 |
1172 // Close everything that belongs to us. | 1182 // Close everything that belongs to us. |
1173 mp0->Close(0); | 1183 mp0->Close(0); |
1174 mp1->Close(1); | 1184 mp1->Close(1); |
1175 EXPECT_EQ(MOJO_RESULT_OK, dispatcher->Close()); | 1185 EXPECT_EQ(MOJO_RESULT_OK, dispatcher->Close()); |
1176 // Note that |local_mp|'s port 0 belong to |dispatcher|, which was closed. | 1186 // Note that |local_mp|'s port 0 belong to |dispatcher|, which was closed. |
1177 local_mp->Close(1); | 1187 local_mp->Close(1); |
1178 } | 1188 } |
1179 | 1189 |
1180 } // namespace | 1190 } // namespace |
1181 } // namespace system | 1191 } // namespace system |
1182 } // namespace mojo | 1192 } // namespace mojo |
OLD | NEW |