Lines Matching refs:mCore
24 #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, \
74 mCore(core), in BufferQueueProducer()
93 std::lock_guard<std::mutex> lock(mCore->mMutex); in requestBuffer()
95 if (mCore->mIsAbandoned) { in requestBuffer()
100 if (mCore->mConnectedApi == BufferQueueCore::NO_CONNECTED_API) { in requestBuffer()
128 std::unique_lock<std::mutex> lock(mCore->mMutex); in setMaxDequeuedBufferCount()
129 mCore->waitWhileAllocatingLocked(lock); in setMaxDequeuedBufferCount()
131 if (mCore->mIsAbandoned) { in setMaxDequeuedBufferCount()
137 if (maxDequeuedBuffers == mCore->mMaxDequeuedBufferCount) { in setMaxDequeuedBufferCount()
144 for (int s : mCore->mActiveBuffers) { in setMaxDequeuedBufferCount()
156 int bufferCount = mCore->getMinUndequeuedBufferCountLocked(); in setMaxDequeuedBufferCount()
165 const int minBufferSlots = mCore->getMinMaxBufferCountLocked(); in setMaxDequeuedBufferCount()
172 if (bufferCount > mCore->mMaxBufferCount) { in setMaxDequeuedBufferCount()
176 mCore->mMaxBufferCount, mCore->mMaxAcquiredBufferCount, in setMaxDequeuedBufferCount()
177 mCore->mAsyncMode, mCore->mDequeueBufferCannotBlock); in setMaxDequeuedBufferCount()
181 int delta = maxDequeuedBuffers - mCore->mMaxDequeuedBufferCount; in setMaxDequeuedBufferCount()
182 if (!mCore->adjustAvailableSlotsLocked(delta)) { in setMaxDequeuedBufferCount()
185 mCore->mMaxDequeuedBufferCount = maxDequeuedBuffers; in setMaxDequeuedBufferCount()
188 listener = mCore->mConsumerListener; in setMaxDequeuedBufferCount()
190 mCore->mDequeueCondition.notify_all(); in setMaxDequeuedBufferCount()
207 std::unique_lock<std::mutex> lock(mCore->mMutex); in setAsyncMode()
208 mCore->waitWhileAllocatingLocked(lock); in setAsyncMode()
210 if (mCore->mIsAbandoned) { in setAsyncMode()
215 if (async == mCore->mAsyncMode) { in setAsyncMode()
219 if ((mCore->mMaxAcquiredBufferCount + mCore->mMaxDequeuedBufferCount + in setAsyncMode()
220 (async || mCore->mDequeueBufferCannotBlock ? 1 : 0)) > in setAsyncMode()
221 mCore->mMaxBufferCount) { in setAsyncMode()
225 mCore->mMaxBufferCount, mCore->mMaxAcquiredBufferCount, in setAsyncMode()
226 mCore->mMaxDequeuedBufferCount, in setAsyncMode()
227 mCore->mDequeueBufferCannotBlock); in setAsyncMode()
231 int delta = mCore->getMaxBufferCountLocked(async, in setAsyncMode()
232 mCore->mDequeueBufferCannotBlock, mCore->mMaxBufferCount) in setAsyncMode()
233 - mCore->getMaxBufferCountLocked(); in setAsyncMode()
235 if (!mCore->adjustAvailableSlotsLocked(delta)) { in setAsyncMode()
240 mCore->mAsyncMode = async; in setAsyncMode()
242 mCore->mDequeueCondition.notify_all(); in setAsyncMode()
244 listener = mCore->mConsumerListener; in setAsyncMode()
256 if (mCore->mFreeBuffers.empty()) { in getFreeBufferLocked()
259 int slot = mCore->mFreeBuffers.front(); in getFreeBufferLocked()
260 mCore->mFreeBuffers.pop_front(); in getFreeBufferLocked()
265 if (mCore->mFreeSlots.empty()) { in getFreeSlotLocked()
268 int slot = *(mCore->mFreeSlots.begin()); in getFreeSlotLocked()
269 mCore->mFreeSlots.erase(slot); in getFreeSlotLocked()
279 if (mCore->mIsAbandoned) { in waitForFreeSlotThenRelock()
286 for (int s : mCore->mActiveBuffers) { in waitForFreeSlotThenRelock()
298 if (mCore->mBufferHasBeenQueued && in waitForFreeSlotThenRelock()
299 dequeuedCount >= mCore->mMaxDequeuedBufferCount) { in waitForFreeSlotThenRelock()
304 mCore->mMaxDequeuedBufferCount); in waitForFreeSlotThenRelock()
315 const int maxBufferCount = mCore->getMaxBufferCountLocked(); in waitForFreeSlotThenRelock()
316 bool tooManyBuffers = mCore->mQueue.size() in waitForFreeSlotThenRelock()
320 mCore->mQueue.size()); in waitForFreeSlotThenRelock()
324 if (mCore->mSharedBufferMode && mCore->mSharedBufferSlot != in waitForFreeSlotThenRelock()
326 *found = mCore->mSharedBufferSlot; in waitForFreeSlotThenRelock()
333 } else if (mCore->mAllowAllocation) { in waitForFreeSlotThenRelock()
360 if ((mCore->mDequeueBufferCannotBlock || mCore->mAsyncMode) && in waitForFreeSlotThenRelock()
361 (acquiredCount <= mCore->mMaxAcquiredBufferCount)) { in waitForFreeSlotThenRelock()
365 std::cv_status result = mCore->mDequeueCondition.wait_for(lock, in waitForFreeSlotThenRelock()
371 mCore->mDequeueCondition.wait(lock); in waitForFreeSlotThenRelock()
385 std::lock_guard<std::mutex> lock(mCore->mMutex); in dequeueBuffer()
386 mConsumerName = mCore->mConsumerName; in dequeueBuffer()
388 if (mCore->mIsAbandoned) { in dequeueBuffer()
393 if (mCore->mConnectedApi == BufferQueueCore::NO_CONNECTED_API) { in dequeueBuffer()
412 std::unique_lock<std::mutex> lock(mCore->mMutex); in dequeueBuffer()
416 if (mCore->mFreeBuffers.empty() && mCore->mIsAllocating) { in dequeueBuffer()
418 mCore->waitWhileAllocatingLocked(lock); in dequeueBuffer()
424 format = mCore->mDefaultBufferFormat; in dequeueBuffer()
428 usage |= mCore->mConsumerUsageBits; in dequeueBuffer()
432 width = mCore->mDefaultWidth; in dequeueBuffer()
433 height = mCore->mDefaultHeight; in dequeueBuffer()
434 if (mCore->mAutoPrerotation && in dequeueBuffer()
435 (mCore->mTransformHintInUse & NATIVE_WINDOW_TRANSFORM_ROT_90)) { in dequeueBuffer()
459 if (!mCore->mAllowAllocation) { in dequeueBuffer()
461 if (mCore->mSharedBufferSlot == found) { in dequeueBuffer()
465 mCore->mFreeSlots.insert(found); in dequeueBuffer()
466 mCore->clearBufferSlotLocked(found); in dequeueBuffer()
474 if (mCore->mSharedBufferSlot == found && in dequeueBuffer()
482 if (mCore->mSharedBufferSlot != found) { in dequeueBuffer()
483 mCore->mActiveBuffers.insert(found); in dequeueBuffer()
502 mCore->mBufferAge = 0; in dequeueBuffer()
503 mCore->mIsAllocating = true; in dequeueBuffer()
509 mCore->mBufferAge = mCore->mFrameCounter + 1 - mSlots[found].mFrameNumber; in dequeueBuffer()
513 mCore->mBufferAge); in dequeueBuffer()
525 *outFence = (mCore->mSharedBufferMode && in dequeueBuffer()
526 mCore->mSharedBufferSlot == found) ? in dequeueBuffer()
533 if (mCore->mSharedBufferMode && mCore->mSharedBufferSlot == in dequeueBuffer()
535 mCore->mSharedBufferSlot = found; in dequeueBuffer()
540 if (mCore->mConsumerListener != nullptr) { in dequeueBuffer()
541 mCore->mConsumerListener->onFrameDequeued(mSlots[*outSlot].mGraphicBuffer->getId()); in dequeueBuffer()
555 std::lock_guard<std::mutex> lock(mCore->mMutex); in dequeueBuffer()
557 if (error == NO_ERROR && !mCore->mIsAbandoned) { in dequeueBuffer()
558 graphicBuffer->setGenerationNumber(mCore->mGenerationNumber); in dequeueBuffer()
560 if (mCore->mConsumerListener != nullptr) { in dequeueBuffer()
561 mCore->mConsumerListener->onFrameDequeued( in dequeueBuffer()
566 mCore->mIsAllocating = false; in dequeueBuffer()
567 mCore->mIsAllocatingCondition.notify_all(); in dequeueBuffer()
570 mCore->mFreeSlots.insert(*outSlot); in dequeueBuffer()
571 mCore->clearBufferSlotLocked(*outSlot); in dequeueBuffer()
576 if (mCore->mIsAbandoned) { in dequeueBuffer()
577 mCore->mFreeSlots.insert(*outSlot); in dequeueBuffer()
578 mCore->clearBufferSlotLocked(*outSlot); in dequeueBuffer()
612 *outBufferAge = mCore->mBufferAge; in dequeueBuffer()
626 std::lock_guard<std::mutex> lock(mCore->mMutex); in detachBuffer()
628 if (mCore->mIsAbandoned) { in detachBuffer()
633 if (mCore->mConnectedApi == BufferQueueCore::NO_CONNECTED_API) { in detachBuffer()
638 if (mCore->mSharedBufferMode || mCore->mSharedBufferSlot == slot) { in detachBuffer()
657 listener = mCore->mConsumerListener; in detachBuffer()
663 mCore->mActiveBuffers.erase(slot); in detachBuffer()
664 mCore->mFreeSlots.insert(slot); in detachBuffer()
665 mCore->clearBufferSlotLocked(slot); in detachBuffer()
666 mCore->mDequeueCondition.notify_all(); in detachBuffer()
691 std::unique_lock<std::mutex> lock(mCore->mMutex); in detachNextBuffer()
693 if (mCore->mIsAbandoned) { in detachNextBuffer()
698 if (mCore->mConnectedApi == BufferQueueCore::NO_CONNECTED_API) { in detachNextBuffer()
703 if (mCore->mSharedBufferMode) { in detachNextBuffer()
709 mCore->waitWhileAllocatingLocked(lock); in detachNextBuffer()
711 if (mCore->mFreeBuffers.empty()) { in detachNextBuffer()
715 int found = mCore->mFreeBuffers.front(); in detachNextBuffer()
716 mCore->mFreeBuffers.remove(found); in detachNextBuffer()
717 mCore->mFreeSlots.insert(found); in detachNextBuffer()
723 mCore->clearBufferSlotLocked(found); in detachNextBuffer()
725 listener = mCore->mConsumerListener; in detachNextBuffer()
747 std::unique_lock<std::mutex> lock(mCore->mMutex); in attachBuffer()
749 if (mCore->mIsAbandoned) { in attachBuffer()
754 if (mCore->mConnectedApi == BufferQueueCore::NO_CONNECTED_API) { in attachBuffer()
759 if (mCore->mSharedBufferMode) { in attachBuffer()
764 if (buffer->getGenerationNumber() != mCore->mGenerationNumber) { in attachBuffer()
767 mCore->mGenerationNumber); in attachBuffer()
771 mCore->waitWhileAllocatingLocked(lock); in attachBuffer()
798 mCore->mActiveBuffers.insert(found); in attachBuffer()
848 std::lock_guard<std::mutex> lock(mCore->mMutex); in queueBuffer()
850 if (mCore->mIsAbandoned) { in queueBuffer()
855 if (mCore->mConnectedApi == BufferQueueCore::NO_CONNECTED_API) { in queueBuffer()
876 if (mCore->mSharedBufferMode && mCore->mSharedBufferSlot == in queueBuffer()
878 mCore->mSharedBufferSlot = slot; in queueBuffer()
884 slot, mCore->mFrameCounter + 1, requestedPresentTimestamp, dataSpace, in queueBuffer()
901 dataSpace = mCore->mDefaultBufferDataSpace; in queueBuffer()
909 ++mCore->mFrameCounter; in queueBuffer()
910 currentFrameNumber = mCore->mFrameCounter; in queueBuffer()
929 item.mIsDroppable = mCore->mAsyncMode || in queueBuffer()
930 (mConsumerIsSurfaceFlinger && mCore->mQueueBufferCanDrop) || in queueBuffer()
931 (mCore->mLegacyBufferDrop && mCore->mQueueBufferCanDrop) || in queueBuffer()
932 (mCore->mSharedBufferMode && mCore->mSharedBufferSlot == slot); in queueBuffer()
935 item.mAutoRefresh = mCore->mSharedBufferMode && mCore->mAutoRefresh; in queueBuffer()
936 item.mApi = mCore->mConnectedApi; in queueBuffer()
941 if (mCore->mSharedBufferMode) { in queueBuffer()
942 mCore->mSharedBufferCache.crop = crop; in queueBuffer()
943 mCore->mSharedBufferCache.transform = transform; in queueBuffer()
944 mCore->mSharedBufferCache.scalingMode = static_cast<uint32_t>( in queueBuffer()
946 mCore->mSharedBufferCache.dataspace = dataSpace; in queueBuffer()
950 if (mCore->mQueue.empty()) { in queueBuffer()
953 mCore->mQueue.push_back(item); in queueBuffer()
954 frameAvailableListener = mCore->mConsumerListener; in queueBuffer()
958 const BufferItem& last = mCore->mQueue.itemAt( in queueBuffer()
959 mCore->mQueue.size() - 1); in queueBuffer()
968 if (!mCore->mSharedBufferMode && in queueBuffer()
974 mCore->mActiveBuffers.erase(last.mSlot); in queueBuffer()
975 mCore->mFreeBuffers.push_back(last.mSlot); in queueBuffer()
990 mCore->mQueue.editItemAt(mCore->mQueue.size() - 1) = item; in queueBuffer()
991 frameReplacedListener = mCore->mConsumerListener; in queueBuffer()
993 mCore->mQueue.push_back(item); in queueBuffer()
994 frameAvailableListener = mCore->mConsumerListener; in queueBuffer()
998 mCore->mBufferHasBeenQueued = true; in queueBuffer()
999 mCore->mDequeueCondition.notify_all(); in queueBuffer()
1000 mCore->mLastQueuedSlot = slot; in queueBuffer()
1002 output->width = mCore->mDefaultWidth; in queueBuffer()
1003 output->height = mCore->mDefaultHeight; in queueBuffer()
1004 output->transformHint = mCore->mTransformHintInUse = mCore->mTransformHint; in queueBuffer()
1005 output->numPendingBuffers = static_cast<uint32_t>(mCore->mQueue.size()); in queueBuffer()
1006 output->nextFrameNumber = mCore->mFrameCounter + 1; in queueBuffer()
1008 ATRACE_INT(mCore->mConsumerName.string(), in queueBuffer()
1009 static_cast<int32_t>(mCore->mQueue.size())); in queueBuffer()
1011 mCore->mOccupancyTracker.registerOccupancyChange(mCore->mQueue.size()); in queueBuffer()
1055 connectedApi = mCore->mConnectedApi; in queueBuffer()
1080 std::lock_guard<std::mutex> lock(mCore->mMutex); in cancelBuffer()
1082 if (mCore->mIsAbandoned) { in cancelBuffer()
1087 if (mCore->mConnectedApi == BufferQueueCore::NO_CONNECTED_API) { in cancelBuffer()
1092 if (mCore->mSharedBufferMode) { in cancelBuffer()
1114 if (!mCore->mSharedBufferMode && mSlots[slot].mBufferState.isFree()) { in cancelBuffer()
1120 mCore->mActiveBuffers.erase(slot); in cancelBuffer()
1121 mCore->mFreeBuffers.push_back(slot); in cancelBuffer()
1125 if (mCore->mConsumerListener != nullptr && gb != nullptr) { in cancelBuffer()
1126 mCore->mConsumerListener->onFrameCancelled(gb->getId()); in cancelBuffer()
1129 mCore->mDequeueCondition.notify_all(); in cancelBuffer()
1137 std::lock_guard<std::mutex> lock(mCore->mMutex); in query()
1144 if (mCore->mIsAbandoned) { in query()
1152 value = static_cast<int32_t>(mCore->mDefaultWidth); in query()
1155 value = static_cast<int32_t>(mCore->mDefaultHeight); in query()
1158 value = static_cast<int32_t>(mCore->mDefaultBufferFormat); in query()
1165 value = mCore->getMinUndequeuedBufferCountLocked(); in query()
1171 value = (mCore->mQueue.size() > 1); in query()
1175 value = static_cast<int32_t>(mCore->mConsumerUsageBits); in query()
1178 value = static_cast<int32_t>(mCore->mDefaultBufferDataSpace); in query()
1181 if (mCore->mBufferAge > INT32_MAX) { in query()
1184 value = static_cast<int32_t>(mCore->mBufferAge); in query()
1188 value = static_cast<int32_t>(mCore->mConsumerIsProtected); in query()
1202 std::lock_guard<std::mutex> lock(mCore->mMutex); in connect()
1203 mConsumerName = mCore->mConsumerName; in connect()
1207 if (mCore->mIsAbandoned) { in connect()
1212 if (mCore->mConsumerListener == nullptr) { in connect()
1222 if (mCore->mConnectedApi != BufferQueueCore::NO_CONNECTED_API) { in connect()
1224 mCore->mConnectedApi, api); in connect()
1228 int delta = mCore->getMaxBufferCountLocked(mCore->mAsyncMode, in connect()
1230 mCore->mConsumerControlledByApp && producerControlledByApp : false, in connect()
1231 mCore->mMaxBufferCount) - in connect()
1232 mCore->getMaxBufferCountLocked(); in connect()
1233 if (!mCore->adjustAvailableSlotsLocked(delta)) { in connect()
1245 mCore->mConnectedApi = api; in connect()
1247 output->width = mCore->mDefaultWidth; in connect()
1248 output->height = mCore->mDefaultHeight; in connect()
1249 output->transformHint = mCore->mTransformHintInUse = mCore->mTransformHint; in connect()
1251 static_cast<uint32_t>(mCore->mQueue.size()); in connect()
1252 output->nextFrameNumber = mCore->mFrameCounter + 1; in connect()
1254 output->maxBufferCount = mCore->mMaxBufferCount; in connect()
1267 mCore->mLinkedToDeath = listener; in connect()
1270 mCore->mConnectedProducerListener = listener; in connect()
1271 mCore->mBufferReleasedCbEnabled = listener->needsReleaseNotify(); in connect()
1279 mCore->mConnectedPid = BufferQueueThreadState::getCallingPid(); in connect()
1280 mCore->mBufferHasBeenQueued = false; in connect()
1281 mCore->mDequeueBufferCannotBlock = false; in connect()
1282 mCore->mQueueBufferCanDrop = false; in connect()
1283 mCore->mLegacyBufferDrop = true; in connect()
1284 if (mCore->mConsumerControlledByApp && producerControlledByApp) { in connect()
1285 mCore->mDequeueBufferCannotBlock = mDequeueTimeout < 0; in connect()
1286 mCore->mQueueBufferCanDrop = mDequeueTimeout <= 0; in connect()
1289 mCore->mAllowAllocation = true; in connect()
1301 std::unique_lock<std::mutex> lock(mCore->mMutex); in disconnect()
1304 if (BufferQueueThreadState::getCallingPid() != mCore->mConnectedPid) { in disconnect()
1310 mCore->waitWhileAllocatingLocked(lock); in disconnect()
1312 if (mCore->mIsAbandoned) { in disconnect()
1319 if (mCore->mConnectedApi == NATIVE_WINDOW_API_MEDIA) { in disconnect()
1322 api = mCore->mConnectedApi; in disconnect()
1335 if (mCore->mConnectedApi == api) { in disconnect()
1336 mCore->freeAllBuffersLocked(); in disconnect()
1340 if (mCore->mLinkedToDeath != nullptr) { in disconnect()
1342 IInterface::asBinder(mCore->mLinkedToDeath); in disconnect()
1349 mCore->mSharedBufferSlot = in disconnect()
1351 mCore->mLinkedToDeath = nullptr; in disconnect()
1352 mCore->mConnectedProducerListener = nullptr; in disconnect()
1353 mCore->mConnectedApi = BufferQueueCore::NO_CONNECTED_API; in disconnect()
1354 mCore->mConnectedPid = -1; in disconnect()
1355 mCore->mSidebandStream.clear(); in disconnect()
1356 mCore->mDequeueCondition.notify_all(); in disconnect()
1357 mCore->mAutoPrerotation = false; in disconnect()
1358 listener = mCore->mConsumerListener; in disconnect()
1359 } else if (mCore->mConnectedApi == BufferQueueCore::NO_CONNECTED_API) { in disconnect()
1364 "(cur=%d req=%d)", mCore->mConnectedApi, api); in disconnect()
1387 std::lock_guard<std::mutex> _l(mCore->mMutex); in setSidebandStream()
1388 mCore->mSidebandStream = stream; in setSidebandStream()
1389 listener = mCore->mConsumerListener; in setSidebandStream()
1411 std::unique_lock<std::mutex> lock(mCore->mMutex); in allocateBuffers()
1412 mCore->waitWhileAllocatingLocked(lock); in allocateBuffers()
1414 if (!mCore->mAllowAllocation) { in allocateBuffers()
1422 newBufferCount = mCore->mFreeSlots.empty() ? 0 : 1; in allocateBuffers()
1427 allocWidth = width > 0 ? width : mCore->mDefaultWidth; in allocateBuffers()
1428 allocHeight = height > 0 ? height : mCore->mDefaultHeight; in allocateBuffers()
1429 if (useDefaultSize && mCore->mAutoPrerotation && in allocateBuffers()
1430 (mCore->mTransformHintInUse & NATIVE_WINDOW_TRANSFORM_ROT_90)) { in allocateBuffers()
1434 allocFormat = format != 0 ? format : mCore->mDefaultBufferFormat; in allocateBuffers()
1435 allocUsage = usage | mCore->mConsumerUsageBits; in allocateBuffers()
1436 allocName.assign(mCore->mConsumerName.string(), mCore->mConsumerName.size()); in allocateBuffers()
1438 mCore->mIsAllocating = true; in allocateBuffers()
1452 std::lock_guard<std::mutex> lock(mCore->mMutex); in allocateBuffers()
1453 mCore->mIsAllocating = false; in allocateBuffers()
1454 mCore->mIsAllocatingCondition.notify_all(); in allocateBuffers()
1461 std::unique_lock<std::mutex> lock(mCore->mMutex); in allocateBuffers()
1462 uint32_t checkWidth = width > 0 ? width : mCore->mDefaultWidth; in allocateBuffers()
1463 uint32_t checkHeight = height > 0 ? height : mCore->mDefaultHeight; in allocateBuffers()
1464 if (useDefaultSize && mCore->mAutoPrerotation && in allocateBuffers()
1465 (mCore->mTransformHintInUse & NATIVE_WINDOW_TRANSFORM_ROT_90)) { in allocateBuffers()
1470 format : mCore->mDefaultBufferFormat; in allocateBuffers()
1471 uint64_t checkUsage = usage | mCore->mConsumerUsageBits; in allocateBuffers()
1476 mCore->mIsAllocating = false; in allocateBuffers()
1477 mCore->mIsAllocatingCondition.notify_all(); in allocateBuffers()
1482 if (mCore->mFreeSlots.empty()) { in allocateBuffers()
1487 auto slot = mCore->mFreeSlots.begin(); in allocateBuffers()
1488 mCore->clearBufferSlotLocked(*slot); // Clean up the slot first in allocateBuffers()
1494 mCore->mFreeBuffers.push_front(*slot); in allocateBuffers()
1501 mCore->mFreeSlots.erase(slot); in allocateBuffers()
1504 mCore->mIsAllocating = false; in allocateBuffers()
1505 mCore->mIsAllocatingCondition.notify_all(); in allocateBuffers()
1521 std::lock_guard<std::mutex> lock(mCore->mMutex); in allowAllocation()
1522 mCore->mAllowAllocation = allow; in allowAllocation()
1530 std::lock_guard<std::mutex> lock(mCore->mMutex); in setGenerationNumber()
1531 mCore->mGenerationNumber = generationNumber; in setGenerationNumber()
1537 std::lock_guard<std::mutex> lock(mCore->mMutex); in getConsumerName()
1546 std::lock_guard<std::mutex> lock(mCore->mMutex); in setSharedBufferMode()
1548 mCore->mSharedBufferSlot = BufferQueueCore::INVALID_BUFFER_SLOT; in setSharedBufferMode()
1550 mCore->mSharedBufferMode = sharedBufferMode; in setSharedBufferMode()
1558 std::lock_guard<std::mutex> lock(mCore->mMutex); in setAutoRefresh()
1560 mCore->mAutoRefresh = autoRefresh; in setAutoRefresh()
1568 std::lock_guard<std::mutex> lock(mCore->mMutex); in setDequeueTimeout()
1570 timeout >= 0 ? false : mCore->mDequeueBufferCannotBlock; in setDequeueTimeout()
1571 int delta = mCore->getMaxBufferCountLocked(mCore->mAsyncMode, dequeueBufferCannotBlock, in setDequeueTimeout()
1572 mCore->mMaxBufferCount) - mCore->getMaxBufferCountLocked(); in setDequeueTimeout()
1573 if (!mCore->adjustAvailableSlotsLocked(delta)) { in setDequeueTimeout()
1580 mCore->mDequeueBufferCannotBlock = dequeueBufferCannotBlock; in setDequeueTimeout()
1582 mCore->mQueueBufferCanDrop = false; in setDequeueTimeout()
1593 std::lock_guard<std::mutex> lock(mCore->mMutex); in setLegacyBufferDrop()
1594 mCore->mLegacyBufferDrop = drop; in setLegacyBufferDrop()
1603 std::lock_guard<std::mutex> lock(mCore->mMutex); in getLastQueuedBuffer()
1604 if (mCore->mLastQueuedSlot == BufferItem::INVALID_BUFFER_SLOT) { in getLastQueuedBuffer()
1610 *outBuffer = mSlots[mCore->mLastQueuedSlot].mGraphicBuffer; in getLastQueuedBuffer()
1618 mSlots[mCore->mLastQueuedSlot].mGraphicBuffer, mLastQueuedCrop, in getLastQueuedBuffer()
1629 std::lock_guard<std::mutex> lock(mCore->mMutex); in getLastQueuedBuffer()
1630 if (mCore->mLastQueuedSlot == BufferItem::INVALID_BUFFER_SLOT) { in getLastQueuedBuffer()
1636 *outBuffer = mSlots[mCore->mLastQueuedSlot].mGraphicBuffer; in getLastQueuedBuffer()
1659 std::lock_guard<std::mutex> lock(mCore->mMutex); in addAndGetFrameTimestamps()
1660 listener = mCore->mConsumerListener; in addAndGetFrameTimestamps()
1672 int api = mCore->mConnectedApi; in binderDied()
1679 *outId = mCore->mUniqueId; in getUniqueId()
1686 std::lock_guard<std::mutex> lock(mCore->mMutex); in getConsumerUsage()
1687 *outUsage = mCore->mConsumerUsageBits; in getConsumerUsage()
1695 std::lock_guard<std::mutex> lock(mCore->mMutex); in setAutoPrerotation()
1697 mCore->mAutoPrerotation = autoPrerotation; in setAutoPrerotation()