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

Unified Diff: mojo/public/cpp/bindings/tests/connector_unittest.cc

Issue 1055703002: Gather trace data by waiting on handles with a fixed timeout (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 5 years, 9 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 side-by-side diff with in-line comments
Download patch
Index: mojo/public/cpp/bindings/tests/connector_unittest.cc
diff --git a/mojo/public/cpp/bindings/tests/connector_unittest.cc b/mojo/public/cpp/bindings/tests/connector_unittest.cc
index 3e00a67131d9d938dfb5f2dd25ad630955197c7d..b5e34059018229d9afc2d8c581a4ad66d1fc2db6 100644
--- a/mojo/public/cpp/bindings/tests/connector_unittest.cc
+++ b/mojo/public/cpp/bindings/tests/connector_unittest.cc
@@ -59,7 +59,7 @@ class ReentrantMessageAccumulator : public MessageAccumulator {
return false;
number_of_calls_++;
if (number_of_calls_ == 1) {
- return connector_->WaitForIncomingMessage();
+ return connector_->WaitForIncomingMessage(MOJO_DEADLINE_INDEFINITE);
}
return true;
}
@@ -139,7 +139,7 @@ TEST_F(ConnectorTest, Basic_Synchronous) {
MessageAccumulator accumulator;
connector1.set_incoming_receiver(&accumulator);
- connector1.WaitForIncomingMessage();
+ connector1.WaitForIncomingMessage(MOJO_DEADLINE_INDEFINITE);
ASSERT_FALSE(accumulator.IsEmpty());
@@ -223,7 +223,7 @@ TEST_F(ConnectorTest, Basic_TwoMessages_Synchronous) {
MessageAccumulator accumulator;
connector1.set_incoming_receiver(&accumulator);
- connector1.WaitForIncomingMessage();
+ connector1.WaitForIncomingMessage(MOJO_DEADLINE_INDEFINITE);
ASSERT_FALSE(accumulator.IsEmpty());
@@ -327,7 +327,7 @@ TEST_F(ConnectorTest, WaitForIncomingMessageWithError) {
internal::Connector connector0(handle0_.Pass());
// Close the other end of the pipe.
handle1_.reset();
- ASSERT_FALSE(connector0.WaitForIncomingMessage());
+ ASSERT_FALSE(connector0.WaitForIncomingMessage(MOJO_DEADLINE_INDEFINITE));
}
TEST_F(ConnectorTest, WaitForIncomingMessageWithDeletion) {
@@ -344,7 +344,7 @@ TEST_F(ConnectorTest, WaitForIncomingMessageWithDeletion) {
ConnectorDeletingMessageAccumulator accumulator(&connector1);
connector1->set_incoming_receiver(&accumulator);
- connector1->WaitForIncomingMessage();
+ connector1->WaitForIncomingMessage(MOJO_DEADLINE_INDEFINITE);
ASSERT_FALSE(connector1);
ASSERT_FALSE(accumulator.IsEmpty());

Powered by Google App Engine
This is Rietveld 408576698