| /cts/tests/tests/telecom/src/android/telecom/cts/ |
| D | ConnectionTest.java | 44 final Semaphore lock = new Semaphore(0); in testStateCallbacks() local
45 Connection connection = createConnection(lock); in testStateCallbacks()
47 waitForStateChange(lock); in testStateCallbacks()
51 waitForStateChange(lock); in testStateCallbacks()
55 waitForStateChange(lock); in testStateCallbacks()
59 waitForStateChange(lock); in testStateCallbacks()
63 waitForStateChange(lock); in testStateCallbacks()
67 waitForStateChange(lock); in testStateCallbacks()
71 waitForStateChange(lock); in testStateCallbacks()
75 waitForStateChange(lock); in testStateCallbacks()
[all …]
|
| D | CtsSelfManagedConnectionService.java | 201 public boolean waitForUpdate(int lock) { in waitForUpdate() argument
202 mLocks[lock] = TestUtils.waitForLock(mLocks[lock]); in waitForUpdate()
203 return mLocks[lock] != null; in waitForUpdate()
|
| D | BaseRemoteTelecomTest.java | 111 if (!remoteConnectionService.lock.tryAcquire(TestUtils.WAIT_FOR_STATE_CHANGE_TIMEOUT_MS, in verifyConnectionForOutgoingCallOnRemoteCS()
134 if (!remoteConnectionService.lock.tryAcquire(TestUtils.WAIT_FOR_STATE_CHANGE_TIMEOUT_MS, in verifyConnectionForIncomingCallOnRemoteCS()
152 assertEquals("Lock should have no permits!", 0, mInCallCallbacks.lock.availablePermits()); in setAndVerifyConferenceablesForOutgoingConnectionOnRemoteCS()
172 if (!remoteConnectionService.lock.tryAcquire(TestUtils.WAIT_FOR_STATE_CHANGE_TIMEOUT_MS, in verifyConferenceForOutgoingCallOnRemoteCS()
|
| D | MockConnectionService.java | 60 public Semaphore lock = new Semaphore(0); field in MockConnectionService
92 lock.release(); in onCreateOutgoingConnection()
119 lock.release(); in onCreateIncomingConnection()
139 lock.release(); in onConference()
|
| D | ConnectionServiceTest.java | 64 mInCallCallbacks.lock.drainPermits(); in testAddExistingConnection()
88 mInCallCallbacks.lock.drainPermits(); in testAddExistingConnection_invalidPhoneAccountPackageName()
110 mInCallCallbacks.lock.drainPermits(); in testAddExistingConnection_invalidPhoneAccountAccountId()
234 mInCallCallbacks.lock.drainPermits(); in testGetAllConnections()
|
| D | BasicInCallServiceTest.java | 80 if (callbacks.lock.tryAcquire(TestUtils.WAIT_FOR_CALL_ADDED_TIMEOUT_S, in testTelephonyCall_bindsToInCallServiceAndAddsCall()
96 lock.release(); in createCallbacks()
|
| D | TestUtils.java | 232 final CountDownLatch lock = new CountDownLatch(1); in waitOnLocalMainLooper() local
233 mainHandler.post(lock::countDown); in waitOnLocalMainLooper()
234 while (lock.getCount() > 0) { in waitOnLocalMainLooper()
236 lock.await(timeoutMs, TimeUnit.MILLISECONDS); in waitOnLocalMainLooper()
287 public static boolean waitForLatchCountDown(CountDownLatch lock) { in waitForLatchCountDown() argument
288 if (lock == null) { in waitForLatchCountDown()
294 success = lock.await(5000, TimeUnit.MILLISECONDS); in waitForLatchCountDown()
308 public static CountDownLatch waitForLock(CountDownLatch lock) { in waitForLock() argument
309 boolean success = waitForLatchCountDown(lock); in waitForLock()
|
| D | BaseTelecomTestWithMockServices.java | 229 this.lock.release(); in setupCallbacks()
238 this.lock.release(); in setupCallbacks()
243 this.lock.release(); in setupCallbacks()
358 assertEquals("Lock should have no permits!", 0, mInCallCallbacks.lock.availablePermits()); in addAndVerifyNewIncomingCall()
371 if (!mInCallCallbacks.lock.tryAcquire(TestUtils.WAIT_FOR_CALL_ADDED_TIMEOUT_S, in addAndVerifyNewIncomingCall()
415 assertEquals("Lock should have no permits!", 0, mInCallCallbacks.lock.availablePermits()); in placeAndVerifyCall()
424 if (!mInCallCallbacks.lock.tryAcquire(TestUtils.WAIT_FOR_CALL_ADDED_TIMEOUT_S, in placeAndVerifyCall()
458 if (!connectionService.lock.tryAcquire(TestUtils.WAIT_FOR_STATE_CHANGE_TIMEOUT_MS, in verifyConnectionForOutgoingCall()
479 if (!connectionService.lock.tryAcquire(TestUtils.WAIT_FOR_STATE_CHANGE_TIMEOUT_MS, in verifyConnectionForIncomingCall()
500 assertEquals("Lock should have no permits!", 0, mInCallCallbacks.lock.availablePermits()); in setAndVerifyConferenceablesForOutgoingConnection()
[all …]
|
| D | CallScreeningServiceTest.java | 102 if (callbacks.lock.tryAcquire(TestUtils.WAIT_FOR_CALL_ADDED_TIMEOUT_S, in testTelephonyCall_bindsToCallScreeningService()
132 lock.release(); in createCallbacks()
|
| D | ExternalCallTest.java | 59 lock.release(); in setUp()
|
| D | MockCallScreeningService.java | 38 public Semaphore lock = new Semaphore(0); field in MockCallScreeningService.CallScreeningServiceCallbacks
|
| /cts/tests/app/app/src/android/app/stubs/ |
| D | KeyboardShortcutsActivity.java | 47 mLock.lock(); in waitForMenuToBeOpen()
59 mLock.lock(); in onWindowFocusChanged()
72 mLock.lock(); in waitForKeyboardShortcutsToBeRequested()
85 mLock.lock(); in onProvideKeyboardShortcuts()
|
| /cts/tests/tests/speech/src/android/speech/tts/cts/ |
| D | TextToSpeechWrapper.java | 149 mLock.lock(); in onInit()
160 mLock.lock(); in waitForInit()
196 mLock.lock(); in onDone()
208 mLock.lock(); in onError()
219 mLock.lock(); in onError()
230 mLock.lock(); in onStart()
243 mLock.lock(); in onStop()
261 mLock.lock(); in onBeginSynthesis()
273 mLock.lock(); in onAudioAvailable()
289 mLock.lock(); in onRangeStart()
[all …]
|
| /cts/tests/tests/os/src/android/os/cts/ |
| D | PowerManager_WakeLockTest.java | 74 final WakeLock lock = pm.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK, TAG); in testWakeLockTimeout() local
75 lock.acquire(2000); in testWakeLockTimeout()
78 lock.release(); in testWakeLockTimeout()
|
| /cts/suite/audio_quality/lib/src/audio/ |
| D | RemoteAudio.cpp | 127 android::Mutex::Autolock lock(handler->mStateLock); in handlePacket() local
166 handler->mStateLock.lock(); in waitForPlaybackOrRecordingCompletion()
182 handler->mStateLock.lock(); in doStop()
201 handler->mStateLock.lock(); in downloadData()
235 handler->mStateLock.lock(); in startPlayback()
280 handler->mStateLock.lock(); in startRecording()
314 handler->mStateLock.lock(); in getDeviceInfo()
|
| /cts/tests/tests/graphics/jni/ |
| D | ImageReaderTestHelpers.cpp | 75 std::lock_guard<std::mutex> lock(mMutex); in getBufferFromCurrentImage() local
114 std::lock_guard<std::mutex> lock(mMutex); in handleImageAvailable() local
|
| /cts/tests/tests/libcorefileio/src/android/cts/ |
| D | FileChannelInterProcessLockTest.java | 665 return fc.lock();
667 return afc.lock().get();
671 return fc.lock(LOCK_POSITION, LOCK_SIZE, false /*isShared*/);
673 return afc.lock(LOCK_POSITION, LOCK_SIZE, false /*isShared*/).get();
677 return fc.lock(LOCK_POSITION + LOCK_SIZE, LOCK_SIZE, false /*isShared*/);
679 return afc.lock(LOCK_POSITION + LOCK_SIZE, LOCK_SIZE, false /*isShared*/).get();
683 return fc.lock(LOCK_POSITION, LOCK_SIZE, true /*isShared*/);
685 return afc.lock(LOCK_POSITION, LOCK_SIZE, true /*isShared*/).get();
689 return fc.lock(LOCK_POSITION + LOCK_SIZE, LOCK_SIZE, true /*isShared*/);
691 return afc.lock(LOCK_POSITION + LOCK_SIZE, LOCK_SIZE, true /*isShared*/).get();
|
| /cts/tests/camera/libctscamera2jni/ |
| D | native-camera-jni.cpp | 58 std::lock_guard<std::mutex> lock(thiz->mMutex); in onAvailable() local
70 std::lock_guard<std::mutex> lock(thiz->mMutex); in onUnavailable() local
77 std::lock_guard<std::mutex> lock(mMutex); in resetCount() local
84 std::lock_guard<std::mutex> lock(mMutex); in getAvailableCount() local
89 std::lock_guard<std::mutex> lock(mMutex); in getUnavailableCount() local
94 std::lock_guard<std::mutex> lock(mMutex); in isAvailable() local
116 std::lock_guard<std::mutex> lock(thiz->mMutex); in onDisconnected() local
127 std::lock_guard<std::mutex> lock(thiz->mMutex); in onError() local
150 std::lock_guard<std::mutex> lock(thiz->mMutex); in onClosed() local
161 std::lock_guard<std::mutex> lock(thiz->mMutex); in onReady() local
[all …]
|
| /cts/hostsidetests/statsd/apps/statsdapp/src/com/android/server/cts/device/statsd/ |
| D | AtomTests.java | 378 WifiManager.WifiLock lock = wm.createWifiLock("StatsdCTSWifiLock"); in testWifiLock() local
379 lock.acquire(); in testWifiLock()
381 lock.release(); in testWifiLock()
388 WifiManager.MulticastLock lock = wm.createMulticastLock("StatsdCTSMulticastLock"); in testWifiMulticastLock() local
389 lock.acquire(); in testWifiMulticastLock()
391 lock.release(); in testWifiMulticastLock()
|
| /cts/tests/tests/security/src/android/security/cts/ |
| D | StagefrightTest.java | 976 lock.lock(); in onError()
978 lock.unlock(); in onError()
991 lock.lock(); in onCompletion()
994 lock.unlock(); in onCompletion()
998 lock.lock(); in waitForError()
1002 lock.unlock(); in waitForError()
1013 lock.lock(); in waitForErrorOrCompletion()
1017 lock.unlock(); in waitForErrorOrCompletion()
1021 ReentrantLock lock = new ReentrantLock(); field in StagefrightTest.MediaPlayerCrashListener
1022 Condition condition = lock.newCondition();
|
| /cts/tests/tests/display/src/android/display/cts/ |
| D | VirtualDisplayTest.java | 91 mImageReaderLock.lock(); in setUp()
104 mImageReaderLock.lock(); in tearDown()
352 mImageReaderLock.lock(); in onImageAvailable()
|
| /cts/suite/audio_quality/client/src/com/android/cts/audiotest/ |
| D | AudioProtocol.java | 96 mClientLock.lock(); in stop()
180 mClientLock.lock(); in reset()
456 mClientLock.lock(); in sendReplyWithData()
516 mClientLock.lock(); in run()
|
| /cts/suite/audio_quality/lib/src/ |
| D | FileUtil.cpp | 113 android::Mutex::Autolock lock(mWriteLock); in doVprintf() local
|
| /cts/apps/CtsVerifier/assets/scripts/power_monitors/ |
| D | monsoon.py | 62 def lock( device ): member in Power_Monitor
129 self._lockfile = Power_Monitor.lock( device )
200 lockfile = Power_Monitor.lock( dev )
|
| /cts/tests/tests/media/libmediandkjni/ |
| D | native-media-jni.cpp | 146 mMutex.lock(); in ~CallbackData()
156 mMutex.lock(); in addInputBufferId()
163 mMutex.lock(); in getInputBufferId()
173 mMutex.lock(); in addOutputBuffer()
180 mMutex.lock(); in addOutputFormat()
188 mMutex.lock(); in getOutput()
|