diff options
Diffstat (limited to 'domx/domx/omx_rpc/src/omx_rpc_utils.c')
| -rwxr-xr-x | domx/domx/omx_rpc/src/omx_rpc_utils.c | 446 |
1 files changed, 0 insertions, 446 deletions
diff --git a/domx/domx/omx_rpc/src/omx_rpc_utils.c b/domx/domx/omx_rpc/src/omx_rpc_utils.c deleted file mode 100755 index b1e47a8..0000000 --- a/domx/domx/omx_rpc/src/omx_rpc_utils.c +++ /dev/null @@ -1,446 +0,0 @@ -/* - * Copyright (c) 2010, Texas Instruments Incorporated - * All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions - * are met: - * - * * Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * - * * Redistributions in binary form must reproduce the above copyright - * notice, this list of conditions and the following disclaimer in the - * documentation and/or other materials provided with the distribution. - * - * * Neither the name of Texas Instruments Incorporated nor the names of - * its contributors may be used to endorse or promote products derived - * from this software without specific prior written permission. - * - * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" - * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, - * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR - * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR - * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, - * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, - * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; - * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, - * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR - * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, - * EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - */ - -/** - * @file omx_rpc_utils.c - * This file contains methods that provides the functionality for - * the OpenMAX1.1 DOMX Framework RPC. - * - * @path \WTSD_DucatiMMSW\framework\domx\omx_rpc\src - * - * @rev 1.0 - */ - -/*============================================================== - *! Revision History - *! ============================ - *! 29-Mar-2010 Abhishek Ranka : Revamped DOMX implementation - *! - *! 19-August-2009 B Ravi Kiran ravi.kiran@ti.com: Initial Version - *================================================================*/ -/****************************************************************** - * INCLUDE FILES - ******************************************************************/ -#include <string.h> -#include <stdio.h> - -#include "omx_rpc.h" -#include "omx_rpc_internal.h" -#include "omx_rpc_utils.h" -#include <MultiProc.h> -#include <ProcMgr.h> - -extern char rcmservertable[MAX_PROC][MAX_SERVER_NAME_LENGTH]; -extern char Core_Array[MAX_PROC][MAX_CORENAME_LENGTH]; - -/* ===========================================================================*/ -/** - * @name EMPTY-STUB - * @brief - * @param - * @return - * - */ -/* ===========================================================================*/ -RPC_OMX_ERRORTYPE RPC_UTIL_GetTargetServerName(OMX_STRING ComponentName, - OMX_STRING ServerName) -{ - OMX_U8 count = 0; - OMX_U8 i = 0; - OMX_U8 servertable_idx = 0; - OMX_STRING str; - char Core[MAX_CORENAME_LENGTH]; - - DOMX_ENTER(""); - DOMX_DEBUG(" Calling Component Name %s", ComponentName); - - while (*ComponentName != '\0') - { - if (*ComponentName == '.') - { - count++; - if (count == 2) - { - ComponentName++; - str = ComponentName; - - while (*str != '.') - { - Core[i] = *str; - i++; - str++; - } - Core[i] = '\0'; - break; - } - - } - - ComponentName++; - } - - DOMX_DEBUG(" CORE NAME RECOVERED: %s", Core); - DOMX_DEBUG - ("____________________________________________________________"); - DOMX_DEBUG("Recovering Server Table Index"); - for (i = 0; i < CORE_MAX; i++) - { - - if (strcmp(Core, Core_Array[i]) == 0) - { - servertable_idx = i; - DOMX_DEBUG("Recovered Server table index = %d", i); - break; - } - } - strncpy(ServerName, (OMX_STRING) rcmservertable[servertable_idx], - MAX_SERVER_NAME_LENGTH); - DOMX_DEBUG(" ServerName recovered = %s", ServerName); - - return RPC_OMX_ErrorNone; -} - -/* ===========================================================================*/ -/** - * @name EMPTY-STUB - * @brief - * @param - * @return - * - */ -/* ===========================================================================*/ -RPC_OMX_ERRORTYPE RPC_UTIL_GetLocalServerName(OMX_STRING ComponentName, - OMX_STRING * ServerName) -{ -/* Implementation returns only current core ID - But this is a place holder to abstract out the -default server and other additional servers available on the current core. This additional servers -should be available in the RPC global that is indexed using the calling component name*/ - RPC_OMX_ERRORTYPE eRPCError = RPC_OMX_ErrorNone; - OMX_U8 servertable_idx = 0; - - servertable_idx = MultiProc_getId(NULL); //This can be replace with the mechanism to obtain new addition rcm servers - if (MultiProc_INVALIDID != servertable_idx) - *ServerName = rcmservertable[servertable_idx]; - else - eRPCError = RPC_OMX_ErrorUndefined; - - return eRPCError; -} - - - -/* ===========================================================================*/ -/** - * @name RPC_UTIL_GenerateLocalServerName() - * @brief This function generates a server name to be used while creating the - * RCM server. The name is based on the pid so that eacj process gets a - * unique server name. - * @param cServerName - This is filled in and returned with a valid value. - * @return RPC_OMX_ErrorNone = Successful - * @sa TBD - * - */ -/* ===========================================================================*/ -RPC_OMX_ERRORTYPE RPC_UTIL_GenerateLocalServerName(OMX_STRING cServerName) -{ - RPC_OMX_ERRORTYPE eRPCError = RPC_OMX_ErrorNone; - OMX_S32 pid = 0; - OMX_U32 nProcId = 0; - - pid = getpid(); - /*Using pid as the server name, thus limiting to only 1 server per process. - This limitaion is partly enforce by syslink as well since max size of server - name is 32 so only pid can fit into the name */ - sprintf(cServerName, "%ld", pid); - - nProcId = MultiProc_getId(NULL); - if (MultiProc_INVALIDID != nProcId) - /*Fill the server table with the newly generated name */ - strncpy(rcmservertable[nProcId], cServerName, - MAX_SERVER_NAME_LENGTH); - else - eRPCError = RPC_OMX_ErrorUndefined; - - return eRPCError; -} - - - -/* ===========================================================================*/ -/** - * @name RPC_UTIL_GetTargetCore() - * @brief This function gets the target core id by parsing the component name. - * It is assumed that component names follow the convention - * <OMX>.<Company Name>.<Core Name>.<Domain>.<Component Details> with - * all characters in upper case for e.g. OMX.TI.DUCATI1.VIDEO.H264E - * @param cComponentName - Name of the component. - * @param nCoreId - Core ID, this is filled in and returned. - * @return RPC_OMX_ErrorNone = Successful - * @sa TBD - * - */ -/* ===========================================================================*/ -RPC_OMX_ERRORTYPE RPC_UTIL_GetTargetCore(OMX_STRING cComponentName, - OMX_U32 * nCoreId) -{ - RPC_OMX_ERRORTYPE eRPCError = RPC_OMX_ErrorNone; - OMX_S8 cCoreName[MAX_SERVER_NAME_LENGTH] = { 0 }; - OMX_S32 ret = 0; - OMX_U32 i = 0; - - ret = - sscanf(cComponentName, "%*[^'.'].%*[^'.'].%[^'.'].%*s", - cCoreName); - RPC_assert(ret == 1, RPC_OMX_ErrorBadParameter, - "Incorrect component name"); - - for (i = 0; i < CORE_MAX; i++) - { - if (strcmp((char *)cCoreName, Core_Array[i]) == 0) - break; - } - RPC_assert(i < CORE_MAX, RPC_OMX_ErrorBadParameter, - "Unknown core name"); - *nCoreId = i; - - EXIT: - return eRPCError; -} - - - -/* ===========================================================================*/ -/** - * @name EMPTY-STUB - * @brief the Api creates the RCM client on the target core(where the component sits). -This happens in the context of the Default RCM server on the target core. -The RCM server name to connect for this client will be the default RCM server on the calling core. -This can be provided as an option as the name that you pass in the string server is used as the RCM server name -input to the client create call. -@Default_RcmServer - The default rcm server on the target core -@Server - The name of the server on the calling core to connect to - * @param - * @return - * - */ -/* ===========================================================================*/ -/* -RPC_OMX_ERRORTYPE RPC_GetTargetClient(OMX_STRING Default_RcmServer, OMX_STRING server, rcmhHndl) -{ - - -} -*/ - -/* ===========================================================================*/ -/** - * @name EMPTY-STUB - * @brief - * @param - * @return - * - */ -/* ===========================================================================*/ -RPC_OMX_ERRORTYPE RPC_MapBuffer(OMX_U32 mappedBuffer) -{ - DOMX_ENTER(""); - DOMX_DEBUG("Empty implementation "); - //PlaceHolder for Mapping Buffers - Cuurently no implementation here - return RPC_OMX_ErrorNone; -} - -/* ===========================================================================*/ -/** - * @name EMPTY-STUB - * @brief - * @param - * @return - * - */ -/* ===========================================================================*/ -RPC_OMX_ERRORTYPE RPC_UnMapBuffer(OMX_U32 mappedBuffer) -{ - DOMX_ENTER(""); - DOMX_DEBUG("Empty implementation "); - //PlaceHolder for UnMapping Buffers - Cuurently no implementation here - return RPC_OMX_ErrorNone; -} - -/* ===========================================================================*/ -/** - * @name RPC_FlushBuffer - * @brief Used to flush buffers from cache to memory. Used when buffers are - * being transferred across processor boundaries. - * @param pBuffer : Pointer to the data that has to be flushed. - * size : Size of the data to be flushed. - * nTargetCoreId : Core to which buffer is being transferred. - * @return RPC_OMX_ErrorNone : Success. - * RPC_OMX_ErrorUndefined : Flush operation failed. - */ -/* ===========================================================================*/ -RPC_OMX_ERRORTYPE RPC_FlushBuffer(OMX_U8 * pBuffer, OMX_U32 size, - OMX_U32 nTargetCoreId) -{ - DOMX_ENTER(""); - RPC_OMX_ERRORTYPE eRPCError = RPC_OMX_ErrorNone; - OMX_S32 nStatus = 0; - - DOMX_DEBUG("About to flush %d bytes", size); - nStatus = ProcMgr_flushMemory((OMX_PTR) pBuffer, size, - (ProcMgr_ProcId) nTargetCoreId); - RPC_assert(nStatus >= 0, RPC_OMX_ErrorUndefined, - "Cache flush failed"); - - EXIT: - return eRPCError; -} - - - -/* ===========================================================================*/ -/** - * @name RPC_InvalidateBuffer - * @brief Used to flush buffers from cache to memory. Used when buffers are - * being transferred across processor boundaries. - * @param pBuffer : Pointer to the data that has to be flushed. - * size : Size of the data to be flushed. - * nTargetCoreId : Core to which buffer is being transferred. - * @return RPC_OMX_ErrorNone : Success. - * RPC_OMX_ErrorUndefined : Invalidate operation failed. - */ -/* ===========================================================================*/ -RPC_OMX_ERRORTYPE RPC_InvalidateBuffer(OMX_U8 * pBuffer, OMX_U32 size, - OMX_U32 nTargetCoreId) -{ - RPC_OMX_ERRORTYPE eRPCError = RPC_OMX_ErrorNone; - OMX_S32 nStatus = 0; - DOMX_ENTER(""); - - DOMX_DEBUG("About to invalidate %d bytes", size); - nStatus = ProcMgr_invalidateMemory((OMX_PTR) pBuffer, size, - (ProcMgr_ProcId) nTargetCoreId); - RPC_assert(nStatus >= 0, RPC_OMX_ErrorUndefined, - "Cache invalidate failed"); - - EXIT: - return eRPCError; -} - - - -/* ===========================================================================*/ -/** - * @name RPC_Util_AcquireJobId - * @brief Used to get a new job id from syslink - all messages sent with the - * same job id will be processed serially. Messages with different job id - * will be processed parallely. - * @param hRPCCtx : RPC context handle. - * pJobId : Pointer to job id - this'll be filled in and returned. - * @return RPC_OMX_ErrorNone : Success. - * Any other : Operation failed. - */ -/* ===========================================================================*/ -RPC_OMX_ERRORTYPE RPC_Util_AcquireJobId(RPC_OMX_CONTEXT * hRPCCtx, - OMX_U16 * pJobId) -{ - RPC_OMX_ERRORTYPE eRPCError = RPC_OMX_ErrorNone; - OMX_S32 nStatus = 0; - DOMX_ENTER(""); - - nStatus = - RcmClient_acquireJobId(hRPCCtx->ClientHndl[RCM_DEFAULT_CLIENT], - pJobId); - RPC_assert(nStatus >= 0, RPC_OMX_ErrorUndefined, - "Acquire job id failed"); - - EXIT: - DOMX_EXIT("eRPCError = %d", eRPCError); - return eRPCError; -} - - - -/* ===========================================================================*/ -/** - * @name RPC_Util_ReleaseJobId - * @brief Used to release job id to syslink. Once release, this job id cannot be - * reused. - * @param hRPCCtx : RPC context handle. - * nJobId : Job ID to be released. - * @return RPC_OMX_ErrorNone : Success. - * Any other : Operation failed. - */ -/* ===========================================================================*/ -RPC_OMX_ERRORTYPE RPC_Util_ReleaseJobId(RPC_OMX_CONTEXT * hRPCCtx, - OMX_U16 nJobId) -{ - RPC_OMX_ERRORTYPE eRPCError = RPC_OMX_ErrorNone; - OMX_S32 nStatus = 0; - DOMX_ENTER(""); - - nStatus = - RcmClient_releaseJobId(hRPCCtx->ClientHndl[RCM_DEFAULT_CLIENT], - nJobId); - RPC_assert(nStatus >= 0, RPC_OMX_ErrorUndefined, - "Release job id failed"); - - EXIT: - DOMX_EXIT("eRPCError = %d", eRPCError); - return eRPCError; -} - - - -/* ===========================================================================*/ -/** - * @name RPC_Util_GetPoolId - * @brief Used to get pool id. Messages sent with same pool id will get - * processed at the same priority on remote core. - * @param hRPCCtx : RPC context handle. - * pPoolId : Pointer to pool id - this'll be filled in and - * returned. - * @return RPC_OMX_ErrorNone : Success. - * Any other : Operation failed. - */ -/* ===========================================================================*/ -RPC_OMX_ERRORTYPE RPC_Util_GetPoolId(RPC_OMX_CONTEXT * hRPCCtx, - OMX_U16 * pPoolId) -{ - RPC_OMX_ERRORTYPE eRPCError = RPC_OMX_ErrorNone; - DOMX_ENTER(""); - - *pPoolId = 0x8001; - -//EXIT: - DOMX_EXIT("eRPCError = %d", eRPCError); - return eRPCError; -} |