Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(75)

Side by Side Diff: mojo/system/local_data_pipe_unittest.cc

Issue 597413002: Mojo: NULL -> nullptr in mojo/system and mojo/embedder. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: EXPECT_TRUE Created 6 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « mojo/system/handle_table.cc ('k') | mojo/system/local_message_pipe_endpoint.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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
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);
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);
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
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
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
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
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);
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);
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);
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
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);
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
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);
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);
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
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
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
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);
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
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);
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
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);
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);
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
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);
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);
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);
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);
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);
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);
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
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
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
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
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
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
OLDNEW
« no previous file with comments | « mojo/system/handle_table.cc ('k') | mojo/system/local_message_pipe_endpoint.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698