| /aosp12/system/bt/osi/src/ |
| H A D | future.cc | 63 CHECK(future != NULL); in future_ready()
64 CHECK(future->ready_can_be_called); in future_ready()
67 future->result = value; in future_ready()
68 semaphore_post(future->semaphore); in future_ready()
72 CHECK(future != NULL); in future_await()
75 if (future->semaphore) semaphore_wait(future->semaphore); in future_await()
77 void* result = future->result; in future_await()
78 future_free(future); in future_await()
83 if (!future) return; in future_free()
85 semaphore_free(future->semaphore); in future_free()
[all …]
|
| /aosp12/frameworks/base/apex/appsearch/testing/java/com/android/server/appsearch/testing/ |
| H A D | AppSearchSessionShimImpl.java | 90 future, in createSearchSession()
113 mAppSearchSession.getSchema(mExecutor, future::set); in getSchema()
121 mAppSearchSession.getNamespaces(mExecutor, future::set); in getNamespaces()
131 request, mExecutor, new BatchResultCallbackAdapter<>(future)); in put()
132 return future; in put()
143 return future; in getByDocumentId()
158 mAppSearchSession.reportUsage(request, mExecutor, future::set); in reportUsage()
168 return future; in remove()
184 mAppSearchSession.getStorageInfo(mExecutor, future::set); in getStorageInfo()
199 future.set(AppSearchResult.newSuccessfulResult(null)); in requestFlush()
[all …]
|
| /aosp12/frameworks/base/core/tests/coretests/src/android/animation/ |
| H A D | AutoCancelTest.java | 88 future.set(false); in setupAnimators()
102 future.set(false); in setupAnimators()
110 future.release(); in setupAnimators()
132 final FutureWaiter future = new FutureWaiter(); in testAutoCancel() local
135 setupAnimators(0, false, future); in testAutoCancel()
137 future.setException(e); in testAutoCancel()
146 final FutureWaiter future = new FutureWaiter(); in testAutoCancelDelayed() local
151 future.setException(e); in testAutoCancelDelayed()
163 setupAnimators(0, true, future); in testAutoCancelTestLater()
165 future.setException(e); in testAutoCancelTestLater()
[all …]
|
| /aosp12/packages/services/Car/tests/carservice_unit_test/src/com/android/car/user/ |
| H A D | CarUserManagerUnitTest.java | 218 assertThat(future).isNotNull(); in testSwitchUser_success()
231 assertThat(future).isNotNull(); in testSwitchUser_remoteException()
243 assertThat(future).isNotNull(); in testSwitchUser_runtimeException()
298 assertThat(future).isNotNull(); in testCreateUser_withType_success()
319 assertThat(future).isNotNull(); in testCreateUser_withType_remoteException()
334 assertThat(future).isNotNull(); in testCreateUser_withType_runtimeException()
349 assertThat(future).isNotNull(); in testCreateUser_success()
370 assertThat(future).isNotNull(); in testCreateUser_remoteException()
385 assertThat(future).isNotNull(); in testCreateGuest_success()
407 assertThat(future).isNotNull(); in testCreateGuest_remoteException()
[all …]
|
| H A D | ExperimentalCarUserManagerUnitTest.java | 77 UserCreationResult result = getResult(future); in testCreateDriver_Success_Admin()
91 UserCreationResult result = getResult(future); in testCreateDriver_Success_NonAdmin()
103 assertThat(future).isNotNull(); in testCreateDriver_Error()
104 UserCreationResult result = getResult(future); in testCreateDriver_Error()
125 AndroidFuture<UserSwitchResult> future = mManager.switchDriver(10); in testSwitchDriver_Success() local
126 UserSwitchResult result = getResult(future); in testSwitchDriver_Success()
133 AndroidFuture<UserSwitchResult> future = mManager.switchDriver(20); in testSwitchDriver_Error() local
134 assertThat(future).isNotNull(); in testSwitchDriver_Error()
135 UserSwitchResult result = getResult(future); in testSwitchDriver_Error()
189 AndroidFuture<UserCreationResult> future = new AndroidFuture<>(); in expectCreateDriverSucceed() local
[all …]
|
| /aosp12/packages/services/Telephony/src/com/android/services/telephony/rcs/ |
| H A D | UceControllerManager.java | 169 future.get(); in requestCapabilities()
194 future.get(); in requestNetworkAvailability()
216 return future.get(); in getUcePublishState()
238 return future.get(); in addUceRegistrationOverride()
260 return future.get(); in removeUceRegistrationOverride()
281 return future.get(); in clearUceRegistrationOverride()
302 return future.get(); in getLatestRcsContactUceCapability()
324 return future.get(); in getLastPidfXml()
350 return future.get(); in removeUceRequestDisallowedStatus()
401 future.get(); in registerPublishStateCallback()
[all …]
|
| /aosp12/frameworks/base/core/tests/coretests/src/com/android/internal/infra/ |
| H A D | AndroidFutureTest.java | 44 AndroidFuture<Integer> future = new AndroidFuture<>(); in testGet() local
45 future.complete(5); in testGet()
46 assertThat(future.get()).isEqualTo(5); in testGet()
51 AndroidFuture<Integer> future = new AndroidFuture<>(); in testWhenComplete_AlreadyComplete() local
52 future.complete(5); in testWhenComplete_AlreadyComplete()
54 future.whenComplete((obj, err) -> { in testWhenComplete_AlreadyComplete()
66 future.whenComplete((obj, err) -> { in testWhenComplete_NotYetComplete()
72 future.complete(5); in testWhenComplete_NotYetComplete()
81 future.completeExceptionally(origException); in testCompleteExceptionally()
91 future.completeExceptionally(origException); in testCompleteExceptionally_Listener()
[all …]
|
| /aosp12/frameworks/native/libs/ftl/ |
| H A D | future_test.cpp | 31 auto future = ftl::defer([](int x) { return x + 1; }, 99); in TEST() local
32 EXPECT_EQ(future.get(), 100); in TEST()
35 auto future = ftl::yield(42); in TEST() local
36 EXPECT_EQ(future.get(), 42); in TEST()
40 auto future = ftl::yield(std::move(ptr)); in TEST() local
41 EXPECT_EQ(*future.get(), '!'); in TEST()
44 auto future = ftl::yield(123); in TEST() local
45 std::future<char> futures[] = {ftl::yield('a'), ftl::yield('b')}; in TEST()
47 std::future<char> chain = ftl::chain(std::move(future)) in TEST()
74 std::packaged_task<std::future<ByteVector>(ByteVector)> decrement_bytes( in TEST()
[all …]
|
| /aosp12/frameworks/native/include/ftl/ |
| H A D | future.h | 45 inline std::future<T> yield(T&& v) { in yield()
57 struct future_result<std::future<T>> {
80 Chain(std::future<T>&& f) : future(std::move(f)) {}
81 operator std::future<T>&&() && { return std::move(future); }
83 T get() && { return future.get(); }
96 std::move(future), std::forward<F>(op));
99 std::future<T> future;
105 inline auto chain(std::future<T>&& f) -> details::Chain<T> {
|
| /aosp12/packages/modules/Permission/framework-s/java/android/app/role/ |
| H A D | RoleControllerManager.java | 142 AndroidFuture<Bundle> future = new AndroidFuture<>(); in grantDefaultRoles()
144 return future; in grantDefaultRoles()
159 new RemoteCallback(future::complete)); in onAddRoleHolder()
160 return future; in onAddRoleHolder()
175 new RemoteCallback(future::complete)); in onRemoveRoleHolder()
176 return future; in onRemoveRoleHolder()
191 new RemoteCallback(future::complete)); in onClearRoleHolders()
192 return future; in onClearRoleHolders()
208 new RemoteCallback(future::complete)); in isApplicationVisibleForRole()
209 return future; in isApplicationVisibleForRole()
[all …]
|
| /aosp12/system/bt/osi/test/ |
| H A 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()
|
| /aosp12/frameworks/base/services/tests/servicestests/src/com/android/server/people/data/ |
| H A D | MockScheduledExecutorService.java | 55 for (MockScheduledFuture<?> future : futuresCopy) { in fastForwardTime()
56 if (future.getDelay() < mTimeElapsedMillis) { in fastForwardTime()
57 future.getRunnable().run(); in fastForwardTime()
58 mExecutes.add(future.getRunnable()); in fastForwardTime()
61 mFutures.add(future); in fastForwardTime()
87 mFutures.add(future); in schedule()
88 return future; in schedule()
137 future.getCallable().call(); in submit()
141 return future; in submit()
154 future.getRunnable().run(); in submit()
[all …]
|
| /aosp12/frameworks/av/media/libstagefright/renderfright/threaded/ |
| H A D | RenderEngineThreaded.cpp | 88 std::future<void> resultFuture = resultPromise.get_future(); in primeCache()
120 std::future<bool> resultFuture = resultPromise.get_future(); in useNativeFenceSync()
135 std::future<bool> resultFuture = resultPromise.get_future(); in useWaitSync()
150 std::future<void> resultFuture = resultPromise.get_future(); in genTextures()
165 std::future<void> resultFuture = resultPromise.get_future(); in deleteTextures()
180 std::future<void> resultFuture = resultPromise.get_future(); in bindExternalTextureImage()
214 std::future<void> resultFuture = resultPromise.get_future(); in cacheExternalTextureBuffer()
229 std::future<void> resultFuture = resultPromise.get_future(); in unbindExternalTextureBuffer()
259 std::future<void> resultFuture = resultPromise.get_future(); in unbindFrameBuffer()
304 std::future<bool> resultFuture = resultPromise.get_future(); in isProtected()
[all …]
|
| /aosp12/frameworks/base/services/core/java/com/android/server/powerstats/ |
| H A D | PowerStatsService.java | 293 future, energyConsumerIds)); in getEnergyConsumedAsync()
294 return future; in getEnergyConsumedAsync()
308 future, powerEntityIds)); in getStateResidencyAsync()
309 return future; in getStateResidencyAsync()
323 future, channelIds)); in readEnergyMeterAsync()
324 return future; in readEnergyMeterAsync()
328 private void getEnergyConsumedAsync(CompletableFuture<EnergyConsumerResult[]> future, in getEnergyConsumedAsync() argument
330 future.complete(getPowerStatsHal().getEnergyConsumed(energyConsumerIds)); in getEnergyConsumedAsync()
335 future.complete(getPowerStatsHal().getStateResidency(powerEntityIds)); in getStateResidencyAsync()
338 private void readEnergyMeterAsync(CompletableFuture<EnergyMeasurement[]> future, in readEnergyMeterAsync() argument
[all …]
|
| /aosp12/packages/modules/Permission/service/java/com/android/role/ |
| H A D | RoleShellCommand.java | 115 CallbackFuture future = new CallbackFuture(); in runAddRoleHolder() local
117 future.createCallback()); in runAddRoleHolder()
118 return future.waitForResult(); in runAddRoleHolder()
127 CallbackFuture future = new CallbackFuture(); in runRemoveRoleHolder() local
129 future.createCallback()); in runRemoveRoleHolder()
130 return future.waitForResult(); in runRemoveRoleHolder()
138 CallbackFuture future = new CallbackFuture(); in runClearRoleHolders() local
139 mRoleManager.clearRoleHoldersAsUser(roleName, flags, userId, future.createCallback()); in runClearRoleHolders()
140 return future.waitForResult(); in runClearRoleHolders()
|
| /aosp12/system/bt/osi/test/fuzzers/future/ |
| H A 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()
|
| /aosp12/frameworks/base/libs/usb/api/ |
| H A D | current.txt | 2 package com.android.future.usb {
14 method public static com.android.future.usb.UsbAccessory getAccessory(android.content.Intent);
15 method public com.android.future.usb.UsbAccessory[] getAccessoryList();
16 method public static com.android.future.usb.UsbManager getInstance(android.content.Context);
17 method public boolean hasPermission(com.android.future.usb.UsbAccessory);
18 … method public android.os.ParcelFileDescriptor openAccessory(com.android.future.usb.UsbAccessory);
19 …method public void requestPermission(com.android.future.usb.UsbAccessory, android.app.PendingInten…
|
| /aosp12/packages/apps/Contacts/src/com/android/contacts/util/concurrent/ |
| H A D | FuturesUtil.java | 26 public static <V> ListenableFuture<V> withTimeout(final ListenableFuture<V> future, long time, in withTimeout() argument
28 return withTimeout(future, time, unit, ContactsExecutors.newHandlerExecutor(handler)); in withTimeout()
39 public static <V> ListenableFuture<V> withTimeout(final ListenableFuture<V> future, long time, in withTimeout() argument
45 didTimeout.set(!future.isDone() && !future.isCancelled()); in withTimeout()
46 future.cancel(true); in withTimeout()
50 return Futures.catchingAsync(future, Throwable.class, new AsyncFunction<Throwable, V>() { in withTimeout()
|
| /aosp12/system/iorap/src/common/ |
| H A 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()
|
| /aosp12/packages/apps/Car/libs/car-apps-common/src/com/android/car/apps/common/util/ |
| H A D | FutureData.java | 49 public static <T> T getData(@Nullable FutureData<T> future) { in getData() argument
50 return (future != null) ? future.getData() : null; in getData()
55 public static <T> T getPastData(@Nullable FutureData<T> future) { in getPastData() argument
56 return (future != null) ? future.getPastData() : null; in getPastData()
|
| /aosp12/system/bt/common/benchmark/ |
| H A 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()
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()
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()
274 std::future<void> counter_future = g_counter_promise->get_future(); in BENCHMARK_F()
302 std::future<void> counter_future = g_counter_promise->get_future(); in BENCHMARK_F()
328 std::future<void> set_up_future = set_up_promise_->get_future(); in SetUp()
352 std::future<void> counter_future = g_counter_promise->get_future(); in BENCHMARK_F()
[all …]
|
| /aosp12/packages/apps/Dialer/java/com/android/dialer/metrics/ |
| H A D | FutureTimer.java | 75 public <T> void applyTiming(ListenableFuture<T> future, String eventName) { in applyTiming() argument
76 applyTiming(future, unused -> eventName, LogCatMode.DONT_LOG_VALUES); in applyTiming()
84 ListenableFuture<T> future, String eventName, @LogCatMode int logCatMode) { in applyTiming() argument
85 applyTiming(future, unused -> eventName, logCatMode); in applyTiming()
95 ListenableFuture<T> future, Function<T, String> eventNameFromResultFunction) { in applyTiming() argument
96 applyTiming(future, eventNameFromResultFunction, LogCatMode.DONT_LOG_VALUES); in applyTiming()
100 ListenableFuture<T> future, in applyTiming() argument
106 future, in applyTiming()
|
| /aosp12/packages/services/Car/car-lib/src/android/car/user/ |
| H A D | ExperimentalCarUserManager.java | 85 AndroidFuture<UserCreationResult> future = new AndroidFuture<>(); in createDriver()
86 future.complete(new UserCreationResult(UserCreationResult.STATUS_HAL_INTERNAL_FAILURE)); in createDriver()
88 return future; in createDriver()
125 AndroidFuture<UserSwitchResult> future = new AndroidFuture<>() { in switchDriver() local
134 mService.switchDriver(driverId, future); in switchDriver()
135 return future; in switchDriver()
137 AndroidFuture<UserSwitchResult> future = new AndroidFuture<>(); in switchDriver()
138 future.complete( in switchDriver()
141 return future; in switchDriver()
|
| /aosp12/packages/services/Car/car-lib/src/android/car/admin/ |
| H A D | CarDevicePolicyManager.java | 147 AndroidFuture<UserRemovalResult> future = new AndroidFuture<UserRemovalResult>(); in removeUser() local
148 mService.removeUser(userId, future); in removeUser()
149 UserRemovalResult result = future.get(DEVICE_POLICY_MANAGER_TIMEOUT_MS, in removeUser()
191 mService.createUser(name, type, future); in createUser()
192 UserCreationResult result = future.get(DEVICE_POLICY_MANAGER_TIMEOUT_MS, in createUser()
229 AndroidFuture<UserStartResult> future = new AndroidFuture<>(); in startUserInBackground() local
230 mService.startUserInBackground(userId, future); in startUserInBackground()
231 UserStartResult result = future.get(DEVICE_POLICY_MANAGER_TIMEOUT_MS, in startUserInBackground()
268 AndroidFuture<UserStopResult> future = new AndroidFuture<>(); in stopUser() local
269 mService.stopUser(userId, future); in stopUser()
[all …]
|
| /aosp12/packages/services/Car/tests/carservice_unit_test/src/android/car/test/mocks/ |
| H A D | JavaMockitoHelperTest.java | 78 Future<String> future = mock(Future.class); in testGetResult() local
79 when(future.get(anyLong(), any())).thenReturn("done"); in testGetResult()
81 assertThat(JavaMockitoHelper.getResult(future)).isEqualTo("done"); in testGetResult()
87 Future<String> future = mock(Future.class); in testGetResult_withCustomTimeout() local
88 when(future.get(anyLong(), any(TimeUnit.class))).thenReturn("done"); in testGetResult_withCustomTimeout()
90 assertThat(JavaMockitoHelper.getResult(future, TIMEOUT_MS)).isEqualTo("done"); in testGetResult_withCustomTimeout()
91 verify(future).get(TIMEOUT_MS, TimeUnit.MILLISECONDS); in testGetResult_withCustomTimeout()
|