MCPcopy Create free account
hub / github.com/apache/mesos / awaitFinished

Function awaitFinished

src/tests/fetcher_cache_tests.cpp:401–410  ·  view source on GitHub ↗

Create a future that indicates that the task observed by the given status queue is finished.

Source from the content-addressed store, hash-verified

399// Create a future that indicates that the task observed by the given
400// status queue is finished.
401static Future<Nothing> awaitFinished(FetcherCacheTest::Task task)
402{
403 return task.statusQueue.get()
404 .then([=](const TaskStatus& status) -> Future<Nothing> {
405 if (status.state() == TASK_FINISHED) {
406 return Nothing();
407 }
408 return awaitFinished(task);
409 });
410}
411
412
413// Create a future that indicates that all tasks are finished.

Callers 2

foreachFunction · 0.85
TEST_FFunction · 0.85

Calls 5

NothingClass · 0.85
collectFunction · 0.85
thenMethod · 0.45
getMethod · 0.45
stateMethod · 0.45

Tested by

no test coverage detected