| /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 | 156 public boolean waitForUpdate(int lock) { in waitForUpdate() argument
157 mLocks[lock] = waitForLock(mLocks[lock]); in waitForUpdate()
158 return mLocks[lock] != null; in waitForUpdate()
178 private static CountDownLatch waitForLock(CountDownLatch lock) { in waitForLock() argument
181 success = lock.await(5000, TimeUnit.MILLISECONDS); in waitForLock()
|
| D | MockConnectionService.java | 46 public Semaphore lock = new Semaphore(0); field in MockConnectionService
70 lock.release(); in onCreateOutgoingConnection()
88 lock.release(); in onCreateIncomingConnection()
108 lock.release(); in onConference()
|
| D | ConnectionServiceTest.java | 56 mInCallCallbacks.lock.drainPermits(); in testAddExistingConnection()
80 mInCallCallbacks.lock.drainPermits(); in testAddExistingConnection_invalidPhoneAccountPackageName()
102 mInCallCallbacks.lock.drainPermits(); in testAddExistingConnection_invalidPhoneAccountAccountId()
129 mInCallCallbacks.lock.drainPermits(); in testGetAllConnections()
|
| 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 | BaseTelecomTestWithMockServices.java | 160 this.lock.release(); in setupCallbacks()
169 this.lock.release(); in setupCallbacks()
174 this.lock.release(); in setupCallbacks()
252 assertEquals("Lock should have no permits!", 0, mInCallCallbacks.lock.availablePermits()); in addAndVerifyNewIncomingCall()
265 if (!mInCallCallbacks.lock.tryAcquire(TestUtils.WAIT_FOR_CALL_ADDED_TIMEOUT_S, in addAndVerifyNewIncomingCall()
309 assertEquals("Lock should have no permits!", 0, mInCallCallbacks.lock.availablePermits()); in placeAndVerifyCall()
318 if (!mInCallCallbacks.lock.tryAcquire(TestUtils.WAIT_FOR_CALL_ADDED_TIMEOUT_S, in placeAndVerifyCall()
352 if (!connectionService.lock.tryAcquire(TestUtils.WAIT_FOR_STATE_CHANGE_TIMEOUT_MS, in verifyConnectionForOutgoingCall()
373 if (!connectionService.lock.tryAcquire(TestUtils.WAIT_FOR_STATE_CHANGE_TIMEOUT_MS, in verifyConnectionForIncomingCall()
394 assertEquals("Lock should have no permits!", 0, mInCallCallbacks.lock.availablePermits()); in setAndVerifyConferenceablesForOutgoingConnection()
[all …]
|
| D | BasicInCallServiceTest.java | 80 if (callbacks.lock.tryAcquire(TestUtils.WAIT_FOR_CALL_ADDED_TIMEOUT_S, in testTelephonyCall_bindsToInCallServiceAndAddsCall()
96 lock.release(); in createCallbacks()
|
| D | CallScreeningServiceTest.java | 102 if (callbacks.lock.tryAcquire(TestUtils.WAIT_FOR_CALL_ADDED_TIMEOUT_S, in testTelephonyCall_bindsToCallScreeningService()
132 lock.release(); in createCallbacks()
|
| D | TestUtils.java | 210 public static CountDownLatch waitForLock(CountDownLatch lock) { in waitForLock() argument
213 if (lock == null) { in waitForLock()
216 success = lock.await(5000, TimeUnit.MILLISECONDS); in waitForLock()
|
| D | ExternalCallTest.java | 59 lock.release(); in setUp()
|
| D | MockCallScreeningService.java | 38 public Semaphore lock = new Semaphore(0); field in MockCallScreeningService.CallScreeningServiceCallbacks
|
| D | RemoteConferenceTest.java | 533 lock.release(); in addRemoteConnectionOutgoingCalls()
570 lock.release(); in addRemoteConnectionOutgoingCalls()
|
| D | MockInCallService.java | 47 public Semaphore lock = new Semaphore(0); field in MockInCallService.InCallServiceCallbacks
|
| /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/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/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/security/src/android/security/cts/ |
| D | StagefrightTest.java | 405 lock.lock(); in onError()
407 lock.unlock(); in onError()
420 lock.lock(); in onCompletion()
422 lock.unlock(); in onCompletion()
426 lock.lock(); in waitForError()
430 lock.unlock(); in waitForError()
440 ReentrantLock lock = new ReentrantLock(); field in StagefrightTest.MediaPlayerCrashListener
441 Condition condition = lock.newCondition();
|
| /cts/tests/camera/libctscamera2jni/ |
| D | native-camera-jni.cpp | 55 std::lock_guard<std::mutex> lock(thiz->mMutex); in onAvailable() local
67 std::lock_guard<std::mutex> lock(thiz->mMutex); in onUnavailable() local
74 std::lock_guard<std::mutex> lock(mMutex); in resetCount() local
81 std::lock_guard<std::mutex> lock(mMutex); in getAvailableCount() local
86 std::lock_guard<std::mutex> lock(mMutex); in getUnavailableCount() local
91 std::lock_guard<std::mutex> lock(mMutex); in isAvailable() local
113 std::lock_guard<std::mutex> lock(thiz->mMutex); in onDisconnected() local
124 std::lock_guard<std::mutex> lock(thiz->mMutex); in onError() local
147 std::lock_guard<std::mutex> lock(thiz->mMutex); in onClosed() local
158 std::lock_guard<std::mutex> lock(thiz->mMutex); in onReady() local
[all …]
|
| /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/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/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/suite/audio_quality/lib/src/ |
| D | FileUtil.cpp | 113 android::Mutex::Autolock lock(mWriteLock); in doVprintf() local
|
| /cts/tests/tests/media/libimagereaderjni/ |
| D | AImageReaderCts.cpp | 325 std::lock_guard<std::mutex> lock(mMutex); in getAcquiredImageCount() local
330 std::lock_guard<std::mutex> lock(mMutex); in HandleImageAvailable() local
|
| /cts/common/host-side/tradefed/src/com/android/compatibility/common/tradefed/testtype/ |
| D | ModuleRepo.java | 72 private static Object lock = new Object(); field in ModuleRepo
182 synchronized (lock) { in initialize()
529 synchronized (lock) { in getModules()
|