CpuConsumer.cpp revision 595264f1af12e25dce57d7c5b1d52ed86ac0d0c9
1/* 2 * Copyright (C) 2012 The Android Open Source Project 3 * 4 * Licensed under the Apache License, Version 2.0 (the "License"); 5 * you may not use this file except in compliance with the License. 6 * You may obtain a copy of the License at 7 * 8 * http://www.apache.org/licenses/LICENSE-2.0 9 * 10 * Unless required by applicable law or agreed to in writing, software 11 * distributed under the License is distributed on an "AS IS" BASIS, 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13 * See the License for the specific language governing permissions and 14 * limitations under the License. 15 */ 16 17//#define LOG_NDEBUG 0 18#define LOG_TAG "CpuConsumer" 19#define ATRACE_TAG ATRACE_TAG_GRAPHICS 20 21#include <cutils/compiler.h> 22#include <utils/Log.h> 23#include <gui/CpuConsumer.h> 24 25#define CC_LOGV(x, ...) ALOGV("[%s] "x, mName.string(), ##__VA_ARGS__) 26#define CC_LOGD(x, ...) ALOGD("[%s] "x, mName.string(), ##__VA_ARGS__) 27#define CC_LOGI(x, ...) ALOGI("[%s] "x, mName.string(), ##__VA_ARGS__) 28#define CC_LOGW(x, ...) ALOGW("[%s] "x, mName.string(), ##__VA_ARGS__) 29#define CC_LOGE(x, ...) ALOGE("[%s] "x, mName.string(), ##__VA_ARGS__) 30 31namespace android { 32 33CpuConsumer::CpuConsumer(const sp<BufferQueue>& bq, 34 uint32_t maxLockedBuffers, bool controlledByApp) : 35 ConsumerBase(bq, controlledByApp), 36 mMaxLockedBuffers(maxLockedBuffers), 37 mCurrentLockedBuffers(0) 38{ 39 // Create tracking entries for locked buffers 40 mAcquiredBuffers.insertAt(0, maxLockedBuffers); 41 42 mBufferQueue->setConsumerUsageBits(GRALLOC_USAGE_SW_READ_OFTEN); 43 mBufferQueue->setMaxAcquiredBufferCount(maxLockedBuffers); 44} 45 46CpuConsumer::~CpuConsumer() { 47 // ConsumerBase destructor does all the work. 48} 49 50 51 52void CpuConsumer::setName(const String8& name) { 53 Mutex::Autolock _l(mMutex); 54 mName = name; 55 mBufferQueue->setConsumerName(name); 56} 57 58status_t CpuConsumer::setDefaultBufferSize(uint32_t width, uint32_t height) 59{ 60 Mutex::Autolock _l(mMutex); 61 return mBufferQueue->setDefaultBufferSize(width, height); 62} 63 64status_t CpuConsumer::setDefaultBufferFormat(uint32_t defaultFormat) 65{ 66 Mutex::Autolock _l(mMutex); 67 return mBufferQueue->setDefaultBufferFormat(defaultFormat); 68} 69 70status_t CpuConsumer::lockNextBuffer(LockedBuffer *nativeBuffer) { 71 status_t err; 72 73 if (!nativeBuffer) return BAD_VALUE; 74 if (mCurrentLockedBuffers == mMaxLockedBuffers) { 75 return INVALID_OPERATION; 76 } 77 78 BufferQueue::BufferItem b; 79 80 Mutex::Autolock _l(mMutex); 81 82 err = acquireBufferLocked(&b, 0); 83 if (err != OK) { 84 if (err == BufferQueue::NO_BUFFER_AVAILABLE) { 85 return BAD_VALUE; 86 } else { 87 CC_LOGE("Error acquiring buffer: %s (%d)", strerror(err), err); 88 return err; 89 } 90 } 91 92 int buf = b.mBuf; 93 94 if (b.mFence.get()) { 95 err = b.mFence->waitForever("CpuConsumer::lockNextBuffer"); 96 if (err != OK) { 97 CC_LOGE("Failed to wait for fence of acquired buffer: %s (%d)", 98 strerror(-err), err); 99 return err; 100 } 101 } 102 103 void *bufferPointer = NULL; 104 android_ycbcr ycbcr = android_ycbcr(); 105 106 if (mSlots[buf].mGraphicBuffer->getPixelFormat() == 107 HAL_PIXEL_FORMAT_YCbCr_420_888) { 108 err = mSlots[buf].mGraphicBuffer->lockYCbCr( 109 GraphicBuffer::USAGE_SW_READ_OFTEN, 110 b.mCrop, 111 &ycbcr); 112 113 if (err != OK) { 114 CC_LOGE("Unable to lock YCbCr buffer for CPU reading: %s (%d)", 115 strerror(-err), err); 116 return err; 117 } 118 bufferPointer = ycbcr.y; 119 } else { 120 err = mSlots[buf].mGraphicBuffer->lock( 121 GraphicBuffer::USAGE_SW_READ_OFTEN, 122 b.mCrop, 123 &bufferPointer); 124 125 if (err != OK) { 126 CC_LOGE("Unable to lock buffer for CPU reading: %s (%d)", 127 strerror(-err), err); 128 return err; 129 } 130 } 131 132 size_t lockedIdx = 0; 133 for (; lockedIdx < mMaxLockedBuffers; lockedIdx++) { 134 if (mAcquiredBuffers[lockedIdx].mSlot == 135 BufferQueue::INVALID_BUFFER_SLOT) { 136 break; 137 } 138 } 139 assert(lockedIdx < mMaxLockedBuffers); 140 141 AcquiredBuffer &ab = mAcquiredBuffers.editItemAt(lockedIdx); 142 ab.mSlot = buf; 143 ab.mBufferPointer = bufferPointer; 144 ab.mGraphicBuffer = mSlots[buf].mGraphicBuffer; 145 146 nativeBuffer->data = 147 reinterpret_cast<uint8_t*>(bufferPointer); 148 nativeBuffer->width = mSlots[buf].mGraphicBuffer->getWidth(); 149 nativeBuffer->height = mSlots[buf].mGraphicBuffer->getHeight(); 150 nativeBuffer->format = mSlots[buf].mGraphicBuffer->getPixelFormat(); 151 nativeBuffer->stride = (ycbcr.y != NULL) ? 152 ycbcr.ystride : 153 mSlots[buf].mGraphicBuffer->getStride(); 154 155 nativeBuffer->crop = b.mCrop; 156 nativeBuffer->transform = b.mTransform; 157 nativeBuffer->scalingMode = b.mScalingMode; 158 nativeBuffer->timestamp = b.mTimestamp; 159 nativeBuffer->frameNumber = b.mFrameNumber; 160 161 nativeBuffer->dataCb = reinterpret_cast<uint8_t*>(ycbcr.cb); 162 nativeBuffer->dataCr = reinterpret_cast<uint8_t*>(ycbcr.cr); 163 nativeBuffer->chromaStride = ycbcr.cstride; 164 nativeBuffer->chromaStep = ycbcr.chroma_step; 165 166 mCurrentLockedBuffers++; 167 168 return OK; 169} 170 171status_t CpuConsumer::unlockBuffer(const LockedBuffer &nativeBuffer) { 172 Mutex::Autolock _l(mMutex); 173 size_t lockedIdx = 0; 174 status_t err; 175 176 void *bufPtr = reinterpret_cast<void *>(nativeBuffer.data); 177 for (; lockedIdx < mMaxLockedBuffers; lockedIdx++) { 178 if (bufPtr == mAcquiredBuffers[lockedIdx].mBufferPointer) break; 179 } 180 if (lockedIdx == mMaxLockedBuffers) { 181 CC_LOGE("%s: Can't find buffer to free", __FUNCTION__); 182 return BAD_VALUE; 183 } 184 185 return releaseAcquiredBufferLocked(lockedIdx); 186} 187 188status_t CpuConsumer::releaseAcquiredBufferLocked(int lockedIdx) { 189 status_t err; 190 191 err = mAcquiredBuffers[lockedIdx].mGraphicBuffer->unlock(); 192 if (err != OK) { 193 CC_LOGE("%s: Unable to unlock graphic buffer %d", __FUNCTION__, 194 lockedIdx); 195 return err; 196 } 197 int buf = mAcquiredBuffers[lockedIdx].mSlot; 198 199 // release the buffer if it hasn't already been freed by the BufferQueue. 200 // This can happen, for example, when the producer of this buffer 201 // disconnected after this buffer was acquired. 202 if (CC_LIKELY(mAcquiredBuffers[lockedIdx].mGraphicBuffer == 203 mSlots[buf].mGraphicBuffer)) { 204 releaseBufferLocked( 205 buf, mAcquiredBuffers[lockedIdx].mGraphicBuffer, 206 EGL_NO_DISPLAY, EGL_NO_SYNC_KHR); 207 } 208 209 AcquiredBuffer &ab = mAcquiredBuffers.editItemAt(lockedIdx); 210 ab.mSlot = BufferQueue::INVALID_BUFFER_SLOT; 211 ab.mBufferPointer = NULL; 212 ab.mGraphicBuffer.clear(); 213 214 mCurrentLockedBuffers--; 215 return OK; 216} 217 218void CpuConsumer::freeBufferLocked(int slotIndex) { 219 ConsumerBase::freeBufferLocked(slotIndex); 220} 221 222} // namespace android 223