26 #define VALIDATE_CONSISTENCY() do { mCore->validateConsistencyLocked(); } while (0)
50           mCore->mUniqueId, mCore->mConnectedApi, mCore->mConnectedPid, (mCore->mUniqueId) >> 32, \
54           mCore->mUniqueId, mCore->mConnectedApi, mCore->mConnectedPid, (mCore->mUniqueId) >> 32, \
58           mCore->mUniqueId, mCore->mConnectedApi, mCore->mConnectedPid, (mCore->mUniqueId) >> 32, \
62           mCore->mUniqueId, mCore->mConnectedApi, mCore->mConnectedPid, (mCore->mUniqueId) >> 32, \
66           mCore->mUniqueId, mCore->mConnectedApi, mCore->mConnectedPid, (mCore->mUniqueId) >> 32, \
72     mCore(core),  in BufferQueueConsumer()
85         std::unique_lock<std::mutex> lock(mCore->mMutex);  in acquireBuffer()
92         for (int s : mCore->mActiveBuffers) {  in acquireBuffer()
97         const bool acquireNonDroppableBuffer = mCore->mAllowExtraAcquire &&  in acquireBuffer()
98                 numAcquiredBuffers == mCore->mMaxAcquiredBufferCount + 1;  in acquireBuffer()
99         if (numAcquiredBuffers >= mCore->mMaxAcquiredBufferCount + 1 &&  in acquireBuffer()
102                     numAcquiredBuffers, mCore->mMaxAcquiredBufferCount);  in acquireBuffer()
106         bool sharedBufferAvailable = mCore->mSharedBufferMode &&  in acquireBuffer()
107                 mCore->mAutoRefresh && mCore->mSharedBufferSlot !=  in acquireBuffer()
112         if (mCore->mQueue.empty() && !sharedBufferAvailable) {  in acquireBuffer()
116         BufferQueueCore::Fifo::iterator front(mCore->mQueue.begin());  in acquireBuffer()
123         if (expectedPresent != 0 && !mCore->mQueue.empty()) {  in acquireBuffer()
142             while (mCore->mQueue.size() > 1 && !mCore->mQueue[0].mIsAutoTimestamp) {  in acquireBuffer()
143                 const BufferItem& bufferItem(mCore->mQueue[1]);  in acquireBuffer()
176                         desiredPresent, expectedPresent, mCore->mQueue.size());  in acquireBuffer()
185                     if (!mCore->mSharedBufferMode &&  in acquireBuffer()
192                         mCore->mActiveBuffers.erase(front->mSlot);  in acquireBuffer()
193                         mCore->mFreeBuffers.push_back(front->mSlot);  in acquireBuffer()
196                     if (mCore->mBufferReleasedCbEnabled) {  in acquireBuffer()
197                         listener = mCore->mConnectedProducerListener;  in acquireBuffer()
202                 mCore->mQueue.erase(front);  in acquireBuffer()
203                 front = mCore->mQueue.begin();  in acquireBuffer()
232         if (sharedBufferAvailable && mCore->mQueue.empty()) {  in acquireBuffer()
234             mCore->waitWhileAllocatingLocked(lock);  in acquireBuffer()
236             slot = mCore->mSharedBufferSlot;  in acquireBuffer()
243             outBuffer->mCrop = mCore->mSharedBufferCache.crop;  in acquireBuffer()
244             outBuffer->mTransform = mCore->mSharedBufferCache.transform &  in acquireBuffer()
247             outBuffer->mScalingMode = mCore->mSharedBufferCache.scalingMode;  in acquireBuffer()
248             outBuffer->mDataSpace = mCore->mSharedBufferCache.dataspace;  in acquireBuffer()
249             outBuffer->mFrameNumber = mCore->mFrameCounter;  in acquireBuffer()
253                     (mCore->mSharedBufferCache.transform &  in acquireBuffer()
258             outBuffer->mAutoRefresh = mCore->mSharedBufferMode &&  in acquireBuffer()
259                     mCore->mAutoRefresh;  in acquireBuffer()
278             if (mCore->mQueue.empty()) {  in acquireBuffer()
293         mCore->mQueue.erase(front);  in acquireBuffer()
298         mCore->mDequeueCondition.notify_all();  in acquireBuffer()
300         ATRACE_INT(mCore->mConsumerName.c_str(), static_cast<int32_t>(mCore->mQueue.size()));  in acquireBuffer()
302         mCore->mOccupancyTracker.registerOccupancyChange(mCore->mQueue.size());  in acquireBuffer()
322         std::lock_guard<std::mutex> lock(mCore->mMutex);  in detachBuffer()
324         if (mCore->mIsAbandoned) {  in detachBuffer()
329         if (mCore->mSharedBufferMode || slot == mCore->mSharedBufferSlot) {  in detachBuffer()
343         if (mCore->mBufferReleasedCbEnabled) {  in detachBuffer()
344             listener = mCore->mConnectedProducerListener;  in detachBuffer()
348         mCore->mActiveBuffers.erase(slot);  in detachBuffer()
349         mCore->mFreeSlots.insert(slot);  in detachBuffer()
350         mCore->clearBufferSlotLocked(slot);  in detachBuffer()
351         mCore->mDequeueCondition.notify_all();  in detachBuffer()
373     std::lock_guard<std::mutex> lock(mCore->mMutex);  in attachBuffer()
375     if (mCore->mSharedBufferMode) {  in attachBuffer()
382     for (int s : mCore->mActiveBuffers) {  in attachBuffer()
388     if (numAcquiredBuffers >= mCore->mMaxAcquiredBufferCount + 1) {  in attachBuffer()
391                 mCore->mMaxAcquiredBufferCount);  in attachBuffer()
395     if (buffer->getGenerationNumber() != mCore->mGenerationNumber) {  in attachBuffer()
398                 mCore->mGenerationNumber);  in attachBuffer()
404     if (!mCore->mFreeSlots.empty()) {  in attachBuffer()
405         auto slot = mCore->mFreeSlots.begin();  in attachBuffer()
407         mCore->mFreeSlots.erase(slot);  in attachBuffer()
408     } else if (!mCore->mFreeBuffers.empty()) {  in attachBuffer()
409         found = mCore->mFreeBuffers.front();  in attachBuffer()
410         mCore->mFreeBuffers.remove(found);  in attachBuffer()
417     mCore->mActiveBuffers.insert(found);  in attachBuffer()
465         std::lock_guard<std::mutex> lock(mCore->mMutex);  in releaseBuffer()
492         if (!mCore->mSharedBufferMode && mSlots[slot].mBufferState.isFree()) {  in releaseBuffer()
497             mCore->mActiveBuffers.erase(slot);  in releaseBuffer()
498             mCore->mFreeBuffers.push_back(slot);  in releaseBuffer()
501         if (mCore->mBufferReleasedCbEnabled) {  in releaseBuffer()
502             listener = mCore->mConnectedProducerListener;  in releaseBuffer()
506         mCore->mDequeueCondition.notify_all();  in releaseBuffer()
530     std::lock_guard<std::mutex> lock(mCore->mMutex);  in connect()
532     if (mCore->mIsAbandoned) {  in connect()
537     mCore->mConsumerListener = consumerListener;  in connect()
538     mCore->mConsumerControlledByApp = controlledByApp;  in connect()
548     std::lock_guard<std::mutex> lock(mCore->mMutex);  in disconnect()
550     if (mCore->mConsumerListener == nullptr) {  in disconnect()
555     mCore->mIsAbandoned = true;  in disconnect()
556     mCore->mConsumerListener = nullptr;  in disconnect()
557     mCore->mQueue.clear();  in disconnect()
558     mCore->freeAllBuffersLocked();  in disconnect()
559     mCore->mSharedBufferSlot = BufferQueueCore::INVALID_BUFFER_SLOT;  in disconnect()
560     mCore->mDequeueCondition.notify_all();  in disconnect()
572     std::lock_guard<std::mutex> lock(mCore->mMutex);  in getReleasedBuffers()
574     if (mCore->mIsAbandoned) {  in getReleasedBuffers()
589     BufferQueueCore::Fifo::iterator current(mCore->mQueue.begin());  in getReleasedBuffers()
590     while (current != mCore->mQueue.end()) {  in getReleasedBuffers()
614     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setDefaultBufferSize()
615     mCore->mDefaultWidth = width;  in setDefaultBufferSize()
616     mCore->mDefaultHeight = height;  in setDefaultBufferSize()
628     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setMaxBufferCount()
630     if (mCore->mConnectedApi != BufferQueueCore::NO_CONNECTED_API) {  in setMaxBufferCount()
635     if (bufferCount < mCore->mMaxAcquiredBufferCount) {  in setMaxBufferCount()
638                 mCore->mMaxAcquiredBufferCount);  in setMaxBufferCount()
642     int delta = mCore->getMaxBufferCountLocked(mCore->mAsyncMode,  in setMaxBufferCount()
643             mCore->mDequeueBufferCannotBlock, bufferCount) -  in setMaxBufferCount()
644             mCore->getMaxBufferCountLocked();  in setMaxBufferCount()
645     if (!mCore->adjustAvailableSlotsLocked(delta)) {  in setMaxBufferCount()
651     mCore->mMaxBufferCount = bufferCount;  in setMaxBufferCount()
668         std::unique_lock<std::mutex> lock(mCore->mMutex);  in setMaxAcquiredBufferCount()
669         mCore->waitWhileAllocatingLocked(lock);  in setMaxAcquiredBufferCount()
671         if (mCore->mIsAbandoned) {  in setMaxAcquiredBufferCount()
676         if (maxAcquiredBuffers == mCore->mMaxAcquiredBufferCount) {  in setMaxAcquiredBufferCount()
683         for (int slot : mCore->mActiveBuffers) {  in setMaxAcquiredBufferCount()
695         if ((maxAcquiredBuffers + mCore->mMaxDequeuedBufferCount +  in setMaxAcquiredBufferCount()
696                 (mCore->mAsyncMode || mCore->mDequeueBufferCannotBlock ? 1 : 0))  in setMaxAcquiredBufferCount()
697                 > mCore->mMaxBufferCount) {  in setMaxAcquiredBufferCount()
700                     maxAcquiredBuffers, mCore->mMaxBufferCount,  in setMaxAcquiredBufferCount()
701                     mCore->mMaxDequeuedBufferCount, mCore->mAsyncMode ||  in setMaxAcquiredBufferCount()
702                     mCore->mDequeueBufferCannotBlock);  in setMaxAcquiredBufferCount()
706         int delta = maxAcquiredBuffers - mCore->mMaxAcquiredBufferCount;  in setMaxAcquiredBufferCount()
707         if (!mCore->adjustAvailableSlotsLocked(delta)) {  in setMaxAcquiredBufferCount()
712         mCore->mMaxAcquiredBufferCount = maxAcquiredBuffers;  in setMaxAcquiredBufferCount()
714         if (delta < 0 && mCore->mBufferReleasedCbEnabled) {  in setMaxAcquiredBufferCount()
715             listener = mCore->mConsumerListener;  in setMaxAcquiredBufferCount()
729     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setConsumerName()
730     mCore->mConsumerName = name;  in setConsumerName()
738     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setDefaultBufferFormat()
739     mCore->mDefaultBufferFormat = defaultFormat;  in setDefaultBufferFormat()
747     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setDefaultBufferDataSpace()
748     mCore->mDefaultBufferDataSpace = defaultDataSpace;  in setDefaultBufferDataSpace()
755     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setConsumerUsageBits()
756     mCore->mConsumerUsageBits = usage;  in setConsumerUsageBits()
763     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setConsumerIsProtected()
764     mCore->mConsumerIsProtected = isProtected;  in setConsumerIsProtected()
771     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setTransformHint()
772     mCore->mTransformHint = hint;  in setTransformHint()
777     std::lock_guard<std::mutex> lock(mCore->mMutex);  in getSidebandStream()
778     *outStream = mCore->mSidebandStream;  in getSidebandStream()
784     std::lock_guard<std::mutex> lock(mCore->mMutex);  in getOccupancyHistory()
786     *outHistory = mCore->mOccupancyTracker.getSegmentHistory(forceFlush);  in getOccupancyHistory()
795     std::lock_guard<std::mutex> lock(mCore->mMutex);  in discardFreeBuffers()
796     mCore->discardFreeBuffersLocked();  in discardFreeBuffers()
833     mCore->dumpState(prefix, outResult);  in dumpState()
838     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setAllowExtraAcquire()
839     mCore->mAllowExtraAcquire = allow;  in setAllowExtraAcquire()