/**
 * src\common\XAStreamInformationItf.c
 * Part of OpenMAX AL Implementation
 * Copyright (c) 2009 Nokia Inc.
 *
 * This file contains implementation of XAStreamInformationItf
 **/

#include <assert.h>

#include "xastreaminformationitf.h"
#include "xastreaminformationitfadaptation.h"
#include "xastreaminformationitfadaptationmmf.h"

/* XAStreamInformationItfImpl* GetImpl
 * Description: Validate interface pointer and cast it to implementation pointer.
 */
static XAStreamInformationItfImpl* GetImpl(XAStreamInformationItf self)
{
    if(self)
    {
        XAStreamInformationItfImpl* impl = (XAStreamInformationItfImpl*)(*self);
        if(impl && impl == impl->self)
        {
            return impl;
        }
    }
    return NULL;
}

/**
 * Base interface XAPlayItf implementation
 */


XAresult XAStreamInformationItfImpl_QueryMediaContainerInformation(
                XAStreamInformationItf self,
                XAMediaContainerInformation * info)
{
    XAresult ret = XA_RESULT_SUCCESS;
    XAStreamInformationItfImpl* impl = GetImpl(self);
    DEBUG_API("->XAStreamInformationItfImpl_QueryMediaContainerInformation");
    if(!impl || !info)
    {
        /* invalid parameter */
        DEBUG_ERR("XA_RESULT_PARAMETER_INVALID");
        DEBUG_API("-<XAStreamInformationItfImpl_QueryMediaContainerInformation");
        return XA_RESULT_PARAMETER_INVALID;
    }


    if(impl->adapCtx->fwtype == FWMgrFWGST)
        {
        ret = XAAdaptationBase_ThreadEntry(impl->adapCtx);
        if( ret == XA_RESULT_PARAMETER_INVALID )
        {
            DEBUG_API("<-XAStreamInformationItfImpl_QueryMediaContainerInformation");
            return ret;
        }
        ret = XAStreamInformationItfAdapt_QueryMediaContainerInformation(
                    impl->adapCtx,
                    &(info->containerType),
                    &(info->mediaDuration),
                    &(info->numStreams));
        XAAdaptationBase_ThreadExit(impl->adapCtx);
        }
    else
        {
        ret = XAAdaptationBase_ThreadEntry(impl->adapCtx);
        if( ret == XA_RESULT_PARAMETER_INVALID )
        {
            DEBUG_API("<-XAStreamInformationItfImpl_QueryMediaContainerInformation");
            return ret;
        }
        ret = XAStreamInformationItfAdaptMMF_QueryMediaContainerInformation(
                    impl->adapCtx,
                    &(info->containerType),
                    &(info->mediaDuration),
                    &(info->numStreams));
        XAAdaptationBase_ThreadExit(impl->adapCtx);;
        }

    DEBUG_API("-<XAStreamInformationItfImpl_QueryMediaContainerInformation");
    return ret;
}

XAresult XAStreamInformationItfImpl_QueryStreamType(
                XAStreamInformationItf self,
                XAuint32 streamIndex, 
                XAuint32 *domain)
{
    XAresult ret = XA_RESULT_SUCCESS;
    XAStreamInformationItfImpl* impl = GetImpl(self);
    DEBUG_API("->XAStreamInformationItfImpl_QueryStreamType");
    if(!impl || !domain || (streamIndex == 0))
    {
        /* invalid parameter */
        DEBUG_ERR("XA_RESULT_PARAMETER_INVALID");
        DEBUG_API("-<XAStreamInformationItfImpl_QueryStreamType");
        return XA_RESULT_PARAMETER_INVALID;
    }
    if(impl->adapCtx->fwtype == FWMgrFWGST)
        {
        ret = XAAdaptationBase_ThreadEntry(impl->adapCtx);
        if( ret == XA_RESULT_PARAMETER_INVALID )
        {
            DEBUG_API("<-XAStreamInformationItfImpl_QueryStreamType");
            return ret;
        }
    
        ret = XAStreamInformationItfAdapt_QueryStreamType(
                    impl->adapCtx,
                    streamIndex,
                    domain);
    
        XAAdaptationBase_ThreadExit(impl->adapCtx);
        }
    else
        {
        ret = XAAdaptationBase_ThreadEntry(impl->adapCtx);
        if( ret == XA_RESULT_PARAMETER_INVALID )
        {
            DEBUG_API("<-XAStreamInformationItfImpl_QueryStreamType");
            return ret;
        }
    
        ret = XAStreamInformationItfAdaptMMF_QueryStreamType(
                    impl->adapCtx,
                    streamIndex,
                    domain);
    
        XAAdaptationBase_ThreadExit(impl->adapCtx);;
        }
    DEBUG_API("-<XAStreamInformationItfImpl_QueryStreamType");
    return ret;
}

XAresult XAStreamInformationItfImpl_QueryStreamInformation(
                XAStreamInformationItf self, 
                XAuint32 streamIndex,
                void * info)
{
    XAresult ret = XA_RESULT_SUCCESS;
    XAStreamInformationItfImpl* impl = GetImpl(self);
    DEBUG_API("->XAStreamInformationItfImpl_QueryStreamInformation");
    if(!impl || !info || (streamIndex == 0))
    {
        /* invalid parameter */
        DEBUG_ERR("XA_RESULT_PARAMETER_INVALID");
        DEBUG_API("-<XAStreamInformationItfImpl_QueryStreamInformation");
        return XA_RESULT_PARAMETER_INVALID;
    }

    if(impl->adapCtx->fwtype == FWMgrFWGST)
        {
        ret = XAAdaptationBase_ThreadEntry(impl->adapCtx);
        if( ret == XA_RESULT_PARAMETER_INVALID )
        {
            DEBUG_API("<-XAStreamInformationItfImpl_QueryStreamInformation");
            return ret;
        }
    
        ret = XAStreamInformationItfAdapt_QueryStreamInformation(
                    impl->adapCtx,
                    streamIndex,
                    info);
    
        XAAdaptationBase_ThreadExit(impl->adapCtx);
        }
    else
        {
        ret = XAAdaptationBase_ThreadEntry(impl->adapCtx);
        if( ret == XA_RESULT_PARAMETER_INVALID )
        {
            DEBUG_API("<-XAStreamInformationItfImpl_QueryStreamInformation");
            return ret;
        }
    
        ret = XAStreamInformationItfAdaptMMF_QueryStreamInformation(
                    impl->adapCtx,
                    streamIndex,
                    info);
    
        XAAdaptationBase_ThreadExit(impl->adapCtx);;
        }

    DEBUG_API("-<XAStreamInformationItfImpl_QueryStreamInformation");
    return ret;
}

XAresult XAStreamInformationItfImpl_QueryStreamName(
                XAStreamInformationItf self, 
                XAuint32 streamIndex, 
                XAuint16 * pNameSize,
                XAchar * pName)
{
    XAresult ret = XA_RESULT_SUCCESS;
    XAStreamInformationItfImpl* impl = GetImpl(self);
    DEBUG_API("->XAStreamInformationItfImpl_QueryStreamName");
    if(!impl || (streamIndex == 0) || !pNameSize)
    {
        /* invalid parameter */
        DEBUG_ERR("XA_RESULT_PARAMETER_INVALID");
        DEBUG_API("-<XAStreamInformationItfImpl_QueryStreamName");
        return XA_RESULT_PARAMETER_INVALID;
    }

    if(impl->adapCtx->fwtype == FWMgrFWGST)
        {
        ret = XAAdaptationBase_ThreadEntry(impl->adapCtx);
        if( ret == XA_RESULT_PARAMETER_INVALID )
        {
            DEBUG_API("<-XAStreamInformationItfImpl_QueryStreamName");
            return ret;
        }
    
        ret = XAStreamInformationItfAdapt_QueryStreamName(
                    impl->adapCtx,
                    streamIndex,
                    pNameSize,
                    pName);
    
        XAAdaptationBase_ThreadExit(impl->adapCtx);
        }
    else
        {
        ret = XAAdaptationBase_ThreadEntry(impl->adapCtx);
        if( ret == XA_RESULT_PARAMETER_INVALID )
        {
            DEBUG_API("<-XAStreamInformationItfImpl_QueryStreamName");
            return ret;
        }
    
        ret = XAStreamInformationItfAdaptMMF_QueryStreamName(
                    impl->adapCtx,
                    streamIndex,
                    pNameSize,
                    pName);
    
        XAAdaptationBase_ThreadExit(impl->adapCtx);;
        }
    DEBUG_API("-<XAStreamInformationItfImpl_QueryStreamName");
    return ret;
}

XAresult XAStreamInformationItfImpl_RegisterStreamChangeCallback(
                XAStreamInformationItf self,
                xaStreamEventChangeCallback callback,
                void * pContext)
{
    XAresult ret = XA_RESULT_SUCCESS;
    XAStreamInformationItfImpl* impl = GetImpl(self);
    DEBUG_API("->XAStreamInformationItfImpl_RegisterStreamChangeCallback");
    if(!impl)
    {
        /* invalid parameter */
        DEBUG_ERR("XA_RESULT_PARAMETER_INVALID");
        DEBUG_API("-<XAStreamInformationItfImpl_RegisterStreamChangeCallback");
        return XA_RESULT_PARAMETER_INVALID;
    }

    /* callback may be NULL (to remove callback) */
    impl->callback = callback;
    impl->cbcontext = pContext;
    impl->cbPtrToSelf = self;

    DEBUG_API("-<XAStreamInformationItfImpl_RegisterStreamChangeCallback");
    return ret;
}

XAresult XAStreamInformationItfImpl_QueryActiveStreams(
                XAStreamInformationItf self,
                XAuint32 *numStreams,
                XAboolean *activeStreams)
{
    XAresult ret = XA_RESULT_SUCCESS;
    XAStreamInformationItfImpl* impl = GetImpl(self);
    DEBUG_API("->XAStreamInformationItfImpl_QueryActiveStreams");
    if(!impl || !numStreams)
    {
        /* invalid parameter */
        DEBUG_ERR("XA_RESULT_PARAMETER_INVALID");
        DEBUG_API("-<XAStreamInformationItfImpl_QueryActiveStreams");
        return XA_RESULT_PARAMETER_INVALID;
    }

    if(impl->adapCtx->fwtype == FWMgrFWGST)
        {    
        ret = XAAdaptationBase_ThreadEntry(impl->adapCtx);
        if( ret == XA_RESULT_PARAMETER_INVALID )
        {
            DEBUG_API("<-XAStreamInformationItfImpl_QueryActiveStreams");
            return ret;
        }
    
        ret = XAStreamInformationItfAdapt_QueryActiveStreams(
                    impl->adapCtx,
                    numStreams,
                    activeStreams);
    
        XAAdaptationBase_ThreadExit(impl->adapCtx);
        }
    else
        {
        ret = XAAdaptationBase_ThreadEntry(impl->adapCtx);
        if( ret == XA_RESULT_PARAMETER_INVALID )
        {
            DEBUG_API("<-XAStreamInformationItfImpl_QueryActiveStreams");
            return ret;
        }
    
        ret = XAStreamInformationItfAdaptMMF_QueryActiveStreams(
                    impl->adapCtx,
                    numStreams,
                    activeStreams);
    
        XAAdaptationBase_ThreadExit(impl->adapCtx);;
        }

    DEBUG_API("-<XAStreamInformationItfImpl_QueryActiveStreams");
    return ret;
}

XAresult XAStreamInformationItfImpl_SetActiveStream(
                XAStreamInformationItf self, 
                XAuint32 streamNum,
                XAboolean active, 
                XAboolean commitNow)
{
    XAresult ret = XA_RESULT_SUCCESS;
    XAStreamInformationItfImpl* impl = GetImpl(self);
    DEBUG_API("->XAStreamInformationItfImpl_SetActiveStream");
    if(!impl)
    {
        /* invalid parameter */
        DEBUG_ERR("XA_RESULT_PARAMETER_INVALID");
        DEBUG_API("-<XAStreamInformationItfImpl_SetActiveStream");
        return XA_RESULT_PARAMETER_INVALID;
    }

    if(impl->adapCtx->fwtype == FWMgrFWGST)
        {      
        ret = XAAdaptationBase_ThreadEntry(impl->adapCtx);
        if( ret == XA_RESULT_PARAMETER_INVALID )
        {
            DEBUG_API("<-XAStreamInformationItfImpl_SetActiveStream");
            return ret;
        }
    
        ret = XAStreamInformationItfAdapt_SetActiveStream(
                    impl->adapCtx,
                    streamNum,
                    active, 
                    commitNow);
    
        XAAdaptationBase_ThreadExit(impl->adapCtx);
        }
    else
        {
        ret = XAAdaptationBase_ThreadEntry(impl->adapCtx);
        if( ret == XA_RESULT_PARAMETER_INVALID )
        {
            DEBUG_API("<-XAStreamInformationItfImpl_SetActiveStream");
            return ret;
        }
    
        ret = XAStreamInformationItfAdaptMMF_SetActiveStream(
                    impl->adapCtx,
                    streamNum,
                    active, 
                    commitNow);
    
        XAAdaptationBase_ThreadExit(impl->adapCtx);;
        }

    DEBUG_API("-<XAStreamInformationItfImpl_SetActiveStream");
    return ret;
}

/**
 * XAStreamInformationItfImpl -specific methods
 **/

/**
 * XAStreamInformationItfImpl* XAStreamInformationItfImpl_Create()
 * Description: Allocate and initialize PlayItfImpl
 **/
XAStreamInformationItfImpl* XAStreamInformationItfImpl_Create( XAAdaptationBaseCtx *adapCtx )
{
    XAStreamInformationItfImpl *self;

    DEBUG_API("->XAStreamInformationItfImpl_Create");
    self = (XAStreamInformationItfImpl*)calloc(1,sizeof(XAStreamInformationItfImpl));
    if(self)
    {
        /* init itf default implementation */
        self->itf.QueryMediaContainerInformation = XAStreamInformationItfImpl_QueryMediaContainerInformation;
        self->itf.QueryStreamType = XAStreamInformationItfImpl_QueryStreamType;
        self->itf.QueryStreamInformation = XAStreamInformationItfImpl_QueryStreamInformation;
        self->itf.QueryStreamName = XAStreamInformationItfImpl_QueryStreamName;
        self->itf.RegisterStreamChangeCallback = XAStreamInformationItfImpl_RegisterStreamChangeCallback;
        self->itf.QueryActiveStreams = XAStreamInformationItfImpl_QueryActiveStreams;
        self->itf.SetActiveStream = XAStreamInformationItfImpl_SetActiveStream;

        /* init variables */
        self->cbPtrToSelf = NULL;
        self->callback = NULL;
        self->cbcontext = NULL;
        self->adapCtx = adapCtx;

        self->self = self;
    }

    DEBUG_API("<-XAStreamInformationItfImpl_Create");
    return self;
}

/* void XAStreamInformationItfImpl_Free(XAStreamInformationItfImpl* self)
 * Description: Free all resources reserved at XAStreamInformationItfImpl_Create
 */
void XAStreamInformationItfImpl_Free(XAStreamInformationItfImpl* self)
{
    DEBUG_API("->XAStreamInformationItfImpl_Free");
    assert(self==self->self);
    free(self);
    DEBUG_API("<-XAStreamInformationItfImpl_Free");
}