Home
last modified time | relevance | path

Searched refs:future (Results 1 – 25 of 158) sorted by relevance

1234567

/system/bt/osi/src/
Dfuture.cc36 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/
Dfuture_test.cc40 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/
Dfuzz_future.cc37 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/
Dasync_pool.h30 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/
Ddumpsys_test.cc112 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/
Dthread_performance_benchmark.cc118 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/
Dconfirmationui_invocation_test.cpp60 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/
Drepeating_alarm_unittest.cc47 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()
Dreactor_unittest.cc202 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 …]
Dhandler_unittest.cc55 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()
Dalarm_unittest.cc57 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/
Dstack_manager.cc47 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/
Dthread_performance_test.cc101 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/
Drepeating_timer_unittest.cc81 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()
Donce_timer_unittest.cc93 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/
Dconnect.cc83 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/
Dsignalling_manager_test.cc40 auto future = promise.get_future(); in SyncHandler() local
42 future.wait_for(std::chrono::milliseconds(3)); in SyncHandler()
/system/bt/test/headless/read/
Dname.cc53 auto future = promise_.get_future(); in Run() local
62 tBTM_REMOTE_DEV_NAME name_packet = future.get(); in Run()
/system/bt/btcore/src/
Dmodule.cc136 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/
Drequirements.txt1 future==0.18.2
/system/sepolicy/prebuilts/api/28.0/private/
Duntrusted_app_25.te30 # 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/
Duntrusted_app_25.te34 # 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/
Duntrusted_app_25.te34 # 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/
Dasync_subprocess_logger.py62 self.future = self.executor.submit(self.__logging_loop)
69 result = self.future.result(timeout=self.WAIT_TIMEOUT_SECONDS)
/system/bt/osi/include/
Dfuture.h37 void future_ready(future_t* future, void* value);

1234567