Searched refs:waiter (Results 1 – 8 of 8) sorted by relevance
| /frameworks/base/core/java/android/database/sqlite/ |
| D | SQLiteConnectionPool.java | 713 final ConnectionWaiter waiter; in waitForConnection() local
739 waiter = obtainConnectionWaiterLocked(Thread.currentThread(), startTime, in waitForConnection()
745 waiter.mNext = successor; in waitForConnection()
752 predecessor.mNext = waiter; in waitForConnection()
754 mConnectionWaiterQueue = waiter; in waitForConnection()
757 nonce = waiter.mNonce; in waitForConnection()
766 if (waiter.mNonce == nonce) { in waitForConnection()
767 cancelConnectionWaiterLocked(waiter); in waitForConnection()
777 long nextBusyTimeoutTime = waiter.mStartTime + busyTimeoutMillis; in waitForConnection()
796 final SQLiteConnection connection = waiter.mAssignedConnection; in waitForConnection()
[all …]
|
| /frameworks/native/libs/binder/ |
| D | IServiceManager.cpp | 132 sp<RegistrationWaiter>* waiter);
422 sp<Waiter> waiter = sp<Waiter>::make(); in waitForService() local
423 if (Status status = mTheRealServiceManager->registerForNotifications(name, waiter); in waitForService()
430 mTheRealServiceManager->unregisterForNotifications(name, waiter); in waitForService()
440 std::unique_lock<std::mutex> lock(waiter->mMutex); in waitForService()
442 waiter->mCv.wait_for(lock, 1s, [&] { in waitForService()
443 return waiter->mBinder != nullptr; in waitForService()
445 if (waiter->mBinder != nullptr) return waiter->mBinder; in waitForService()
564 sp<RegistrationWaiter>* waiter) { in removeRegistrationCallbackLocked() argument
569 if (waiter) { in removeRegistrationCallbackLocked()
[all …]
|
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/uicc/ |
| D | AdnRecordCache.java | 330 Message waiter = waiters.get(i); in notifyWaiters() local
332 AsyncResult.forMessage(waiter, ar.result, ar.exception); in notifyWaiters()
333 waiter.sendToTarget(); in notifyWaiters()
|
| /frameworks/base/packages/PrintSpooler/tests/outofprocess/src/com/android/printspooler/outofprocess/tests/ |
| D | WorkflowTest.java | 92 private void waitWithTimeout(Supplier<Boolean> condition, InterruptableConsumer<Long> waiter) in waitWithTimeout() argument
101 waiter.accept(timeLeft); in waitWithTimeout()
|
| /frameworks/base/services/core/java/com/android/server/am/ |
| D | ActivityManagerShellCommand.java | 248 final ProgressWaiter waiter = new ProgressWaiter(0); in onCommand() local
255 waiter.onFinished(0, null /* extras */); in onCommand()
262 waiter.waitForFinish(USER_OPERATION_TIMEOUT_MS); in onCommand()
2480 final ProgressWaiter waiter = wait ? new ProgressWaiter(userId) : null;
2492 isProfile, isVisibleProfile, displayId, waiter);
2499 Slogf.d(TAG, "calling startProfileWithListener(%d, %s)", userId, waiter);
2503 success = mInterface.startProfileWithListener(userId, waiter);
2506 success = mInterface.startUserInBackgroundWithListener(userId, waiter);
2513 displayId, waiter);
2515 waiter);
[all …]
|
| /frameworks/base/services/companion/java/com/android/server/companion/virtual/ |
| D | InputController.java | 767 try (WaitForDevice waiter = new WaitForDevice(deviceName, vendorId, productId, displayId)) { in createDeviceInternal() argument
778 inputDeviceId = waiter.waitForDeviceCreation(); in createDeviceInternal()
|
| /frameworks/base/services/tests/wmtests/src/com/android/server/wm/ |
| D | SyncEngineTests.java | 698 TestWindowContainer(WindowManagerService wms, boolean waiter) { in TestWindowContainer() argument
700 mWaiter = waiter; in TestWindowContainer()
|
| /frameworks/base/core/java/android/app/ |
| D | Instrumentation.java | 2643 public ActivityGoing(ActivityWaiter waiter) { in ActivityGoing() argument
2644 mWaiter = waiter; in ActivityGoing()
|