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/system/local_data_pipe.h" | 5 #include "mojo/system/local_data_pipe.h" |
6 | 6 |
7 #include <string.h> | 7 #include <string.h> |
8 | 8 |
9 #include "base/macros.h" | 9 #include "base/macros.h" |
10 #include "base/memory/ref_counted.h" | 10 #include "base/memory/ref_counted.h" |
(...skipping 236 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
247 EXPECT_EQ(MOJO_RESULT_OK, | 247 EXPECT_EQ(MOJO_RESULT_OK, |
248 dp->ProducerWriteData(UserPointer<const void>(elements), | 248 dp->ProducerWriteData(UserPointer<const void>(elements), |
249 MakeUserPointer(&num_bytes), | 249 MakeUserPointer(&num_bytes), |
250 true)); | 250 true)); |
251 EXPECT_EQ(static_cast<uint32_t>(2u * sizeof(elements[0])), num_bytes); | 251 EXPECT_EQ(static_cast<uint32_t>(2u * sizeof(elements[0])), num_bytes); |
252 | 252 |
253 // Adding a waiter should now succeed. | 253 // Adding a waiter should now succeed. |
254 waiter.Init(); | 254 waiter.Init(); |
255 ASSERT_EQ( | 255 ASSERT_EQ( |
256 MOJO_RESULT_OK, | 256 MOJO_RESULT_OK, |
257 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 56, NULL)); | 257 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 56, nullptr)); |
258 // And it shouldn't be writable yet. | 258 // And it shouldn't be writable yet. |
259 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0, NULL)); | 259 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0, nullptr)); |
260 hss = HandleSignalsState(); | 260 hss = HandleSignalsState(); |
261 dp->ProducerRemoveWaiter(&waiter, &hss); | 261 dp->ProducerRemoveWaiter(&waiter, &hss); |
262 EXPECT_EQ(0u, hss.satisfied_signals); | 262 EXPECT_EQ(0u, hss.satisfied_signals); |
263 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); | 263 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); |
264 | 264 |
265 // Do it again. | 265 // Do it again. |
266 waiter.Init(); | 266 waiter.Init(); |
267 ASSERT_EQ( | 267 ASSERT_EQ( |
268 MOJO_RESULT_OK, | 268 MOJO_RESULT_OK, |
269 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 78, NULL)); | 269 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 78, nullptr)); |
270 | 270 |
271 // Read one element. | 271 // Read one element. |
272 elements[0] = -1; | 272 elements[0] = -1; |
273 elements[1] = -1; | 273 elements[1] = -1; |
274 num_bytes = static_cast<uint32_t>(1u * sizeof(elements[0])); | 274 num_bytes = static_cast<uint32_t>(1u * sizeof(elements[0])); |
275 EXPECT_EQ( | 275 EXPECT_EQ( |
276 MOJO_RESULT_OK, | 276 MOJO_RESULT_OK, |
277 dp->ConsumerReadData( | 277 dp->ConsumerReadData( |
278 UserPointer<void>(elements), MakeUserPointer(&num_bytes), true)); | 278 UserPointer<void>(elements), MakeUserPointer(&num_bytes), true)); |
279 EXPECT_EQ(static_cast<uint32_t>(1u * sizeof(elements[0])), num_bytes); | 279 EXPECT_EQ(static_cast<uint32_t>(1u * sizeof(elements[0])), num_bytes); |
280 EXPECT_EQ(123, elements[0]); | 280 EXPECT_EQ(123, elements[0]); |
281 EXPECT_EQ(-1, elements[1]); | 281 EXPECT_EQ(-1, elements[1]); |
282 | 282 |
283 // Waiting should now succeed. | 283 // Waiting should now succeed. |
284 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(1000, &context)); | 284 EXPECT_EQ(MOJO_RESULT_OK, waiter.Wait(1000, &context)); |
285 EXPECT_EQ(78u, context); | 285 EXPECT_EQ(78u, context); |
286 hss = HandleSignalsState(); | 286 hss = HandleSignalsState(); |
287 dp->ProducerRemoveWaiter(&waiter, &hss); | 287 dp->ProducerRemoveWaiter(&waiter, &hss); |
288 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); | 288 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); |
289 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); | 289 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); |
290 | 290 |
291 // Try writing, using a two-phase write. | 291 // Try writing, using a two-phase write. |
292 void* buffer = NULL; | 292 void* buffer = nullptr; |
293 num_bytes = static_cast<uint32_t>(3u * sizeof(elements[0])); | 293 num_bytes = static_cast<uint32_t>(3u * sizeof(elements[0])); |
294 EXPECT_EQ(MOJO_RESULT_OK, | 294 EXPECT_EQ(MOJO_RESULT_OK, |
295 dp->ProducerBeginWriteData( | 295 dp->ProducerBeginWriteData( |
296 MakeUserPointer(&buffer), MakeUserPointer(&num_bytes), false)); | 296 MakeUserPointer(&buffer), MakeUserPointer(&num_bytes), false)); |
297 EXPECT_TRUE(buffer != NULL); | 297 EXPECT_TRUE(buffer != nullptr); |
jamesr
2014/09/24 22:03:00
EXPECT_TRUE(buffer) ?
viettrungluu
2014/09/24 22:08:05
Done.
| |
298 EXPECT_EQ(static_cast<uint32_t>(1u * sizeof(elements[0])), num_bytes); | 298 EXPECT_EQ(static_cast<uint32_t>(1u * sizeof(elements[0])), num_bytes); |
299 | 299 |
300 static_cast<int32_t*>(buffer)[0] = 789; | 300 static_cast<int32_t*>(buffer)[0] = 789; |
301 EXPECT_EQ(MOJO_RESULT_OK, | 301 EXPECT_EQ(MOJO_RESULT_OK, |
302 dp->ProducerEndWriteData( | 302 dp->ProducerEndWriteData( |
303 static_cast<uint32_t>(1u * sizeof(elements[0])))); | 303 static_cast<uint32_t>(1u * sizeof(elements[0])))); |
304 | 304 |
305 // Add a waiter. | 305 // Add a waiter. |
306 waiter.Init(); | 306 waiter.Init(); |
307 ASSERT_EQ( | 307 ASSERT_EQ( |
308 MOJO_RESULT_OK, | 308 MOJO_RESULT_OK, |
309 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 90, NULL)); | 309 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 90, nullptr)); |
310 | 310 |
311 // Read one element, using a two-phase read. | 311 // Read one element, using a two-phase read. |
312 const void* read_buffer = NULL; | 312 const void* read_buffer = nullptr; |
313 num_bytes = 0u; | 313 num_bytes = 0u; |
314 EXPECT_EQ( | 314 EXPECT_EQ( |
315 MOJO_RESULT_OK, | 315 MOJO_RESULT_OK, |
316 dp->ConsumerBeginReadData( | 316 dp->ConsumerBeginReadData( |
317 MakeUserPointer(&read_buffer), MakeUserPointer(&num_bytes), false)); | 317 MakeUserPointer(&read_buffer), MakeUserPointer(&num_bytes), false)); |
318 EXPECT_TRUE(read_buffer != NULL); | 318 EXPECT_TRUE(read_buffer != nullptr); |
319 // Since we only read one element (after having written three in all), the | 319 // Since we only read one element (after having written three in all), the |
320 // two-phase read should only allow us to read one. This checks an | 320 // two-phase read should only allow us to read one. This checks an |
321 // implementation detail! | 321 // implementation detail! |
322 EXPECT_EQ(static_cast<uint32_t>(1u * sizeof(elements[0])), num_bytes); | 322 EXPECT_EQ(static_cast<uint32_t>(1u * sizeof(elements[0])), num_bytes); |
323 EXPECT_EQ(456, static_cast<const int32_t*>(read_buffer)[0]); | 323 EXPECT_EQ(456, static_cast<const int32_t*>(read_buffer)[0]); |
324 EXPECT_EQ( | 324 EXPECT_EQ( |
325 MOJO_RESULT_OK, | 325 MOJO_RESULT_OK, |
326 dp->ConsumerEndReadData(static_cast<uint32_t>(1u * sizeof(elements[0])))); | 326 dp->ConsumerEndReadData(static_cast<uint32_t>(1u * sizeof(elements[0])))); |
327 | 327 |
328 // Waiting should succeed. | 328 // Waiting should succeed. |
(...skipping 10 matching lines...) Expand all Loading... | |
339 EXPECT_EQ(MOJO_RESULT_OK, | 339 EXPECT_EQ(MOJO_RESULT_OK, |
340 dp->ProducerWriteData(UserPointer<const void>(elements), | 340 dp->ProducerWriteData(UserPointer<const void>(elements), |
341 MakeUserPointer(&num_bytes), | 341 MakeUserPointer(&num_bytes), |
342 false)); | 342 false)); |
343 EXPECT_EQ(static_cast<uint32_t>(1u * sizeof(elements[0])), num_bytes); | 343 EXPECT_EQ(static_cast<uint32_t>(1u * sizeof(elements[0])), num_bytes); |
344 | 344 |
345 // Add a waiter. | 345 // Add a waiter. |
346 waiter.Init(); | 346 waiter.Init(); |
347 ASSERT_EQ( | 347 ASSERT_EQ( |
348 MOJO_RESULT_OK, | 348 MOJO_RESULT_OK, |
349 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 12, NULL)); | 349 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 12, nullptr)); |
350 | 350 |
351 // Close the consumer. | 351 // Close the consumer. |
352 dp->ConsumerClose(); | 352 dp->ConsumerClose(); |
353 | 353 |
354 // It should now be never-writable. | 354 // It should now be never-writable. |
355 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, waiter.Wait(1000, &context)); | 355 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, waiter.Wait(1000, &context)); |
356 EXPECT_EQ(12u, context); | 356 EXPECT_EQ(12u, context); |
357 hss = HandleSignalsState(); | 357 hss = HandleSignalsState(); |
358 dp->ProducerRemoveWaiter(&waiter, &hss); | 358 dp->ProducerRemoveWaiter(&waiter, &hss); |
359 EXPECT_EQ(0u, hss.satisfied_signals); | 359 EXPECT_EQ(0u, hss.satisfied_signals); |
(...skipping 24 matching lines...) Expand all Loading... | |
384 waiter.Init(); | 384 waiter.Init(); |
385 hss = HandleSignalsState(); | 385 hss = HandleSignalsState(); |
386 EXPECT_EQ( | 386 EXPECT_EQ( |
387 MOJO_RESULT_FAILED_PRECONDITION, | 387 MOJO_RESULT_FAILED_PRECONDITION, |
388 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 12, &hss)); | 388 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 12, &hss)); |
389 EXPECT_EQ(0u, hss.satisfied_signals); | 389 EXPECT_EQ(0u, hss.satisfied_signals); |
390 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 390 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
391 | 391 |
392 // Not yet readable. | 392 // Not yet readable. |
393 waiter.Init(); | 393 waiter.Init(); |
394 ASSERT_EQ( | 394 ASSERT_EQ(MOJO_RESULT_OK, |
395 MOJO_RESULT_OK, | 395 dp->ConsumerAddWaiter( |
396 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 34, NULL)); | 396 &waiter, MOJO_HANDLE_SIGNAL_READABLE, 34, nullptr)); |
397 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0, NULL)); | 397 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0, nullptr)); |
398 hss = HandleSignalsState(); | 398 hss = HandleSignalsState(); |
399 dp->ConsumerRemoveWaiter(&waiter, &hss); | 399 dp->ConsumerRemoveWaiter(&waiter, &hss); |
400 EXPECT_EQ(0u, hss.satisfied_signals); | 400 EXPECT_EQ(0u, hss.satisfied_signals); |
401 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 401 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
402 | 402 |
403 // Write two elements. | 403 // Write two elements. |
404 int32_t elements[2] = {123, 456}; | 404 int32_t elements[2] = {123, 456}; |
405 uint32_t num_bytes = static_cast<uint32_t>(2u * sizeof(elements[0])); | 405 uint32_t num_bytes = static_cast<uint32_t>(2u * sizeof(elements[0])); |
406 EXPECT_EQ(MOJO_RESULT_OK, | 406 EXPECT_EQ(MOJO_RESULT_OK, |
407 dp->ProducerWriteData(UserPointer<const void>(elements), | 407 dp->ProducerWriteData(UserPointer<const void>(elements), |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
439 EXPECT_EQ( | 439 EXPECT_EQ( |
440 MOJO_RESULT_OK, | 440 MOJO_RESULT_OK, |
441 dp->ConsumerReadData( | 441 dp->ConsumerReadData( |
442 UserPointer<void>(elements), MakeUserPointer(&num_bytes), true)); | 442 UserPointer<void>(elements), MakeUserPointer(&num_bytes), true)); |
443 EXPECT_EQ(static_cast<uint32_t>(1u * sizeof(elements[0])), num_bytes); | 443 EXPECT_EQ(static_cast<uint32_t>(1u * sizeof(elements[0])), num_bytes); |
444 EXPECT_EQ(456, elements[0]); | 444 EXPECT_EQ(456, elements[0]); |
445 EXPECT_EQ(-1, elements[1]); | 445 EXPECT_EQ(-1, elements[1]); |
446 | 446 |
447 // Adding a waiter should now succeed. | 447 // Adding a waiter should now succeed. |
448 waiter.Init(); | 448 waiter.Init(); |
449 ASSERT_EQ( | 449 ASSERT_EQ(MOJO_RESULT_OK, |
450 MOJO_RESULT_OK, | 450 dp->ConsumerAddWaiter( |
451 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 90, NULL)); | 451 &waiter, MOJO_HANDLE_SIGNAL_READABLE, 90, nullptr)); |
452 | 452 |
453 // Write one element. | 453 // Write one element. |
454 elements[0] = 789; | 454 elements[0] = 789; |
455 elements[1] = -1; | 455 elements[1] = -1; |
456 num_bytes = static_cast<uint32_t>(1u * sizeof(elements[0])); | 456 num_bytes = static_cast<uint32_t>(1u * sizeof(elements[0])); |
457 EXPECT_EQ(MOJO_RESULT_OK, | 457 EXPECT_EQ(MOJO_RESULT_OK, |
458 dp->ProducerWriteData(UserPointer<const void>(elements), | 458 dp->ProducerWriteData(UserPointer<const void>(elements), |
459 MakeUserPointer(&num_bytes), | 459 MakeUserPointer(&num_bytes), |
460 true)); | 460 true)); |
461 | 461 |
(...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
505 | 505 |
506 // Test with two-phase APIs and closing the producer with an active consumer | 506 // Test with two-phase APIs and closing the producer with an active consumer |
507 // waiter. | 507 // waiter. |
508 { | 508 { |
509 scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options)); | 509 scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options)); |
510 Waiter waiter; | 510 Waiter waiter; |
511 uint32_t context = 0; | 511 uint32_t context = 0; |
512 HandleSignalsState hss; | 512 HandleSignalsState hss; |
513 | 513 |
514 // Write two elements. | 514 // Write two elements. |
515 int32_t* elements = NULL; | 515 int32_t* elements = nullptr; |
516 void* buffer = NULL; | 516 void* buffer = nullptr; |
517 // Request room for three (but we'll only write two). | 517 // Request room for three (but we'll only write two). |
518 uint32_t num_bytes = static_cast<uint32_t>(3u * sizeof(elements[0])); | 518 uint32_t num_bytes = static_cast<uint32_t>(3u * sizeof(elements[0])); |
519 EXPECT_EQ(MOJO_RESULT_OK, | 519 EXPECT_EQ(MOJO_RESULT_OK, |
520 dp->ProducerBeginWriteData( | 520 dp->ProducerBeginWriteData( |
521 MakeUserPointer(&buffer), MakeUserPointer(&num_bytes), true)); | 521 MakeUserPointer(&buffer), MakeUserPointer(&num_bytes), true)); |
522 EXPECT_TRUE(buffer != NULL); | 522 EXPECT_TRUE(buffer != nullptr); |
523 EXPECT_GE(num_bytes, static_cast<uint32_t>(3u * sizeof(elements[0]))); | 523 EXPECT_GE(num_bytes, static_cast<uint32_t>(3u * sizeof(elements[0]))); |
524 elements = static_cast<int32_t*>(buffer); | 524 elements = static_cast<int32_t*>(buffer); |
525 elements[0] = 123; | 525 elements[0] = 123; |
526 elements[1] = 456; | 526 elements[1] = 456; |
527 EXPECT_EQ(MOJO_RESULT_OK, | 527 EXPECT_EQ(MOJO_RESULT_OK, |
528 dp->ProducerEndWriteData( | 528 dp->ProducerEndWriteData( |
529 static_cast<uint32_t>(2u * sizeof(elements[0])))); | 529 static_cast<uint32_t>(2u * sizeof(elements[0])))); |
530 | 530 |
531 // Should already be readable. | 531 // Should already be readable. |
532 waiter.Init(); | 532 waiter.Init(); |
533 hss = HandleSignalsState(); | 533 hss = HandleSignalsState(); |
534 EXPECT_EQ( | 534 EXPECT_EQ( |
535 MOJO_RESULT_ALREADY_EXISTS, | 535 MOJO_RESULT_ALREADY_EXISTS, |
536 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 12, &hss)); | 536 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 12, &hss)); |
537 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); | 537 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); |
538 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 538 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
539 | 539 |
540 // Read one element. | 540 // Read one element. |
541 // Request two in all-or-none mode, but only read one. | 541 // Request two in all-or-none mode, but only read one. |
542 const void* read_buffer = NULL; | 542 const void* read_buffer = nullptr; |
543 num_bytes = static_cast<uint32_t>(2u * sizeof(elements[0])); | 543 num_bytes = static_cast<uint32_t>(2u * sizeof(elements[0])); |
544 EXPECT_EQ( | 544 EXPECT_EQ( |
545 MOJO_RESULT_OK, | 545 MOJO_RESULT_OK, |
546 dp->ConsumerBeginReadData( | 546 dp->ConsumerBeginReadData( |
547 MakeUserPointer(&read_buffer), MakeUserPointer(&num_bytes), true)); | 547 MakeUserPointer(&read_buffer), MakeUserPointer(&num_bytes), true)); |
548 EXPECT_TRUE(read_buffer != NULL); | 548 EXPECT_TRUE(read_buffer != nullptr); |
549 EXPECT_EQ(static_cast<uint32_t>(2u * sizeof(elements[0])), num_bytes); | 549 EXPECT_EQ(static_cast<uint32_t>(2u * sizeof(elements[0])), num_bytes); |
550 const int32_t* read_elements = static_cast<const int32_t*>(read_buffer); | 550 const int32_t* read_elements = static_cast<const int32_t*>(read_buffer); |
551 EXPECT_EQ(123, read_elements[0]); | 551 EXPECT_EQ(123, read_elements[0]); |
552 EXPECT_EQ(MOJO_RESULT_OK, | 552 EXPECT_EQ(MOJO_RESULT_OK, |
553 dp->ConsumerEndReadData( | 553 dp->ConsumerEndReadData( |
554 static_cast<uint32_t>(1u * sizeof(elements[0])))); | 554 static_cast<uint32_t>(1u * sizeof(elements[0])))); |
555 | 555 |
556 // Should still be readable. | 556 // Should still be readable. |
557 waiter.Init(); | 557 waiter.Init(); |
558 hss = HandleSignalsState(); | 558 hss = HandleSignalsState(); |
559 EXPECT_EQ( | 559 EXPECT_EQ( |
560 MOJO_RESULT_ALREADY_EXISTS, | 560 MOJO_RESULT_ALREADY_EXISTS, |
561 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 34, &hss)); | 561 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 34, &hss)); |
562 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); | 562 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); |
563 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 563 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
564 | 564 |
565 // Read one element. | 565 // Read one element. |
566 // Request three, but not in all-or-none mode. | 566 // Request three, but not in all-or-none mode. |
567 read_buffer = NULL; | 567 read_buffer = nullptr; |
568 num_bytes = static_cast<uint32_t>(3u * sizeof(elements[0])); | 568 num_bytes = static_cast<uint32_t>(3u * sizeof(elements[0])); |
569 EXPECT_EQ( | 569 EXPECT_EQ( |
570 MOJO_RESULT_OK, | 570 MOJO_RESULT_OK, |
571 dp->ConsumerBeginReadData( | 571 dp->ConsumerBeginReadData( |
572 MakeUserPointer(&read_buffer), MakeUserPointer(&num_bytes), false)); | 572 MakeUserPointer(&read_buffer), MakeUserPointer(&num_bytes), false)); |
573 EXPECT_TRUE(read_buffer != NULL); | 573 EXPECT_TRUE(read_buffer != nullptr); |
574 EXPECT_EQ(static_cast<uint32_t>(1u * sizeof(elements[0])), num_bytes); | 574 EXPECT_EQ(static_cast<uint32_t>(1u * sizeof(elements[0])), num_bytes); |
575 read_elements = static_cast<const int32_t*>(read_buffer); | 575 read_elements = static_cast<const int32_t*>(read_buffer); |
576 EXPECT_EQ(456, read_elements[0]); | 576 EXPECT_EQ(456, read_elements[0]); |
577 EXPECT_EQ(MOJO_RESULT_OK, | 577 EXPECT_EQ(MOJO_RESULT_OK, |
578 dp->ConsumerEndReadData( | 578 dp->ConsumerEndReadData( |
579 static_cast<uint32_t>(1u * sizeof(elements[0])))); | 579 static_cast<uint32_t>(1u * sizeof(elements[0])))); |
580 | 580 |
581 // Adding a waiter should now succeed. | 581 // Adding a waiter should now succeed. |
582 waiter.Init(); | 582 waiter.Init(); |
583 ASSERT_EQ( | 583 ASSERT_EQ(MOJO_RESULT_OK, |
584 MOJO_RESULT_OK, | 584 dp->ConsumerAddWaiter( |
585 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 56, NULL)); | 585 &waiter, MOJO_HANDLE_SIGNAL_READABLE, 56, nullptr)); |
586 | 586 |
587 // Close the producer. | 587 // Close the producer. |
588 dp->ProducerClose(); | 588 dp->ProducerClose(); |
589 | 589 |
590 // Should be never-readable. | 590 // Should be never-readable. |
591 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, waiter.Wait(1000, &context)); | 591 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, waiter.Wait(1000, &context)); |
592 EXPECT_EQ(56u, context); | 592 EXPECT_EQ(56u, context); |
593 hss = HandleSignalsState(); | 593 hss = HandleSignalsState(); |
594 dp->ConsumerRemoveWaiter(&waiter, &hss); | 594 dp->ConsumerRemoveWaiter(&waiter, &hss); |
595 EXPECT_EQ(0u, hss.satisfied_signals); | 595 EXPECT_EQ(0u, hss.satisfied_signals); |
(...skipping 23 matching lines...) Expand all Loading... | |
619 // It should be writable. | 619 // It should be writable. |
620 waiter.Init(); | 620 waiter.Init(); |
621 hss = HandleSignalsState(); | 621 hss = HandleSignalsState(); |
622 EXPECT_EQ( | 622 EXPECT_EQ( |
623 MOJO_RESULT_ALREADY_EXISTS, | 623 MOJO_RESULT_ALREADY_EXISTS, |
624 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 0, &hss)); | 624 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 0, &hss)); |
625 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); | 625 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); |
626 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); | 626 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); |
627 | 627 |
628 uint32_t num_bytes = static_cast<uint32_t>(1u * sizeof(int32_t)); | 628 uint32_t num_bytes = static_cast<uint32_t>(1u * sizeof(int32_t)); |
629 void* write_ptr = NULL; | 629 void* write_ptr = nullptr; |
630 EXPECT_EQ( | 630 EXPECT_EQ( |
631 MOJO_RESULT_OK, | 631 MOJO_RESULT_OK, |
632 dp->ProducerBeginWriteData( | 632 dp->ProducerBeginWriteData( |
633 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), false)); | 633 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), false)); |
634 EXPECT_TRUE(write_ptr != NULL); | 634 EXPECT_TRUE(write_ptr != nullptr); |
635 EXPECT_GE(num_bytes, static_cast<uint32_t>(1u * sizeof(int32_t))); | 635 EXPECT_GE(num_bytes, static_cast<uint32_t>(1u * sizeof(int32_t))); |
636 | 636 |
637 // At this point, it shouldn't be writable. | 637 // At this point, it shouldn't be writable. |
638 waiter.Init(); | 638 waiter.Init(); |
639 ASSERT_EQ( | 639 ASSERT_EQ( |
640 MOJO_RESULT_OK, | 640 MOJO_RESULT_OK, |
641 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 1, NULL)); | 641 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 1, nullptr)); |
642 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0, NULL)); | 642 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0, nullptr)); |
643 hss = HandleSignalsState(); | 643 hss = HandleSignalsState(); |
644 dp->ProducerRemoveWaiter(&waiter, &hss); | 644 dp->ProducerRemoveWaiter(&waiter, &hss); |
645 EXPECT_EQ(0u, hss.satisfied_signals); | 645 EXPECT_EQ(0u, hss.satisfied_signals); |
646 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); | 646 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); |
647 | 647 |
648 // It shouldn't be readable yet either. | 648 // It shouldn't be readable yet either. |
649 waiter.Init(); | 649 waiter.Init(); |
650 ASSERT_EQ( | 650 ASSERT_EQ( |
651 MOJO_RESULT_OK, | 651 MOJO_RESULT_OK, |
652 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 2, NULL)); | 652 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 2, nullptr)); |
653 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0, NULL)); | 653 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0, nullptr)); |
654 hss = HandleSignalsState(); | 654 hss = HandleSignalsState(); |
655 dp->ConsumerRemoveWaiter(&waiter, &hss); | 655 dp->ConsumerRemoveWaiter(&waiter, &hss); |
656 EXPECT_EQ(0u, hss.satisfied_signals); | 656 EXPECT_EQ(0u, hss.satisfied_signals); |
657 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 657 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
658 | 658 |
659 static_cast<int32_t*>(write_ptr)[0] = 123; | 659 static_cast<int32_t*>(write_ptr)[0] = 123; |
660 EXPECT_EQ( | 660 EXPECT_EQ( |
661 MOJO_RESULT_OK, | 661 MOJO_RESULT_OK, |
662 dp->ProducerEndWriteData(static_cast<uint32_t>(1u * sizeof(int32_t)))); | 662 dp->ProducerEndWriteData(static_cast<uint32_t>(1u * sizeof(int32_t)))); |
663 | 663 |
(...skipping 11 matching lines...) Expand all Loading... | |
675 hss = HandleSignalsState(); | 675 hss = HandleSignalsState(); |
676 EXPECT_EQ( | 676 EXPECT_EQ( |
677 MOJO_RESULT_ALREADY_EXISTS, | 677 MOJO_RESULT_ALREADY_EXISTS, |
678 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 4, &hss)); | 678 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 4, &hss)); |
679 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); | 679 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); |
680 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 680 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
681 | 681 |
682 // Start another two-phase write and check that it's readable even in the | 682 // Start another two-phase write and check that it's readable even in the |
683 // middle of it. | 683 // middle of it. |
684 num_bytes = static_cast<uint32_t>(1u * sizeof(int32_t)); | 684 num_bytes = static_cast<uint32_t>(1u * sizeof(int32_t)); |
685 write_ptr = NULL; | 685 write_ptr = nullptr; |
686 EXPECT_EQ( | 686 EXPECT_EQ( |
687 MOJO_RESULT_OK, | 687 MOJO_RESULT_OK, |
688 dp->ProducerBeginWriteData( | 688 dp->ProducerBeginWriteData( |
689 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), false)); | 689 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), false)); |
690 EXPECT_TRUE(write_ptr != NULL); | 690 EXPECT_TRUE(write_ptr != nullptr); |
691 EXPECT_GE(num_bytes, static_cast<uint32_t>(1u * sizeof(int32_t))); | 691 EXPECT_GE(num_bytes, static_cast<uint32_t>(1u * sizeof(int32_t))); |
692 | 692 |
693 // It should be readable. | 693 // It should be readable. |
694 waiter.Init(); | 694 waiter.Init(); |
695 hss = HandleSignalsState(); | 695 hss = HandleSignalsState(); |
696 EXPECT_EQ( | 696 EXPECT_EQ( |
697 MOJO_RESULT_ALREADY_EXISTS, | 697 MOJO_RESULT_ALREADY_EXISTS, |
698 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 5, &hss)); | 698 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 5, &hss)); |
699 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); | 699 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); |
700 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 700 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
701 | 701 |
702 // End the two-phase write without writing anything. | 702 // End the two-phase write without writing anything. |
703 EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(0u)); | 703 EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(0u)); |
704 | 704 |
705 // Start a two-phase read. | 705 // Start a two-phase read. |
706 num_bytes = static_cast<uint32_t>(1u * sizeof(int32_t)); | 706 num_bytes = static_cast<uint32_t>(1u * sizeof(int32_t)); |
707 const void* read_ptr = NULL; | 707 const void* read_ptr = nullptr; |
708 EXPECT_EQ( | 708 EXPECT_EQ( |
709 MOJO_RESULT_OK, | 709 MOJO_RESULT_OK, |
710 dp->ConsumerBeginReadData( | 710 dp->ConsumerBeginReadData( |
711 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), false)); | 711 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), false)); |
712 EXPECT_TRUE(read_ptr != NULL); | 712 EXPECT_TRUE(read_ptr != nullptr); |
713 EXPECT_EQ(static_cast<uint32_t>(1u * sizeof(int32_t)), num_bytes); | 713 EXPECT_EQ(static_cast<uint32_t>(1u * sizeof(int32_t)), num_bytes); |
714 | 714 |
715 // At this point, it should still be writable. | 715 // At this point, it should still be writable. |
716 waiter.Init(); | 716 waiter.Init(); |
717 hss = HandleSignalsState(); | 717 hss = HandleSignalsState(); |
718 EXPECT_EQ( | 718 EXPECT_EQ( |
719 MOJO_RESULT_ALREADY_EXISTS, | 719 MOJO_RESULT_ALREADY_EXISTS, |
720 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 6, &hss)); | 720 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 6, &hss)); |
721 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); | 721 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); |
722 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); | 722 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); |
723 | 723 |
724 // But not readable. | 724 // But not readable. |
725 waiter.Init(); | 725 waiter.Init(); |
726 ASSERT_EQ( | 726 ASSERT_EQ( |
727 MOJO_RESULT_OK, | 727 MOJO_RESULT_OK, |
728 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 7, NULL)); | 728 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 7, nullptr)); |
729 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0, NULL)); | 729 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0, nullptr)); |
730 hss = HandleSignalsState(); | 730 hss = HandleSignalsState(); |
731 dp->ConsumerRemoveWaiter(&waiter, &hss); | 731 dp->ConsumerRemoveWaiter(&waiter, &hss); |
732 EXPECT_EQ(0u, hss.satisfied_signals); | 732 EXPECT_EQ(0u, hss.satisfied_signals); |
733 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 733 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
734 | 734 |
735 // End the two-phase read without reading anything. | 735 // End the two-phase read without reading anything. |
736 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(0u)); | 736 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(0u)); |
737 | 737 |
738 // It should be readable again. | 738 // It should be readable again. |
739 waiter.Init(); | 739 waiter.Init(); |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
771 EXPECT_EQ( | 771 EXPECT_EQ( |
772 MOJO_RESULT_ALREADY_EXISTS, | 772 MOJO_RESULT_ALREADY_EXISTS, |
773 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 0, &hss)); | 773 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 0, &hss)); |
774 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); | 774 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); |
775 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); | 775 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); |
776 | 776 |
777 // Not readable. | 777 // Not readable. |
778 waiter.Init(); | 778 waiter.Init(); |
779 ASSERT_EQ( | 779 ASSERT_EQ( |
780 MOJO_RESULT_OK, | 780 MOJO_RESULT_OK, |
781 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 1, NULL)); | 781 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 1, nullptr)); |
782 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0, NULL)); | 782 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0, nullptr)); |
783 hss = HandleSignalsState(); | 783 hss = HandleSignalsState(); |
784 dp->ConsumerRemoveWaiter(&waiter, &hss); | 784 dp->ConsumerRemoveWaiter(&waiter, &hss); |
785 EXPECT_EQ(0u, hss.satisfied_signals); | 785 EXPECT_EQ(0u, hss.satisfied_signals); |
786 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 786 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
787 | 787 |
788 uint32_t num_bytes = static_cast<uint32_t>(sizeof(int32_t)); | 788 uint32_t num_bytes = static_cast<uint32_t>(sizeof(int32_t)); |
789 int32_t element = 123; | 789 int32_t element = 123; |
790 EXPECT_EQ(MOJO_RESULT_OK, | 790 EXPECT_EQ(MOJO_RESULT_OK, |
791 dp->ProducerWriteData(UserPointer<const void>(&element), | 791 dp->ProducerWriteData(UserPointer<const void>(&element), |
792 MakeUserPointer(&num_bytes), | 792 MakeUserPointer(&num_bytes), |
(...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
854 EXPECT_EQ( | 854 EXPECT_EQ( |
855 MOJO_RESULT_ALREADY_EXISTS, | 855 MOJO_RESULT_ALREADY_EXISTS, |
856 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 6, &hss)); | 856 dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 6, &hss)); |
857 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); | 857 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); |
858 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); | 858 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); |
859 | 859 |
860 // No longer readable. | 860 // No longer readable. |
861 waiter.Init(); | 861 waiter.Init(); |
862 ASSERT_EQ( | 862 ASSERT_EQ( |
863 MOJO_RESULT_OK, | 863 MOJO_RESULT_OK, |
864 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 7, NULL)); | 864 dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 7, nullptr)); |
865 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0, NULL)); | 865 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, waiter.Wait(0, nullptr)); |
866 hss = HandleSignalsState(); | 866 hss = HandleSignalsState(); |
867 dp->ConsumerRemoveWaiter(&waiter, &hss); | 867 dp->ConsumerRemoveWaiter(&waiter, &hss); |
868 EXPECT_EQ(0u, hss.satisfied_signals); | 868 EXPECT_EQ(0u, hss.satisfied_signals); |
869 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 869 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
870 | 870 |
871 dp->ProducerClose(); | 871 dp->ProducerClose(); |
872 dp->ConsumerClose(); | 872 dp->ConsumerClose(); |
873 } | 873 } |
874 | 874 |
875 void Seq(int32_t start, size_t count, int32_t* out) { | 875 void Seq(int32_t start, size_t count, int32_t* out) { |
(...skipping 111 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
987 expected_buffer[8] = 303; | 987 expected_buffer[8] = 303; |
988 expected_buffer[9] = 304; | 988 expected_buffer[9] = 304; |
989 EXPECT_EQ(0, memcmp(buffer, expected_buffer, sizeof(buffer))); | 989 EXPECT_EQ(0, memcmp(buffer, expected_buffer, sizeof(buffer))); |
990 | 990 |
991 // Test two-phase writes, including in all-or-none mode. | 991 // Test two-phase writes, including in all-or-none mode. |
992 // Note: Again, the following depends on an implementation detail -- namely | 992 // Note: Again, the following depends on an implementation detail -- namely |
993 // that the write pointer will point at the 5th element of the buffer (and the | 993 // that the write pointer will point at the 5th element of the buffer (and the |
994 // buffer has exactly the capacity requested). | 994 // buffer has exactly the capacity requested). |
995 | 995 |
996 num_bytes = 0u; | 996 num_bytes = 0u; |
997 void* write_ptr = NULL; | 997 void* write_ptr = nullptr; |
998 EXPECT_EQ( | 998 EXPECT_EQ( |
999 MOJO_RESULT_OK, | 999 MOJO_RESULT_OK, |
1000 dp->ProducerBeginWriteData( | 1000 dp->ProducerBeginWriteData( |
1001 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), false)); | 1001 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), false)); |
1002 EXPECT_TRUE(write_ptr != NULL); | 1002 EXPECT_TRUE(write_ptr != nullptr); |
1003 EXPECT_EQ(6u * sizeof(int32_t), num_bytes); | 1003 EXPECT_EQ(6u * sizeof(int32_t), num_bytes); |
1004 Seq(400, 6, static_cast<int32_t*>(write_ptr)); | 1004 Seq(400, 6, static_cast<int32_t*>(write_ptr)); |
1005 EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(6u * sizeof(int32_t))); | 1005 EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(6u * sizeof(int32_t))); |
1006 // Internally, a circular buffer would now look like: | 1006 // Internally, a circular buffer would now look like: |
1007 // -, -, -, -, 400, 401, 402, 403, 404, 405 | 1007 // -, -, -, -, 400, 401, 402, 403, 404, 405 |
1008 | 1008 |
1009 // |ProducerBeginWriteData()| ignores |*num_bytes| except in "all-or-none" | 1009 // |ProducerBeginWriteData()| ignores |*num_bytes| except in "all-or-none" |
1010 // mode. | 1010 // mode. |
1011 num_bytes = 6u * sizeof(int32_t); | 1011 num_bytes = 6u * sizeof(int32_t); |
1012 write_ptr = NULL; | 1012 write_ptr = nullptr; |
1013 EXPECT_EQ( | 1013 EXPECT_EQ( |
1014 MOJO_RESULT_OK, | 1014 MOJO_RESULT_OK, |
1015 dp->ProducerBeginWriteData( | 1015 dp->ProducerBeginWriteData( |
1016 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), false)); | 1016 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), false)); |
1017 EXPECT_EQ(4u * sizeof(int32_t), num_bytes); | 1017 EXPECT_EQ(4u * sizeof(int32_t), num_bytes); |
1018 static_cast<int32_t*>(write_ptr)[0] = 500; | 1018 static_cast<int32_t*>(write_ptr)[0] = 500; |
1019 EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(1u * sizeof(int32_t))); | 1019 EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(1u * sizeof(int32_t))); |
1020 // Internally, a circular buffer would now look like: | 1020 // Internally, a circular buffer would now look like: |
1021 // 500, -, -, -, 400, 401, 402, 403, 404, 405 | 1021 // 500, -, -, -, 400, 401, 402, 403, 404, 405 |
1022 | 1022 |
1023 // Requesting a 10-element buffer in all-or-none mode fails at this point. | 1023 // Requesting a 10-element buffer in all-or-none mode fails at this point. |
1024 num_bytes = 10u * sizeof(int32_t); | 1024 num_bytes = 10u * sizeof(int32_t); |
1025 write_ptr = NULL; | 1025 write_ptr = nullptr; |
1026 EXPECT_EQ( | 1026 EXPECT_EQ( |
1027 MOJO_RESULT_OUT_OF_RANGE, | 1027 MOJO_RESULT_OUT_OF_RANGE, |
1028 dp->ProducerBeginWriteData( | 1028 dp->ProducerBeginWriteData( |
1029 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), true)); | 1029 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), true)); |
1030 | 1030 |
1031 // But requesting, say, a 5-element (up to 9, really) buffer should be okay. | 1031 // But requesting, say, a 5-element (up to 9, really) buffer should be okay. |
1032 // It will discard two elements. | 1032 // It will discard two elements. |
1033 num_bytes = 5u * sizeof(int32_t); | 1033 num_bytes = 5u * sizeof(int32_t); |
1034 write_ptr = NULL; | 1034 write_ptr = nullptr; |
1035 EXPECT_EQ( | 1035 EXPECT_EQ( |
1036 MOJO_RESULT_OK, | 1036 MOJO_RESULT_OK, |
1037 dp->ProducerBeginWriteData( | 1037 dp->ProducerBeginWriteData( |
1038 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), true)); | 1038 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), true)); |
1039 EXPECT_EQ(5u * sizeof(int32_t), num_bytes); | 1039 EXPECT_EQ(5u * sizeof(int32_t), num_bytes); |
1040 // Only write 4 elements though. | 1040 // Only write 4 elements though. |
1041 Seq(600, 4, static_cast<int32_t*>(write_ptr)); | 1041 Seq(600, 4, static_cast<int32_t*>(write_ptr)); |
1042 EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(4u * sizeof(int32_t))); | 1042 EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(4u * sizeof(int32_t))); |
1043 // Internally, a circular buffer would now look like: | 1043 // Internally, a circular buffer would now look like: |
1044 // 500, 600, 601, 602, 603, -, 402, 403, 404, 405 | 1044 // 500, 600, 601, 602, 603, -, 402, 403, 404, 405 |
1045 | 1045 |
1046 // Do this again. Make sure we can get a buffer all the way out to the end of | 1046 // Do this again. Make sure we can get a buffer all the way out to the end of |
1047 // the internal buffer. | 1047 // the internal buffer. |
1048 num_bytes = 5u * sizeof(int32_t); | 1048 num_bytes = 5u * sizeof(int32_t); |
1049 write_ptr = NULL; | 1049 write_ptr = nullptr; |
1050 EXPECT_EQ( | 1050 EXPECT_EQ( |
1051 MOJO_RESULT_OK, | 1051 MOJO_RESULT_OK, |
1052 dp->ProducerBeginWriteData( | 1052 dp->ProducerBeginWriteData( |
1053 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), true)); | 1053 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), true)); |
1054 EXPECT_EQ(5u * sizeof(int32_t), num_bytes); | 1054 EXPECT_EQ(5u * sizeof(int32_t), num_bytes); |
1055 // Only write 3 elements though. | 1055 // Only write 3 elements though. |
1056 Seq(700, 3, static_cast<int32_t*>(write_ptr)); | 1056 Seq(700, 3, static_cast<int32_t*>(write_ptr)); |
1057 EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(3u * sizeof(int32_t))); | 1057 EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(3u * sizeof(int32_t))); |
1058 // Internally, a circular buffer would now look like: | 1058 // Internally, a circular buffer would now look like: |
1059 // 500, 600, 601, 602, 603, 700, 701, 702, -, - | 1059 // 500, 600, 601, 602, 603, 700, 701, 702, -, - |
(...skipping 299 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
1359 }; | 1359 }; |
1360 MojoCreateDataPipeOptions validated_options = {0}; | 1360 MojoCreateDataPipeOptions validated_options = {0}; |
1361 EXPECT_EQ(MOJO_RESULT_OK, | 1361 EXPECT_EQ(MOJO_RESULT_OK, |
1362 DataPipe::ValidateCreateOptions(MakeUserPointer(&options), | 1362 DataPipe::ValidateCreateOptions(MakeUserPointer(&options), |
1363 &validated_options)); | 1363 &validated_options)); |
1364 | 1364 |
1365 scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options)); | 1365 scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options)); |
1366 | 1366 |
1367 // Try writing way too much (two-phase). | 1367 // Try writing way too much (two-phase). |
1368 uint32_t num_bytes = 20u * sizeof(int32_t); | 1368 uint32_t num_bytes = 20u * sizeof(int32_t); |
1369 void* write_ptr = NULL; | 1369 void* write_ptr = nullptr; |
1370 EXPECT_EQ( | 1370 EXPECT_EQ( |
1371 MOJO_RESULT_OUT_OF_RANGE, | 1371 MOJO_RESULT_OUT_OF_RANGE, |
1372 dp->ProducerBeginWriteData( | 1372 dp->ProducerBeginWriteData( |
1373 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), true)); | 1373 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), true)); |
1374 | 1374 |
1375 // Try writing an amount which isn't a multiple of the element size | 1375 // Try writing an amount which isn't a multiple of the element size |
1376 // (two-phase). | 1376 // (two-phase). |
1377 COMPILE_ASSERT(sizeof(int32_t) > 1u, wow_int32_ts_have_size_1); | 1377 COMPILE_ASSERT(sizeof(int32_t) > 1u, wow_int32_ts_have_size_1); |
1378 num_bytes = 1u; | 1378 num_bytes = 1u; |
1379 write_ptr = NULL; | 1379 write_ptr = nullptr; |
1380 EXPECT_EQ( | 1380 EXPECT_EQ( |
1381 MOJO_RESULT_INVALID_ARGUMENT, | 1381 MOJO_RESULT_INVALID_ARGUMENT, |
1382 dp->ProducerBeginWriteData( | 1382 dp->ProducerBeginWriteData( |
1383 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), true)); | 1383 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), true)); |
1384 | 1384 |
1385 // Try reading way too much (two-phase). | 1385 // Try reading way too much (two-phase). |
1386 num_bytes = 20u * sizeof(int32_t); | 1386 num_bytes = 20u * sizeof(int32_t); |
1387 const void* read_ptr = NULL; | 1387 const void* read_ptr = nullptr; |
1388 EXPECT_EQ(MOJO_RESULT_OUT_OF_RANGE, | 1388 EXPECT_EQ(MOJO_RESULT_OUT_OF_RANGE, |
1389 dp->ConsumerBeginReadData( | 1389 dp->ConsumerBeginReadData( |
1390 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), true)); | 1390 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), true)); |
1391 | 1391 |
1392 // Write half (two-phase). | 1392 // Write half (two-phase). |
1393 num_bytes = 5u * sizeof(int32_t); | 1393 num_bytes = 5u * sizeof(int32_t); |
1394 write_ptr = NULL; | 1394 write_ptr = nullptr; |
1395 EXPECT_EQ( | 1395 EXPECT_EQ( |
1396 MOJO_RESULT_OK, | 1396 MOJO_RESULT_OK, |
1397 dp->ProducerBeginWriteData( | 1397 dp->ProducerBeginWriteData( |
1398 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), true)); | 1398 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), true)); |
1399 // May provide more space than requested. | 1399 // May provide more space than requested. |
1400 EXPECT_GE(num_bytes, 5u * sizeof(int32_t)); | 1400 EXPECT_GE(num_bytes, 5u * sizeof(int32_t)); |
1401 EXPECT_TRUE(write_ptr != NULL); | 1401 EXPECT_TRUE(write_ptr != nullptr); |
1402 Seq(0, 5, static_cast<int32_t*>(write_ptr)); | 1402 Seq(0, 5, static_cast<int32_t*>(write_ptr)); |
1403 EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(5u * sizeof(int32_t))); | 1403 EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(5u * sizeof(int32_t))); |
1404 | 1404 |
1405 // Try reading an amount which isn't a multiple of the element size | 1405 // Try reading an amount which isn't a multiple of the element size |
1406 // (two-phase). | 1406 // (two-phase). |
1407 num_bytes = 1u; | 1407 num_bytes = 1u; |
1408 read_ptr = NULL; | 1408 read_ptr = nullptr; |
1409 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 1409 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
1410 dp->ConsumerBeginReadData( | 1410 dp->ConsumerBeginReadData( |
1411 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), true)); | 1411 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), true)); |
1412 | 1412 |
1413 // Read one (two-phase). | 1413 // Read one (two-phase). |
1414 num_bytes = 1u * sizeof(int32_t); | 1414 num_bytes = 1u * sizeof(int32_t); |
1415 read_ptr = NULL; | 1415 read_ptr = nullptr; |
1416 EXPECT_EQ(MOJO_RESULT_OK, | 1416 EXPECT_EQ(MOJO_RESULT_OK, |
1417 dp->ConsumerBeginReadData( | 1417 dp->ConsumerBeginReadData( |
1418 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), true)); | 1418 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), true)); |
1419 EXPECT_GE(num_bytes, 1u * sizeof(int32_t)); | 1419 EXPECT_GE(num_bytes, 1u * sizeof(int32_t)); |
1420 EXPECT_EQ(0, static_cast<const int32_t*>(read_ptr)[0]); | 1420 EXPECT_EQ(0, static_cast<const int32_t*>(read_ptr)[0]); |
1421 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(1u * sizeof(int32_t))); | 1421 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(1u * sizeof(int32_t))); |
1422 | 1422 |
1423 // We should have four left, leaving room for six. | 1423 // We should have four left, leaving room for six. |
1424 num_bytes = 0u; | 1424 num_bytes = 0u; |
1425 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes))); | 1425 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes))); |
1426 EXPECT_EQ(4u * sizeof(int32_t), num_bytes); | 1426 EXPECT_EQ(4u * sizeof(int32_t), num_bytes); |
1427 | 1427 |
1428 // Assuming a tight circular buffer of the specified capacity, we can't do a | 1428 // Assuming a tight circular buffer of the specified capacity, we can't do a |
1429 // two-phase write of six now. | 1429 // two-phase write of six now. |
1430 num_bytes = 6u * sizeof(int32_t); | 1430 num_bytes = 6u * sizeof(int32_t); |
1431 write_ptr = NULL; | 1431 write_ptr = nullptr; |
1432 EXPECT_EQ( | 1432 EXPECT_EQ( |
1433 MOJO_RESULT_OUT_OF_RANGE, | 1433 MOJO_RESULT_OUT_OF_RANGE, |
1434 dp->ProducerBeginWriteData( | 1434 dp->ProducerBeginWriteData( |
1435 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), true)); | 1435 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), true)); |
1436 | 1436 |
1437 // Write six elements (simple), filling the buffer. | 1437 // Write six elements (simple), filling the buffer. |
1438 num_bytes = 6u * sizeof(int32_t); | 1438 num_bytes = 6u * sizeof(int32_t); |
1439 int32_t buffer[100]; | 1439 int32_t buffer[100]; |
1440 Seq(100, 6, buffer); | 1440 Seq(100, 6, buffer); |
1441 EXPECT_EQ( | 1441 EXPECT_EQ( |
1442 MOJO_RESULT_OK, | 1442 MOJO_RESULT_OK, |
1443 dp->ProducerWriteData( | 1443 dp->ProducerWriteData( |
1444 UserPointer<const void>(buffer), MakeUserPointer(&num_bytes), true)); | 1444 UserPointer<const void>(buffer), MakeUserPointer(&num_bytes), true)); |
1445 EXPECT_EQ(6u * sizeof(int32_t), num_bytes); | 1445 EXPECT_EQ(6u * sizeof(int32_t), num_bytes); |
1446 | 1446 |
1447 // We have ten. | 1447 // We have ten. |
1448 num_bytes = 0u; | 1448 num_bytes = 0u; |
1449 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes))); | 1449 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes))); |
1450 EXPECT_EQ(10u * sizeof(int32_t), num_bytes); | 1450 EXPECT_EQ(10u * sizeof(int32_t), num_bytes); |
1451 | 1451 |
1452 // But a two-phase read of ten should fail. | 1452 // But a two-phase read of ten should fail. |
1453 num_bytes = 10u * sizeof(int32_t); | 1453 num_bytes = 10u * sizeof(int32_t); |
1454 read_ptr = NULL; | 1454 read_ptr = nullptr; |
1455 EXPECT_EQ(MOJO_RESULT_OUT_OF_RANGE, | 1455 EXPECT_EQ(MOJO_RESULT_OUT_OF_RANGE, |
1456 dp->ConsumerBeginReadData( | 1456 dp->ConsumerBeginReadData( |
1457 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), true)); | 1457 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), true)); |
1458 | 1458 |
1459 // Close the producer. | 1459 // Close the producer. |
1460 dp->ProducerClose(); | 1460 dp->ProducerClose(); |
1461 | 1461 |
1462 // A two-phase read of nine should work. | 1462 // A two-phase read of nine should work. |
1463 num_bytes = 9u * sizeof(int32_t); | 1463 num_bytes = 9u * sizeof(int32_t); |
1464 read_ptr = NULL; | 1464 read_ptr = nullptr; |
1465 EXPECT_EQ(MOJO_RESULT_OK, | 1465 EXPECT_EQ(MOJO_RESULT_OK, |
1466 dp->ConsumerBeginReadData( | 1466 dp->ConsumerBeginReadData( |
1467 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), true)); | 1467 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), true)); |
1468 EXPECT_GE(num_bytes, 9u * sizeof(int32_t)); | 1468 EXPECT_GE(num_bytes, 9u * sizeof(int32_t)); |
1469 EXPECT_EQ(1, static_cast<const int32_t*>(read_ptr)[0]); | 1469 EXPECT_EQ(1, static_cast<const int32_t*>(read_ptr)[0]); |
1470 EXPECT_EQ(2, static_cast<const int32_t*>(read_ptr)[1]); | 1470 EXPECT_EQ(2, static_cast<const int32_t*>(read_ptr)[1]); |
1471 EXPECT_EQ(3, static_cast<const int32_t*>(read_ptr)[2]); | 1471 EXPECT_EQ(3, static_cast<const int32_t*>(read_ptr)[2]); |
1472 EXPECT_EQ(4, static_cast<const int32_t*>(read_ptr)[3]); | 1472 EXPECT_EQ(4, static_cast<const int32_t*>(read_ptr)[3]); |
1473 EXPECT_EQ(100, static_cast<const int32_t*>(read_ptr)[4]); | 1473 EXPECT_EQ(100, static_cast<const int32_t*>(read_ptr)[4]); |
1474 EXPECT_EQ(101, static_cast<const int32_t*>(read_ptr)[5]); | 1474 EXPECT_EQ(101, static_cast<const int32_t*>(read_ptr)[5]); |
1475 EXPECT_EQ(102, static_cast<const int32_t*>(read_ptr)[6]); | 1475 EXPECT_EQ(102, static_cast<const int32_t*>(read_ptr)[6]); |
1476 EXPECT_EQ(103, static_cast<const int32_t*>(read_ptr)[7]); | 1476 EXPECT_EQ(103, static_cast<const int32_t*>(read_ptr)[7]); |
1477 EXPECT_EQ(104, static_cast<const int32_t*>(read_ptr)[8]); | 1477 EXPECT_EQ(104, static_cast<const int32_t*>(read_ptr)[8]); |
1478 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(9u * sizeof(int32_t))); | 1478 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(9u * sizeof(int32_t))); |
1479 | 1479 |
1480 // A two-phase read of two should fail, with "failed precondition". | 1480 // A two-phase read of two should fail, with "failed precondition". |
1481 num_bytes = 2u * sizeof(int32_t); | 1481 num_bytes = 2u * sizeof(int32_t); |
1482 read_ptr = NULL; | 1482 read_ptr = nullptr; |
1483 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 1483 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
1484 dp->ConsumerBeginReadData( | 1484 dp->ConsumerBeginReadData( |
1485 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), true)); | 1485 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), true)); |
1486 | 1486 |
1487 dp->ConsumerClose(); | 1487 dp->ConsumerClose(); |
1488 } | 1488 } |
1489 | 1489 |
1490 // Tests that |ProducerWriteData()| and |ConsumerReadData()| writes and reads, | 1490 // Tests that |ProducerWriteData()| and |ConsumerReadData()| writes and reads, |
1491 // respectively, as much as possible, even if it has to "wrap around" the | 1491 // respectively, as much as possible, even if it has to "wrap around" the |
1492 // internal circular buffer. (Note that the two-phase write and read do not do | 1492 // internal circular buffer. (Note that the two-phase write and read do not do |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
1526 EXPECT_EQ( | 1526 EXPECT_EQ( |
1527 MOJO_RESULT_OK, | 1527 MOJO_RESULT_OK, |
1528 dp->ConsumerReadData( | 1528 dp->ConsumerReadData( |
1529 UserPointer<void>(read_buffer), MakeUserPointer(&num_bytes), false)); | 1529 UserPointer<void>(read_buffer), MakeUserPointer(&num_bytes), false)); |
1530 EXPECT_EQ(10u, num_bytes); | 1530 EXPECT_EQ(10u, num_bytes); |
1531 EXPECT_EQ(0, memcmp(read_buffer, &test_data[0], 10u)); | 1531 EXPECT_EQ(0, memcmp(read_buffer, &test_data[0], 10u)); |
1532 | 1532 |
1533 // Check that a two-phase write can now only write (at most) 80 bytes. (This | 1533 // Check that a two-phase write can now only write (at most) 80 bytes. (This |
1534 // checks an implementation detail; this behavior is not guaranteed, but we | 1534 // checks an implementation detail; this behavior is not guaranteed, but we |
1535 // need it for this test.) | 1535 // need it for this test.) |
1536 void* write_buffer_ptr = NULL; | 1536 void* write_buffer_ptr = nullptr; |
1537 num_bytes = 0u; | 1537 num_bytes = 0u; |
1538 EXPECT_EQ(MOJO_RESULT_OK, | 1538 EXPECT_EQ(MOJO_RESULT_OK, |
1539 dp->ProducerBeginWriteData(MakeUserPointer(&write_buffer_ptr), | 1539 dp->ProducerBeginWriteData(MakeUserPointer(&write_buffer_ptr), |
1540 MakeUserPointer(&num_bytes), | 1540 MakeUserPointer(&num_bytes), |
1541 false)); | 1541 false)); |
1542 EXPECT_TRUE(write_buffer_ptr != NULL); | 1542 EXPECT_TRUE(write_buffer_ptr != nullptr); |
1543 EXPECT_EQ(80u, num_bytes); | 1543 EXPECT_EQ(80u, num_bytes); |
1544 EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(0u)); | 1544 EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(0u)); |
1545 | 1545 |
1546 // Write as much data as we can (using |ProducerWriteData()|). We should write | 1546 // Write as much data as we can (using |ProducerWriteData()|). We should write |
1547 // 90 bytes. | 1547 // 90 bytes. |
1548 num_bytes = 200u; | 1548 num_bytes = 200u; |
1549 EXPECT_EQ(MOJO_RESULT_OK, | 1549 EXPECT_EQ(MOJO_RESULT_OK, |
1550 dp->ProducerWriteData(UserPointer<const void>(&test_data[20]), | 1550 dp->ProducerWriteData(UserPointer<const void>(&test_data[20]), |
1551 MakeUserPointer(&num_bytes), | 1551 MakeUserPointer(&num_bytes), |
1552 false)); | 1552 false)); |
1553 EXPECT_EQ(90u, num_bytes); | 1553 EXPECT_EQ(90u, num_bytes); |
1554 | 1554 |
1555 // Check that a two-phase read can now only read (at most) 90 bytes. (This | 1555 // Check that a two-phase read can now only read (at most) 90 bytes. (This |
1556 // checks an implementation detail; this behavior is not guaranteed, but we | 1556 // checks an implementation detail; this behavior is not guaranteed, but we |
1557 // need it for this test.) | 1557 // need it for this test.) |
1558 const void* read_buffer_ptr = NULL; | 1558 const void* read_buffer_ptr = nullptr; |
1559 num_bytes = 0u; | 1559 num_bytes = 0u; |
1560 EXPECT_EQ(MOJO_RESULT_OK, | 1560 EXPECT_EQ(MOJO_RESULT_OK, |
1561 dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr), | 1561 dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr), |
1562 MakeUserPointer(&num_bytes), | 1562 MakeUserPointer(&num_bytes), |
1563 false)); | 1563 false)); |
1564 EXPECT_TRUE(read_buffer_ptr != NULL); | 1564 EXPECT_TRUE(read_buffer_ptr != nullptr); |
1565 EXPECT_EQ(90u, num_bytes); | 1565 EXPECT_EQ(90u, num_bytes); |
1566 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(0u)); | 1566 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(0u)); |
1567 | 1567 |
1568 // Read as much as possible (using |ConsumerReadData()|). We should read 100 | 1568 // Read as much as possible (using |ConsumerReadData()|). We should read 100 |
1569 // bytes. | 1569 // bytes. |
1570 num_bytes = | 1570 num_bytes = |
1571 static_cast<uint32_t>(arraysize(read_buffer) * sizeof(read_buffer[0])); | 1571 static_cast<uint32_t>(arraysize(read_buffer) * sizeof(read_buffer[0])); |
1572 memset(read_buffer, 0, num_bytes); | 1572 memset(read_buffer, 0, num_bytes); |
1573 EXPECT_EQ( | 1573 EXPECT_EQ( |
1574 MOJO_RESULT_OK, | 1574 MOJO_RESULT_OK, |
(...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
1612 | 1612 |
1613 // Write it again, so we'll have something left over. | 1613 // Write it again, so we'll have something left over. |
1614 num_bytes = kTestDataSize; | 1614 num_bytes = kTestDataSize; |
1615 EXPECT_EQ(MOJO_RESULT_OK, | 1615 EXPECT_EQ(MOJO_RESULT_OK, |
1616 dp->ProducerWriteData(UserPointer<const void>(kTestData), | 1616 dp->ProducerWriteData(UserPointer<const void>(kTestData), |
1617 MakeUserPointer(&num_bytes), | 1617 MakeUserPointer(&num_bytes), |
1618 false)); | 1618 false)); |
1619 EXPECT_EQ(kTestDataSize, num_bytes); | 1619 EXPECT_EQ(kTestDataSize, num_bytes); |
1620 | 1620 |
1621 // Start two-phase write. | 1621 // Start two-phase write. |
1622 void* write_buffer_ptr = NULL; | 1622 void* write_buffer_ptr = nullptr; |
1623 num_bytes = 0u; | 1623 num_bytes = 0u; |
1624 EXPECT_EQ(MOJO_RESULT_OK, | 1624 EXPECT_EQ(MOJO_RESULT_OK, |
1625 dp->ProducerBeginWriteData(MakeUserPointer(&write_buffer_ptr), | 1625 dp->ProducerBeginWriteData(MakeUserPointer(&write_buffer_ptr), |
1626 MakeUserPointer(&num_bytes), | 1626 MakeUserPointer(&num_bytes), |
1627 false)); | 1627 false)); |
1628 EXPECT_TRUE(write_buffer_ptr != NULL); | 1628 EXPECT_TRUE(write_buffer_ptr != nullptr); |
1629 EXPECT_GT(num_bytes, 0u); | 1629 EXPECT_GT(num_bytes, 0u); |
1630 | 1630 |
1631 // Start two-phase read. | 1631 // Start two-phase read. |
1632 const void* read_buffer_ptr = NULL; | 1632 const void* read_buffer_ptr = nullptr; |
1633 num_bytes = 0u; | 1633 num_bytes = 0u; |
1634 EXPECT_EQ(MOJO_RESULT_OK, | 1634 EXPECT_EQ(MOJO_RESULT_OK, |
1635 dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr), | 1635 dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr), |
1636 MakeUserPointer(&num_bytes), | 1636 MakeUserPointer(&num_bytes), |
1637 false)); | 1637 false)); |
1638 EXPECT_TRUE(read_buffer_ptr != NULL); | 1638 EXPECT_TRUE(read_buffer_ptr != nullptr); |
1639 EXPECT_EQ(2u * kTestDataSize, num_bytes); | 1639 EXPECT_EQ(2u * kTestDataSize, num_bytes); |
1640 | 1640 |
1641 // Close the producer. | 1641 // Close the producer. |
1642 dp->ProducerClose(); | 1642 dp->ProducerClose(); |
1643 | 1643 |
1644 // The consumer can finish its two-phase read. | 1644 // The consumer can finish its two-phase read. |
1645 EXPECT_EQ(0, memcmp(read_buffer_ptr, kTestData, kTestDataSize)); | 1645 EXPECT_EQ(0, memcmp(read_buffer_ptr, kTestData, kTestDataSize)); |
1646 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(kTestDataSize)); | 1646 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(kTestDataSize)); |
1647 | 1647 |
1648 // And start another. | 1648 // And start another. |
1649 read_buffer_ptr = NULL; | 1649 read_buffer_ptr = nullptr; |
1650 num_bytes = 0u; | 1650 num_bytes = 0u; |
1651 EXPECT_EQ(MOJO_RESULT_OK, | 1651 EXPECT_EQ(MOJO_RESULT_OK, |
1652 dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr), | 1652 dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr), |
1653 MakeUserPointer(&num_bytes), | 1653 MakeUserPointer(&num_bytes), |
1654 false)); | 1654 false)); |
1655 EXPECT_TRUE(read_buffer_ptr != NULL); | 1655 EXPECT_TRUE(read_buffer_ptr != nullptr); |
1656 EXPECT_EQ(kTestDataSize, num_bytes); | 1656 EXPECT_EQ(kTestDataSize, num_bytes); |
1657 | 1657 |
1658 // Close the consumer, which cancels the two-phase read. | 1658 // Close the consumer, which cancels the two-phase read. |
1659 dp->ConsumerClose(); | 1659 dp->ConsumerClose(); |
1660 } | 1660 } |
1661 | 1661 |
1662 // Close consumer first, then producer. | 1662 // Close consumer first, then producer. |
1663 { | 1663 { |
1664 scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options)); | 1664 scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options)); |
1665 | 1665 |
1666 // Write some data, so we'll have something to read. | 1666 // Write some data, so we'll have something to read. |
1667 uint32_t num_bytes = kTestDataSize; | 1667 uint32_t num_bytes = kTestDataSize; |
1668 EXPECT_EQ(MOJO_RESULT_OK, | 1668 EXPECT_EQ(MOJO_RESULT_OK, |
1669 dp->ProducerWriteData(UserPointer<const void>(kTestData), | 1669 dp->ProducerWriteData(UserPointer<const void>(kTestData), |
1670 MakeUserPointer(&num_bytes), | 1670 MakeUserPointer(&num_bytes), |
1671 false)); | 1671 false)); |
1672 EXPECT_EQ(kTestDataSize, num_bytes); | 1672 EXPECT_EQ(kTestDataSize, num_bytes); |
1673 | 1673 |
1674 // Start two-phase write. | 1674 // Start two-phase write. |
1675 void* write_buffer_ptr = NULL; | 1675 void* write_buffer_ptr = nullptr; |
1676 num_bytes = 0u; | 1676 num_bytes = 0u; |
1677 EXPECT_EQ(MOJO_RESULT_OK, | 1677 EXPECT_EQ(MOJO_RESULT_OK, |
1678 dp->ProducerBeginWriteData(MakeUserPointer(&write_buffer_ptr), | 1678 dp->ProducerBeginWriteData(MakeUserPointer(&write_buffer_ptr), |
1679 MakeUserPointer(&num_bytes), | 1679 MakeUserPointer(&num_bytes), |
1680 false)); | 1680 false)); |
1681 EXPECT_TRUE(write_buffer_ptr != NULL); | 1681 EXPECT_TRUE(write_buffer_ptr != nullptr); |
1682 ASSERT_GT(num_bytes, kTestDataSize); | 1682 ASSERT_GT(num_bytes, kTestDataSize); |
1683 | 1683 |
1684 // Start two-phase read. | 1684 // Start two-phase read. |
1685 const void* read_buffer_ptr = NULL; | 1685 const void* read_buffer_ptr = nullptr; |
1686 num_bytes = 0u; | 1686 num_bytes = 0u; |
1687 EXPECT_EQ(MOJO_RESULT_OK, | 1687 EXPECT_EQ(MOJO_RESULT_OK, |
1688 dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr), | 1688 dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr), |
1689 MakeUserPointer(&num_bytes), | 1689 MakeUserPointer(&num_bytes), |
1690 false)); | 1690 false)); |
1691 EXPECT_TRUE(read_buffer_ptr != NULL); | 1691 EXPECT_TRUE(read_buffer_ptr != nullptr); |
1692 EXPECT_EQ(kTestDataSize, num_bytes); | 1692 EXPECT_EQ(kTestDataSize, num_bytes); |
1693 | 1693 |
1694 // Close the consumer. | 1694 // Close the consumer. |
1695 dp->ConsumerClose(); | 1695 dp->ConsumerClose(); |
1696 | 1696 |
1697 // Actually write some data. (Note: Premature freeing of the buffer would | 1697 // Actually write some data. (Note: Premature freeing of the buffer would |
1698 // probably only be detected under ASAN or similar.) | 1698 // probably only be detected under ASAN or similar.) |
1699 memcpy(write_buffer_ptr, kTestData, kTestDataSize); | 1699 memcpy(write_buffer_ptr, kTestData, kTestDataSize); |
1700 // Note: Even though the consumer has been closed, ending the two-phase | 1700 // Note: Even though the consumer has been closed, ending the two-phase |
1701 // write will report success. | 1701 // write will report success. |
1702 EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(kTestDataSize)); | 1702 EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(kTestDataSize)); |
1703 | 1703 |
1704 // But trying to write should result in failure. | 1704 // But trying to write should result in failure. |
1705 num_bytes = kTestDataSize; | 1705 num_bytes = kTestDataSize; |
1706 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 1706 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
1707 dp->ProducerWriteData(UserPointer<const void>(kTestData), | 1707 dp->ProducerWriteData(UserPointer<const void>(kTestData), |
1708 MakeUserPointer(&num_bytes), | 1708 MakeUserPointer(&num_bytes), |
1709 false)); | 1709 false)); |
1710 | 1710 |
1711 // As will trying to start another two-phase write. | 1711 // As will trying to start another two-phase write. |
1712 write_buffer_ptr = NULL; | 1712 write_buffer_ptr = nullptr; |
1713 num_bytes = 0u; | 1713 num_bytes = 0u; |
1714 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 1714 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
1715 dp->ProducerBeginWriteData(MakeUserPointer(&write_buffer_ptr), | 1715 dp->ProducerBeginWriteData(MakeUserPointer(&write_buffer_ptr), |
1716 MakeUserPointer(&num_bytes), | 1716 MakeUserPointer(&num_bytes), |
1717 false)); | 1717 false)); |
1718 | 1718 |
1719 dp->ProducerClose(); | 1719 dp->ProducerClose(); |
1720 } | 1720 } |
1721 | 1721 |
1722 // Test closing the consumer first, then the producer, with an active | 1722 // Test closing the consumer first, then the producer, with an active |
1723 // two-phase write. | 1723 // two-phase write. |
1724 { | 1724 { |
1725 scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options)); | 1725 scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options)); |
1726 | 1726 |
1727 // Start two-phase write. | 1727 // Start two-phase write. |
1728 void* write_buffer_ptr = NULL; | 1728 void* write_buffer_ptr = nullptr; |
1729 uint32_t num_bytes = 0u; | 1729 uint32_t num_bytes = 0u; |
1730 EXPECT_EQ(MOJO_RESULT_OK, | 1730 EXPECT_EQ(MOJO_RESULT_OK, |
1731 dp->ProducerBeginWriteData(MakeUserPointer(&write_buffer_ptr), | 1731 dp->ProducerBeginWriteData(MakeUserPointer(&write_buffer_ptr), |
1732 MakeUserPointer(&num_bytes), | 1732 MakeUserPointer(&num_bytes), |
1733 false)); | 1733 false)); |
1734 EXPECT_TRUE(write_buffer_ptr != NULL); | 1734 EXPECT_TRUE(write_buffer_ptr != nullptr); |
1735 ASSERT_GT(num_bytes, kTestDataSize); | 1735 ASSERT_GT(num_bytes, kTestDataSize); |
1736 | 1736 |
1737 dp->ConsumerClose(); | 1737 dp->ConsumerClose(); |
1738 dp->ProducerClose(); | 1738 dp->ProducerClose(); |
1739 } | 1739 } |
1740 | 1740 |
1741 // Test closing the producer and then trying to read (with no data). | 1741 // Test closing the producer and then trying to read (with no data). |
1742 { | 1742 { |
1743 scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options)); | 1743 scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options)); |
1744 | 1744 |
(...skipping 19 matching lines...) Expand all Loading... | |
1764 EXPECT_EQ(0, memcmp(buffer, kTestData, kTestDataSize)); | 1764 EXPECT_EQ(0, memcmp(buffer, kTestData, kTestDataSize)); |
1765 | 1765 |
1766 // A second read should fail. | 1766 // A second read should fail. |
1767 num_bytes = static_cast<uint32_t>(sizeof(buffer)); | 1767 num_bytes = static_cast<uint32_t>(sizeof(buffer)); |
1768 EXPECT_EQ( | 1768 EXPECT_EQ( |
1769 MOJO_RESULT_FAILED_PRECONDITION, | 1769 MOJO_RESULT_FAILED_PRECONDITION, |
1770 dp->ConsumerReadData( | 1770 dp->ConsumerReadData( |
1771 UserPointer<void>(buffer), MakeUserPointer(&num_bytes), false)); | 1771 UserPointer<void>(buffer), MakeUserPointer(&num_bytes), false)); |
1772 | 1772 |
1773 // A two-phase read should also fail. | 1773 // A two-phase read should also fail. |
1774 const void* read_buffer_ptr = NULL; | 1774 const void* read_buffer_ptr = nullptr; |
1775 num_bytes = 0u; | 1775 num_bytes = 0u; |
1776 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 1776 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
1777 dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr), | 1777 dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr), |
1778 MakeUserPointer(&num_bytes), | 1778 MakeUserPointer(&num_bytes), |
1779 false)); | 1779 false)); |
1780 | 1780 |
1781 // Ditto for discard. | 1781 // Ditto for discard. |
1782 num_bytes = 10u; | 1782 num_bytes = 10u; |
1783 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 1783 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
1784 dp->ConsumerDiscardData(MakeUserPointer(&num_bytes), false)); | 1784 dp->ConsumerDiscardData(MakeUserPointer(&num_bytes), false)); |
(...skipping 25 matching lines...) Expand all Loading... | |
1810 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 1810 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
1811 dp->ProducerEndWriteData(1u * sizeof(int32_t))); | 1811 dp->ProducerEndWriteData(1u * sizeof(int32_t))); |
1812 | 1812 |
1813 // Still no data. | 1813 // Still no data. |
1814 num_bytes = 1000u; | 1814 num_bytes = 1000u; |
1815 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes))); | 1815 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes))); |
1816 EXPECT_EQ(0u, num_bytes); | 1816 EXPECT_EQ(0u, num_bytes); |
1817 | 1817 |
1818 // Try ending a two-phase write with an invalid amount (too much). | 1818 // Try ending a two-phase write with an invalid amount (too much). |
1819 num_bytes = 0u; | 1819 num_bytes = 0u; |
1820 void* write_ptr = NULL; | 1820 void* write_ptr = nullptr; |
1821 EXPECT_EQ( | 1821 EXPECT_EQ( |
1822 MOJO_RESULT_OK, | 1822 MOJO_RESULT_OK, |
1823 dp->ProducerBeginWriteData( | 1823 dp->ProducerBeginWriteData( |
1824 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), false)); | 1824 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), false)); |
1825 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 1825 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
1826 dp->ProducerEndWriteData(num_bytes + | 1826 dp->ProducerEndWriteData(num_bytes + |
1827 static_cast<uint32_t>(sizeof(int32_t)))); | 1827 static_cast<uint32_t>(sizeof(int32_t)))); |
1828 | 1828 |
1829 // But the two-phase write still ended. | 1829 // But the two-phase write still ended. |
1830 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, dp->ProducerEndWriteData(0u)); | 1830 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, dp->ProducerEndWriteData(0u)); |
1831 | 1831 |
1832 // Still no data. | 1832 // Still no data. |
1833 num_bytes = 1000u; | 1833 num_bytes = 1000u; |
1834 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes))); | 1834 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes))); |
1835 EXPECT_EQ(0u, num_bytes); | 1835 EXPECT_EQ(0u, num_bytes); |
1836 | 1836 |
1837 // Try ending a two-phase write with an invalid amount (not a multiple of the | 1837 // Try ending a two-phase write with an invalid amount (not a multiple of the |
1838 // element size). | 1838 // element size). |
1839 num_bytes = 0u; | 1839 num_bytes = 0u; |
1840 write_ptr = NULL; | 1840 write_ptr = nullptr; |
1841 EXPECT_EQ( | 1841 EXPECT_EQ( |
1842 MOJO_RESULT_OK, | 1842 MOJO_RESULT_OK, |
1843 dp->ProducerBeginWriteData( | 1843 dp->ProducerBeginWriteData( |
1844 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), false)); | 1844 MakeUserPointer(&write_ptr), MakeUserPointer(&num_bytes), false)); |
1845 EXPECT_GE(num_bytes, 1u); | 1845 EXPECT_GE(num_bytes, 1u); |
1846 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, dp->ProducerEndWriteData(1u)); | 1846 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, dp->ProducerEndWriteData(1u)); |
1847 | 1847 |
1848 // But the two-phase write still ended. | 1848 // But the two-phase write still ended. |
1849 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, dp->ProducerEndWriteData(0u)); | 1849 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, dp->ProducerEndWriteData(0u)); |
1850 | 1850 |
(...skipping 19 matching lines...) Expand all Loading... | |
1870 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 1870 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
1871 dp->ConsumerEndReadData(1u * sizeof(int32_t))); | 1871 dp->ConsumerEndReadData(1u * sizeof(int32_t))); |
1872 | 1872 |
1873 // Still one element available. | 1873 // Still one element available. |
1874 num_bytes = 0u; | 1874 num_bytes = 0u; |
1875 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes))); | 1875 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes))); |
1876 EXPECT_EQ(1u * sizeof(int32_t), num_bytes); | 1876 EXPECT_EQ(1u * sizeof(int32_t), num_bytes); |
1877 | 1877 |
1878 // Try ending a two-phase read with an invalid amount (too much). | 1878 // Try ending a two-phase read with an invalid amount (too much). |
1879 num_bytes = 0u; | 1879 num_bytes = 0u; |
1880 const void* read_ptr = NULL; | 1880 const void* read_ptr = nullptr; |
1881 EXPECT_EQ( | 1881 EXPECT_EQ( |
1882 MOJO_RESULT_OK, | 1882 MOJO_RESULT_OK, |
1883 dp->ConsumerBeginReadData( | 1883 dp->ConsumerBeginReadData( |
1884 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), false)); | 1884 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), false)); |
1885 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 1885 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
1886 dp->ConsumerEndReadData(num_bytes + | 1886 dp->ConsumerEndReadData(num_bytes + |
1887 static_cast<uint32_t>(sizeof(int32_t)))); | 1887 static_cast<uint32_t>(sizeof(int32_t)))); |
1888 | 1888 |
1889 // Still one element available. | 1889 // Still one element available. |
1890 num_bytes = 0u; | 1890 num_bytes = 0u; |
1891 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes))); | 1891 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes))); |
1892 EXPECT_EQ(1u * sizeof(int32_t), num_bytes); | 1892 EXPECT_EQ(1u * sizeof(int32_t), num_bytes); |
1893 | 1893 |
1894 // Try ending a two-phase read with an invalid amount (not a multiple of the | 1894 // Try ending a two-phase read with an invalid amount (not a multiple of the |
1895 // element size). | 1895 // element size). |
1896 num_bytes = 0u; | 1896 num_bytes = 0u; |
1897 read_ptr = NULL; | 1897 read_ptr = nullptr; |
1898 EXPECT_EQ( | 1898 EXPECT_EQ( |
1899 MOJO_RESULT_OK, | 1899 MOJO_RESULT_OK, |
1900 dp->ConsumerBeginReadData( | 1900 dp->ConsumerBeginReadData( |
1901 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), false)); | 1901 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), false)); |
1902 EXPECT_EQ(1u * sizeof(int32_t), num_bytes); | 1902 EXPECT_EQ(1u * sizeof(int32_t), num_bytes); |
1903 EXPECT_EQ(123, static_cast<const int32_t*>(read_ptr)[0]); | 1903 EXPECT_EQ(123, static_cast<const int32_t*>(read_ptr)[0]); |
1904 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, dp->ConsumerEndReadData(1u)); | 1904 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, dp->ConsumerEndReadData(1u)); |
1905 | 1905 |
1906 // Still one element available. | 1906 // Still one element available. |
1907 num_bytes = 0u; | 1907 num_bytes = 0u; |
(...skipping 28 matching lines...) Expand all Loading... | |
1936 // Write some elements. | 1936 // Write some elements. |
1937 char elements[2] = {'a', 'b'}; | 1937 char elements[2] = {'a', 'b'}; |
1938 uint32_t num_bytes = 2u; | 1938 uint32_t num_bytes = 2u; |
1939 EXPECT_EQ(MOJO_RESULT_OK, | 1939 EXPECT_EQ(MOJO_RESULT_OK, |
1940 dp->ProducerWriteData(UserPointer<const void>(elements), | 1940 dp->ProducerWriteData(UserPointer<const void>(elements), |
1941 MakeUserPointer(&num_bytes), | 1941 MakeUserPointer(&num_bytes), |
1942 false)); | 1942 false)); |
1943 EXPECT_EQ(2u, num_bytes); | 1943 EXPECT_EQ(2u, num_bytes); |
1944 | 1944 |
1945 // Begin reading. | 1945 // Begin reading. |
1946 const void* read_ptr = NULL; | 1946 const void* read_ptr = nullptr; |
1947 num_bytes = 2u; | 1947 num_bytes = 2u; |
1948 EXPECT_EQ( | 1948 EXPECT_EQ( |
1949 MOJO_RESULT_OK, | 1949 MOJO_RESULT_OK, |
1950 dp->ConsumerBeginReadData( | 1950 dp->ConsumerBeginReadData( |
1951 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), false)); | 1951 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), false)); |
1952 EXPECT_EQ(2u, num_bytes); | 1952 EXPECT_EQ(2u, num_bytes); |
1953 EXPECT_EQ('a', static_cast<const char*>(read_ptr)[0]); | 1953 EXPECT_EQ('a', static_cast<const char*>(read_ptr)[0]); |
1954 EXPECT_EQ('b', static_cast<const char*>(read_ptr)[1]); | 1954 EXPECT_EQ('b', static_cast<const char*>(read_ptr)[1]); |
1955 | 1955 |
1956 // Try to write some more. But nothing should be discardable right now. | 1956 // Try to write some more. But nothing should be discardable right now. |
(...skipping 17 matching lines...) Expand all Loading... | |
1974 // End reading. | 1974 // End reading. |
1975 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(2u)); | 1975 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(2u)); |
1976 | 1976 |
1977 // Now writing should succeed. | 1977 // Now writing should succeed. |
1978 EXPECT_EQ(MOJO_RESULT_OK, | 1978 EXPECT_EQ(MOJO_RESULT_OK, |
1979 dp->ProducerWriteData(UserPointer<const void>(elements), | 1979 dp->ProducerWriteData(UserPointer<const void>(elements), |
1980 MakeUserPointer(&num_bytes), | 1980 MakeUserPointer(&num_bytes), |
1981 false)); | 1981 false)); |
1982 | 1982 |
1983 // And if we read, we should get the new values. | 1983 // And if we read, we should get the new values. |
1984 read_ptr = NULL; | 1984 read_ptr = nullptr; |
1985 num_bytes = 2u; | 1985 num_bytes = 2u; |
1986 EXPECT_EQ( | 1986 EXPECT_EQ( |
1987 MOJO_RESULT_OK, | 1987 MOJO_RESULT_OK, |
1988 dp->ConsumerBeginReadData( | 1988 dp->ConsumerBeginReadData( |
1989 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), false)); | 1989 MakeUserPointer(&read_ptr), MakeUserPointer(&num_bytes), false)); |
1990 EXPECT_EQ(2u, num_bytes); | 1990 EXPECT_EQ(2u, num_bytes); |
1991 EXPECT_EQ('x', static_cast<const char*>(read_ptr)[0]); | 1991 EXPECT_EQ('x', static_cast<const char*>(read_ptr)[0]); |
1992 EXPECT_EQ('y', static_cast<const char*>(read_ptr)[1]); | 1992 EXPECT_EQ('y', static_cast<const char*>(read_ptr)[1]); |
1993 | 1993 |
1994 // End reading. | 1994 // End reading. |
1995 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(2u)); | 1995 EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(2u)); |
1996 | 1996 |
1997 dp->ProducerClose(); | 1997 dp->ProducerClose(); |
1998 dp->ConsumerClose(); | 1998 dp->ConsumerClose(); |
1999 } | 1999 } |
2000 | 2000 |
2001 } // namespace | 2001 } // namespace |
2002 } // namespace system | 2002 } // namespace system |
2003 } // namespace mojo | 2003 } // namespace mojo |
OLD | NEW |