/*

* 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 <gst.h>

#include "XAAdaptation.h"

#include "XAMediaPlayerAdaptCtx.h"

#include "XADynamicSourceItfAdaptation.h"

/*

 * XAresult XADynamicSourceItfAdapt_SetSource(XAAdaptationBaseCtx *bCtx, XADataSource *pDataSource)

 * @param XAAdaptationBaseCtx *bCtx - Adaptation context, this will be casted to correct type regarding to contextID value

 * @param XADataSource *pDataSource - new data source

 * @return XAresult ret - Success value

 */

XAresult XADynamicSourceItfAdapt_SetSource(XAAdaptationBaseCtx *bCtx, XADataSource *pDataSource)

{

    XAresult ret = XA_RESULT_SUCCESS;

    DEBUG_API("->XADynamicSourceItfAdapt_SetSource");

    if( !bCtx || !pDataSource || !pDataSource->pLocator )

    {

        DEBUG_ERR("Invalid NULL parameter");

        ret = XA_RESULT_PARAMETER_INVALID;

    }

    else if(bCtx->ctxId == XAMediaPlayerAdaptation || bCtx->ctxId == XAMDAdaptation )

    {

        XAMediaPlayerAdaptationCtx* mCtx = (XAMediaPlayerAdaptationCtx*) bCtx;

        GstStateChangeReturn gret;

        GstState origState;

        GstElement* newSource = XAAdaptationBase_CreateGstSource( pDataSource, "datasrc", &(mCtx->isobjsrc), NULL, NULL);

        if(!newSource)

        {

            DEBUG_ERR("Could not create data source!!!");

            return XA_RESULT_CONTENT_NOT_FOUND;

        }

        DEBUG_INFO("Changing Playback Source");

        /* store current state */

        origState = GST_STATE(bCtx->bin);

        /* unroll pipeline */

        bCtx->binWantedState = GST_STATE_NULL;

        XAAdaptationBase_PrepareAsyncWait(bCtx);

        gret = gst_element_set_state( GST_ELEMENT(bCtx->bin), bCtx->binWantedState);

        if( gret == GST_STATE_CHANGE_ASYNC )

        {

            DEBUG_INFO("Wait for unroll");

            XAAdaptationBase_StartAsyncWait(bCtx);

            DEBUG_INFO("Unroll ready");

        }

        else if( gret == GST_STATE_CHANGE_FAILURE )

        {   /*not much we can do*/

             DEBUG_ERR("WARNING: Failed to unroll pipeline!!")

             return XA_RESULT_INTERNAL_ERROR;

        }

        bCtx->waitingasyncop = XA_BOOLEAN_FALSE;

        /* set new source */

        gst_element_unlink(mCtx->source,mCtx->codecbin);

        gst_bin_remove(GST_BIN(bCtx->bin), mCtx->source);

        mCtx->source = newSource;

        gst_bin_add(GST_BIN(bCtx->bin), mCtx->source);

        gst_element_link(mCtx->source, mCtx->codecbin);

        mCtx->xaSource = pDataSource;

        /* restore pipeline state */

        bCtx->binWantedState = origState;

        DEBUG_INFO_A1("Changing pipeline back to state %s",gst_element_state_get_name(origState));

        XAAdaptationBase_PrepareAsyncWait(bCtx);

        gret = gst_element_set_state( GST_ELEMENT(bCtx->bin), bCtx->binWantedState);

        if( gret == GST_STATE_CHANGE_ASYNC )

        {

            DEBUG_INFO("Wait for state change");

            XAAdaptationBase_StartAsyncWait(bCtx);

        }

        else if( gret == GST_STATE_CHANGE_FAILURE )

        {

            DEBUG_ERR("State change FAILED");

            return XA_RESULT_INTERNAL_ERROR;

        }

        bCtx->waitingasyncop = XA_BOOLEAN_FALSE;

        DEBUG_INFO_A1("Pipeline in state %s",gst_element_state_get_name(GST_STATE(bCtx->bin)));

        if( GST_STATE(bCtx->bin) > GST_STATE_READY )

        {   /* let (possible) extraction itf to know new tags  */

            XAAdaptEvent event = {XA_METADATAEVENTS, XA_ADAPT_MDE_TAGS_AVAILABLE, 0, NULL };

            XAAdaptationBase_SendAdaptEvents(bCtx, &event );

        }

    }

    DEBUG_API("<-XADynamicSourceItfAdapt_SetSource");

    return ret;

}