--- a/khronosfws/openmax_al/src/gst_adaptation/xaplayitfadaptation.c Tue Jul 06 14:50:35 2010 +0300
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,499 +0,0 @@
-/*
-* 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/gst.h>
-#include "unistd.h"
-#include <pthread.h>
-#include "xamediaplayeradaptctx.h"
-#include "xaplayitfadaptation.h"
-#include "xaadaptationgst.h"
-#include "xacameraadaptctx.h"
-
-extern XAboolean cameraRealized;
-extern XACameraAdaptationCtx_* cameraCtx;
-
-/*forward declaration of position updater callback*/
-gboolean XAPlayItfAdapt_PositionUpdate(gpointer ctx);
-
-/*
- * XAresult XAPlayItfAdaptGST_SetPlayState(XAAdaptationGstCtx *bCtx, XAuint32 state)
- * Sets play state to GStreamer.
- * @param XAAdaptationGstCtx *bCtx - Adaptation context, this will be casted to correct type regarding to contextID
- * XAuint32 state - Play state to be set
- * @return XAresult ret - Success value
- */
-XAresult XAPlayItfAdaptGST_SetPlayState(XAAdaptationBaseCtx *ctx, XAuint32 state)
-{
- XAresult ret = XA_RESULT_SUCCESS;
- XAboolean requestStateChange = XA_BOOLEAN_FALSE;
- GstStateChangeReturn gstRet = GST_STATE_CHANGE_SUCCESS;
- XAMediaPlayerAdaptationCtx* mCtx = NULL;
- XAuint32 locType = 0;
- GstState gstOrigState = GST_STATE_PLAYING;
- XADataLocator_Address *address = NULL;
- XAboolean playing = XA_BOOLEAN_FALSE;
- XAAdaptationGstCtx *bCtx = (XAAdaptationGstCtx *)ctx;
-
- DEBUG_API_A1("->XAPlayItfAdaptGST_SetPlayState %s",PLAYSTATENAME(state));
-
-
- if(!bCtx || bCtx->baseObj.ctxId != XAMediaPlayerAdaptation)
- {
- DEBUG_ERR("XA_RESULT_PARAMETER_INVALID");
- return XA_RESULT_PARAMETER_INVALID;
- }
-
- mCtx = (XAMediaPlayerAdaptationCtx*) bCtx;
- switch ( state )
- {
- case XA_PLAYSTATE_STOPPED:
- {
- if ( cameraCtx && cameraRealized && mCtx->isobjsrc && mCtx->source )
- {
- cameraCtx->playing = XA_BOOLEAN_FALSE;
- if(!cameraCtx->recording && !cameraCtx->snapshotting)
- {
- /* Future improvement: We could block MPObjSrc pad from tee-eleement here, when
- * tee-element supports sending stream to one pad when others are blocked */
-
- /* Neither view finder or recorder is running -> pause camera */
- if ( GST_STATE( GST_ELEMENT(mCtx->source)) == GST_STATE_PLAYING )
- {
- GstStateChangeReturn gret;
- DEBUG_INFO("Stop camera source");
- gret = gst_element_set_state( GST_ELEMENT(mCtx->source), GST_STATE_PAUSED );
- if(gret == GST_STATE_CHANGE_SUCCESS)
- gret = gst_element_get_state( GST_ELEMENT(mCtx->source), NULL,NULL, XA_ADAPT_ASYNC_TIMEOUT_SHORT_NSEC );
- }
- }
- }
-
- gstOrigState = GST_STATE(bCtx->bin);
- if ( gstOrigState != GST_STATE_READY )
- {
- DEBUG_INFO("Set gst-bin to GST_STATE_READY");
- bCtx->binWantedState = GST_STATE_READY;
- XAAdaptationGst_PrepareAsyncWait(bCtx);
- gstRet = gst_element_set_state( GST_ELEMENT(bCtx->bin), GST_STATE_READY);
- switch ( gstRet )
- {
- case GST_STATE_CHANGE_FAILURE:
- DEBUG_ERR_A1("FAILED to change state (target %s)",
- gst_element_state_get_name(bCtx->binWantedState));
- bCtx->binWantedState = GST_STATE(bCtx->bin);
- ret = XA_RESULT_INTERNAL_ERROR;
- break;
- case GST_STATE_CHANGE_ASYNC:
- DEBUG_INFO_A1("Change state will happen asyncronously (target %s)",
- gst_element_state_get_name(bCtx->binWantedState));
- XAAdaptationGst_StartAsyncWait(bCtx);
- ret = XA_RESULT_SUCCESS;
- break;
- case GST_STATE_CHANGE_SUCCESS:
- DEBUG_INFO_A1("Successfully changed state (target %s)",
- gst_element_state_get_name(bCtx->binWantedState));
- break;
- default:
- DEBUG_ERR_A1("Unhandled error (%d)",gstRet);
- break;
- }
- bCtx->waitingasyncop = XA_BOOLEAN_FALSE;
- DEBUG_INFO_A1("Setted gst-bin to state %s", gst_element_state_get_name(GST_STATE(bCtx->bin)));
-
- DEBUG_INFO_A1("Restoring gst-bin state to state %s", gst_element_state_get_name(gstOrigState));
- bCtx->binWantedState = gstOrigState;
- XAAdaptationGst_PrepareAsyncWait(bCtx);
- gstRet = gst_element_set_state( GST_ELEMENT(bCtx->bin), gstOrigState);
- switch ( gstRet )
- {
- case GST_STATE_CHANGE_FAILURE:
- DEBUG_ERR_A1("FAILED to change state (target %s)",
- gst_element_state_get_name(bCtx->binWantedState));
- bCtx->binWantedState = GST_STATE(bCtx->bin);
- ret = XA_RESULT_INTERNAL_ERROR;
- break;
- case GST_STATE_CHANGE_ASYNC:
- DEBUG_INFO_A1("Change state will happen asyncronously (target %s)",
- gst_element_state_get_name(bCtx->binWantedState));
- XAAdaptationGst_StartAsyncWait(bCtx);
- ret = XA_RESULT_SUCCESS;
- break;
- case GST_STATE_CHANGE_SUCCESS:
- DEBUG_INFO_A1("Successfully changed state (target %s)",
- gst_element_state_get_name(bCtx->binWantedState));
- break;
- default:
- DEBUG_ERR_A1("Unhandled error (%d)",gstRet);
- break;
- }
- bCtx->waitingasyncop = XA_BOOLEAN_FALSE;
- gstOrigState = GST_STATE(bCtx->bin);
- DEBUG_INFO_A1("Restored gst-bin to state %s", gst_element_state_get_name(gstOrigState));
- }
-
-
-/* if( bCtx->pipeSrcThrCtx.dataHandle )
- {
- XAresult retVal = XA_RESULT_SUCCESS;
- if ( bCtx->pipeSrcThrCtx.state != CPStateNull )
- {
- bCtx->pipeSrcThrCtx.state = CPStateStopped;
- }
-
- retVal = XAImpl_PostSemaphore( bCtx->pipeSrcThrCtx.stateSem );
- if ( retVal != XA_RESULT_SUCCESS )
- {
- DEBUG_ERR("Could not post content pipe semaphore!");
- }
-
- }*/
- /* stop head and drive head to beginning */
- bCtx->binWantedState = GST_STATE_PAUSED;
- if(mCtx->runpositiontimer > 0)
- {
- g_source_remove(mCtx->runpositiontimer);
- mCtx->runpositiontimer=0;
- }
-
- gst_element_send_event(bCtx->bin,gst_event_new_flush_start());
- gst_element_send_event(bCtx->bin,gst_event_new_flush_stop());
-
- locType = *((XAuint32*)( mCtx->xaSource->pLocator ));
- if( locType == XA_DATALOCATOR_ADDRESS )
- {
- address = (XADataLocator_Address*)(mCtx->xaSource->pLocator);
-
- /* init gst buffer from datalocator */
- if( mCtx->source )
- {
- GstBuffer* userBuf = NULL;
-
- /* init GST buffer from XADataLocator*/
- userBuf = gst_buffer_new();
- if( userBuf )
- {
- userBuf->size = address->length;
- userBuf->data = address->pAddress;
- /* push the whole buffer to appsrc so it is ready for preroll */
- DEBUG_INFO("Pushing buffer");
- gst_app_src_push_buffer( GST_APP_SRC(mCtx->source), userBuf );
- DEBUG_INFO_A1("Sent buffer at 0x%x to appsrc", userBuf );
- gst_app_src_end_of_stream( GST_APP_SRC(mCtx->source) );
- }
- else
- {
- DEBUG_ERR("Failure allocating buffer!");
- }
- }
- }
- break;
- }
- case XA_PLAYSTATE_PAUSED:
-
- if ( cameraCtx && cameraRealized && mCtx->isobjsrc && mCtx->source )
- {
- cameraCtx->playing = XA_BOOLEAN_FALSE;
-
- /* Future improvement: We could block MPObjSrc pad from tee-eleement here, when
- * tee-element supports sending stream to one pad when others are blocked */
-
- if(!cameraCtx->recording && !cameraCtx->snapshotting)
- {
- /* Neither view finder or recorder is running -> pause camera */
- if ( GST_STATE( GST_ELEMENT(mCtx->source)) == GST_STATE_PLAYING )
- {
- GstStateChangeReturn gret;
- DEBUG_INFO("Stop camera source");
- gret = gst_element_set_state( GST_ELEMENT(mCtx->source), GST_STATE_PAUSED );
- if(gret == GST_STATE_CHANGE_SUCCESS)
- gret = gst_element_get_state( GST_ELEMENT(mCtx->source), NULL,NULL, XA_ADAPT_ASYNC_TIMEOUT_SHORT_NSEC );
- }
- }
- }
-
-/* if ( bCtx->pipeSrcThrCtx.state != CPStateNull )
- {
- bCtx->pipeSrcThrCtx.state = CPStatePaused;
- }*/
- bCtx->binWantedState = GST_STATE_PAUSED;
- if(mCtx->runpositiontimer > 0)
- {
- g_source_remove(mCtx->runpositiontimer);
- mCtx->runpositiontimer=0;
- }
- break;
- case XA_PLAYSTATE_PLAYING:
- {
- if ( cameraCtx && mCtx->isobjsrc )
- {
- cameraCtx->playing = XA_BOOLEAN_TRUE;
- }
-
- if ( mCtx->videoppBScrbin )
- {
- gst_element_set_state( GST_ELEMENT(mCtx->videoppBScrbin), GST_STATE_PAUSED);
- }
- if (mCtx->isobjsrc && !mCtx->cameraSinkSynced && cameraCtx )
- { /* create videosink now */
- mCtx->cameraSinkSynced = XA_BOOLEAN_TRUE;
- if ( mCtx->videosink )
- {
- gst_element_unlink( mCtx->filter,mCtx->videosink );
- gst_element_set_state( GST_ELEMENT(mCtx->videosink), GST_STATE_NULL);
- gst_bin_remove( GST_BIN(mCtx->baseObj.bin), mCtx->videosink);
- mCtx->videosink = XAAdaptationGst_CreateGstSink( mCtx->xaVideoSink, "videosink", &(mCtx->isobjvsink) );
- gst_bin_add(GST_BIN(mCtx->baseObj.bin), mCtx->videosink);
- if (! gst_element_link(mCtx->filter, mCtx->videosink))
- {
- DEBUG_ERR("Could not link Filter to videosink!!");
- return XA_RESULT_INTERNAL_ERROR;
- }
- }
- }
-
-/* if ( bCtx->pipeSrcThrCtx.state != CPStateNull )
- {
- XAresult retVal = XA_RESULT_SUCCESS;
-
- if ( bCtx->pipeSrcThrCtx.state == CPStateInitialized )
- { Start thread if it's not running
- retVal = XAImpl_StartThread( &(bCtx->pipeSrcThr), NULL, &XAAdaptationGst_ContentPipeScrThrFunc, &(bCtx->pipeSrcThrCtx) );
- if ( retVal != XA_RESULT_SUCCESS )
- {
- DEBUG_ERR("Could not start content pipe thread!");
- }
- }
- if ( bCtx->pipeSrcThrCtx.state == CPStatePaused ||
- bCtx->pipeSrcThrCtx.state == CPStateInitialized ||
- bCtx->pipeSrcThrCtx.state == CPStateStarted )
- retVal = XAImpl_PostSemaphore( bCtx->pipeSrcThrCtx.stateSem );
- if ( retVal != XA_RESULT_SUCCESS )
- {
- DEBUG_ERR("Could not post content pipe semaphore!");
- }
- }*/
-
- bCtx->binWantedState = GST_STATE_PLAYING;
- if(mCtx->playrate!=1 && !mCtx->isobjsrc)
- { /*set seek element for ff, rew and slow*/
- XAAdaptationGst_PrepareAsyncWait(bCtx);
- DEBUG_INFO_A1("Apply new playrate %f.", mCtx->playrate);
- if(!gst_element_seek( bCtx->bin, mCtx->playrate, GST_FORMAT_TIME,
- (GstSeekFlags)(GST_SEEK_FLAG_FLUSH|GST_SEEK_FLAG_ACCURATE),
- GST_SEEK_TYPE_NONE, 0,
- GST_SEEK_TYPE_NONE, -1))
- {
- DEBUG_ERR("WARN: gst reports seek not handled");
- }
- /* flushed seeks always asynchronous */
- XAAdaptationGst_StartAsyncWait(bCtx);
- DEBUG_INFO("New playrate handled.");
- bCtx->waitingasyncop = XA_BOOLEAN_FALSE;
- }
-
- playing = XA_BOOLEAN_TRUE;
- break;
- }
- default:
- ret = XA_RESULT_PARAMETER_INVALID;
- break;
- }
- /* launch Gstreamer state change only if necessary */
- if( GST_STATE_TARGET(bCtx->bin) == bCtx->binWantedState )
- {
- DEBUG_INFO("Gst already in or transitioning to wanted state");
- requestStateChange = XA_BOOLEAN_FALSE;
- }
- else
- {
- if( (GST_STATE(bCtx->bin) == bCtx->binWantedState) &&
- (GST_STATE_PENDING(bCtx->bin) == GST_STATE_VOID_PENDING) )
- {
- DEBUG_ERR_A3("WARNING : gststate %d == wanted %d != gsttarget %d and no statechange pending",
- GST_STATE(bCtx->bin), bCtx->binWantedState, GST_STATE_TARGET(bCtx->bin));
- }
- requestStateChange = XA_BOOLEAN_TRUE;
- }
-
- if( requestStateChange )
- {
- XAAdaptationGst_PrepareAsyncWait(bCtx);
- DEBUG_INFO_A1("Sending change state request to state %d", bCtx->binWantedState);
- gstRet = gst_element_set_state( GST_ELEMENT(bCtx->bin), bCtx->binWantedState);
- switch ( gstRet )
- {
- case GST_STATE_CHANGE_FAILURE:
- DEBUG_ERR_A1("FAILED to change state (target %s)",
- gst_element_state_get_name(bCtx->binWantedState));
- bCtx->binWantedState = GST_STATE(bCtx->bin);
- ret = XA_RESULT_INTERNAL_ERROR;
- break;
- case GST_STATE_CHANGE_ASYNC:
- DEBUG_INFO_A1("Change state will happen asyncronously (target %s)",
- gst_element_state_get_name(bCtx->binWantedState));
- XAAdaptationGst_StartAsyncWait(bCtx);
- ret = XA_RESULT_SUCCESS;
- break;
- case GST_STATE_CHANGE_NO_PREROLL:
- DEBUG_INFO("GST_STATE_CHANGE_NO_PREROLL");
- /* deliberate fall-through */
- case GST_STATE_CHANGE_SUCCESS:
- DEBUG_INFO_A1("Successfully changed state (target %s)",
- gst_element_state_get_name(bCtx->binWantedState));
- ret = XA_RESULT_SUCCESS;
- break;
- default:
- DEBUG_ERR_A1("Unhandled error (%d)",gstRet);
- ret = XA_RESULT_UNKNOWN_ERROR;
- break;
- }
- bCtx->waitingasyncop = XA_BOOLEAN_FALSE;
- }
-
- if (playing && mCtx->isobjsrc && cameraCtx )
- {
- GstPad* moSrc=NULL ;
-
- playing = XA_BOOLEAN_FALSE;
- moSrc = gst_element_get_static_pad( mCtx->source, "MPObjSrc");
- if( moSrc && gst_pad_is_linked(moSrc) )
- {
- DEBUG_INFO_A2("unblock element:%s pad:%s",
- gst_element_get_name( mCtx->source),
- gst_pad_get_name(moSrc));
- gst_pad_set_blocked_async(moSrc, FALSE, XAAdaptationGst_PadBlockCb, NULL);
- }
-
- if ( GST_STATE( GST_ELEMENT(mCtx->source)) != GST_STATE_PLAYING )
- {
- GstStateChangeReturn gret;
- DEBUG_INFO("Start camera source");
- gret = gst_element_set_state( GST_ELEMENT(mCtx->source), GST_STATE_PLAYING );
- if(gret == GST_STATE_CHANGE_SUCCESS)
- gret = gst_element_get_state( GST_ELEMENT(mCtx->source), NULL,NULL, XA_ADAPT_ASYNC_TIMEOUT_SHORT_NSEC );
- }
- }
- DEBUG_API("<-XAPlayItfAdaptGST_SetPlayState");
- return ret;
-}
-
-/*
- * XAresult XAPlayItfAdaptGST_GetDuration(XAAdaptationGstCtx *bCtx, XAmillisecond *pMsec)
- * @param XAAdaptationGstCtx *bCtx - Adaptation context, this will be casted to correct type regarding to contextID
- * XAmillisecond *pMsec - Pointer where to store duration of stream.
- * @return XAresult ret - Success value
- */
-XAresult XAPlayItfAdaptGST_GetDuration(XAAdaptationGstCtx *bCtx, XAmillisecond *pMsec)
-{
- XAresult ret = XA_RESULT_SUCCESS;
- GstFormat format = GST_FORMAT_TIME;
- gint64 duration;
- DEBUG_API("->XAPlayItfAdaptGST_GetDuration");
-
- if(!bCtx || bCtx->baseObj.ctxId != XAMediaPlayerAdaptation || !pMsec)
- {
- DEBUG_ERR("XA_RESULT_PARAMETER_INVALID");
- /* invalid parameter */
- return XA_RESULT_PARAMETER_INVALID;
- }
-
- if( gst_element_query_duration( GST_ELEMENT(bCtx->bin), &format, &duration ) )
- {
- DEBUG_INFO_A1("Duration: %"GST_TIME_FORMAT, GST_TIME_ARGS(duration));
- ret = XA_RESULT_SUCCESS;
- *pMsec = GST_TIME_AS_MSECONDS(duration);/*Warning ok due to used API specification*/
- }
- else
- {
- DEBUG_ERR("WARNING: Gst: could not get duration");
- *pMsec = XA_TIME_UNKNOWN;
- ret = XA_RESULT_SUCCESS;
- }
-
- DEBUG_API("<-XAPlayItfAdaptGST_GetDuration");
- return ret;
-}
-
-/*
- * XAresult XAPlayItfAdaptGST_GetPosition(XAAdaptationGstCtx *bCtx, XAmillisecond *pMsec)
- * @param XAAdaptationGstCtx *bCtx - Adaptation context, this will be casted to correct type regarding to contextID value
- * XAmillisecond *pMsec - Pointer where to store current position in stream.
- * @return XAresult ret - Success value
- */
-XAresult XAPlayItfAdaptGST_GetPosition(XAAdaptationGstCtx *bCtx, XAmillisecond *pMsec)
-{
- XAresult ret = XA_RESULT_SUCCESS;
- gint64 position;
- GstFormat format = GST_FORMAT_TIME;
- DEBUG_API("->XAPlayItfAdapGSTt_GetPosition");
-
- if(!bCtx || bCtx->baseObj.ctxId != XAMediaPlayerAdaptation)
- {
- DEBUG_ERR("XA_RESULT_PARAMETER_INVALID");
- /* invalid parameter */
- return XA_RESULT_PARAMETER_INVALID;
- }
-
- if ( gst_element_query_position( GST_ELEMENT(bCtx->bin), &format, &position ) )
- {
- DEBUG_INFO_A1("Current position %"GST_TIME_FORMAT, GST_TIME_ARGS(position));
- ret = XA_RESULT_SUCCESS;
- *pMsec = GST_TIME_AS_MSECONDS(position);/*Warning ok due to used API specification*/
- }
- else
- {
- DEBUG_ERR("WARNING: Gst: could not get position");
- /* probably not fully prerolled - safe assumption for position = 0 */
- *pMsec = 0;
- ret = XA_RESULT_SUCCESS;
- }
-
- DEBUG_API("<-XAPlayItfAdaptGST_GetPosition");
- return ret;
-}
-
-/*
- * XAresult XAPlayItfAdapt_EnablePositionTracking
- * Enable/disable periodic position tracking callbacks
- */
-XAresult XAPlayItfAdapt_EnablePositionTracking(XAAdaptationGstCtx *bCtx, XAboolean enable)
-{
- XAMediaPlayerAdaptationCtx* mCtx;
-
- DEBUG_API_A1("->XAPlayItfAdapt_EnablePositionTracking (enable: %d)", (int)enable);
- if(!bCtx || bCtx->baseObj.ctxId != XAMediaPlayerAdaptation)
- {
- DEBUG_ERR("XA_RESULT_PARAMETER_INVALID");
- /* invalid parameter */
- return XA_RESULT_PARAMETER_INVALID;
- }
- mCtx = (XAMediaPlayerAdaptationCtx*) bCtx;
- if(enable && !(mCtx->trackpositionenabled))
- {
- mCtx->trackpositionenabled = XA_BOOLEAN_TRUE;
- XAMediaPlayerAdapt_UpdatePositionCbTimer(mCtx);
- }
- else if (!enable && (mCtx->trackpositionenabled))
- {
- mCtx->trackpositionenabled = XA_BOOLEAN_FALSE;
- XAMediaPlayerAdapt_UpdatePositionCbTimer(mCtx);
- }
-
- DEBUG_API("<-XAPlayItfAdapt_EnablePositionTracking");
- return XA_RESULT_SUCCESS;
-}
-