Lines Matching refs:mProcess
585 if (mProcess->mDriverFD < 0) in flushCommands()
616 pthread_mutex_lock(&mProcess->mThreadCountLock); in blockUntilThreadAvailable()
617 mProcess->mWaitingForThreads++; in blockUntilThreadAvailable()
618 while (mProcess->mExecutingThreadsCount >= mProcess->mMaxThreads) { in blockUntilThreadAvailable()
620 static_cast<unsigned long>(mProcess->mExecutingThreadsCount), in blockUntilThreadAvailable()
621 static_cast<unsigned long>(mProcess->mMaxThreads)); in blockUntilThreadAvailable()
622 pthread_cond_wait(&mProcess->mThreadCountDecrement, &mProcess->mThreadCountLock); in blockUntilThreadAvailable()
624 mProcess->mWaitingForThreads--; in blockUntilThreadAvailable()
625 pthread_mutex_unlock(&mProcess->mThreadCountLock); in blockUntilThreadAvailable()
645 pthread_mutex_lock(&mProcess->mThreadCountLock); in getAndExecuteCommand()
646 mProcess->mExecutingThreadsCount++; in getAndExecuteCommand()
647 if (mProcess->mExecutingThreadsCount >= mProcess->mMaxThreads && in getAndExecuteCommand()
648 mProcess->mStarvationStartTimeMs == 0) { in getAndExecuteCommand()
649 mProcess->mStarvationStartTimeMs = uptimeMillis(); in getAndExecuteCommand()
651 pthread_mutex_unlock(&mProcess->mThreadCountLock); in getAndExecuteCommand()
655 pthread_mutex_lock(&mProcess->mThreadCountLock); in getAndExecuteCommand()
656 mProcess->mExecutingThreadsCount--; in getAndExecuteCommand()
657 if (mProcess->mExecutingThreadsCount < mProcess->mMaxThreads && in getAndExecuteCommand()
658 mProcess->mStarvationStartTimeMs != 0) { in getAndExecuteCommand()
659 int64_t starvationTimeMs = uptimeMillis() - mProcess->mStarvationStartTimeMs; in getAndExecuteCommand()
662 mProcess->mMaxThreads, starvationTimeMs); in getAndExecuteCommand()
664 mProcess->mStarvationStartTimeMs = 0; in getAndExecuteCommand()
669 if (mProcess->mWaitingForThreads > 0) { in getAndExecuteCommand()
670 pthread_cond_broadcast(&mProcess->mThreadCountDecrement); in getAndExecuteCommand()
672 pthread_mutex_unlock(&mProcess->mThreadCountLock); in getAndExecuteCommand()
697 refs->decWeak(mProcess.get()); in processPendingDerefs()
707 obj->decStrong(mProcess.get()); in processPendingDerefs()
717 refs->decWeak(mProcess.get()); in processPostWriteDerefs()
723 obj->decStrong(mProcess.get()); in processPostWriteDerefs()
731 pthread_mutex_lock(&mProcess->mThreadCountLock); in joinThreadPool()
732 mProcess->mCurrentThreads++; in joinThreadPool()
733 pthread_mutex_unlock(&mProcess->mThreadCountLock); in joinThreadPool()
745 mProcess->mDriverFD, result); in joinThreadPool()
761 pthread_mutex_lock(&mProcess->mThreadCountLock); in joinThreadPool()
762 LOG_ALWAYS_FATAL_IF(mProcess->mCurrentThreads == 0, in joinThreadPool()
766 mProcess->mCurrentThreads--; in joinThreadPool()
767 pthread_mutex_unlock(&mProcess->mThreadCountLock); in joinThreadPool()
772 if (mProcess->mDriverFD < 0) { in setupPolling()
778 *fd = mProcess->mDriverFD; in setupPolling()
779 pthread_mutex_lock(&mProcess->mThreadCountLock); in setupPolling()
780 mProcess->mCurrentThreads++; in setupPolling()
781 pthread_mutex_unlock(&mProcess->mThreadCountLock); in setupPolling()
802 int fd = mProcess->mDriverFD; in stopProcess()
803 mProcess->mDriverFD = -1; in stopProcess()
892 proxy->incStrong(mProcess.get()); in incStrongHandle()
912 proxy->getWeakRefs()->incWeak(mProcess.get()); in incWeakHandle()
936 self()->mProcess->expungeHandle(handle, binder); // NOLINT in expungeHandle()
956 : mProcess(ProcessState::self()), in IPCThreadState()
965 mCallRestriction(mProcess->mCallRestriction) { in IPCThreadState()
1094 if (mProcess->mDriverFD < 0) { in talkWithDriver()
1150 if (ioctl(mProcess->mDriverFD, BINDER_WRITE_READ, &bwr) >= 0) in talkWithDriver()
1157 if (mProcess->mDriverFD < 0) { in talkWithDriver()
1208 ALOGE_IF(mProcess->mDriverFD >= 0, in talkWithDriver()
1211 statusToString(err).c_str(), mProcess->mDriverName.c_str()); in talkWithDriver()
1278 obj->incStrong(mProcess.get()); in executeCommand()
1304 refs->incWeak(mProcess.get()); in executeCommand()
1328 const bool success = refs->attemptIncStrong(mProcess.get()); in executeCommand()
1497 mProcess->spawnPooledThread(false); in executeCommand()
1523 if (self->mProcess->mDriverFD >= 0) { in threadDestructor()
1524 ioctl(self->mProcess->mDriverFD, BINDER_THREAD_EXIT, 0); in threadDestructor()
1539 if (ioctl(self()->mProcess->mDriverFD, BINDER_GET_FROZEN_INFO, &info) < 0) in getProcessFreezeInfo()
1558 if (ioctl(self()->mProcess->mDriverFD, BINDER_FREEZE, &info) < 0) in freeze()
1576 if (ioctl(self()->mProcess->mDriverFD, BINDER_GET_EXTENDED_ERROR, &ee) < 0) { in logExtendedError()