Home
last modified time | relevance | path

Searched refs:async_manager_ (Results 1 – 6 of 6) sorted by relevance

/aosp12/system/bt/vendor_libs/test_vendor_lib/test/
H A Dasync_manager_unittest.cc74 async_manager_.StopWatchingFileDescriptor(fd); in ReadIncomingMessage()
94 async_manager_.StopWatchingFileDescriptor(socket_fd_); in TearDown()
131 AsyncManager async_manager_; member in test_vendor_lib::AsyncManagerSocketTest
173 AsyncManager async_manager_; member in test_vendor_lib::AsyncManagerTest
179 AsyncUserId user1 = async_manager_.GetNextUserId(); in TEST_F()
185 ASSERT_TRUE(async_manager_.CancelAsyncTask(task1_id)); in TEST_F()
190 AsyncUserId user1 = async_manager_.GetNextUserId(); in TEST_F()
207 ASSERT_TRUE(async_manager_.CancelAsyncTask(task2_id)); in TEST_F()
211 AsyncUserId user1 = async_manager_.GetNextUserId(); in TEST_F()
212 AsyncUserId user2 = async_manager_.GetNextUserId(); in TEST_F()
[all …]
H A Dlink_layer_socket_device_test.cc125 async_manager_.WatchFdForNonBlockingReads(socket_fd_, [this](int fd) { in SetUp()
138 async_manager_.StopWatchingFileDescriptor(socket_fd_); in TearDown()
223 AsyncManager async_manager_; member in test_vendor_lib::LinkLayerSocketDeviceTest
/aosp12/system/bt/vendor_libs/test_vendor_lib/desktop/
H A Dtest_environment.cc40 auto user_id = async_manager_.GetNextUserId(); in initialize()
44 async_manager_.ExecAsync(user_id, std::chrono::milliseconds(0), in initialize()
82 async_manager_.WatchFdForNonBlockingReads(socket_fd, [this, connection_callback](int socket_fd) { in SetUpHciServer()
108 async_manager_.WatchFdForNonBlockingReads(socket_fd, [this, connection_callback](int socket_fd) { in SetUpLinkLayerServer()
173 async_manager_.WatchFdForNonBlockingReads(socket_fd, [this](int socket_fd) { in SetUpTestChannel()
183 async_manager_.StopWatchingFileDescriptor(conn_fd); in SetUpTestChannel()
193 async_manager_.WatchFdForNonBlockingReads(conn_fd, [this](int conn_fd) { in SetUpTestChannel()
195 async_manager_.StopWatchingFileDescriptor(conn_fd); in SetUpTestChannel()
H A Dtest_environment.h56 test_vendor_lib::AsyncManager async_manager_; variable
70 [this]() { return async_manager_.GetNextUserId(); },
74 return async_manager_.ExecAsync(user_id, delay, task);
80 return async_manager_.ExecAsyncPeriodically(user_id, delay, period,
85 async_manager_.CancelAsyncTasksFromUser(user);
89 async_manager_.CancelAsyncTask(task);
/aosp12/system/bt/test/rootcanal/
H A Dbluetooth_hci.h76 test_vendor_lib::AsyncManager async_manager_; variable
89 test_vendor_lib::AsyncUserId user_id_ = async_manager_.GetNextUserId();
91 [this]() { return async_manager_.GetNextUserId(); },
95 return async_manager_.ExecAsync(user_id, delay, task);
101 return async_manager_.ExecAsyncPeriodically(user_id, delay, period,
106 async_manager_.CancelAsyncTasksFromUser(user_id);
110 async_manager_.CancelAsyncTask(task);
H A Dbluetooth_hci.cc99 async_manager_.ExecAsync( in initialize_impl()
166 return async_manager_.ExecAsync(user_id_, delay, task); in initialize_impl()
172 return async_manager_.ExecAsyncPeriodically(user_id_, delay, period, in initialize_impl()
177 [this](AsyncTaskId task) { async_manager_.CancelAsyncTask(task); }); in initialize_impl()
243 async_manager_.ExecAsync(user_id_, std::chrono::milliseconds(0), in sendHciCommand()
254 async_manager_.ExecAsync(user_id_, std::chrono::milliseconds(0), in sendAclData()
265 async_manager_.ExecAsync(user_id_, std::chrono::milliseconds(0), in sendScoData()
276 async_manager_.ExecAsync(user_id_, std::chrono::milliseconds(0), in sendIsoData()
298 async_manager_.WatchFdForNonBlockingReads(socket_fd, [this, connection_callback](int socket_fd) { in SetUpHciServer()
387 async_manager_.WatchFdForNonBlockingReads(socket_fd, [this](int socket_fd) { in SetUpTestChannel()
[all …]