| |
| /* |
| * Copyright (C) Texas Instruments - http://www.ti.com/ |
| * |
| * This library is free software; you can redistribute it and/or |
| * modify it under the terms of the GNU Lesser General Public |
| * License as published by the Free Software Foundation; either |
| * version 2.1 of the License, or (at your option) any later version. |
| * |
| * |
| * This library is distributed in the hope that it will be useful, |
| * but WITHOUT ANY WARRANTY; without even the implied warranty of |
| * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU |
| * Lesser General Public License for more details. |
| * |
| * |
| * You should have received a copy of the GNU Lesser General Public |
| * License along with this library; if not, write to the Free Software |
| * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA |
| */ |
| /* ============================================================================= |
| * Texas Instruments OMAP (TM) Platform Software |
| * (c) Copyright Texas Instruments, Incorporated. All Rights Reserved. |
| * |
| * Use of this software is controlled by the terms and conditions found |
| * in the license agreement under which this software has been supplied. |
| * =========================================================================== */ |
| /** |
| * @file OMX_Mp3Dec_CompThread.c |
| * |
| * This file implements various utilitiy functions for various activities |
| * like handling command from application, callback from LCML etc. |
| * |
| * @path $(CSLPATH)\OMAPSW_MPU\linux\audio\src\openmax_il\mp3_dec\src |
| * |
| * @rev 1.0 |
| */ |
| /* ---------------------------------------------------------------------------- |
| *! |
| *! Revision History |
| *! =================================== |
| *! 21-sept-2006 bk: updated some review findings for alpha release |
| *! 24-Aug-2006 bk: Khronos OpenMAX (TM) 1.0 Conformance tests some more |
| *! 18-July-2006 bk: Khronos OpenMAX (TM) 1.0 Conformance tests validated for few cases |
| *! This is newest file |
| * =========================================================================== */ |
| /* ------compilation control switches -------------------------*/ |
| /**************************************************************** |
| * INCLUDE FILES |
| ****************************************************************/ |
| /* ----- system and platform files ----------------------------*/ |
| |
| |
| |
| #ifdef UNDER_CE |
| #include <windows.h> |
| #include <oaf_osal.h> |
| #include <omx_core.h> |
| #include <stdlib.h> |
| #else |
| #include <wchar.h> |
| #include <unistd.h> |
| #include <sys/types.h> |
| #include <sys/wait.h> |
| #include <sys/types.h> |
| #include <sys/stat.h> |
| #include <dlfcn.h> |
| #include <sys/select.h> |
| #include <memory.h> |
| #include <fcntl.h> |
| #include <signal.h> |
| #endif |
| |
| #include <dbapi.h> |
| #include <string.h> |
| #include <stdio.h> |
| |
| #ifdef ANDROID |
| #include <utils/threads.h> |
| #include <sys/prctl.h> |
| #endif |
| |
| #include "OMX_Mp3Dec_Utils.h" |
| |
| /* ================================================================================= * */ |
| /** |
| * @fn MP3DEC_ComponentThread() This is component thread that keeps listening for |
| * commands or event/messages/buffers from application or from LCML. |
| * |
| * @param pThreadData This is thread argument. |
| * |
| * @pre None |
| * |
| * @post None |
| * |
| * @return OMX_ErrorNone = Always |
| * |
| * @see None |
| */ |
| /* ================================================================================ * */ |
| void* MP3DEC_ComponentThread (void* pThreadData) |
| { |
| int status; |
| struct timespec tv; |
| int fdmax; |
| fd_set rfds; |
| OMX_U32 nRet; |
| OMX_ERRORTYPE eError = OMX_ErrorNone; |
| MP3DEC_COMPONENT_PRIVATE* pComponentPrivate = (MP3DEC_COMPONENT_PRIVATE*)pThreadData; |
| OMX_COMPONENTTYPE *pHandle = pComponentPrivate->pHandle; |
| |
| #ifdef ANDROID |
| setpriority(PRIO_PROCESS, 0, ANDROID_PRIORITY_AUDIO); |
| prctl(PR_SET_NAME, (unsigned long)"MP3Component", 0, 0, 0); |
| #endif |
| |
| OMX_PRINT1(pComponentPrivate->dbg, ":: Entering ComponentThread \n"); |
| |
| #ifdef __PERF_INSTRUMENTATION__ |
| pComponentPrivate->pPERFcomp = PERF_Create(PERF_FOURCC('M', 'P', '3',' '), |
| PERF_ModuleComponent | |
| PERF_ModuleAudioDecode); |
| #endif |
| |
| fdmax = pComponentPrivate->cmdPipe[0]; |
| |
| if (pComponentPrivate->dataPipe[0] > fdmax) { |
| fdmax = pComponentPrivate->dataPipe[0]; |
| } |
| |
| while (1) { |
| FD_ZERO (&rfds); |
| FD_SET (pComponentPrivate->cmdPipe[0], &rfds); |
| FD_SET (pComponentPrivate->dataPipe[0], &rfds); |
| tv.tv_sec = 1; |
| tv.tv_nsec = 0; |
| |
| #ifndef UNDER_CE |
| sigset_t set; |
| sigemptyset (&set); |
| sigaddset (&set, SIGALRM); |
| status = pselect (fdmax+1, &rfds, NULL, NULL, &tv, &set); |
| #else |
| status = select (fdmax+1, &rfds, NULL, NULL, &tv); |
| #endif |
| |
| if (pComponentPrivate->bExitCompThrd == 1) { |
| OMX_PRINT1(pComponentPrivate->dbg, ":: Comp Thrd Exiting here...\n"); |
| goto EXIT; |
| } |
| |
| |
| |
| if (0 == status) { |
| OMX_PRSTATE2(pComponentPrivate->dbg, "\n\n\n!!!!! Component Time Out !!!!!!!!!!!! \n"); |
| OMX_PRSTATE2(pComponentPrivate->dbg, "Current State: %d \n", pComponentPrivate->curState); |
| |
| OMX_PRDSP2(pComponentPrivate->dbg, "%d:: lcml_nCntOp = %lu\n",__LINE__,pComponentPrivate->lcml_nCntOp); |
| OMX_PRDSP2(pComponentPrivate->dbg, "%d : lcml_nCntIp = %lu\n",__LINE__,pComponentPrivate->lcml_nCntIp); |
| OMX_PRDSP2(pComponentPrivate->dbg, "%d : lcml_nCntIpRes = %lu\n",__LINE__,pComponentPrivate->lcml_nCntIpRes); |
| OMX_PRDSP2(pComponentPrivate->dbg, "%d :: lcml_nCntOpReceived = %lu\n",__LINE__,pComponentPrivate->lcml_nCntOpReceived); |
| |
| if (pComponentPrivate->bExitCompThrd == 1) { |
| OMX_ERROR4(pComponentPrivate->dbg, ":: Comp Thrd Exiting here...\n"); |
| goto EXIT; |
| } |
| |
| |
| } else if (-1 == status) { |
| OMX_ERROR4(pComponentPrivate->dbg, ":: Error in Select\n"); |
| pComponentPrivate->cbInfo.EventHandler (pHandle, |
| pHandle->pApplicationPrivate, |
| OMX_EventError, |
| OMX_ErrorInsufficientResources, |
| OMX_TI_ErrorSevere, |
| "Error from COmponent Thread in select"); |
| eError = OMX_ErrorInsufficientResources; |
| |
| } else if ((FD_ISSET (pComponentPrivate->dataPipe[0], &rfds))) { |
| int ret; |
| OMX_BUFFERHEADERTYPE *pBufHeader = NULL; |
| |
| OMX_PRCOMM2(pComponentPrivate->dbg, ":: DATA pipe is set in Component Thread\n"); |
| ret = read(pComponentPrivate->dataPipe[0], &pBufHeader, sizeof(pBufHeader)); |
| if (ret == -1) { |
| OMX_ERROR2(pComponentPrivate->dbg, ":: Error while reading from the pipe\n"); |
| } |
| |
| eError = MP3DEC_HandleDataBuf_FromApp (pBufHeader,pComponentPrivate); |
| if (eError != OMX_ErrorNone) { |
| OMX_ERROR2(pComponentPrivate->dbg, ":: Error From HandleDataBuf_FromApp\n"); |
| break; |
| } |
| } else if (FD_ISSET (pComponentPrivate->cmdPipe[0], &rfds)) { |
| OMX_PRCOMM2(pComponentPrivate->dbg, ":: CMD pipe is set in Component Thread\n"); |
| nRet = MP3DEC_HandleCommand (pComponentPrivate); |
| if (nRet == EXIT_COMPONENT_THRD) { |
| OMX_PRDSP2(pComponentPrivate->dbg, "Exiting from Component thread\n"); |
| MP3DEC_CleanupInitParams(pHandle); |
| OMX_PRSTATE2(pComponentPrivate->dbg, "****************** Component State Set to Loaded\n\n"); |
| |
| pComponentPrivate->curState = OMX_StateLoaded; |
| #ifdef __PERF_INSTRUMENTATION__ |
| PERF_Boundary(pComponentPrivate->pPERFcomp,PERF_BoundaryComplete | PERF_BoundaryCleanup); |
| #endif |
| if(pComponentPrivate->bPreempted == 0){ |
| pComponentPrivate->cbInfo.EventHandler(pHandle, pHandle->pApplicationPrivate, |
| OMX_EventCmdComplete, |
| OMX_ErrorNone,pComponentPrivate->curState, |
| NULL); |
| }else{ |
| pComponentPrivate->cbInfo.EventHandler(pHandle, |
| pHandle->pApplicationPrivate, |
| OMX_EventError, |
| OMX_ErrorResourcesLost, |
| OMX_TI_ErrorMajor, |
| NULL); |
| pComponentPrivate->bPreempted = 0; |
| } |
| } |
| } |
| } |
| EXIT: |
| |
| pComponentPrivate->bCompThreadStarted = 0; |
| |
| |
| #ifdef __PERF_INSTRUMENTATION__ |
| PERF_Done(pComponentPrivate->pPERFcomp); |
| #endif |
| |
| OMX_PRINT1(pComponentPrivate->dbg, ":: Exiting ComponentThread \n"); |
| return (void*)eError; |
| } |