utest/async-testutils/test_loop_tests.cpp

7 #include <lib/async-testutils/test_loop.h>
8 #include <lib/async/cpp/task.h>
9 #include <lib/async/cpp/time.h>
10 #include <lib/async/cpp/wait.h>
11 #include <lib/async/default.h>
21 void InitWait(async::Wait* wait, fbl::Closure closure, const zx::event& event,
24         [closure = fbl::move(closure)] (async_dispatcher_t*, async::Wait*,
39         async::TestLoop loop;;
50     async::TestLoop loop;
53     EXPECT_EQ(0, async::Now(loop.dispatcher()).get());
57     EXPECT_EQ(0, async::Now(loop.dispatcher()).get());
61     EXPECT_EQ(1, async::Now(loop.dispatcher()).get());
65     EXPECT_EQ(3, async::Now(loop.dispatcher()).get());
69     EXPECT_EQ(10, async::Now(loop.dispatcher()).get());
73     EXPECT_EQ(12, async::Now(loop.dispatcher()).get());
78     EXPECT_EQ(12, async::Now(loop.dispatcher()).get());
86     async::TestLoop loop;
88     async::PostDelayedTask(loop.dispatcher(), [&called] { called = true; }, zx::sec(2));
99     async::PostTask(loop.dispatcher(), [&called] { called = true; });
109     async::TestLoop loop;
113     async::PostTask(loop.dispatcher(), [&] {
117     async::PostTask(loop.dispatcher(), [&] {
128     async::PostDelayedTask(
135     async::PostDelayedTask(
154     async::TestLoop loop;
157     async::PostTask(loop.dispatcher(), [&] {
158         async::PostDelayedTask(
161                 async::PostDelayedTask(
178     async::TestLoop loop;
181     async::PostTask(loop.dispatcher(), [&] {
184         async::PostDelayedTask(
188                 async::PostDelayedTask(
192                           async::PostTask(loop.dispatcher(), [&] {
211     async::TestLoop loop;
216     async::TaskClosure taskA([&calledA] { calledA = true; });
217     async::TaskClosure taskB([&calledB] { calledB = true; });
218     async::TaskClosure taskC([&calledC] { calledC = true; });
238     async::TestLoop loop;
241     async::TaskClosure task([&called] { called = true; });
242     auto time1 = async::Now(loop.dispatcher());
249     EXPECT_EQ(time1.get(), async::Now(loop.dispatcher()).get());
253     auto time2 = async::Now(loop.dispatcher());
261     EXPECT_EQ(time2.get(), async::Now(loop.dispatcher()).get());
269     async::TestLoop loop;
270     async::Wait wait;
300     async::TestLoop loop;
302     async::Wait waitA;
303     async::Wait waitB;
304     async::Wait waitC;
362     async::TestLoop loop;
364     async::Wait waitA;
365     async::Wait waitB;
366     async::Wait waitC;
397     async::TestLoop loop;
399     async::Wait wait;
408             async::PostDelayedTask(loop.dispatcher(),
415     async::PostDelayedTask(loop.dispatcher(),
445     async::TestLoop loop;
454     async::TaskClosure taskC([&calledC] { calledC = true; });
456     async::PostTask(loopB->dispatcher(), [&calledB] { calledB = true; });
457     async::PostDelayedTask(loop.dispatcher(), [&called] { called = true; }, zx::sec(1));
459     async::PostDelayedTask(loopA->dispatcher(), [&calledA] { calledA = true; }, zx::sec(2));
486     async::TestLoop loop;
490     async::Wait wait;
491     async::Wait waitA;
492     async::Wait waitB;
493     async::Wait waitC;
531     async::TestLoop loop;
535     async::Wait wait;
536     async::Wait waitB;
543     async::PostTask(loopA->dispatcher(), [&] { (*order)[1] = ++i; });
545     async::PostTask(loopC->dispatcher(), [&] { (*order)[3] = ++i; });