1
2 /*
3 * Copyright (C) Texas Instruments - http://www.ti.com/
4 *
5 * This library is free software; you can redistribute it and/or
6 * modify it under the terms of the GNU Lesser General Public
7 * License as published by the Free Software Foundation; either
8 * version 2.1 of the License, or (at your option) any later version.
9 *
10 *
11 * This library is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * Lesser General Public License for more details.
15 *
16 *
17 * You should have received a copy of the GNU Lesser General Public
18 * License along with this library; if not, write to the Free Software
19 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
20 */
21 /* =============================================================================
22 * Texas Instruments OMAP (TM) Platform Software
23 * (c) Copyright Texas Instruments, Incorporated. All Rights Reserved.
24 *
25 * Use of this software is controlled by the terms and conditions found
26 * in the license agreement under which this software has been supplied.
27 * =========================================================================== */
28 /**
29 * @file OMX_G729Dec_ComponentThread.c
30 *
31 * This file implements OMX Component for G729 decoder that
32 * is fully compliant with the OMX Audio specification .
33 *
34 * @path $(OMAPSW_MPU)\linux\audio\src\openmax_il\g729_dec\src
35 *
36 * @rev 0.1
37 */
38 /* -----------------------------------------------------------------------------
39 *!
40 *! Revision History
41 *! ===================================
42 *! Date Author(s) Version Description
43 *! --------- ------------------- ------- ---------------------------------
44 *! 03-Jan-2007 A.Donjon 0.1 Code update for G729 DECODER
45 *!
46 *!
47 * ================================================================================= */
48
49 /* ------compilation control switches -------------------------*/
50 /****************************************************************
51 * INCLUDE FILES
52 ****************************************************************/
53 /* ----- system and platform files ----------------------------*/
54 #ifdef UNDER_CE
55 #include <windows.h>
56 #else
57 #include <unistd.h>
58 #include <dbapi.h>
59 #include <string.h>
60 #include <fcntl.h>
61 #include <stdlib.h>
62 #include <stdio.h>
63 #include <errno.h>
64 #include <sys/select.h>
65 #include <sys/time.h>
66 #include <signal.h>
67 #endif
68
69 /*-------program files ----------------------------------------*/
70 #include "OMX_G729Dec_Utils.h"
71 #include "OMX_G729Decoder.h"
72 #include "OMX_G729Dec_ComponentThread.h"
73
74 #ifdef RESOURCE_MANAGER_ENABLED
75 #include <ResourceManagerProxyAPI.h>
76 #endif
77 #ifdef __PERF_INSTRUMENTATION__
78 #include "perf.h"
79 #endif
80
81 /****************************************************************
82 * EXTERNAL REFERENCES NOTE : only use if not found in header file
83 ****************************************************************/
84 /*--------data declarations -----------------------------------*/
85 /*--------function prototypes ---------------------------------*/
86
87 /****************************************************************
88 * PUBLIC DECLARATIONS Defined here, used elsewhere
89 ****************************************************************/
90 /*--------data declarations -----------------------------------*/
91
92 /*--------function prototypes ---------------------------------*/
93
94 /****************************************************************
95 * PRIVATE DECLARATIONS Defined here, used only here
96 ****************************************************************/
97 /*--------data declarations -----------------------------------*/
98 /*--------function prototypes ---------------------------------*/
99 /*--------macros ----------------------------------------------*/
100
101
G729DEC_ComponentThread(void * pThreadData)102 void* G729DEC_ComponentThread (void* pThreadData)
103 {
104 OMX_S16 status = 0;
105 struct timespec tv;
106 OMX_S16 fdmax = 0;
107 fd_set rfds;
108 OMX_U32 nRet = 0;
109 OMX_ERRORTYPE eError = OMX_ErrorNone;
110 G729DEC_COMPONENT_PRIVATE* pComponentPrivate = (G729DEC_COMPONENT_PRIVATE*)pThreadData;
111 OMX_COMPONENTTYPE *pHandle = pComponentPrivate->pHandle;
112 OMX_BUFFERHEADERTYPE *pBufHeader = NULL;
113 ssize_t ret = 0;
114
115 G729DEC_DPRINT("OMX_G729Dec_ComponentThread:%d\n",__LINE__);
116 #ifdef __PERF_INSTRUMENTATION__
117 pComponentPrivate->pPERFcomp = PERF_Create(PERF_FOURCC('7', '2', '9', 'E'),
118 PERF_ModuleComponent |
119 PERF_ModuleAudioDecode);
120 #endif
121 fdmax = pComponentPrivate->cmdPipe[0];
122
123 if (pComponentPrivate->dataPipe[0] > fdmax) {
124 fdmax = pComponentPrivate->dataPipe[0];
125 }
126
127 while (1) {
128 FD_ZERO (&rfds);
129 FD_SET (pComponentPrivate->cmdPipe[0], &rfds);
130 FD_SET (pComponentPrivate->dataPipe[0], &rfds);
131
132 tv.tv_sec = 1;
133 tv.tv_nsec = 0;
134
135 sigset_t set;
136 sigemptyset (&set);
137 sigaddset (&set, SIGALRM);
138 status = pselect (fdmax+1, &rfds, NULL, NULL, &tv, &set);
139
140 if (0 == status) {
141
142 G729DEC_DPRINT("%d : bIsStopping = %d\n",__LINE__,
143 (int)pComponentPrivate->bIsStopping);
144
145 G729DEC_DPRINT("%d : lcml_nOpBuf = %d\n",__LINE__,
146 (int)pComponentPrivate->lcml_nOpBuf);
147
148 G729DEC_DPRINT("%d : lcml_nIpBuf = %d\n",__LINE__,
149 (int)pComponentPrivate->lcml_nIpBuf);
150 G729DEC_DPRINT("%d : app_nBuf = %d\n",__LINE__,
151 (int)pComponentPrivate->app_nBuf);
152
153 if (pComponentPrivate->bIsStopping == 1) {
154 G729DEC_DPRINT("%d:G729ComponentThread \n",__LINE__);
155
156 G729DEC_DPRINT("%d:G729ComponentThread \n",__LINE__);
157 if(eError != OMX_ErrorNone) {
158 G729DEC_DPRINT("%d: Error Occurred in Codec Stop..\n",__LINE__);
159 break;
160 }
161 pComponentPrivate->bIsStopping = 0;
162 pComponentPrivate->lcml_nOpBuf = 0;
163 pComponentPrivate->lcml_nIpBuf = 0;
164 pComponentPrivate->app_nBuf = 0;
165 pComponentPrivate->num_Op_Issued = 0;
166 pComponentPrivate->num_Sent_Ip_Buff = 0;
167 pComponentPrivate->num_Reclaimed_Op_Buff = 0;
168 pComponentPrivate->bIsEOFSent = 0;
169
170 G729DEC_DPRINT("%d:G729ComponentThread \n",__LINE__);
171 if (pComponentPrivate->curState != OMX_StateIdle) {
172 G729DEC_DPRINT("%d:G729AComponentThread \n",__LINE__);
173 goto EXIT;
174 }
175 }
176 G729DEC_DPRINT ("%d :: Component Time Out !!!!!!!!!!!! \n",__LINE__);
177
178 } else if (-1 == status) {
179
180 G729DEC_EPRINT ("%d :: Error in Select\n", __LINE__);
181 pComponentPrivate->cbInfo.EventHandler (
182 pHandle,
183 pHandle->pApplicationPrivate,
184 OMX_EventError,OMX_ErrorInsufficientResources,0,
185 "Error from COmponent Thread in select");
186 eError = OMX_ErrorInsufficientResources;
187
188 }
189 else if ((FD_ISSET (pComponentPrivate->dataPipe[0], &rfds))){
190 G729DEC_DPRINT ("%d :: DATA pipe is set in Component Thread\n",__LINE__);
191 ret = read(pComponentPrivate->dataPipe[0], &pBufHeader, sizeof(pBufHeader));
192 if (ret == -1) {
193 G729DEC_DPRINT ("%d :: Error while reading from the pipe\n",__LINE__);
194 }
195 eError = G729DECHandleDataBuf_FromApp (pBufHeader,pComponentPrivate);
196 if (eError != OMX_ErrorNone) {
197 G729DEC_DPRINT ("%d :: Error From G729DECHandleDataBuf_FromApp\n", __LINE__);
198 break;
199 }
200
201 }
202 else if (FD_ISSET (pComponentPrivate->cmdPipe[0], &rfds)) {
203 /* Do not accept any command when the component is stopping */
204 G729DEC_DPRINT ("%d :: CMD pipe is set in Component Thread\n",__LINE__);
205 nRet = G729DECHandleCommand (pComponentPrivate);
206 if (nRet == EXIT_COMPONENT_THRD) {
207 G729DEC_DPRINT ("Exiting from Component thread\n");
208 G729DEC_CleanupInitParams(pHandle);
209 if(eError != OMX_ErrorNone) {
210 G729DEC_DPRINT("%d :: Function G729Dec_FreeCompResources returned\
211 error\n",__LINE__);
212 goto EXIT;
213 }
214 G729DEC_DPRINT("%d :: ARM Side Resources Have Been Freed\n",__LINE__);
215 pComponentPrivate->curState = OMX_StateLoaded;
216 if (pComponentPrivate->bPreempted == 0) {
217 pComponentPrivate->cbInfo.EventHandler(
218 pHandle, pHandle->pApplicationPrivate,
219 OMX_EventCmdComplete,
220 OMX_ErrorNone,pComponentPrivate->curState, NULL);
221 }
222 else {
223 pComponentPrivate->cbInfo.EventHandler(
224 pHandle, pHandle->pApplicationPrivate,
225 OMX_EventError,
226 OMX_ErrorResourcesLost,pComponentPrivate->curState, NULL);
227 pComponentPrivate->bPreempted = 0;
228 }
229
230 }
231 }
232
233 }
234 EXIT:
235 G729DEC_DPRINT("%d::Exiting ComponentThread\n",__LINE__);
236 return (void*)eError;
237 }
238