Searched refs:async_manager_ (Results 1 – 6 of 6) sorted by relevance
/system/bt/test/rootcanal/ |
D | bluetooth_hci.cc | 85 async_manager_.ExecAsync(std::chrono::milliseconds(0), in initialize() 109 return async_manager_.ExecAsync(delay, task); in initialize() 114 return async_manager_.ExecAsyncPeriodically(delay, period, task); in initialize() 117 …controller_->RegisterTaskCancel([this](AsyncTaskId task) { async_manager_.CancelAsyncTask(task); }… in initialize() 164 async_manager_.ExecAsync(std::chrono::milliseconds(0), [this, packet]() { in sendHciCommand() 173 async_manager_.ExecAsync(std::chrono::milliseconds(0), [this, packet]() { in sendAclData() 182 async_manager_.ExecAsync(std::chrono::milliseconds(0), [this, packet]() { in sendScoData() 201 async_manager_.WatchFdForNonBlockingReads(socket_fd, [this, connection_callback](int socket_fd) { in SetUpHciServer() 227 async_manager_.WatchFdForNonBlockingReads(socket_fd, [this, connection_callback](int socket_fd) { in SetUpLinkLayerServer() 286 async_manager_.WatchFdForNonBlockingReads(socket_fd, [this](int socket_fd) { in SetUpTestChannel() [all …]
|
D | bluetooth_hci.h | 64 test_vendor_lib::AsyncManager async_manager_; variable 79 return async_manager_.ExecAsync(delay, task); 84 return async_manager_.ExecAsyncPeriodically(delay, period, task); 87 [this](test_vendor_lib::AsyncTaskId task) { async_manager_.CancelAsyncTask(task); },
|
/system/bt/vendor_libs/test_vendor_lib/desktop/ |
D | test_environment.h | 46 test_vendor_lib::AsyncManager async_manager_; variable 61 return async_manager_.ExecAsync(delay, task); 66 return async_manager_.ExecAsyncPeriodically(delay, period, task); 69 [this](test_vendor_lib::AsyncTaskId task) { async_manager_.CancelAsyncTask(task); },
|
D | test_environment.cc | 43 async_manager_.ExecAsync(std::chrono::milliseconds(0), in initialize() 71 async_manager_.WatchFdForNonBlockingReads(socket_fd, [this, connection_callback](int socket_fd) { in SetUpHciServer() 97 async_manager_.WatchFdForNonBlockingReads(socket_fd, [this, connection_callback](int socket_fd) { in SetUpLinkLayerServer() 156 async_manager_.WatchFdForNonBlockingReads(socket_fd, [this](int socket_fd) { in SetUpTestChannel() 167 async_manager_.WatchFdForNonBlockingReads(conn_fd, [this](int conn_fd) { in SetUpTestChannel() 169 async_manager_.StopWatchingFileDescriptor(conn_fd); in SetUpTestChannel()
|
/system/bt/vendor_libs/test_vendor_lib/test/ |
D | async_manager_unittest.cc | 74 async_manager_.StopWatchingFileDescriptor(fd); in ReadIncomingMessage() 86 async_manager_.WatchFdForNonBlockingReads(socket_fd_, [this](int fd) { in SetUp() 89 …async_manager_.WatchFdForNonBlockingReads(connection_fd, [this](int fd) { ReadIncomingMessage(fd);… in SetUp() 94 async_manager_.StopWatchingFileDescriptor(socket_fd_); in TearDown() 131 AsyncManager async_manager_; member in test_vendor_lib::AsyncManagerSocketTest
|
D | link_layer_socket_device_test.cc | 128 async_manager_.WatchFdForNonBlockingReads(socket_fd_, [this](int fd) { in SetUp() 141 async_manager_.StopWatchingFileDescriptor(socket_fd_); in TearDown() 233 AsyncManager async_manager_; member in test_vendor_lib::LinkLayerSocketDeviceTest
|