| /prebuilts/tools/common/m2/repository/com/google/dagger/dagger-producers/2.0-beta/ |
| dagger-producers-2.0-beta.jar | |
| /prebuilts/tools/common/m2/repository/io/netty/netty-resolver/4.1.0.CR3/ |
| netty-resolver-4.1.0.CR3.jar | |
| /prebuilts/tools/common/m2/repository/io/netty/netty-resolver/4.1.3.Final/ |
| netty-resolver-4.1.3.Final.jar | |
| /prebuilts/tools/common/m2/repository/io/netty/netty-resolver/4.1.6.Final/ |
| netty-resolver-4.1.6.Final.jar | |
| /frameworks/base/services/robotests/src/com/android/server/backup/transport/ |
| TransportClientTest.java | 531 CompletableFuture<T> future = new CompletableFuture<>(); local
532 mWorkerHandler.post(() -> future.complete(supplier.get()));
539 return future.get();
|
| /frameworks/native/libs/input/ |
| InputTransport.cpp | 58 // far into the future. This time is further bounded by 50% of the last time delta.
737 History future; local
740 // Interpolate between current sample and future sample.
741 // So current->eventTime <= sampleTime <= future.eventTime.
742 future.initializeFrom(*next);
743 other = &future;
744 nsecs_t delta = future.eventTime - current->eventTime;
753 // Extrapolate future sample using current sample and past sample.
771 ALOGD("Sample time is too far in the future, adjusting prediction "
[all...] |
| /system/update_engine/ |
| omaha_request_action_unittest.cc | 1912 int64_t future = local
[all...] |
| /external/conscrypt/openjdk-integ-tests/src/test/java/org/conscrypt/javax/net/ssl/ |
| SSLSessionTest.java | 36 import java.util.concurrent.Future;
247 Future<Void> s = executor.submit(new Callable<Void>() {
254 Future<Void> c = executor.submit(new Callable<Void>() {
455 Future<Void> future = executor.submit(new Callable<Void>() { local
468 future.get();
|
| /cts/tests/tests/net/src/android/net/cts/ |
| LocalSocketTest.java | 36 import java.util.concurrent.Future;
437 Future<Result> future = service.submit(callable); local
438 Result result = future.get(allowedTime, TimeUnit.MILLISECONDS);
439 if (!future.isDone()) {
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| JSR166TestCase.java | 292 * milliseconds in the future.
562 * Checks that future.get times out, with the default timeout of
565 void assertFutureTimesOut(Future future) {
566 assertFutureTimesOut(future, timeoutMillis());
570 * Checks that future.get times out, with the given millisecond timeout.
572 void assertFutureTimesOut(Future future, long timeoutMillis) {
575 future.get(timeoutMillis, MILLISECONDS);
580 } finally { future.cancel(true);
[all...] |
| /frameworks/base/services/core/java/com/android/server/ |
| DropBoxManagerService.java | 780 // >10sec in the future (due to clock skew), drag them back to avoid
784 EntryFile[] future = null; local
786 future = tail.toArray(new EntryFile[tail.size()]);
794 if (future != null) {
795 for (EntryFile late : future) {
[all...] |
| /packages/apps/Contacts/src/com/android/contacts/ |
| SimImportFragment.java | 462 final ListenableFuture<List<Object>> future = Futures.<Object>allAsList( local
472 return Futures.transform(future, new Function<List<Object>, LoaderResult>() {
|
| /packages/apps/DocumentsUI/src/com/android/documentsui/services/ |
| FileOperationService.java | 45 import java.util.concurrent.Future;
242 Future<?> future = getExecutorService(operation.getOpType()).submit(job); local
243 mJobs.put(jobId, new JobRecord(job, future));
440 private final Future<?> future; field in class:FileOperationService.JobRecord
442 public JobRecord(Job job, Future<?> future) {
444 this.future = future;
[all...] |
| /packages/apps/Email/provider_src/com/android/email/service/ |
| EmailServiceUtils.java | 265 private static void finishAccountManagerBlocker(AccountManagerFuture<?> future) {
269 future.getResult();
[all...] |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-netty/0.13.2/ |
| grpc-netty-0.13.2.jar | |
| /cts/tests/tests/keystore/src/android/keystore/cts/ |
| KeyPairGeneratorTest.java | 63 import java.util.concurrent.Future;
1425 Future<Certificate[]> future = executor.submit(new Callable<Certificate[]>() { local
[all...] |
| /cts/tests/tests/permission/src/android/permission/cts/ |
| FileSystemPermissionTest.java | 50 import java.util.concurrent.Future;
821 Future<Boolean> future = null; local
825 future = executor.submit(readFile);
828 completed = future.get(3, TimeUnit.SECONDS);
838 if (future != null) {
839 future.cancel(true);
[all...] |
| /external/conscrypt/platform/src/test/java/org/conscrypt/ |
| TrustedCertificateStoreTest.java | 43 import java.util.concurrent.Future;
741 Future<List<X509Certificate>> future = executor local
751 certs = future.get(10, TimeUnit.SECONDS);
[all...] |
| /external/python/cpython3/Modules/ |
| _asynciomodule.c | 83 class _asyncio.Future "FutureObj *" "&Future_Type"
87 /* Get FutureIter from Future */
225 "and cannot be raised into a Future");
321 _asyncio.Future.__init__
326 This class is *almost* compatible with concurrent.futures.Future.
331 raise an exception when the future isn't done yet.
373 _asyncio.Future.result
375 Return the result this future represents.
377 If the future has been cancelled, raises CancelledError. If the
378 future's result isn't yet available, raises InvalidStateError. I
966 FutureObj *future; member in struct:__anon33208
[all...] |
| /external/tensorflow/tensorflow/python/framework/ |
| ops_test.py | 1586 def future(): function in function:ControlDependenciesTest.testEager
[all...] |
| /frameworks/base/graphics/java/android/graphics/drawable/ |
| DrawableContainer.java | 680 * This class was made public to enable testing, and its visibility may change in a future
909 // Prepare future drawable if necessary.
930 // No need to call createAllFutures, since future drawables will
1001 final ConstantState future = mDrawableFutures.get(i) local
[all...] |
| /frameworks/base/packages/SystemUI/src/com/android/systemui/recents/ |
| RecentsImpl.java | 911 AppTransitionAnimationSpecsFuture future = new AppTransitionAnimationSpecsFuture(mHandler) { local
[all...] |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-netty/1.0.3/ |
| grpc-netty-1.0.3.jar | |
| /tools/tradefederation/core/tests/src/com/android/tradefed/device/ |
| DeviceManagerTest.java | 1116 SettableFuture<Integer> future = SettableFuture.create(); local
[all...] |
| /tools/tradefederation/core/tests/src/com/android/tradefed/invoker/ |
| TestInvocationTest.java | 1364 SettableFuture<Integer> future = SettableFuture.create(); local
1392 SettableFuture<Integer> future = SettableFuture.create(); local
1430 SettableFuture<Integer> future = SettableFuture.create(); local
[all...] |
