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.string(),  in acquireBuffer()
301                 static_cast<int32_t>(mCore->mQueue.size()));  in acquireBuffer()
303         mCore->mOccupancyTracker.registerOccupancyChange(mCore->mQueue.size());  in acquireBuffer()
321     std::lock_guard<std::mutex> lock(mCore->mMutex);  in detachBuffer()
323     if (mCore->mIsAbandoned) {  in detachBuffer()
328     if (mCore->mSharedBufferMode || slot == mCore->mSharedBufferSlot) {  in detachBuffer()
344     mCore->mActiveBuffers.erase(slot);  in detachBuffer()
345     mCore->mFreeSlots.insert(slot);  in detachBuffer()
346     mCore->clearBufferSlotLocked(slot);  in detachBuffer()
347     mCore->mDequeueCondition.notify_all();  in detachBuffer()
365     std::lock_guard<std::mutex> lock(mCore->mMutex);  in attachBuffer()
367     if (mCore->mSharedBufferMode) {  in attachBuffer()
374     for (int s : mCore->mActiveBuffers) {  in attachBuffer()
380     if (numAcquiredBuffers >= mCore->mMaxAcquiredBufferCount + 1) {  in attachBuffer()
383                 mCore->mMaxAcquiredBufferCount);  in attachBuffer()
387     if (buffer->getGenerationNumber() != mCore->mGenerationNumber) {  in attachBuffer()
390                 mCore->mGenerationNumber);  in attachBuffer()
396     if (!mCore->mFreeSlots.empty()) {  in attachBuffer()
397         auto slot = mCore->mFreeSlots.begin();  in attachBuffer()
399         mCore->mFreeSlots.erase(slot);  in attachBuffer()
400     } else if (!mCore->mFreeBuffers.empty()) {  in attachBuffer()
401         found = mCore->mFreeBuffers.front();  in attachBuffer()
402         mCore->mFreeBuffers.remove(found);  in attachBuffer()
409     mCore->mActiveBuffers.insert(found);  in attachBuffer()
457         std::lock_guard<std::mutex> lock(mCore->mMutex);  in releaseBuffer()
484         if (!mCore->mSharedBufferMode && mSlots[slot].mBufferState.isFree()) {  in releaseBuffer()
489             mCore->mActiveBuffers.erase(slot);  in releaseBuffer()
490             mCore->mFreeBuffers.push_back(slot);  in releaseBuffer()
493         if (mCore->mBufferReleasedCbEnabled) {  in releaseBuffer()
494             listener = mCore->mConnectedProducerListener;  in releaseBuffer()
498         mCore->mDequeueCondition.notify_all();  in releaseBuffer()
522     std::lock_guard<std::mutex> lock(mCore->mMutex);  in connect()
524     if (mCore->mIsAbandoned) {  in connect()
529     mCore->mConsumerListener = consumerListener;  in connect()
530     mCore->mConsumerControlledByApp = controlledByApp;  in connect()
540     std::lock_guard<std::mutex> lock(mCore->mMutex);  in disconnect()
542     if (mCore->mConsumerListener == nullptr) {  in disconnect()
547     mCore->mIsAbandoned = true;  in disconnect()
548     mCore->mConsumerListener = nullptr;  in disconnect()
549     mCore->mQueue.clear();  in disconnect()
550     mCore->freeAllBuffersLocked();  in disconnect()
551     mCore->mSharedBufferSlot = BufferQueueCore::INVALID_BUFFER_SLOT;  in disconnect()
552     mCore->mDequeueCondition.notify_all();  in disconnect()
564     std::lock_guard<std::mutex> lock(mCore->mMutex);  in getReleasedBuffers()
566     if (mCore->mIsAbandoned) {  in getReleasedBuffers()
581     BufferQueueCore::Fifo::iterator current(mCore->mQueue.begin());  in getReleasedBuffers()
582     while (current != mCore->mQueue.end()) {  in getReleasedBuffers()
606     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setDefaultBufferSize()
607     mCore->mDefaultWidth = width;  in setDefaultBufferSize()
608     mCore->mDefaultHeight = height;  in setDefaultBufferSize()
620     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setMaxBufferCount()
622     if (mCore->mConnectedApi != BufferQueueCore::NO_CONNECTED_API) {  in setMaxBufferCount()
627     if (bufferCount < mCore->mMaxAcquiredBufferCount) {  in setMaxBufferCount()
630                 mCore->mMaxAcquiredBufferCount);  in setMaxBufferCount()
634     int delta = mCore->getMaxBufferCountLocked(mCore->mAsyncMode,  in setMaxBufferCount()
635             mCore->mDequeueBufferCannotBlock, bufferCount) -  in setMaxBufferCount()
636             mCore->getMaxBufferCountLocked();  in setMaxBufferCount()
637     if (!mCore->adjustAvailableSlotsLocked(delta)) {  in setMaxBufferCount()
643     mCore->mMaxBufferCount = bufferCount;  in setMaxBufferCount()
660         std::unique_lock<std::mutex> lock(mCore->mMutex);  in setMaxAcquiredBufferCount()
661         mCore->waitWhileAllocatingLocked(lock);  in setMaxAcquiredBufferCount()
663         if (mCore->mIsAbandoned) {  in setMaxAcquiredBufferCount()
668         if (maxAcquiredBuffers == mCore->mMaxAcquiredBufferCount) {  in setMaxAcquiredBufferCount()
675         for (int slot : mCore->mActiveBuffers) {  in setMaxAcquiredBufferCount()
687         if ((maxAcquiredBuffers + mCore->mMaxDequeuedBufferCount +  in setMaxAcquiredBufferCount()
688                 (mCore->mAsyncMode || mCore->mDequeueBufferCannotBlock ? 1 : 0))  in setMaxAcquiredBufferCount()
689                 > mCore->mMaxBufferCount) {  in setMaxAcquiredBufferCount()
692                     maxAcquiredBuffers, mCore->mMaxBufferCount,  in setMaxAcquiredBufferCount()
693                     mCore->mMaxDequeuedBufferCount, mCore->mAsyncMode ||  in setMaxAcquiredBufferCount()
694                     mCore->mDequeueBufferCannotBlock);  in setMaxAcquiredBufferCount()
698         int delta = maxAcquiredBuffers - mCore->mMaxAcquiredBufferCount;  in setMaxAcquiredBufferCount()
699         if (!mCore->adjustAvailableSlotsLocked(delta)) {  in setMaxAcquiredBufferCount()
704         mCore->mMaxAcquiredBufferCount = maxAcquiredBuffers;  in setMaxAcquiredBufferCount()
706         if (delta < 0 && mCore->mBufferReleasedCbEnabled) {  in setMaxAcquiredBufferCount()
707             listener = mCore->mConsumerListener;  in setMaxAcquiredBufferCount()
721     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setConsumerName()
722     mCore->mConsumerName = name;  in setConsumerName()
730     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setDefaultBufferFormat()
731     mCore->mDefaultBufferFormat = defaultFormat;  in setDefaultBufferFormat()
739     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setDefaultBufferDataSpace()
740     mCore->mDefaultBufferDataSpace = defaultDataSpace;  in setDefaultBufferDataSpace()
747     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setConsumerUsageBits()
748     mCore->mConsumerUsageBits = usage;  in setConsumerUsageBits()
755     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setConsumerIsProtected()
756     mCore->mConsumerIsProtected = isProtected;  in setConsumerIsProtected()
763     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setTransformHint()
764     mCore->mTransformHint = hint;  in setTransformHint()
769     std::lock_guard<std::mutex> lock(mCore->mMutex);  in getSidebandStream()
770     *outStream = mCore->mSidebandStream;  in getSidebandStream()
776     std::lock_guard<std::mutex> lock(mCore->mMutex);  in getOccupancyHistory()
778     *outHistory = mCore->mOccupancyTracker.getSegmentHistory(forceFlush);  in getOccupancyHistory()
787     std::lock_guard<std::mutex> lock(mCore->mMutex);  in discardFreeBuffers()
788     mCore->discardFreeBuffersLocked();  in discardFreeBuffers()
829     mCore->dumpState(prefix, outResult);  in dumpState()
834     std::lock_guard<std::mutex> lock(mCore->mMutex);  in setAllowExtraAcquire()
835     mCore->mAllowExtraAcquire = allow;  in setAllowExtraAcquire()