Lines Matching refs:mProcess
357 return mProcess; in process()
476 if (mProcess->mDriverFD < 0) in flushCommands()
507 pthread_mutex_lock(&mProcess->mThreadCountLock); in blockUntilThreadAvailable()
508 mProcess->mWaitingForThreads++; in blockUntilThreadAvailable()
509 while (mProcess->mExecutingThreadsCount >= mProcess->mMaxThreads) { in blockUntilThreadAvailable()
511 static_cast<unsigned long>(mProcess->mExecutingThreadsCount), in blockUntilThreadAvailable()
512 static_cast<unsigned long>(mProcess->mMaxThreads)); in blockUntilThreadAvailable()
513 pthread_cond_wait(&mProcess->mThreadCountDecrement, &mProcess->mThreadCountLock); in blockUntilThreadAvailable()
515 mProcess->mWaitingForThreads--; in blockUntilThreadAvailable()
516 pthread_mutex_unlock(&mProcess->mThreadCountLock); in blockUntilThreadAvailable()
534 pthread_mutex_lock(&mProcess->mThreadCountLock); in getAndExecuteCommand()
535 mProcess->mExecutingThreadsCount++; in getAndExecuteCommand()
536 if (mProcess->mExecutingThreadsCount >= mProcess->mMaxThreads && in getAndExecuteCommand()
537 mProcess->mStarvationStartTimeMs == 0) { in getAndExecuteCommand()
538 mProcess->mStarvationStartTimeMs = uptimeMillis(); in getAndExecuteCommand()
540 pthread_mutex_unlock(&mProcess->mThreadCountLock); in getAndExecuteCommand()
544 pthread_mutex_lock(&mProcess->mThreadCountLock); in getAndExecuteCommand()
545 mProcess->mExecutingThreadsCount--; in getAndExecuteCommand()
546 if (mProcess->mExecutingThreadsCount < mProcess->mMaxThreads && in getAndExecuteCommand()
547 mProcess->mStarvationStartTimeMs != 0) { in getAndExecuteCommand()
548 int64_t starvationTimeMs = uptimeMillis() - mProcess->mStarvationStartTimeMs; in getAndExecuteCommand()
551 mProcess->mMaxThreads, starvationTimeMs); in getAndExecuteCommand()
553 mProcess->mStarvationStartTimeMs = 0; in getAndExecuteCommand()
558 if (mProcess->mWaitingForThreads > 0) { in getAndExecuteCommand()
559 pthread_cond_broadcast(&mProcess->mThreadCountDecrement); in getAndExecuteCommand()
561 pthread_mutex_unlock(&mProcess->mThreadCountLock); in getAndExecuteCommand()
586 refs->decWeak(mProcess.get()); in processPendingDerefs()
596 obj->decStrong(mProcess.get()); in processPendingDerefs()
606 refs->decWeak(mProcess.get()); in processPostWriteDerefs()
612 obj->decStrong(mProcess.get()); in processPostWriteDerefs()
632 mProcess->mDriverFD, result); in joinThreadPool()
652 if (mProcess->mDriverFD < 0) { in setupPolling()
658 *fd = mProcess->mDriverFD; in setupPolling()
679 int fd = mProcess->mDriverFD; in stopProcess()
680 mProcess->mDriverFD = -1; in stopProcess()
764 proxy->incStrong(mProcess.get()); in incStrongHandle()
784 proxy->getWeakRefs()->incWeak(mProcess.get()); in incWeakHandle()
826 self()->mProcess->expungeHandle(handle, binder); // NOLINT in expungeHandle()
846 : mProcess(ProcessState::self()), in IPCThreadState()
854 mCallRestriction(mProcess->mCallRestriction) { in IPCThreadState()
977 if (mProcess->mDriverFD < 0) { in talkWithDriver()
1028 if (ioctl(mProcess->mDriverFD, BINDER_WRITE_READ, &bwr) >= 0) in talkWithDriver()
1035 if (mProcess->mDriverFD < 0) { in talkWithDriver()
1145 obj->incStrong(mProcess.get()); in executeCommand()
1171 refs->incWeak(mProcess.get()); in executeCommand()
1194 const bool success = refs->attemptIncStrong(mProcess.get()); in executeCommand()
1351 mProcess->spawnPooledThread(false); in executeCommand()
1377 if (self->mProcess->mDriverFD >= 0) { in threadDestructor()
1378 ioctl(self->mProcess->mDriverFD, BINDER_THREAD_EXIT, 0); in threadDestructor()
1392 if (ioctl(self()->mProcess->mDriverFD, BINDER_GET_FROZEN_INFO, &info) < 0) in getProcessFreezeInfo()
1410 if (ioctl(self()->mProcess->mDriverFD, BINDER_GET_FROZEN_INFO, &info) < 0) in getProcessFreezeInfo()
1430 if (ioctl(self()->mProcess->mDriverFD, BINDER_FREEZE, &info) < 0) in freeze()