diff options
Diffstat (limited to 'media/libstagefright/omx/OMXNodeInstance.cpp')
| -rw-r--r-- | media/libstagefright/omx/OMXNodeInstance.cpp | 757 |
1 files changed, 0 insertions, 757 deletions
diff --git a/media/libstagefright/omx/OMXNodeInstance.cpp b/media/libstagefright/omx/OMXNodeInstance.cpp deleted file mode 100644 index bff3def..0000000 --- a/media/libstagefright/omx/OMXNodeInstance.cpp +++ /dev/null @@ -1,757 +0,0 @@ -/* - * Copyright (C) 2009 The Android Open Source Project - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -//#define LOG_NDEBUG 0 -#define LOG_TAG "OMXNodeInstance" -#include <utils/Log.h> - -#include "../include/OMXNodeInstance.h" -#include "OMXMaster.h" - -#include <OMX_Component.h> - -#include <binder/IMemory.h> -#include <HardwareAPI.h> -#include <media/stagefright/foundation/ADebug.h> -#include <media/stagefright/MediaErrors.h> - -namespace android { - -struct BufferMeta { - BufferMeta(const sp<IMemory> &mem, bool is_backup = false) - : mMem(mem), - mIsBackup(is_backup) { - } - - BufferMeta(size_t size) - : mSize(size), - mIsBackup(false) { - } - - BufferMeta(const sp<GraphicBuffer> &graphicBuffer) - : mGraphicBuffer(graphicBuffer), - mIsBackup(false) { - } - - void CopyFromOMX(const OMX_BUFFERHEADERTYPE *header) { - if (!mIsBackup) { - return; - } - - memcpy((OMX_U8 *)mMem->pointer() + header->nOffset, - header->pBuffer + header->nOffset, - header->nFilledLen); - } - - void CopyToOMX(const OMX_BUFFERHEADERTYPE *header) { - if (!mIsBackup) { - return; - } - - memcpy(header->pBuffer + header->nOffset, - (const OMX_U8 *)mMem->pointer() + header->nOffset, - header->nFilledLen); - } - -private: - sp<GraphicBuffer> mGraphicBuffer; - sp<IMemory> mMem; - size_t mSize; - bool mIsBackup; - - BufferMeta(const BufferMeta &); - BufferMeta &operator=(const BufferMeta &); -}; - -// static -OMX_CALLBACKTYPE OMXNodeInstance::kCallbacks = { - &OnEvent, &OnEmptyBufferDone, &OnFillBufferDone -}; - -OMXNodeInstance::OMXNodeInstance( - OMX *owner, const sp<IOMXObserver> &observer) - : mOwner(owner), - mNodeID(NULL), - mHandle(NULL), - mObserver(observer), - mDying(false) { -} - -OMXNodeInstance::~OMXNodeInstance() { - CHECK(mHandle == NULL); -} - -void OMXNodeInstance::setHandle(OMX::node_id node_id, OMX_HANDLETYPE handle) { - CHECK(mHandle == NULL); - mNodeID = node_id; - mHandle = handle; -} - -OMX *OMXNodeInstance::owner() { - return mOwner; -} - -sp<IOMXObserver> OMXNodeInstance::observer() { - return mObserver; -} - -OMX::node_id OMXNodeInstance::nodeID() { - return mNodeID; -} - -static status_t StatusFromOMXError(OMX_ERRORTYPE err) { - switch (err) { - case OMX_ErrorNone: - return OK; - case OMX_ErrorUnsupportedSetting: - return ERROR_UNSUPPORTED; - default: - return UNKNOWN_ERROR; - } -} - -status_t OMXNodeInstance::freeNode(OMXMaster *master) { - static int32_t kMaxNumIterations = 10; - - // Transition the node from its current state all the way down - // to "Loaded". - // This ensures that all active buffers are properly freed even - // for components that don't do this themselves on a call to - // "FreeHandle". - - // The code below may trigger some more events to be dispatched - // by the OMX component - we want to ignore them as our client - // does not expect them. - mDying = true; - - OMX_STATETYPE state; - CHECK_EQ(OMX_GetState(mHandle, &state), OMX_ErrorNone); - switch (state) { - case OMX_StateExecuting: - { - ALOGV("forcing Executing->Idle"); - sendCommand(OMX_CommandStateSet, OMX_StateIdle); - OMX_ERRORTYPE err; - int32_t iteration = 0; - while ((err = OMX_GetState(mHandle, &state)) == OMX_ErrorNone - && state != OMX_StateIdle - && state != OMX_StateInvalid) { - if (++iteration > kMaxNumIterations) { - ALOGE("component failed to enter Idle state, aborting."); - state = OMX_StateInvalid; - break; - } - - usleep(100000); - } - CHECK_EQ(err, OMX_ErrorNone); - - if (state == OMX_StateInvalid) { - break; - } - - // fall through - } - - case OMX_StateIdle: - { - ALOGV("forcing Idle->Loaded"); - sendCommand(OMX_CommandStateSet, OMX_StateLoaded); - - freeActiveBuffers(); - - OMX_ERRORTYPE err; - int32_t iteration = 0; - while ((err = OMX_GetState(mHandle, &state)) == OMX_ErrorNone - && state != OMX_StateLoaded - && state != OMX_StateInvalid) { - if (++iteration > kMaxNumIterations) { - ALOGE("component failed to enter Loaded state, aborting."); - state = OMX_StateInvalid; - break; - } - - ALOGV("waiting for Loaded state..."); - usleep(100000); - } - CHECK_EQ(err, OMX_ErrorNone); - - // fall through - } - - case OMX_StateLoaded: - case OMX_StateInvalid: - break; - - default: - CHECK(!"should not be here, unknown state."); - break; - } - - ALOGV("calling destroyComponentInstance"); - OMX_ERRORTYPE err = master->destroyComponentInstance( - static_cast<OMX_COMPONENTTYPE *>(mHandle)); - ALOGV("destroyComponentInstance returned err %d", err); - - mHandle = NULL; - - if (err != OMX_ErrorNone) { - ALOGE("FreeHandle FAILED with error 0x%08x.", err); - } - - mOwner->invalidateNodeID(mNodeID); - mNodeID = NULL; - - ALOGV("OMXNodeInstance going away."); - delete this; - - return StatusFromOMXError(err); -} - -status_t OMXNodeInstance::sendCommand( - OMX_COMMANDTYPE cmd, OMX_S32 param) { - Mutex::Autolock autoLock(mLock); - - OMX_ERRORTYPE err = OMX_SendCommand(mHandle, cmd, param, NULL); - return StatusFromOMXError(err); -} - -status_t OMXNodeInstance::getParameter( - OMX_INDEXTYPE index, void *params, size_t size) { - Mutex::Autolock autoLock(mLock); - - OMX_ERRORTYPE err = OMX_GetParameter(mHandle, index, params); - - return StatusFromOMXError(err); -} - -status_t OMXNodeInstance::setParameter( - OMX_INDEXTYPE index, const void *params, size_t size) { - Mutex::Autolock autoLock(mLock); - - OMX_ERRORTYPE err = OMX_SetParameter( - mHandle, index, const_cast<void *>(params)); - - return StatusFromOMXError(err); -} - -status_t OMXNodeInstance::getConfig( - OMX_INDEXTYPE index, void *params, size_t size) { - Mutex::Autolock autoLock(mLock); - - OMX_ERRORTYPE err = OMX_GetConfig(mHandle, index, params); - return StatusFromOMXError(err); -} - -status_t OMXNodeInstance::setConfig( - OMX_INDEXTYPE index, const void *params, size_t size) { - Mutex::Autolock autoLock(mLock); - - OMX_ERRORTYPE err = OMX_SetConfig( - mHandle, index, const_cast<void *>(params)); - - return StatusFromOMXError(err); -} - -status_t OMXNodeInstance::getState(OMX_STATETYPE* state) { - Mutex::Autolock autoLock(mLock); - - OMX_ERRORTYPE err = OMX_GetState(mHandle, state); - - return StatusFromOMXError(err); -} - -status_t OMXNodeInstance::enableGraphicBuffers( - OMX_U32 portIndex, OMX_BOOL enable) { - Mutex::Autolock autoLock(mLock); - - OMX_INDEXTYPE index; - OMX_ERRORTYPE err = OMX_GetExtensionIndex( - mHandle, - const_cast<OMX_STRING>("OMX.google.android.index.enableAndroidNativeBuffers"), - &index); - - if (err != OMX_ErrorNone) { - ALOGE("OMX_GetExtensionIndex failed"); - - return StatusFromOMXError(err); - } - - OMX_VERSIONTYPE ver; - ver.s.nVersionMajor = 1; - ver.s.nVersionMinor = 0; - ver.s.nRevision = 0; - ver.s.nStep = 0; - EnableAndroidNativeBuffersParams params = { - sizeof(EnableAndroidNativeBuffersParams), ver, portIndex, enable, - }; - - err = OMX_SetParameter(mHandle, index, ¶ms); - - if (err != OMX_ErrorNone) { - ALOGE("OMX_EnableAndroidNativeBuffers failed with error %d (0x%08x)", - err, err); - - return UNKNOWN_ERROR; - } - - return OK; -} - -status_t OMXNodeInstance::getGraphicBufferUsage( - OMX_U32 portIndex, OMX_U32* usage) { - Mutex::Autolock autoLock(mLock); - - OMX_INDEXTYPE index; - OMX_ERRORTYPE err = OMX_GetExtensionIndex( - mHandle, - const_cast<OMX_STRING>( - "OMX.google.android.index.getAndroidNativeBufferUsage"), - &index); - - if (err != OMX_ErrorNone) { - ALOGE("OMX_GetExtensionIndex failed"); - - return StatusFromOMXError(err); - } - - OMX_VERSIONTYPE ver; - ver.s.nVersionMajor = 1; - ver.s.nVersionMinor = 0; - ver.s.nRevision = 0; - ver.s.nStep = 0; - GetAndroidNativeBufferUsageParams params = { - sizeof(GetAndroidNativeBufferUsageParams), ver, portIndex, 0, - }; - - err = OMX_GetParameter(mHandle, index, ¶ms); - - if (err != OMX_ErrorNone) { - ALOGE("OMX_GetAndroidNativeBufferUsage failed with error %d (0x%08x)", - err, err); - return UNKNOWN_ERROR; - } - - *usage = params.nUsage; - - return OK; -} - -status_t OMXNodeInstance::storeMetaDataInBuffers( - OMX_U32 portIndex, - OMX_BOOL enable) { - Mutex::Autolock autolock(mLock); - - OMX_INDEXTYPE index; - OMX_STRING name = const_cast<OMX_STRING>( - "OMX.google.android.index.storeMetaDataInBuffers"); - - OMX_ERRORTYPE err = OMX_GetExtensionIndex(mHandle, name, &index); - if (err != OMX_ErrorNone) { - ALOGE("OMX_GetExtensionIndex %s failed", name); - return StatusFromOMXError(err); - } - - StoreMetaDataInBuffersParams params; - memset(¶ms, 0, sizeof(params)); - params.nSize = sizeof(params); - - // Version: 1.0.0.0 - params.nVersion.s.nVersionMajor = 1; - - params.nPortIndex = portIndex; - params.bStoreMetaData = enable; - if ((err = OMX_SetParameter(mHandle, index, ¶ms)) != OMX_ErrorNone) { - ALOGE("OMX_SetParameter() failed for StoreMetaDataInBuffers: 0x%08x", err); - return UNKNOWN_ERROR; - } - return err; -} - -status_t OMXNodeInstance::useBuffer( - OMX_U32 portIndex, const sp<IMemory> ¶ms, - OMX::buffer_id *buffer) { - Mutex::Autolock autoLock(mLock); - - BufferMeta *buffer_meta = new BufferMeta(params); - - OMX_BUFFERHEADERTYPE *header; - - OMX_ERRORTYPE err = OMX_UseBuffer( - mHandle, &header, portIndex, buffer_meta, - params->size(), static_cast<OMX_U8 *>(params->pointer())); - - if (err != OMX_ErrorNone) { - ALOGE("OMX_UseBuffer failed with error %d (0x%08x)", err, err); - - delete buffer_meta; - buffer_meta = NULL; - - *buffer = 0; - - return UNKNOWN_ERROR; - } - - CHECK_EQ(header->pAppPrivate, buffer_meta); - - *buffer = header; - - addActiveBuffer(portIndex, *buffer); - - return OK; -} - -status_t OMXNodeInstance::useGraphicBuffer2_l( - OMX_U32 portIndex, const sp<GraphicBuffer>& graphicBuffer, - OMX::buffer_id *buffer) { - - // port definition - OMX_PARAM_PORTDEFINITIONTYPE def; - def.nSize = sizeof(OMX_PARAM_PORTDEFINITIONTYPE); - def.nVersion.s.nVersionMajor = 1; - def.nVersion.s.nVersionMinor = 0; - def.nVersion.s.nRevision = 0; - def.nVersion.s.nStep = 0; - def.nPortIndex = portIndex; - OMX_ERRORTYPE err = OMX_GetParameter(mHandle, OMX_IndexParamPortDefinition, &def); - if (err != OMX_ErrorNone) - { - ALOGE("%s::%d:Error getting OMX_IndexParamPortDefinition", __FUNCTION__, __LINE__); - return err; - } - - BufferMeta *bufferMeta = new BufferMeta(graphicBuffer); - - OMX_BUFFERHEADERTYPE *header = NULL; - OMX_U8* bufferHandle = const_cast<OMX_U8*>( - reinterpret_cast<const OMX_U8*>(graphicBuffer->handle)); - - err = OMX_UseBuffer( - mHandle, - &header, - portIndex, - bufferMeta, - def.nBufferSize, - bufferHandle); - - if (err != OMX_ErrorNone) { - ALOGE("OMX_UseBuffer failed with error %d (0x%08x)", err, err); - delete bufferMeta; - bufferMeta = NULL; - *buffer = 0; - return UNKNOWN_ERROR; - } - - CHECK_EQ(header->pBuffer, bufferHandle); - CHECK_EQ(header->pAppPrivate, bufferMeta); - - *buffer = header; - - addActiveBuffer(portIndex, *buffer); - - return OK; -} - -// XXX: This function is here for backwards compatibility. Once the OMX -// implementations have been updated this can be removed and useGraphicBuffer2 -// can be renamed to useGraphicBuffer. -status_t OMXNodeInstance::useGraphicBuffer( - OMX_U32 portIndex, const sp<GraphicBuffer>& graphicBuffer, - OMX::buffer_id *buffer) { - Mutex::Autolock autoLock(mLock); - - // See if the newer version of the extension is present. - OMX_INDEXTYPE index; - if (OMX_GetExtensionIndex( - mHandle, - const_cast<OMX_STRING>("OMX.google.android.index.useAndroidNativeBuffer2"), - &index) == OMX_ErrorNone) { - return useGraphicBuffer2_l(portIndex, graphicBuffer, buffer); - } - - OMX_ERRORTYPE err = OMX_GetExtensionIndex( - mHandle, - const_cast<OMX_STRING>("OMX.google.android.index.useAndroidNativeBuffer"), - &index); - - if (err != OMX_ErrorNone) { - ALOGE("OMX_GetExtensionIndex failed"); - - return StatusFromOMXError(err); - } - - BufferMeta *bufferMeta = new BufferMeta(graphicBuffer); - - OMX_BUFFERHEADERTYPE *header; - - OMX_VERSIONTYPE ver; - ver.s.nVersionMajor = 1; - ver.s.nVersionMinor = 0; - ver.s.nRevision = 0; - ver.s.nStep = 0; - UseAndroidNativeBufferParams params = { - sizeof(UseAndroidNativeBufferParams), ver, portIndex, bufferMeta, - &header, graphicBuffer, - }; - - err = OMX_SetParameter(mHandle, index, ¶ms); - - if (err != OMX_ErrorNone) { - ALOGE("OMX_UseAndroidNativeBuffer failed with error %d (0x%08x)", err, - err); - - delete bufferMeta; - bufferMeta = NULL; - - *buffer = 0; - - return UNKNOWN_ERROR; - } - - CHECK_EQ(header->pAppPrivate, bufferMeta); - - *buffer = header; - - addActiveBuffer(portIndex, *buffer); - - return OK; -} - -status_t OMXNodeInstance::allocateBuffer( - OMX_U32 portIndex, size_t size, OMX::buffer_id *buffer, - void **buffer_data) { - Mutex::Autolock autoLock(mLock); - - BufferMeta *buffer_meta = new BufferMeta(size); - - OMX_BUFFERHEADERTYPE *header; - - OMX_ERRORTYPE err = OMX_AllocateBuffer( - mHandle, &header, portIndex, buffer_meta, size); - - if (err != OMX_ErrorNone) { - ALOGE("OMX_AllocateBuffer failed with error %d (0x%08x)", err, err); - - delete buffer_meta; - buffer_meta = NULL; - - *buffer = 0; - - return UNKNOWN_ERROR; - } - - CHECK_EQ(header->pAppPrivate, buffer_meta); - - *buffer = header; - *buffer_data = header->pBuffer; - - addActiveBuffer(portIndex, *buffer); - - return OK; -} - -status_t OMXNodeInstance::allocateBufferWithBackup( - OMX_U32 portIndex, const sp<IMemory> ¶ms, - OMX::buffer_id *buffer) { - Mutex::Autolock autoLock(mLock); - - BufferMeta *buffer_meta = new BufferMeta(params, true); - - OMX_BUFFERHEADERTYPE *header; - - OMX_ERRORTYPE err = OMX_AllocateBuffer( - mHandle, &header, portIndex, buffer_meta, params->size()); - - if (err != OMX_ErrorNone) { - ALOGE("OMX_AllocateBuffer failed with error %d (0x%08x)", err, err); - - delete buffer_meta; - buffer_meta = NULL; - - *buffer = 0; - - return UNKNOWN_ERROR; - } - - CHECK_EQ(header->pAppPrivate, buffer_meta); - - *buffer = header; - - addActiveBuffer(portIndex, *buffer); - - return OK; -} - -status_t OMXNodeInstance::freeBuffer( - OMX_U32 portIndex, OMX::buffer_id buffer) { - Mutex::Autolock autoLock(mLock); - - removeActiveBuffer(portIndex, buffer); - - OMX_BUFFERHEADERTYPE *header = (OMX_BUFFERHEADERTYPE *)buffer; - BufferMeta *buffer_meta = static_cast<BufferMeta *>(header->pAppPrivate); - - OMX_ERRORTYPE err = OMX_FreeBuffer(mHandle, portIndex, header); - - delete buffer_meta; - buffer_meta = NULL; - - return StatusFromOMXError(err); -} - -status_t OMXNodeInstance::fillBuffer(OMX::buffer_id buffer) { - Mutex::Autolock autoLock(mLock); - - OMX_BUFFERHEADERTYPE *header = (OMX_BUFFERHEADERTYPE *)buffer; - header->nFilledLen = 0; - header->nOffset = 0; - header->nFlags = 0; - - OMX_ERRORTYPE err = OMX_FillThisBuffer(mHandle, header); - - return StatusFromOMXError(err); -} - -status_t OMXNodeInstance::emptyBuffer( - OMX::buffer_id buffer, - OMX_U32 rangeOffset, OMX_U32 rangeLength, - OMX_U32 flags, OMX_TICKS timestamp) { - Mutex::Autolock autoLock(mLock); - - OMX_BUFFERHEADERTYPE *header = (OMX_BUFFERHEADERTYPE *)buffer; - header->nFilledLen = rangeLength; - header->nOffset = rangeOffset; - header->nFlags = flags; - header->nTimeStamp = timestamp; - - BufferMeta *buffer_meta = - static_cast<BufferMeta *>(header->pAppPrivate); - buffer_meta->CopyToOMX(header); - - OMX_ERRORTYPE err = OMX_EmptyThisBuffer(mHandle, header); - - return StatusFromOMXError(err); -} - -status_t OMXNodeInstance::getExtensionIndex( - const char *parameterName, OMX_INDEXTYPE *index) { - Mutex::Autolock autoLock(mLock); - - OMX_ERRORTYPE err = OMX_GetExtensionIndex( - mHandle, const_cast<char *>(parameterName), index); - - return StatusFromOMXError(err); -} - -void OMXNodeInstance::onMessage(const omx_message &msg) { - if (msg.type == omx_message::FILL_BUFFER_DONE) { - OMX_BUFFERHEADERTYPE *buffer = - static_cast<OMX_BUFFERHEADERTYPE *>( - msg.u.extended_buffer_data.buffer); - - BufferMeta *buffer_meta = - static_cast<BufferMeta *>(buffer->pAppPrivate); - - buffer_meta->CopyFromOMX(buffer); - } - - mObserver->onMessage(msg); -} - -void OMXNodeInstance::onObserverDied(OMXMaster *master) { - ALOGE("!!! Observer died. Quickly, do something, ... anything..."); - - // Try to force shutdown of the node and hope for the best. - freeNode(master); -} - -void OMXNodeInstance::onGetHandleFailed() { - delete this; -} - -// static -OMX_ERRORTYPE OMXNodeInstance::OnEvent( - OMX_IN OMX_HANDLETYPE hComponent, - OMX_IN OMX_PTR pAppData, - OMX_IN OMX_EVENTTYPE eEvent, - OMX_IN OMX_U32 nData1, - OMX_IN OMX_U32 nData2, - OMX_IN OMX_PTR pEventData) { - OMXNodeInstance *instance = static_cast<OMXNodeInstance *>(pAppData); - if (instance->mDying) { - return OMX_ErrorNone; - } - return instance->owner()->OnEvent( - instance->nodeID(), eEvent, nData1, nData2, pEventData); -} - -// static -OMX_ERRORTYPE OMXNodeInstance::OnEmptyBufferDone( - OMX_IN OMX_HANDLETYPE hComponent, - OMX_IN OMX_PTR pAppData, - OMX_IN OMX_BUFFERHEADERTYPE* pBuffer) { - OMXNodeInstance *instance = static_cast<OMXNodeInstance *>(pAppData); - if (instance->mDying) { - return OMX_ErrorNone; - } - return instance->owner()->OnEmptyBufferDone(instance->nodeID(), pBuffer); -} - -// static -OMX_ERRORTYPE OMXNodeInstance::OnFillBufferDone( - OMX_IN OMX_HANDLETYPE hComponent, - OMX_IN OMX_PTR pAppData, - OMX_IN OMX_BUFFERHEADERTYPE* pBuffer) { - OMXNodeInstance *instance = static_cast<OMXNodeInstance *>(pAppData); - if (instance->mDying) { - return OMX_ErrorNone; - } - return instance->owner()->OnFillBufferDone(instance->nodeID(), pBuffer); -} - -void OMXNodeInstance::addActiveBuffer(OMX_U32 portIndex, OMX::buffer_id id) { - ActiveBuffer active; - active.mPortIndex = portIndex; - active.mID = id; - mActiveBuffers.push(active); -} - -void OMXNodeInstance::removeActiveBuffer( - OMX_U32 portIndex, OMX::buffer_id id) { - bool found = false; - for (size_t i = 0; i < mActiveBuffers.size(); ++i) { - if (mActiveBuffers[i].mPortIndex == portIndex - && mActiveBuffers[i].mID == id) { - found = true; - mActiveBuffers.removeItemsAt(i); - break; - } - } - - if (!found) { - ALOGW("Attempt to remove an active buffer we know nothing about..."); - } -} - -void OMXNodeInstance::freeActiveBuffers() { - // Make sure to count down here, as freeBuffer will in turn remove - // the active buffer from the vector... - for (size_t i = mActiveBuffers.size(); i--;) { - freeBuffer(mActiveBuffers[i].mPortIndex, mActiveBuffers[i].mID); - } -} - -} // namespace android |