Lines Matching refs:async
28 fdioInstance = std::make_unique<sdbusplus::async::fdio>(*ctx, fd); in MutexTest()
31 std::optional<sdbusplus::async::context> ctx{std::in_place};
33 auto testAsyncAddition(int val = 1) -> sdbusplus::async::task<> in testAsyncAddition()
35 sdbusplus::async::lock_guard lg{mutex}; in testAsyncAddition()
41 auto testAsyncSubtraction(int val = 1) -> sdbusplus::async::task<> in testAsyncSubtraction()
43 sdbusplus::async::lock_guard lg{mutex}; in testAsyncSubtraction()
49 auto writeToFile() -> sdbusplus::async::task<> in writeToFile()
61 auto readFromFile() -> sdbusplus::async::task<> in readFromFile()
75 auto testFdEvents() -> sdbusplus::async::task<> in testFdEvents()
77 sdbusplus::async::lock_guard lg{mutex}; in testFdEvents()
90 sdbusplus::async::mutex mutex;
93 std::unique_ptr<sdbusplus::async::fdio> fdioInstance;
105 sdbusplus::async::sleep_for(*ctx, 1s) | in TEST_F()
106 sdbusplus::async::execution::then([&]() { ctx->request_stop(); })); in TEST_F()
123 sdbusplus::async::sleep_for(*ctx, 1s) | in TEST_F()
124 sdbusplus::async::execution::then([&]() { ctx->request_stop(); })); in TEST_F()
140 sdbusplus::async::sleep_for(*ctx, 3s) | in TEST_F()
141 sdbusplus::async::execution::then([&]() { ctx->request_stop(); })); in TEST_F()
148 sdbusplus::async::lock_guard lg{mutex}; in TEST_F()