1 // Copyright 2023 The Pigweed Authors
2 //
3 // Licensed under the Apache License, Version 2.0 (the "License"); you may not
4 // use this file except in compliance with the License. You may obtain a copy of
5 // the License at
6 //
7 // https://www.apache.org/licenses/LICENSE-2.0
8 //
9 // Unless required by applicable law or agreed to in writing, software
10 // distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
11 // WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
12 // License for the specific language governing permissions and limitations under
13 // the License.
14 #include "pw_async/fake_dispatcher_fixture.h"
15
16 #include <chrono>
17
18 #include "pw_unit_test/framework.h"
19
20 namespace pw::async {
21 namespace {
22
23 using FakeDispatcherFixture = test::FakeDispatcherFixture;
24
TEST_F(FakeDispatcherFixture,PostTasksAndStop)25 TEST_F(FakeDispatcherFixture, PostTasksAndStop) {
26 int count = 0;
27 auto inc_count = [&count](Context& /*c*/, Status /*status*/) { ++count; };
28
29 Task task(inc_count);
30 dispatcher().Post(task);
31
32 ASSERT_EQ(count, 0);
33 EXPECT_TRUE(RunUntilIdle());
34 ASSERT_EQ(count, 1);
35 EXPECT_FALSE(RunUntilIdle());
36
37 dispatcher().Post(task);
38 EXPECT_TRUE(RunUntil(dispatcher().now()));
39 ASSERT_EQ(count, 2);
40 EXPECT_FALSE(RunUntilIdle());
41
42 dispatcher().Post(task);
43 EXPECT_TRUE(RunFor(std::chrono::seconds(1)));
44 ASSERT_EQ(count, 3);
45 EXPECT_FALSE(RunUntilIdle());
46
47 dispatcher().PostAfter(task, std::chrono::minutes(1));
48 dispatcher().RequestStop();
49 ASSERT_EQ(count, 3);
50 EXPECT_TRUE(RunUntilIdle());
51 ASSERT_EQ(count, 4);
52 }
53
54 } // namespace
55 } // namespace pw::async
56