/*
* Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of "Eclipse Public License v1.0"
* which accompanies this distribution, and is available
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
*
* Initial Contributors:
* Nokia Corporation - initial contribution.
*
* Contributors:
*
* Description:
*
*/
#include <stdlib.h>
#include <assert.h>
#include "openmaxalwrapper.h"
#include "xadynintmgmtitf.h"
#include "xadebug.h"
/* XADIMItfImpl* GetImpl(XADIMItf self)
* Description: Validate interface pointer and cast it to implementation pointer.
*/
static XADIMItfImpl* GetImpl(XADynamicInterfaceManagementItf self)
{
if( self )
{
XADIMItfImpl* impl = (XADIMItfImpl*)(*self);
if( impl && (impl == impl->self) )
{
return impl;
}
}
return NULL;
}
/**
* Base Interface XADynamicInterfaceManagementItf implementation
**/
/* XAresult XADIMItfImpl_AddInterface
* Optionally asynchronous method for exposing an interface on an object.
*/
XAresult XADIMItfImpl_AddInterface(XADynamicInterfaceManagementItf self,
const XAInterfaceID iid,
XAboolean async)
{
XADIMItfImpl* impl = GetImpl(self);
XAresult retval = XA_RESULT_SUCCESS;
DEBUG_API("->XADIMItfImpl_AddInterface");
if( !impl )
{
DEBUG_ERR("XA_RESULT_PARAMETER_INVALID");
DEBUG_API("<-XADIMItfImpl_AddInterface");
return XA_RESULT_PARAMETER_INVALID;
}
if( async )
{
/* invoke asynchronously */
/* check if another async operation is processed */
if(impl->asyncOngoing)
{
/* abort ongoing operation */
XAImpl_CancelThread(impl->asyncThr);
}
impl->asyncOngoing = XA_BOOLEAN_TRUE;
impl->asyncID = iid;
if(XAImpl_StartThread(impl->asyncThr, NULL,
&XADIMItfImpl_AsyncAddItf,(void*)(self)))
{
impl->asyncOngoing = XA_BOOLEAN_FALSE;
retval = XA_RESULT_RESOURCE_ERROR;
}
else
{
retval = XA_RESULT_SUCCESS;
}
}
else
{
/* invoke synchronously */
retval = XADIMItfImpl_DoAddItf(impl, iid);
}
DEBUG_API_A1("<-XADIMItfImpl_AddInterface %lu", retval);
return retval;
}
/* XAresult XADIMItfImpl_RemoveInterface
* Synchronous method for removing a dynamically exposed interface on an object.
*/
XAresult XADIMItfImpl_RemoveInterface(XADynamicInterfaceManagementItf self,
const XAInterfaceID iid)
{
XADIMItfImpl* impl = GetImpl(self);
XAresult retval = XA_RESULT_SUCCESS;
DEBUG_API("->XADIMItfImpl_RemoveInterface");
if( impl )
{
XAObjItfMapEntry *mapEntry = NULL;
if(impl->parent)
{
mapEntry = XAObjectItfImpl_GetItfEntry(impl->parent, iid);
}
if( mapEntry && mapEntry->isDynamic )
{
if( (mapEntry->pItf) )
{
if( impl->DoRemoveItfImpl )
{
retval = impl->DoRemoveItfImpl(impl->parent, mapEntry);
}
else
{
DEBUG_ERR("XADIMItfImpl_RemoveInterface: Object has specified dynamic itfs but not implemented DoRemoveItfImpl!!!");
retval = XA_RESULT_INTERNAL_ERROR;
}
}
else
{
DEBUG_ERR("XADIMItfImpl_RemoveInterface interface not exposed");
retval = XA_RESULT_PRECONDITIONS_VIOLATED;
}
}
else /*( mapEntry && mapEntry->isDynamic )*/
{ /* interface is not supported for dynamic management */
DEBUG_ERR("XADIMItfImpl_RemoveInterface interface not supported");
retval = XA_RESULT_FEATURE_UNSUPPORTED;
}
}
else
{
retval = XA_RESULT_PARAMETER_INVALID;
DEBUG_ERR("XADIMItfImpl_RemoveInterface: INVALID args");
}
DEBUG_API_A1("<-XADIMItfImpl_RemoveInterface %lu", retval);
return retval;
}
/* XAresult XADIMItfImpl_ResumeInterface
* Optionally asynchronous method for resuming a dynamically exposed interface on the object.
*/
XAresult XADIMItfImpl_ResumeInterface(XADynamicInterfaceManagementItf self,
const XAInterfaceID iid,
XAboolean async)
{
XADIMItfImpl* impl = GetImpl(self);
XAresult retval = XA_RESULT_SUCCESS;
DEBUG_API("->XADIMItfImpl_ResumeInterface");
if( !impl )
{
DEBUG_ERR("XA_RESULT_PARAMETER_INVALID");
DEBUG_API("<-XADIMItfImpl_ResumeInterface");
return XA_RESULT_PARAMETER_INVALID;
}
if( async )
{
/* invoke asynchronously */
/* check if another async operation is processed */
if(impl->asyncOngoing)
{
/* abort ongoing operation */
XAImpl_CancelThread(impl->asyncThr);
}
impl->asyncOngoing = XA_BOOLEAN_TRUE;
impl->asyncID = iid;
if(XAImpl_StartThread(impl->asyncThr, NULL,
&XADIMItfImpl_AsyncResumeItf,(void*)(self)))
{
impl->asyncOngoing = XA_BOOLEAN_FALSE;
retval = XA_RESULT_RESOURCE_ERROR;
}
else
{
retval = XA_RESULT_SUCCESS;
}
}
else
{
/* invoke synchronously */
retval = XADIMItfImpl_DoResumeItf(impl, iid);
}
DEBUG_API_A1("<-XADIMItfImpl_ResumeInterface %lu", retval);
return retval;
}
/* XAresult XADIMItfImpl_RegisterCallback
* Registers a callback on the object
*/
XAresult XADIMItfImpl_RegisterCallback(XADynamicInterfaceManagementItf self,
xaDynamicInterfaceManagementCallback callback,
void * pContext)
{
XADIMItfImpl* impl = GetImpl(self);
DEBUG_API("->XADIMItfImpl_RegisterCallback");
if( !impl )
{
DEBUG_ERR("XA_RESULT_PARAMETER_INVALID");
DEBUG_API("<-XADIMItfImpl_RegisterCallback");
return XA_RESULT_PARAMETER_INVALID;
}
impl->dimCb = callback;
impl->dimCbContext = pContext;
impl->dimCbPtrToSelf = self;
DEBUG_API("<-XADIMItfImpl_RegisterCallback");
return XA_RESULT_SUCCESS;
}
/**
* XADIMItfImpl -specific methods
**/
/* XADIMItfImpl* XADIMItfImpl_Create()
* Description: Allocate and initialize DIMItfImpl
*/
XADIMItfImpl* XADIMItfImpl_Create()
{
XADIMItfImpl *self = (XADIMItfImpl*)calloc(1,sizeof(XADIMItfImpl));
DEBUG_API("->XADIMItfImpl_Create");
if( self )
{
/* init itf default implementation */
self->itf.AddInterface = XADIMItfImpl_AddInterface;
self->itf.RemoveInterface = XADIMItfImpl_RemoveInterface;
self->itf.ResumeInterface = XADIMItfImpl_ResumeInterface;
self->itf.RegisterCallback = XADIMItfImpl_RegisterCallback;
/* init variables */
self->asyncOngoing = XA_BOOLEAN_FALSE;
self->dimCbPtrToSelf = NULL;
self->self = self;
if( XAImpl_CreateThreadHandle(&(self->asyncThr)) != XA_RESULT_SUCCESS )
{
free(self);
self = NULL;
}
}
DEBUG_API("<-XADIMItfImpl_Create");
return self;
}
/* void XADIMItfImpl_Free(XADIMItfImpl* self)
* Description: Free all resources reserved at XADIMItfImpl_Create
*/
void XADIMItfImpl_Free(XADIMItfImpl* self)
{
DEBUG_API("->XADIMItfImpl_Free");
assert(self==self->self);
XAImpl_DeleteThreadHandle(self->asyncThr);
free(self);
DEBUG_API("<-XADIMItfImpl_Free");
}
/* void XADIMItfImpl_Init
* Description: Initialize DIM interface. Mandatory to call if dynamic
* interfaces are supported by object.
*/
void XADIMItfImpl_Init( XADIMItfImpl* self,
XAObjectItf parent,
xaDoAddItfImpl doAdd,
xaDoResumeItfImpl doResume,
xaDoRemoveItfImpl doRemove)
{
DEBUG_API("->XADIMItfImpl_Init");
assert(self==self->self && parent && doAdd && doResume && doRemove);
self->parent = parent;
self->DoAddItfImpl = doAdd;
self->DoResumeItfImpl = doResume;
self->DoRemoveItfImpl = doRemove;
DEBUG_API("<-XADIMItfImpl_Init");
}
/* void XADIMItfImpl_SendCbEvent
* Description: Object can use this method to send resource events
*/
void XADIMItfImpl_SendCbEvent( XADIMItfImpl* self,
XAuint32 event,
XAresult result,
const XAInterfaceID iid )
{
DEBUG_API("->XADIMItfImpl_SendCbEvent");
if( self->dimCb )
{
self->dimCb((XADynamicInterfaceManagementItf)(self), self->dimCbContext,
event, result, iid);
}
DEBUG_API("<-XADIMItfImpl_SendCbEvent");
}
/* void* XADIMItfImpl_AsyncAddItf
* Description: Launch AddItf from async thread.
*/
void* XADIMItfImpl_AsyncAddItf(void* args)
{
XAresult retval = XA_RESULT_SUCCESS;
XADIMItfImpl* impl = GetImpl(args);
DEBUG_API("->XADIMItfImpl_AsyncAddItf");
if( impl )
{
retval = XADIMItfImpl_DoAddItf(impl, impl->asyncID);
if( impl->dimCb )
{
impl->dimCb((XADynamicInterfaceManagementItf)(args), impl->dimCbContext,
XA_DYNAMIC_ITF_EVENT_ASYNC_TERMINATION, retval, impl->asyncID);
}
impl->asyncOngoing = XA_BOOLEAN_FALSE;
XAImpl_ExitThread(impl->asyncThr);
}
else
{
DEBUG_ERR("XADIMItfImpl_AsyncAddItf: INVALID args");
}
DEBUG_API("<-XADIMItfImpl_AsyncAddItf");
return NULL;
}
/* XAresult XADIMItfImpl_DoAddItf
* Description: Handle Itf dynamic addition and call object-specific parts.
* Launched either from async thread or directly.
*/
XAresult XADIMItfImpl_DoAddItf(XADIMItfImpl* impl,
const XAInterfaceID iid)
{
XAresult retval = XA_RESULT_SUCCESS;
DEBUG_API("->XADIMItfImpl_DoAddItf");
if( impl )
{
XAObjItfMapEntry *mapEntry = NULL;
if(impl->parent)
{
mapEntry = XAObjectItfImpl_GetItfEntry(impl->parent, iid);
}
if( mapEntry && mapEntry->isDynamic )
{
if( !(mapEntry->pItf) )
{
if( impl->DoAddItfImpl )
{
retval = impl->DoAddItfImpl(impl->parent, mapEntry);
}
else
{
DEBUG_ERR("XADIMItfImpl_DoAddItf: Object has specified dynamic itfs but not implemented DoAddItfImpl!!!");
retval = XA_RESULT_INTERNAL_ERROR;
}
}
else
{
DEBUG_ERR("XADIMItfImpl_DoAddItf interface already exposed");
retval = XA_RESULT_PRECONDITIONS_VIOLATED;
}
}
else /*( mapEntry && mapEntry->isDynamic )*/
{ /* interface is not supported for dynamic management */
DEBUG_ERR("XADIMItfImpl_DoAddItf interface not supported");
retval = XA_RESULT_FEATURE_UNSUPPORTED;
}
}
else
{
retval = XA_RESULT_INTERNAL_ERROR;
DEBUG_ERR("XADIMItfImpl_DoAddItf: INVALID args");
}
DEBUG_API("<-XADIMItfImpl_DoAddItf");
return retval;
}
/* void* XADIMItfImpl_AsyncResumeItf
* Description: Launch ResumeItf from async thread.
*/
void* XADIMItfImpl_AsyncResumeItf(void* args)
{
XAresult retval = XA_RESULT_SUCCESS;
XADIMItfImpl* impl = GetImpl(args);
DEBUG_API("->XADIMItfImpl_AsyncResumeItf");
if( impl )
{
retval = XADIMItfImpl_DoResumeItf(impl, impl->asyncID);
if( impl->dimCb )
{
impl->dimCb((XADynamicInterfaceManagementItf)(args), impl->dimCbContext,
XA_DYNAMIC_ITF_EVENT_ASYNC_TERMINATION, retval, impl->asyncID);
}
impl->asyncOngoing = XA_BOOLEAN_FALSE;
XAImpl_ExitThread(impl->asyncThr);
}
else
{
DEBUG_ERR("XADIMItfImpl_AsyncResumeItf: INVALID args");
}
DEBUG_API("<-XADIMItfImpl_AsyncResumeItf");
return NULL;
}
/* void XADIMItfImpl_DoResumeItf
* Description: Handle Itf dynamic resuming and call object-specific parts.
* Launched either from async thread or directly.
*/
XAresult XADIMItfImpl_DoResumeItf(XADIMItfImpl* impl,
const XAInterfaceID iid)
{
XAresult retval = XA_RESULT_SUCCESS;
DEBUG_API("->XADIMItfImpl_DoResumeItf");
if( impl )
{
XAObjItfMapEntry *mapEntry = XAObjectItfImpl_GetItfEntry(impl->parent, iid);
if( mapEntry && mapEntry->isDynamic )
{
if( (!mapEntry->pItf) )
{
if( impl->DoResumeItfImpl )
{
retval = impl->DoResumeItfImpl(impl->parent, mapEntry);
}
else
{
DEBUG_ERR("XADIMItfImpl_DoResumeItf: Object has specified dynamic itfs but not implemented DoResumeItfImpl!!!");
retval = XA_RESULT_INTERNAL_ERROR;
}
}
else
{
DEBUG_ERR("XADIMItfImpl_DoResumeItf interface already exposed");
retval = XA_RESULT_PRECONDITIONS_VIOLATED;
}
}
else /*( mapEntry && mapEntry->isDynamic )*/
{ /* interface is not supported for dynamic management */
DEBUG_ERR("XADIMItfImpl_DoResumeItf interface not supported");
retval = XA_RESULT_FEATURE_UNSUPPORTED;
}
}
else
{
retval = XA_RESULT_INTERNAL_ERROR;
DEBUG_ERR("XADIMItfImpl_DoResumeItf: INVALID args");
}
DEBUG_API("<-XADIMItfImpl_DoResumeItf");
return retval;
}