/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
FuturesTest.java | 57 import java.util.concurrent.Future; 85 * Clear interrupt for future tests. 96 ListenableFuture<String> future = Futures.immediateFuture(DATA1); local 99 assertSame(DATA1, future.get(0L, TimeUnit.MILLISECONDS)); 113 ListenableFuture<String> future = local 117 future.get(0L, TimeUnit.MILLISECONDS); 128 CheckedFuture<String, MyException> future = Futures.immediateCheckedFuture( local 132 assertSame(DATA1, future.get(0L, TimeUnit.MILLISECONDS)); 133 assertSame(DATA1, future.checkedGet(0L, TimeUnit.MILLISECONDS)); 151 CheckedFuture<String, MyException> future local 186 ListenableFuture<FooChild> future = Futures.immediateFuture(null); local [all...] |
JSR166TestCase.java | 290 * milliseconds in the future. 560 * Checks that future.get times out, with the default timeout of 563 void assertFutureTimesOut(Future future) { 564 assertFutureTimesOut(future, timeoutMillis()); 568 * Checks that future.get times out, with the given millisecond timeout. 570 void assertFutureTimesOut(Future future, long timeoutMillis) { 573 future.get(timeoutMillis, MILLISECONDS); 578 } finally { future.cancel(true); [all...] |
/packages/apps/Gallery2/src/com/android/gallery3d/data/ |
MediaSet.java | 20 import com.android.gallery3d.util.Future; 232 * Requests sync on this MediaSet. It returns a Future object that can be used by the caller 234 * defined in this class and can be obtained by Future.get(). 238 * The default implementation here returns a Future stub that does nothing and returns 241 public Future<Integer> requestSync(SyncListener listener) { 246 private static final Future<Integer> FUTURE_STUB = new Future<Integer>() { 269 protected Future<Integer> requestSyncOnMultipleSets(MediaSet[] sets, SyncListener listener) { 273 private class MultiSetSyncFuture implements Future<Integer>, SyncListener { 278 private final Future<Integer> mFutures[] [all...] |
/frameworks/native/libs/input/ |
InputTransport.cpp | 54 // far into the future. This time is further bounded by 50% of the last time delta. 714 History future; local 717 // Interpolate between current sample and future sample. 718 // So current->eventTime <= sampleTime <= future.eventTime. 719 future.initializeFrom(next); 720 other = &future; 721 nsecs_t delta = future.eventTime - current->eventTime; 730 // Extrapolate future sample using current sample and past sample. 743 ALOGD("Sample time is too far in the future, adjusting prediction " [all...] |
/frameworks/base/services/tests/servicestests/src/com/android/server/ |
NetworkPolicyManagerServiceTest.java | 91 import java.util.concurrent.Future; 258 final Future<Intent> backgroundChanged = mServiceContext.nextBroadcastIntent( 314 Future<Void> future; local 318 future = expectRulesChanged(UID_A, RULE_ALLOW_ALL); 321 future.get(); 327 future = expectRulesChanged(UID_A, RULE_ALLOW_ALL); 330 future.get(); 337 future = expectRulesChanged(UID_A, RULE_REJECT_METERED); 340 future.get() 355 Future<Void> future; local 385 Future<Void> future; local 416 Future<Void> future; local 582 Future<Void> future; local 632 Future<Void> future; local 658 Future<Void> future; local 789 Future<Void> future; local 858 final FutureAnswer future = new FutureAnswer(); local 905 final FutureAnswer future = new FutureAnswer(); local 912 final FutureAnswer future = new FutureAnswer(); local 919 final FutureAnswer future = new FutureAnswer(); local 980 final IdleFuture future = new IdleFuture(); local [all...] |
/cts/tests/tests/permission/src/android/permission/cts/ |
FileSystemPermissionTest.java | 38 import java.util.concurrent.Future; 577 Future<Boolean> future = null; local 581 future = executor.submit(readFile); 584 completed = future.get(3, TimeUnit.SECONDS); 594 if (future != null) { 595 future.cancel(true); [all...] |
/external/chromium_org/chrome/browser/chromeos/login/ |
wallpaper_manager.cc | 433 // future due to DST. 437 base::Time future = now + update_interval; local 438 base::Time next_update = future.LocalMidnight(); 440 future += update_interval; 441 next_update = future.LocalMidnight(); [all...] |
/frameworks/base/services/java/com/android/server/ |
DropBoxManagerService.java | 652 // >10sec in the future (due to clock skew), drag them back to avoid 656 EntryFile[] future = null; local 658 future = tail.toArray(new EntryFile[tail.size()]); 666 if (future != null) { 667 for (EntryFile late : future) {
|
/packages/apps/Email/src/com/android/email/service/ |
EmailServiceUtils.java | 256 private static void finishAccountManagerBlocker(AccountManagerFuture<?> future) { 260 future.getResult(); [all...] |
/sdk/emulator/qtools/ |
trace_reader.cpp | 74 inline BBReader::Future *BBReader::AllocFuture() 76 Future *future = free_; local 78 return future; 81 inline void BBReader::FreeFuture(Future *future) 83 future->next = free_; 84 free_ = future; 87 inline void BBReader::InsertFuture(Future *future) 197 Future *future = head_; local 222 Future *future = AllocFuture(); local 245 Future *future = head_; local [all...] |
/libcore/luni/src/test/java/libcore/javax/net/ssl/ |
SSLSocketTest.java | 40 import java.util.concurrent.Future; 296 Future<Void> future = executor.submit(new Callable<Void>() { local 327 future.get(); 353 final Future<byte[]> future1 = executor.submit(new SSLServerSessionIdCallable(server1)); 366 final Future<byte[]> future2 = executor.submit(new SSLServerSessionIdCallable(server2)); 391 Future<Void> future = executor.submit(new Callable<Void>() { local 407 future.get(); 428 Future<Void> future = executor.submit(new Callable<Void>() local 448 Future<Void> future = executor.submit(new Callable<Void>() { local 568 Future<Void> future = executor.submit(new Callable<Void>() { local 634 Future<IOException> future = executor.submit(new Callable<IOException>() { local 688 Future<Void> future = executor.submit(new Callable<Void>() { local 718 Future<Void> future = executor.submit(new Callable<Void>() { local 790 Future<Void> future = executor.submit(new Callable<Void>() { local 837 Future<Void> future = executor.submit(new Callable<Void>() { local 875 Future<Void> future = executor.submit(new Callable<Void>() { local 904 Future<Void> future = executor.submit(new Callable<Void>() { local 1208 Future<Void> future = executor.submit(new Callable<Void>() { local 1266 Future<Void> future = executor.submit(new Callable<Void>() { local [all...] |
/frameworks/base/core/java/android/view/ |
ViewDebug.java | 1016 FutureTask<Object> future = new FutureTask<Object>(callable); local [all...] |
/prebuilts/python/darwin-x86/2.7.5/lib/python2.7/compiler/ |
pycodegen.py | 9 from compiler import pyassem, misc, future, symbols namespace 212 # XXX set flags based on future features [all...] |
/prebuilts/python/linux-x86/2.7.5/lib/python2.7/compiler/ |
pycodegen.py | 9 from compiler import pyassem, misc, future, symbols namespace 212 # XXX set flags based on future features [all...] |
/external/guava/guava/src/com/google/common/cache/ |
LocalCache.java | 3544 SettableFuture<V> future = SettableFuture.create(); local [all...] |
/libcore/crypto/src/test/java/org/conscrypt/ |
NativeCryptoTest.java | 46 import java.util.concurrent.Future; 760 public static Future<TestSSLHandshakeCallbacks> handshake(final ServerSocket listener, 764 Future<TestSSLHandshakeCallbacks> future = executor.submit( local 805 return future; 841 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks, null, null); 842 Future<TestSSLHandshakeCallbacks> server = handshake(listener, 0, false, sHooks, null, null); [all...] |
/external/e2fsprogs/lib/blkid/ |
probe.h | 206 __u32 future; member in struct:cramfs_super_block 662 * to allowr for stripe alignment in the future 723 /* future expansion */
|
/prebuilts/tools/common/easymock-tools/ |
easymock-3.1-tests.jar | |
/prebuilts/sdk/tools/lib/ |
guava-10.0.1.jar | |
lint.jar | |
lint_api.jar | |
lint_checks.jar | |
/external/droiddriver/libs/ |
guava-13.0.jar | |
/prebuilts/devtools/tools/lib/ |
guava-13.0.1.jar | |
/prebuilts/tools/common/guava-tools/ |
guava-13.0.1.jar | |