Lines Matching refs:mProcess

356     return mProcess;  in process()
467 if (mProcess->mDriverFD < 0) in flushCommands()
483 pthread_mutex_lock(&mProcess->mThreadCountLock); in blockUntilThreadAvailable()
484 while (mProcess->mExecutingThreadsCount >= mProcess->mMaxThreads) { in blockUntilThreadAvailable()
486 static_cast<unsigned long>(mProcess->mExecutingThreadsCount), in blockUntilThreadAvailable()
487 static_cast<unsigned long>(mProcess->mMaxThreads)); in blockUntilThreadAvailable()
488 pthread_cond_wait(&mProcess->mThreadCountDecrement, &mProcess->mThreadCountLock); in blockUntilThreadAvailable()
490 pthread_mutex_unlock(&mProcess->mThreadCountLock); in blockUntilThreadAvailable()
508 pthread_mutex_lock(&mProcess->mThreadCountLock); in getAndExecuteCommand()
509 mProcess->mExecutingThreadsCount++; in getAndExecuteCommand()
510 if (mProcess->mExecutingThreadsCount >= mProcess->mMaxThreads && in getAndExecuteCommand()
511 mProcess->mStarvationStartTimeMs == 0) { in getAndExecuteCommand()
512 mProcess->mStarvationStartTimeMs = uptimeMillis(); in getAndExecuteCommand()
514 pthread_mutex_unlock(&mProcess->mThreadCountLock); in getAndExecuteCommand()
518 pthread_mutex_lock(&mProcess->mThreadCountLock); in getAndExecuteCommand()
519 mProcess->mExecutingThreadsCount--; in getAndExecuteCommand()
520 if (mProcess->mExecutingThreadsCount < mProcess->mMaxThreads && in getAndExecuteCommand()
521 mProcess->mStarvationStartTimeMs != 0) { in getAndExecuteCommand()
522 int64_t starvationTimeMs = uptimeMillis() - mProcess->mStarvationStartTimeMs; in getAndExecuteCommand()
525 mProcess->mMaxThreads, starvationTimeMs); in getAndExecuteCommand()
527 mProcess->mStarvationStartTimeMs = 0; in getAndExecuteCommand()
529 pthread_cond_broadcast(&mProcess->mThreadCountDecrement); in getAndExecuteCommand()
530 pthread_mutex_unlock(&mProcess->mThreadCountLock); in getAndExecuteCommand()
555 refs->decWeak(mProcess.get()); in processPendingDerefs()
565 obj->decStrong(mProcess.get()); in processPendingDerefs()
575 refs->decWeak(mProcess.get()); in processPostWriteDerefs()
581 obj->decStrong(mProcess.get()); in processPostWriteDerefs()
600 mProcess->mDriverFD, result); in joinThreadPool()
619 if (mProcess->mDriverFD < 0) { in setupPolling()
624 *fd = mProcess->mDriverFD; in setupPolling()
645 int fd = mProcess->mDriverFD; in stopProcess()
646 mProcess->mDriverFD = -1; in stopProcess()
727 proxy->incStrong(mProcess.get()); in incStrongHandle()
744 proxy->getWeakRefs()->incWeak(mProcess.get()); in incWeakHandle()
784 self()->mProcess->expungeHandle(handle, binder); // NOLINT in expungeHandle()
804 : mProcess(ProcessState::self()), in IPCThreadState()
810 mCallRestriction(mProcess->mCallRestriction) in IPCThreadState()
925 if (mProcess->mDriverFD < 0) { in talkWithDriver()
976 if (ioctl(mProcess->mDriverFD, BINDER_WRITE_READ, &bwr) >= 0) in talkWithDriver()
983 if (mProcess->mDriverFD < 0) { in talkWithDriver()
1093 obj->incStrong(mProcess.get()); in executeCommand()
1119 refs->incWeak(mProcess.get()); in executeCommand()
1142 const bool success = refs->attemptIncStrong(mProcess.get()); in executeCommand()
1285 mProcess->spawnPooledThread(false); in executeCommand()
1311 if (self->mProcess->mDriverFD >= 0) { in threadDestructor()
1312 ioctl(self->mProcess->mDriverFD, BINDER_THREAD_EXIT, 0); in threadDestructor()