MCPcopy Create free account
hub / github.com/apache/arrow / TestTimedWait

Method TestTimedWait

cpp/src/arrow/util/future_test.cc:1484–1494  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1482 }
1483
1484 void TestTimedWait() {
1485 MakeExecutor(2);
1486 const auto& futures = executor_->futures();
1487 ASSERT_FALSE(futures[0].Wait(kTinyWait));
1488 ASSERT_FALSE(futures[1].Wait(kTinyWait));
1489 AssertAllNotFinished({0, 1});
1490 executor_->SetFinishedDeferred({{0, true}, {1, true}});
1491 ASSERT_TRUE(futures[0].Wait(kLargeWait));
1492 ASSERT_TRUE(futures[1].Wait(kLargeWait));
1493 AssertAllSuccessfulNow();
1494 }
1495
1496 void TestStressWait() {
1497#ifdef ARROW_VALGRIND

Callers 1

TYPED_TESTFunction · 0.80

Calls 3

MakeExecutorFunction · 0.85
SetFinishedDeferredMethod · 0.80
WaitMethod · 0.45

Tested by

no test coverage detected