/*
* 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 <string.h>
#include <gst/gst.h>
#include "xaengineadaptctx.h"
#include "xaadaptationgst.h"

/*
 * gboolean XAEngineAdapt_GstBusCb( GstBus *bus, GstMessage *message, gpointer data )
 * MediaPlayer Gst-bus message handler (Callback)
 */
gboolean XAEngineAdapt_GstBusCb( GstBus *bus, GstMessage *message, gpointer data )
{
    XAEngineAdaptationCtx* mCtx = (XAEngineAdaptationCtx*)data;
    DEBUG_API("->XAEngineAdapt_GstBusCb");

    /* only listen to pipeline messages */
    if(GST_MESSAGE_SRC(message)==(GstObject*)(mCtx->baseObj.bin) )
    {
        DEBUG_API_A2("->XAEngineAdapt_GstBusCb:\"%s\" from object \"%s\"",
                        GST_MESSAGE_TYPE_NAME(message), GST_OBJECT_NAME(GST_MESSAGE_SRC(message)));
    }

    DEBUG_API("<-XAEngineAdapt_GstBusCb");
    return TRUE;
}

/*
 * XAAdaptationGstCtx* XAEngineAdapt_Create()
 * Allocates memory for Engine Adaptation Context and makes 1st phase initialization
 * @returns XAEngineAdaptationCtx* - Pointer to created context
 */
XAAdaptationGstCtx* XAEngineAdapt_Create()
{
    XAEngineAdaptationCtx *pSelf = NULL;
    DEBUG_API("->XAEngineAdapt_Create");

    pSelf = (XAEngineAdaptationCtx*)calloc(1, sizeof(XAEngineAdaptationCtx));
    if ( pSelf)
    {
        if( XAAdaptationBase_Init(&(pSelf->baseObj.baseObj),XAEngineAdaptation)
                    != XA_RESULT_SUCCESS )
            {
                DEBUG_ERR("Failed to init base context!!!");
                free(pSelf);
                pSelf = NULL;
            }
            else
            {
                /* Init internal variables */
            }
    }

    DEBUG_API("<-XAEngineAdapt_Create");
    return (XAAdaptationGstCtx*)pSelf;
}

/*
 * XAresult XAEngineAdapt_PostInit()
 * 2nd phase initialization of engine Adaptation Context
 */
XAresult XAEngineAdapt_PostInit(XAAdaptationGstCtx* bCtx)
{
    XAresult ret = XA_RESULT_SUCCESS;
    GstStateChangeReturn gret = GST_STATE_CHANGE_SUCCESS;
    XAEngineAdaptationCtx* ctx = NULL;

    DEBUG_API("->XAEngineAdapt_PostInit");
    if( !bCtx || bCtx->baseObj.ctxId != XAEngineAdaptation )
    {
        DEBUG_ERR("XA_RESULT_PARAMETER_INVALID");
        DEBUG_API("<-XAEngineAdapt_PostInit");
        return XA_RESULT_PARAMETER_INVALID;
    }
    ctx = (XAEngineAdaptationCtx*)bCtx;

    if ( !ctx )
    {
        DEBUG_ERR("XA_RESULT_INTERNAL_ERROR");
        DEBUG_API("<-XAEngineAdapt_PostInit");
        return XA_RESULT_INTERNAL_ERROR;
    }

    XAAdaptationBase_PostInit( &(ctx->baseObj.baseObj) );

    ctx->baseObj.bin = gst_pipeline_new("engine");
   // gst_bin_add(GST_BIN(ctx->baseObj.bin), gst_element_factory_make( "alsamixer", "alsamixer"));

    if ( !ctx->baseObj.bin )
    {
        DEBUG_ERR("Failed to create alsamixer");
        DEBUG_ERR("XA_RESULT_INTERNAL_ERROR");
        DEBUG_API("<-XAEngineAdapt_PostInit");
        return XA_RESULT_INTERNAL_ERROR;
    }

    /* Create Gst bus listener. */
    ret = XAAdaptationGst_InitGstListener(&(ctx->baseObj));
    if( ret!=XA_RESULT_SUCCESS )
    {
        DEBUG_ERR_A1("Bus listener creation failed!! - (%d)", ret);
        DEBUG_API("<-XAEngineAdapt_PostInit");
        return ret;
    }

    /* Add Engine specific handler */
    if(ctx->baseObj.bus)
    {
        ctx->baseObj.busCb = XAEngineAdapt_GstBusCb;
    }
    else
    {
        DEBUG_ERR("Failed to create message bus");
        DEBUG_ERR("XA_RESULT_INTERNAL_ERROR");
        DEBUG_API("<-XAEngineAdapt_PostInit");
        return XA_RESULT_INTERNAL_ERROR;
    }

    /* roll up bin */
    ctx->baseObj.binWantedState = GST_STATE_PAUSED;
    XAAdaptationGst_PrepareAsyncWait(&(ctx->baseObj));
    gret = gst_element_set_state( GST_ELEMENT(ctx->baseObj.bin), ctx->baseObj.binWantedState);
    if( gret == GST_STATE_CHANGE_ASYNC )
    {
        DEBUG_INFO("Wait for preroll");
        XAAdaptationGst_StartAsyncWait(&(ctx->baseObj));
        DEBUG_INFO("Preroll ready");
    }
    ctx->baseObj.waitingasyncop = XA_BOOLEAN_FALSE;

    //ret = XAStaticCapsAdapt_InitCaps();

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

/*
 * void XAEngineAdapt_Destroy(XAEngineAdaptationCtx* ctx)
 * Destroys Engine Adaptation Context
 * @param ctx - Engine Adaptation context to be destroyed
 */
void XAEngineAdapt_Destroy(XAAdaptationGstCtx* bCtx)
{
	XAEngineAdaptationCtx* ctx = NULL;

	DEBUG_API("->XAEngineAdapt_Destroy");
	if( !bCtx || bCtx->baseObj.ctxId != XAEngineAdaptation )
	{
		DEBUG_ERR("XA_RESULT_PARAMETER_INVALID");
		DEBUG_API("<-XAEngineAdapt_Destroy");
		return;
	}
	ctx = (XAEngineAdaptationCtx*)bCtx;

    XAAdaptationBase_Free(&(ctx->baseObj.baseObj));

/*    gst_deinit(); */

    free(ctx);
    ctx = NULL;

    DEBUG_API("<-XAEngineAdapt_Destroy");
}