Chromium Code Reviews| 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 |