/system/bt/osi/src/ |
D | future.cc | 36 static void future_free(future_t* future); 62 void future_ready(future_t* future, void* value) { in future_ready() argument 63 CHECK(future != NULL); in future_ready() 64 CHECK(future->ready_can_be_called); in future_ready() 66 future->ready_can_be_called = false; in future_ready() 67 future->result = value; in future_ready() 68 semaphore_post(future->semaphore); in future_ready() 71 void* future_await(future_t* future) { in future_await() argument 72 CHECK(future != NULL); in future_await() 75 if (future->semaphore) semaphore_wait(future->semaphore); in future_await() [all …]
|
/system/bt/osi/test/ |
D | future_test.cc | 40 future_t* future = future_new(); in TEST_F() local 41 ASSERT_TRUE(future != NULL); in TEST_F() 45 worker_thread.DoInThread(FROM_HERE, base::Bind(post_to_future, future)); in TEST_F() 47 EXPECT_EQ(pass_back_data0, future_await(future)); in TEST_F() 53 future_t* future = future_new_immediate((void*)pass_back_data1); in TEST_F() local 54 ASSERT_TRUE(future != NULL); in TEST_F() 55 EXPECT_EQ(pass_back_data1, future_await(future)); in TEST_F()
|
/system/bt/osi/test/fuzzers/future/ |
D | fuzz_future.cc | 37 future_t* future = nullptr; in LLVMFuzzerTestOneInput() local 40 future = future_new_immediate(buf); in LLVMFuzzerTestOneInput() 42 future = future_new(); in LLVMFuzzerTestOneInput() 46 if (future != nullptr) { in LLVMFuzzerTestOneInput() 49 future_ready(future, buf); in LLVMFuzzerTestOneInput() 53 future_await(future); in LLVMFuzzerTestOneInput()
|
/system/iorap/src/common/ |
D | async_pool.h | 30 std::deque<std::future<void>> futures_; 57 std::future<void> future = std::move(*it); in Join() local 61 future.get(); in Join() 79 auto future = std::async(std::launch::async, std::forward<T>(u)); in LaunchAsync() local 83 futures_.push_back(std::move(future)); in LaunchAsync()
|
/system/bt/gd/shim/ |
D | dumpsys_test.cc | 112 std::future future = promise.get_future(); in TEST_F() local 114 future.wait(); in TEST_F() 129 std::future future = promise.get_future(); in TEST_F() local 131 future.wait(); in TEST_F()
|
/system/bt/common/benchmark/ |
D | thread_performance_benchmark.cc | 118 std::future<void> set_up_future = set_up_promise_->get_future(); in SetUp() 139 std::future<void> counter_future = g_counter_promise->get_future(); in BENCHMARK_F() 153 std::future<void> counter_future = g_counter_promise->get_future(); in BENCHMARK_F() 165 std::future<void> set_up_future = set_up_promise_->get_future(); in SetUp() 186 std::future<void> counter_future = g_counter_promise->get_future(); in BENCHMARK_F() 200 std::future<void> counter_future = g_counter_promise->get_future(); in BENCHMARK_F() 212 std::future<void> set_up_future = set_up_promise_->get_future(); in SetUp() 231 std::future<void> counter_future = g_counter_promise->get_future(); in BENCHMARK_F() 245 std::future<void> counter_future = g_counter_promise->get_future(); in BENCHMARK_F() 274 std::future<void> counter_future = g_counter_promise->get_future(); in BENCHMARK_F() [all …]
|
/system/security/keystore/tests/ |
D | confirmationui_invocation_test.cpp | 60 auto future = listener->get_future(); in TEST() local 66 auto fstatus = future.wait_for(2s); in TEST() 72 future.wait(); in TEST() 73 auto [responseCode, dataThatWasConfirmed] = future.get(); in TEST()
|
/system/bt/gd/os/linux_generic/ |
D | repeating_alarm_unittest.cc | 47 auto future = promise.get_future(); in VerifyMultipleDelayedTasks() local 61 future.get(); in VerifyMultipleDelayedTasks() 97 auto future = promise.get_future(); in TEST_F() local 102 future.get(); in TEST_F() 124 auto future = promise.get_future(); in TEST_F() local 127 future.get(); in TEST_F()
|
D | reactor_unittest.cc | 202 auto future = g_promise->get_future(); in TEST_F() local 206 EXPECT_EQ(future.get(), kReadReadyValue); in TEST_F() 214 auto future = g_promise->get_future(); in TEST_F() local 221 EXPECT_EQ(future.get(), kReadReadyValue); in TEST_F() 290 auto future = g_promise->get_future(); in TEST_F() local 294 future.wait_for(std::chrono::milliseconds(10)); in TEST_F() 296 EXPECT_EQ(future.get(), 2); in TEST_F() 303 auto future = g_promise->get_future(); in TEST_F() local 310 EXPECT_EQ(future.get(), kReadReadyValue); in TEST_F() 313 future = g_promise->get_future(); in TEST_F() [all …]
|
D | handler_unittest.cc | 55 auto future = closure_ran.get_future(); in TEST_F() local 64 future.wait(); in TEST_F() 76 [](int* val, std::promise<void> closure_started, std::future<void> can_continue_future) { in TEST_F() 106 auto future = promise.get_future(); in TEST_F() local 109 future.wait(); in TEST_F()
|
D | alarm_unittest.cc | 57 auto future = promise.get_future(); in TEST_F() local 63 future.get(); in TEST_F() 83 auto future = promise.get_future(); in TEST_F() local 86 future.get(); in TEST_F()
|
/system/bt/gd/ |
D | stack_manager.cc | 47 auto future = promise.get_future(); in StartUp() local 51 auto init_status = future.wait_for(std::chrono::seconds(3)); in StartUp() 76 auto future = promise.get_future(); in ShutDown() local 79 auto stop_status = future.wait_for(std::chrono::seconds(5)); in ShutDown()
|
/system/bt/common/test/ |
D | thread_performance_test.cc | 101 std::future<void> set_up_future = set_up_promise_->get_future(); in SetUp() 121 std::future<void> counter_future = g_counter_promise->get_future(); in TEST_F() 146 std::future<void> set_up_future = set_up_promise_->get_future(); in SetUp() 166 std::future<void> counter_future = g_counter_promise->get_future(); in TEST_F() 192 std::future<void> set_up_future = set_up_promise_->get_future(); in SetUp() 211 std::future<void> counter_future = g_counter_promise->get_future(); in TEST_F() 252 std::future<void> counter_future = g_counter_promise->get_future(); in TEST_F() 279 std::future<void> set_up_future = set_up_promise_->get_future(); in SetUp() 302 std::future<void> counter_future = g_counter_promise->get_future(); in TEST_F() 328 std::future<void> set_up_future = set_up_promise_->get_future(); in SetUp() [all …]
|
/system/bt/common/ |
D | repeating_timer_unittest.cc | 81 auto future = promise_->get_future(); in VerifyMultipleDelayedTasks() local 90 future.get(); in VerifyMultipleDelayedTasks() 138 auto future = promise_->get_future(); in TEST_F() local 147 future.get(); in TEST_F() 200 auto future = promise_->get_future(); in TEST_F() local 207 future.wait(); in TEST_F() 235 auto future = promise_->get_future(); in TEST_F() local 244 future.wait(); in TEST_F()
|
D | once_timer_unittest.cc | 93 auto future = promise_->get_future(); in TEST_F() local 102 future.get(); in TEST_F() 162 auto future = promise_->get_future(); in TEST_F() local 170 future.get(); in TEST_F() 214 auto future = promise_->get_future(); in TEST_F() local 223 future.get(); in TEST_F()
|
/system/bt/test/headless/connect/ |
D | connect.cc | 83 auto future = acl_state_changed_promise.get_future(); in do_connect() local 89 acl_state_changed_params_t result = future.get(); in do_connect() 94 future = acl_state_changed_promise.get_future(); in do_connect() 106 result = future.get(); in do_connect()
|
/system/bt/gd/l2cap/classic/internal/ |
D | signalling_manager_test.cc | 40 auto future = promise.get_future(); in SyncHandler() local 42 future.wait_for(std::chrono::milliseconds(3)); in SyncHandler()
|
/system/bt/test/headless/read/ |
D | name.cc | 53 auto future = promise_.get_future(); in Run() local 62 tBTM_REMOTE_DEV_NAME name_packet = future.get(); in Run()
|
/system/bt/btcore/src/ |
D | module.cc | 136 future_t* future = function(); in call_lifecycle_function() local 139 if (!future) return true; in call_lifecycle_function() 142 return future_await(future); in call_lifecycle_function()
|
/system/chre/chpp/api_parser/ |
D | requirements.txt | 1 future==0.18.2
|
/system/sepolicy/prebuilts/api/28.0/private/ |
D | untrusted_app_25.te | 30 # This will go away in a future Android release 34 # This will go away in a future Android release 41 # This will go away in a future Android release
|
/system/sepolicy/prebuilts/api/27.0/private/ |
D | untrusted_app_25.te | 34 # This will go away in a future Android release 38 # This will go away in a future Android release 45 # This will go away in a future Android release
|
/system/sepolicy/prebuilts/api/26.0/private/ |
D | untrusted_app_25.te | 34 # This will go away in a future Android release 38 # This will go away in a future Android release 45 # This will go away in a future Android release
|
/system/bt/gd/cert/ |
D | async_subprocess_logger.py | 62 self.future = self.executor.submit(self.__logging_loop) 69 result = self.future.result(timeout=self.WAIT_TIMEOUT_SECONDS)
|
/system/bt/osi/include/ |
D | future.h | 37 void future_ready(future_t* future, void* value);
|