24 #define VALIDATE_CONSISTENCY() do { mCore->validateConsistencyLocked(); } while (0)
42     mCore(core),  in BufferQueueConsumer()
55         Mutex::Autolock lock(mCore->mMutex);  in acquireBuffer()
62         for (int s : mCore->mActiveBuffers) {  in acquireBuffer()
67         if (numAcquiredBuffers >= mCore->mMaxAcquiredBufferCount + 1) {  in acquireBuffer()
69                     numAcquiredBuffers, mCore->mMaxAcquiredBufferCount);  in acquireBuffer()
73         bool sharedBufferAvailable = mCore->mSharedBufferMode &&  in acquireBuffer()
74                 mCore->mAutoRefresh && mCore->mSharedBufferSlot !=  in acquireBuffer()
79         if (mCore->mQueue.empty() && !sharedBufferAvailable) {  in acquireBuffer()
83         BufferQueueCore::Fifo::iterator front(mCore->mQueue.begin());  in acquireBuffer()
90         if (expectedPresent != 0 && !mCore->mQueue.empty()) {  in acquireBuffer()
111             while (mCore->mQueue.size() > 1 && !mCore->mQueue[0].mIsAutoTimestamp) {  in acquireBuffer()
112                 const BufferItem& bufferItem(mCore->mQueue[1]);  in acquireBuffer()
145                         desiredPresent, expectedPresent, mCore->mQueue.size());  in acquireBuffer()
154                     if (!mCore->mSharedBufferMode &&  in acquireBuffer()
161                         mCore->mActiveBuffers.erase(front->mSlot);  in acquireBuffer()
162                         mCore->mFreeBuffers.push_back(front->mSlot);  in acquireBuffer()
165                     listener = mCore->mConnectedProducerListener;  in acquireBuffer()
169                 mCore->mQueue.erase(front);  in acquireBuffer()
170                 front = mCore->mQueue.begin();  in acquireBuffer()
198         if (sharedBufferAvailable && mCore->mQueue.empty()) {  in acquireBuffer()
200             mCore->waitWhileAllocatingLocked();  in acquireBuffer()
202             slot = mCore->mSharedBufferSlot;  in acquireBuffer()
209             outBuffer->mCrop = mCore->mSharedBufferCache.crop;  in acquireBuffer()
210             outBuffer->mTransform = mCore->mSharedBufferCache.transform &  in acquireBuffer()
213             outBuffer->mScalingMode = mCore->mSharedBufferCache.scalingMode;  in acquireBuffer()
214             outBuffer->mDataSpace = mCore->mSharedBufferCache.dataspace;  in acquireBuffer()
215             outBuffer->mFrameNumber = mCore->mFrameCounter;  in acquireBuffer()
219                     (mCore->mSharedBufferCache.transform &  in acquireBuffer()
224             outBuffer->mAutoRefresh = mCore->mSharedBufferMode &&  in acquireBuffer()
225                     mCore->mAutoRefresh;  in acquireBuffer()
241             if (mCore->mQueue.empty()) {  in acquireBuffer()
256         mCore->mQueue.erase(front);  in acquireBuffer()
261         mCore->mDequeueCondition.broadcast();  in acquireBuffer()
263         ATRACE_INT(mCore->mConsumerName.string(),  in acquireBuffer()
264                 static_cast<int32_t>(mCore->mQueue.size()));  in acquireBuffer()
265         mCore->mOccupancyTracker.registerOccupancyChange(mCore->mQueue.size());  in acquireBuffer()
283     Mutex::Autolock lock(mCore->mMutex);  in detachBuffer()
285     if (mCore->mIsAbandoned) {  in detachBuffer()
290     if (mCore->mSharedBufferMode || slot == mCore->mSharedBufferSlot) {  in detachBuffer()
306     mCore->mActiveBuffers.erase(slot);  in detachBuffer()
307     mCore->mFreeSlots.insert(slot);  in detachBuffer()
308     mCore->clearBufferSlotLocked(slot);  in detachBuffer()
309     mCore->mDequeueCondition.broadcast();  in detachBuffer()
327     Mutex::Autolock lock(mCore->mMutex);  in attachBuffer()
329     if (mCore->mSharedBufferMode) {  in attachBuffer()
336     for (int s : mCore->mActiveBuffers) {  in attachBuffer()
342     if (numAcquiredBuffers >= mCore->mMaxAcquiredBufferCount + 1) {  in attachBuffer()
345                 mCore->mMaxAcquiredBufferCount);  in attachBuffer()
349     if (buffer->getGenerationNumber() != mCore->mGenerationNumber) {  in attachBuffer()
352                 mCore->mGenerationNumber);  in attachBuffer()
358     if (!mCore->mFreeSlots.empty()) {  in attachBuffer()
359         auto slot = mCore->mFreeSlots.begin();  in attachBuffer()
361         mCore->mFreeSlots.erase(slot);  in attachBuffer()
362     } else if (!mCore->mFreeBuffers.empty()) {  in attachBuffer()
363         found = mCore->mFreeBuffers.front();  in attachBuffer()
364         mCore->mFreeBuffers.remove(found);  in attachBuffer()
371     mCore->mActiveBuffers.insert(found);  in attachBuffer()
419         Mutex::Autolock lock(mCore->mMutex);  in releaseBuffer()
446         if (!mCore->mSharedBufferMode && mSlots[slot].mBufferState.isFree()) {  in releaseBuffer()
451             mCore->mActiveBuffers.erase(slot);  in releaseBuffer()
452             mCore->mFreeBuffers.push_back(slot);  in releaseBuffer()
455         listener = mCore->mConnectedProducerListener;  in releaseBuffer()
458         mCore->mDequeueCondition.broadcast();  in releaseBuffer()
482     Mutex::Autolock lock(mCore->mMutex);  in connect()
484     if (mCore->mIsAbandoned) {  in connect()
489     mCore->mConsumerListener = consumerListener;  in connect()
490     mCore->mConsumerControlledByApp = controlledByApp;  in connect()
500     Mutex::Autolock lock(mCore->mMutex);  in disconnect()
502     if (mCore->mConsumerListener == NULL) {  in disconnect()
507     mCore->mIsAbandoned = true;  in disconnect()
508     mCore->mConsumerListener = NULL;  in disconnect()
509     mCore->mQueue.clear();  in disconnect()
510     mCore->freeAllBuffersLocked();  in disconnect()
511     mCore->mSharedBufferSlot = BufferQueueCore::INVALID_BUFFER_SLOT;  in disconnect()
512     mCore->mDequeueCondition.broadcast();  in disconnect()
524     Mutex::Autolock lock(mCore->mMutex);  in getReleasedBuffers()
526     if (mCore->mIsAbandoned) {  in getReleasedBuffers()
541     BufferQueueCore::Fifo::iterator current(mCore->mQueue.begin());  in getReleasedBuffers()
542     while (current != mCore->mQueue.end()) {  in getReleasedBuffers()
566     Mutex::Autolock lock(mCore->mMutex);  in setDefaultBufferSize()
567     mCore->mDefaultWidth = width;  in setDefaultBufferSize()
568     mCore->mDefaultHeight = height;  in setDefaultBufferSize()
580     Mutex::Autolock lock(mCore->mMutex);  in setMaxBufferCount()
582     if (mCore->mConnectedApi != BufferQueueCore::NO_CONNECTED_API) {  in setMaxBufferCount()
587     if (bufferCount < mCore->mMaxAcquiredBufferCount) {  in setMaxBufferCount()
590                 mCore->mMaxAcquiredBufferCount);  in setMaxBufferCount()
594     int delta = mCore->getMaxBufferCountLocked(mCore->mAsyncMode,  in setMaxBufferCount()
595             mCore->mDequeueBufferCannotBlock, bufferCount) -  in setMaxBufferCount()
596             mCore->getMaxBufferCountLocked();  in setMaxBufferCount()
597     if (!mCore->adjustAvailableSlotsLocked(delta)) {  in setMaxBufferCount()
603     mCore->mMaxBufferCount = bufferCount;  in setMaxBufferCount()
620         Mutex::Autolock lock(mCore->mMutex);  in setMaxAcquiredBufferCount()
621         mCore->waitWhileAllocatingLocked();  in setMaxAcquiredBufferCount()
623         if (mCore->mIsAbandoned) {  in setMaxAcquiredBufferCount()
628         if (maxAcquiredBuffers == mCore->mMaxAcquiredBufferCount) {  in setMaxAcquiredBufferCount()
635         for (int slot : mCore->mActiveBuffers) {  in setMaxAcquiredBufferCount()
647         if ((maxAcquiredBuffers + mCore->mMaxDequeuedBufferCount +  in setMaxAcquiredBufferCount()
648                 (mCore->mAsyncMode || mCore->mDequeueBufferCannotBlock ? 1 : 0))  in setMaxAcquiredBufferCount()
649                 > mCore->mMaxBufferCount) {  in setMaxAcquiredBufferCount()
652                     maxAcquiredBuffers, mCore->mMaxBufferCount,  in setMaxAcquiredBufferCount()
653                     mCore->mMaxDequeuedBufferCount, mCore->mAsyncMode ||  in setMaxAcquiredBufferCount()
654                     mCore->mDequeueBufferCannotBlock);  in setMaxAcquiredBufferCount()
658         int delta = maxAcquiredBuffers - mCore->mMaxAcquiredBufferCount;  in setMaxAcquiredBufferCount()
659         if (!mCore->adjustAvailableSlotsLocked(delta)) {  in setMaxAcquiredBufferCount()
664         mCore->mMaxAcquiredBufferCount = maxAcquiredBuffers;  in setMaxAcquiredBufferCount()
667             listener = mCore->mConsumerListener;  in setMaxAcquiredBufferCount()
681     Mutex::Autolock lock(mCore->mMutex);  in setConsumerName()
682     mCore->mConsumerName = name;  in setConsumerName()
690     Mutex::Autolock lock(mCore->mMutex);  in setDefaultBufferFormat()
691     mCore->mDefaultBufferFormat = defaultFormat;  in setDefaultBufferFormat()
699     Mutex::Autolock lock(mCore->mMutex);  in setDefaultBufferDataSpace()
700     mCore->mDefaultBufferDataSpace = defaultDataSpace;  in setDefaultBufferDataSpace()
707     Mutex::Autolock lock(mCore->mMutex);  in setConsumerUsageBits()
708     mCore->mConsumerUsageBits = usage;  in setConsumerUsageBits()
715     Mutex::Autolock lock(mCore->mMutex);  in setConsumerIsProtected()
716     mCore->mConsumerIsProtected = isProtected;  in setConsumerIsProtected()
723     Mutex::Autolock lock(mCore->mMutex);  in setTransformHint()
724     mCore->mTransformHint = hint;  in setTransformHint()
729     Mutex::Autolock lock(mCore->mMutex);  in getSidebandStream()
730     *outStream = mCore->mSidebandStream;  in getSidebandStream()
736     Mutex::Autolock lock(mCore->mMutex);  in getOccupancyHistory()
737     *outHistory = mCore->mOccupancyTracker.getSegmentHistory(forceFlush);  in getOccupancyHistory()
742     Mutex::Autolock lock(mCore->mMutex);  in discardFreeBuffers()
743     mCore->discardFreeBuffersLocked();  in discardFreeBuffers()
761     mCore->dumpState(prefix, outResult);  in dumpState()