| /frameworks/libs/net/common/testutils/devicetests/com/android/testutils/ |
| D | HandlerUtils.kt | 30 fun HandlerThread.waitForIdle(timeoutMs: Int) = threadHandler.waitForIdle(timeoutMs.toLong()) in HandlerThread()
31 fun HandlerThread.waitForIdle(timeoutMs: Long) = threadHandler.waitForIdle(timeoutMs) in HandlerThread()
32 fun Handler.waitForIdle(timeoutMs: Int) = waitForIdle(timeoutMs.toLong()) in HandlerThread()
33 fun Handler.waitForIdle(timeoutMs: Long) { in HandlerThread()
36 if (!cv.block(timeoutMs)) { in HandlerThread()
44 fun waitForIdleSerialExecutor(executor: Executor, timeoutMs: Long) { in waitForIdleSerialExecutor()
47 if (!cv.block(timeoutMs)) { in waitForIdleSerialExecutor()
|
| D | TestableNetworkCallback.kt | 176 constructor(timeoutMs: Long = DEFAULT_TIMEOUT): this(null, timeoutMs)
188 fun pollForNextCallback(timeoutMs: Long = defaultTimeoutMs): CallbackEntry { in pollForNextCallback()
189 return history.poll(timeoutMs) ?: fail("Did not receive callback after ${timeoutMs}ms") in pollForNextCallback()
197 fun assertNoCallback(timeoutMs: Long) { in assertNoCallback()
198 val cb = history.poll(timeoutMs) in assertNoCallback()
206 timeoutMs: Long = defaultTimeoutMs in expectCallback()
207 ): T = pollForNextCallback(timeoutMs).let { in expectCallback()
219 timeoutMs: Long = defaultTimeoutMs, in eventuallyExpect()
222 ): T = eventuallyExpectOrNull(timeoutMs, from, predicate).also { in <lambda>()
228 timeoutMs: Long = defaultTimeoutMs, in eventuallyExpect()
[all …]
|
| D | TapPacketReader.java | 83 public byte[] popPacket(long timeoutMs) { in popPacket() argument
84 return poll(timeoutMs); in popPacket()
93 public byte[] popPacket(long timeoutMs, @NonNull Predicate<byte[]> filter) { in popPacket() argument
94 return poll(timeoutMs, filter); in popPacket()
101 public byte[] poll(long timeoutMs) { in poll() argument
102 return mReadHead.getValue().poll(timeoutMs, packet -> true); in poll()
109 public byte[] poll(long timeoutMs, @NonNull Predicate<byte[]> filter) { in poll() argument
110 return mReadHead.getValue().poll(timeoutMs, filter::test); in poll()
|
| /frameworks/base/services/net/java/android/net/util/ |
| D | NetdService.java | 82 long timeoutMs = 0; in get() local
93 timeoutMs = Math.min(timeoutMs + BASE_TIMEOUT_MS, MAX_TIMEOUT_MS); in get()
94 timeoutMs = Math.min(timeoutMs, remaining); in get()
96 Thread.sleep(timeoutMs); in get()
|
| /frameworks/base/services/backup/java/com/android/server/backup/remote/ |
| D | RemoteCall.java | 57 public static RemoteResult execute(RemoteCallable<IBackupCallback> callable, long timeoutMs) in execute() argument
59 return new RemoteCall(callable, timeoutMs).call(); in execute()
75 public RemoteCall(RemoteCallable<IBackupCallback> callable, long timeoutMs) { in RemoteCall() argument
76 this(false, callable, timeoutMs); in RemoteCall()
86 public RemoteCall(boolean cancelled, RemoteCallable<IBackupCallback> callable, long timeoutMs) { in RemoteCall() argument
88 mTimeoutMs = timeoutMs; in RemoteCall()
|
| /frameworks/libs/net/common/testutils/hostdevice/com/android/net/module/util/ |
| D | TrackRecord.kt | 46 fun poll(timeoutMs: Long, pos: Int, predicate: (E) -> Boolean = { true }): E? in add()
103 override fun poll(timeoutMs: Long, pos: Int, predicate: (E) -> Boolean) = lock.withLock { in <lambda>()
104 elements.getOrNull(pollForIndexReadLocked(timeoutMs, pos, predicate)) in <lambda>()
115 private fun pollForIndexReadLocked(timeoutMs: Long, pos: Int, predicate: (E) -> Boolean): Int { in pollForIndexReadLocked()
116 val deadline = System.currentTimeMillis() + timeoutMs in pollForIndexReadLocked()
261 fun poll(timeoutMs: Long, predicate: (E) -> Boolean = { true }): E? { in newReadHead()
266 val index = pollForIndexReadLocked(timeoutMs, readHead, predicate) in newReadHead()
287 private fun Condition.await(timeoutMs: Long) = this.await(timeoutMs, TimeUnit.MILLISECONDS)
|
| /frameworks/ex/camera2/public/src/com/android/ex/camera2/blocking/ |
| D | BlockingSessionCallback.java | 139 public CameraCaptureSession waitAndGetSession(long timeoutMs) { in waitAndGetSession() argument
141 return mSessionFuture.get(timeoutMs, TimeUnit.MILLISECONDS); in waitAndGetSession()
144 String.format("Failed to get session after %s milliseconds", timeoutMs), e); in waitAndGetSession()
233 CameraCaptureSession session, Surface surface, long timeoutMs) { in waitForSurfacePrepared() argument
240 long waitTimeRemaining = timeoutMs; in waitForSurfacePrepared()
243 mPreparedSurfaces.wait(timeoutMs); in waitForSurfacePrepared()
253 "Unable to get Surface prepared in " + timeoutMs + "ms"); in waitForSurfacePrepared()
292 long timeoutMs = unit.convert(timeout, TimeUnit.MILLISECONDS); in get() local
293 if (!mCondVar.block(timeoutMs)) { in get()
|
| D | BlockingExtensionSessionCallback.java | 122 public CameraExtensionSession waitAndGetSession(long timeoutMs) { in waitAndGetSession() argument
124 return mSessionFuture.get(timeoutMs, TimeUnit.MILLISECONDS); in waitAndGetSession()
127 String.format("Failed to get session after %s milliseconds", timeoutMs), e); in waitAndGetSession()
192 long timeoutMs = unit.convert(timeout, TimeUnit.MILLISECONDS); in get() local
193 if (!mCondVar.block(timeoutMs)) { in get()
|
| /frameworks/base/core/tests/coretests/src/android/app/activity/ |
| D | ActivityTestsBase.java | 143 public int waitForResultOrThrow(int timeoutMs) { in waitForResultOrThrow() argument
144 return waitForResultOrThrow(timeoutMs, null); in waitForResultOrThrow()
147 public int waitForResultOrThrow(int timeoutMs, String expected) { in waitForResultOrThrow() argument
148 int res = waitForResult(timeoutMs, expected); in waitForResultOrThrow()
163 public int waitForResult(int timeoutMs, String expected) { in waitForResult() argument
166 long endTime = System.currentTimeMillis() + timeoutMs; in waitForResult()
|
| /frameworks/base/cmds/incidentd/src/ |
| D | Section.h | 44 const int64_t timeoutMs; // each section must have a timeout variable
47 Section(int id, int64_t timeoutMs = REMOTE_CALL_TIMEOUT_MS);
59 int64_t timeoutMs = 5000 /* 5 seconds */);
89 WorkerThreadSection(int id, int64_t timeoutMs = REMOTE_CALL_TIMEOUT_MS);
102 CommandSection(int id, int64_t timeoutMs, const char* command, ...);
187 TombstoneSection(int id, const char* type, int64_t timeoutMs = 120000 /* 2 minutes */);
|
| D | Section.cpp | 79 Section::Section(int i, int64_t timeoutMs) in Section() argument
81 timeoutMs(timeoutMs) { in Section()
89 FileSection::FileSection(int id, const char* filename, const int64_t timeoutMs) in FileSection() argument
90 : Section(id, timeoutMs), mFilename(filename) { in FileSection()
127 this->timeoutMs, mIsSysfs); in Execute()
208 fd.get(), std::move(p2cPipe.writeFd()), std::move(c2pPipe.readFd()), this->timeoutMs, in Execute()
252 WorkerThreadSection::WorkerThreadSection(int id, const int64_t timeoutMs) in WorkerThreadSection() argument
253 : Section(id, timeoutMs) {} in WorkerThreadSection()
291 err = buffer.read(data->pipe.readFd().get(), this->timeoutMs); in Execute()
331 CommandSection::CommandSection(int id, const int64_t timeoutMs, const char* command, ...) in CommandSection() argument
[all …]
|
| /frameworks/base/core/java/android/os/ |
| D | ConditionVariable.java | 117 public boolean block(long timeoutMs) in block() argument
122 if (timeoutMs != 0) { in block()
125 long end = now + timeoutMs; in block()
|
| /frameworks/base/libs/WindowManager/Shell/src/com/android/wm/shell/animation/ |
| D | PhysicsAnimatorTestUtils.kt | 53 var timeoutMs: Long = 2000 in <lambda>() variable
73 timeoutMs = 2000 in <lambda>()
98 fun setBlockTimeout(timeoutMs: Long) { in <lambda>()
99 PhysicsAnimatorTestUtils.timeoutMs = timeoutMs in <lambda>()
147 latch.await(timeoutMs, TimeUnit.MILLISECONDS) in <lambda>()
198 latch.await(timeoutMs, TimeUnit.MILLISECONDS) in <lambda>()
462 unblockLatch.await(timeoutMs, TimeUnit.MILLISECONDS) in <lambda>()
482 unblockLatch.await(timeoutMs, TimeUnit.MILLISECONDS) in <lambda>()
|
| /frameworks/ex/camera2/public/src/com/android/ex/camera2/utils/ |
| D | StateWaiter.java | 97 public void waitForState(int state, long timeoutMs) { in waitForState() argument
100 waitForAnyOfStates(Arrays.asList(stateArray), timeoutMs); in waitForState() local
120 public int waitForAnyOfStates(Collection<Integer> states, final long timeoutMs) { in waitForAnyOfStates() argument
136 long timeoutLeft = timeoutMs; in waitForAnyOfStates()
160 s.append(timeoutMs); in waitForAnyOfStates()
|
| /frameworks/ex/camera2/portability/src/com/android/ex/camera2/portability/ |
| D | DispatchThread.java | 73 public void runJobSync(final Runnable job, Object waitLock, long timeoutMs, String jobMsg) { in runJobSync() argument
74 String timeoutMsg = "Timeout waiting " + timeoutMs + "ms for " + jobMsg; in runJobSync()
76 long timeoutBound = SystemClock.uptimeMillis() + timeoutMs; in runJobSync()
79 waitLock.wait(timeoutMs); in runJobSync()
|
| D | CameraStateHolder.java | 95 long timeoutMs) { in waitForCondition() argument
96 long timeBound = SystemClock.uptimeMillis() + timeoutMs; in waitForCondition()
100 this.wait(timeoutMs); in waitForCondition()
|
| /frameworks/av/media/utils/fuzzers/ |
| D | TimeCheckFuzz.cpp | 37 uint32_t timeoutMs = in LLVMFuzzerTestOneInput() local
51 android::TimeCheck timeCheck(name.c_str(), timeoutMs); in LLVMFuzzerTestOneInput()
53 uint8_t sleep_amount_ms = data_provider.ConsumeIntegralInRange<uint8_t>(0, timeoutMs / 2); in LLVMFuzzerTestOneInput()
|
| /frameworks/base/packages/SystemUI/src/com/android/keyguard/ |
| D | KeyguardAbsKeyInputViewController.java | 169 void onPasswordChecked(int userId, boolean matched, int timeoutMs, boolean isValidPassword) { in onPasswordChecked() argument
180 getKeyguardSecurityCallback().reportUnlockAttempt(userId, false, timeoutMs); in onPasswordChecked()
181 if (timeoutMs > 0) { in onPasswordChecked()
183 userId, timeoutMs); in onPasswordChecked()
187 if (timeoutMs == 0) { in onPasswordChecked()
233 public void onChecked(boolean matched, int timeoutMs) { in verifyPasswordAndUnlock()
238 onPasswordChecked(userId, false /* matched */, timeoutMs, in verifyPasswordAndUnlock()
|
| D | KeyguardPatternViewController.java | 136 public void onChecked(boolean matched, int timeoutMs) { in onPatternDetected()
141 onPatternChecked(userId, false /* matched */, timeoutMs, in onPatternDetected()
159 private void onPatternChecked(int userId, boolean matched, int timeoutMs, in onPatternChecked() argument
172 getKeyguardSecurityCallback().reportUnlockAttempt(userId, false, timeoutMs); in onPatternChecked()
173 if (timeoutMs > 0) { in onPatternChecked()
175 userId, timeoutMs); in onPatternChecked()
179 if (timeoutMs == 0) { in onPatternChecked()
|
| /frameworks/av/media/utils/ |
| D | TimeCheck.cpp | 67 TimeCheck::TimeCheck(const char *tag, uint32_t timeoutMs) in TimeCheck() argument
68 : mEndTimeNs(getTimeCheckThread()->startMonitoring(tag, timeoutMs)) in TimeCheck()
84 nsecs_t TimeCheck::TimeCheckThread::startMonitoring(const char *tag, uint32_t timeoutMs) { in startMonitoring() argument
86 nsecs_t endTimeNs = systemTime() + milliseconds(timeoutMs); in startMonitoring()
|
| /frameworks/base/tests/SurfaceViewBufferTests/cpp/ |
| D | SurfaceProxy.cpp | 50 JNIEnv*, jclass, jlong jFrameNumber, jint timeoutMs) { in Java_com_android_test_SurfaceProxy_waitUntilBufferDisplayed() argument
71 timeoutMs) { in Java_com_android_test_SurfaceProxy_waitUntilBufferDisplayed()
124 jint timeoutMs) { in Java_com_android_test_SurfaceProxy_SurfaceDequeueBuffer() argument
133 if (timeoutMs == 0) { in Java_com_android_test_SurfaceProxy_SurfaceDequeueBuffer()
137 int waitResult = fence->wait(timeoutMs); in Java_com_android_test_SurfaceProxy_SurfaceDequeueBuffer()
212 JNIEnv* /* env */, jclass /* clazz */, jlong timeoutMs) { in Java_com_android_test_SurfaceProxy_SurfaceSetDequeueTimeout() argument
215 return surface->setDequeueTimeout(timeoutMs); in Java_com_android_test_SurfaceProxy_SurfaceSetDequeueTimeout()
|
| /frameworks/libs/net/common/testutils/hostdevice/com/android/testutils/ |
| D | ConcurrentUtils.kt | 28 fun CountDownLatch.await(timeoutMs: Long): Boolean = await(timeoutMs, TimeUnit.MILLISECONDS)
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/biometrics/ |
| D | AuthCredentialPatternView.java | 83 private void onPatternVerified(@NonNull VerifyCredentialResponse response, int timeoutMs) { in onPatternVerified() argument
84 AuthCredentialPatternView.this.onCredentialVerified(response, timeoutMs); in onPatternVerified()
85 if (timeoutMs > 0) { in onPatternVerified()
|
| /frameworks/opt/car/services/src/jni/ |
| D | com_android_internal_car_CarServiceHelperService.cpp | 31 static jint nativeForceSuspend(JNIEnv* /* env */, jclass /* clazz */, jint timeoutMs) { in nativeForceSuspend() argument
32 jint ret = autosuspend_force_suspend(timeoutMs); in nativeForceSuspend()
|
| /frameworks/av/media/utils/include/mediautils/ |
| D | TimeCheck.h | 36 TimeCheck(const char *tag, uint32_t timeoutMs = kDefaultTimeOutMs);
49 nsecs_t startMonitoring(const char *tag, uint32_t timeoutMs);
|