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 // NOTE(vtl): Some of these tests are inherently flaky (e.g., if run on a | 5 // NOTE(vtl): Some of these tests are inherently flaky (e.g., if run on a |
6 // heavily-loaded system). Sorry. |test::EpsilonTimeout()| may be increased to | 6 // heavily-loaded system). Sorry. |test::EpsilonTimeout()| may be increased to |
7 // increase tolerance and reduce observed flakiness (though doing so reduces the | 7 // increase tolerance and reduce observed flakiness (though doing so reduces the |
8 // meaningfulness of the test). | 8 // meaningfulness of the test). |
9 | 9 |
10 #include "mojo/system/message_pipe_dispatcher.h" | 10 #include "mojo/system/message_pipe_dispatcher.h" |
(...skipping 513 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
524 write_dispatcher_(write_dispatcher), | 524 write_dispatcher_(write_dispatcher), |
525 messages_written_(messages_written), | 525 messages_written_(messages_written), |
526 bytes_written_(bytes_written) { | 526 bytes_written_(bytes_written) { |
527 *messages_written_ = 0; | 527 *messages_written_ = 0; |
528 *bytes_written_ = 0; | 528 *bytes_written_ = 0; |
529 } | 529 } |
530 | 530 |
531 virtual ~WriterThread() { Join(); } | 531 virtual ~WriterThread() { Join(); } |
532 | 532 |
533 private: | 533 private: |
534 virtual void Run() OVERRIDE { | 534 virtual void Run() override { |
535 // Make some data to write. | 535 // Make some data to write. |
536 unsigned char buffer[kMaxMessageSize]; | 536 unsigned char buffer[kMaxMessageSize]; |
537 for (size_t i = 0; i < kMaxMessageSize; i++) | 537 for (size_t i = 0; i < kMaxMessageSize; i++) |
538 buffer[i] = static_cast<unsigned char>(i); | 538 buffer[i] = static_cast<unsigned char>(i); |
539 | 539 |
540 // Number of messages to write. | 540 // Number of messages to write. |
541 *messages_written_ = static_cast<size_t>(base::RandInt(1000, 6000)); | 541 *messages_written_ = static_cast<size_t>(base::RandInt(1000, 6000)); |
542 | 542 |
543 // Write messages. | 543 // Write messages. |
544 for (size_t i = 0; i < *messages_written_; i++) { | 544 for (size_t i = 0; i < *messages_written_; i++) { |
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
577 read_dispatcher_(read_dispatcher), | 577 read_dispatcher_(read_dispatcher), |
578 messages_read_(messages_read), | 578 messages_read_(messages_read), |
579 bytes_read_(bytes_read) { | 579 bytes_read_(bytes_read) { |
580 *messages_read_ = 0; | 580 *messages_read_ = 0; |
581 *bytes_read_ = 0; | 581 *bytes_read_ = 0; |
582 } | 582 } |
583 | 583 |
584 virtual ~ReaderThread() { Join(); } | 584 virtual ~ReaderThread() { Join(); } |
585 | 585 |
586 private: | 586 private: |
587 virtual void Run() OVERRIDE { | 587 virtual void Run() override { |
588 unsigned char buffer[kMaxMessageSize]; | 588 unsigned char buffer[kMaxMessageSize]; |
589 Waiter w; | 589 Waiter w; |
590 HandleSignalsState hss; | 590 HandleSignalsState hss; |
591 MojoResult result; | 591 MojoResult result; |
592 | 592 |
593 // Read messages. | 593 // Read messages. |
594 for (;;) { | 594 for (;;) { |
595 // Wait for it to be readable. | 595 // Wait for it to be readable. |
596 w.Init(); | 596 w.Init(); |
597 hss = HandleSignalsState(); | 597 hss = HandleSignalsState(); |
(...skipping 122 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
720 EXPECT_EQ(total_messages_written, total_messages_read); | 720 EXPECT_EQ(total_messages_written, total_messages_read); |
721 EXPECT_EQ(total_bytes_written, total_bytes_read); | 721 EXPECT_EQ(total_bytes_written, total_bytes_read); |
722 | 722 |
723 EXPECT_EQ(MOJO_RESULT_OK, d_write->Close()); | 723 EXPECT_EQ(MOJO_RESULT_OK, d_write->Close()); |
724 EXPECT_EQ(MOJO_RESULT_OK, d_read->Close()); | 724 EXPECT_EQ(MOJO_RESULT_OK, d_read->Close()); |
725 } | 725 } |
726 | 726 |
727 } // namespace | 727 } // namespace |
728 } // namespace system | 728 } // namespace system |
729 } // namespace mojo | 729 } // namespace mojo |
OLD | NEW |