sl@0: // Copyright (c) 2003-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: // source\server\mmfswcodecconvertdatapath.cpp
sl@0: // 
sl@0: //
sl@0: 
sl@0: #include "mmfSwCodecConvertDataPath.h"
sl@0: #include <mmf/server/mmfswcodecwrapper.h>
sl@0: #include <mmf/common/mmfpaniccodes.h>
sl@0: 
sl@0: 
sl@0: CMMFSwCodecConvertDataPath* CMMFSwCodecConvertDataPath::NewL()
sl@0: 	{
sl@0: 	CMMFSwCodecConvertDataPath* self = new(ELeave) CMMFSwCodecConvertDataPath;
sl@0: 	CleanupStack::PushL(self);
sl@0: 	self->ConstructL();
sl@0: 	CleanupStack::Pop();
sl@0: 	return self;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFSwCodecConvertDataPath::ConstructL()
sl@0: 	{
sl@0: 	iDataPathConverter = new (ELeave) CDataPathConverter(*this,CActive::EPriorityUserInput);
sl@0: 	}
sl@0: 
sl@0: 
sl@0: CMMFSwCodecConvertDataPath::~CMMFSwCodecConvertDataPath()
sl@0: 	{	
sl@0: 	delete iDataPathConverter;
sl@0: 	if (iCodec)
sl@0: 		{
sl@0: 		delete iSourceBuffer;
sl@0: 		if (!iCodec->IsNullCodec()) 
sl@0: 			delete iSinkBuffer;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: 
sl@0: TInt CMMFSwCodecConvertDataPath::SetObserver(MMMFHwDeviceObserver& aObserver)
sl@0: 	{
sl@0: 	TInt error;
sl@0: 	if (iHwDeviceObserver)
sl@0: 		{
sl@0: 		error =  KErrAlreadyExists;
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		iHwDeviceObserver = &aObserver;
sl@0: 		error  = KErrNone;
sl@0: 		}
sl@0: 	return error;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: TInt CMMFSwCodecConvertDataPath::AddCodec(CMMFSwCodec& aCodec)
sl@0: 	{
sl@0: 	if (iCodec)
sl@0: 		return KErrNotSupported; //doesn't support multiple codecs
sl@0: 
sl@0: 	TInt err = KErrNone;
sl@0: 	iCodec = &aCodec;
sl@0: 
sl@0: 	iSourceBufferSize = iCodec->SourceBufferSize();
sl@0: 	iSinkBufferSize = iCodec->SinkBufferSize();
sl@0: 
sl@0: 	if ((!iSourceBufferSize)||(!iSinkBufferSize))
sl@0: 		err = KErrArgument; //codec plugin has not specified buffer size
sl@0: 
sl@0: 	if (err == KErrNone)
sl@0: 		{
sl@0: 		TRAP(err,iSourceBuffer = CMMFDataBuffer::NewL(iSourceBufferSize));
sl@0: 		}
sl@0: 
sl@0: 	if (err == KErrNone)
sl@0: 		{
sl@0: 		// Allocate data buffer
sl@0: 		if (iCodec->IsNullCodec())
sl@0: 			{//don't need a separate sink buffer if null codec
sl@0: 			iSinkBuffer = NULL; //sink buffer is the sound device buffer	
sl@0: 			}
sl@0: 		else
sl@0: 			{//need a separate sink buffer for the codec
sl@0: 			TRAP(err,iSinkBuffer = CMMFDataBuffer::NewL(iSinkBufferSize));
sl@0: 			}	
sl@0: 		}
sl@0: 	return err;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: TInt CMMFSwCodecConvertDataPath::Start()
sl@0: 	{
sl@0: 	TInt startError = KErrNone;
sl@0: 	if (!iCodec) 
sl@0: 		{//check that a codec has been added
sl@0: 		startError = KErrNotReady;
sl@0: 		}
sl@0: 	if (!startError)
sl@0: 		{
sl@0: 		// Start the player objects
sl@0: 		iSourceBuffer->SetLastBuffer(EFalse);
sl@0: 		iDataPathConverter->Start();
sl@0: 		iState = EPlaying;
sl@0: 		iNoMoreSourceData = EFalse;
sl@0:    		}
sl@0: 	return startError;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: 
sl@0: void CMMFSwCodecConvertDataPath::Stop()
sl@0: 	{
sl@0: 	iDataPathConverter->Cancel();
sl@0: 	iState = EStopped;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFSwCodecConvertDataPath::Pause()
sl@0: 	{//pause is equivalent to stop for a data transfer
sl@0: 	iDataPathConverter->Cancel();
sl@0: 	iState = EStopped;
sl@0: 	}
sl@0: 
sl@0: /*** Main play loop ***/
sl@0: 
sl@0: void CMMFSwCodecConvertDataPath::FillSourceBufferL()
sl@0: 	{
sl@0: 	STATIC_CAST(CMMFDataBuffer*, iSourceBuffer)->SetRequestSizeL(iSourceBufferSize);
sl@0:             
sl@0:     // Ask immediately for data from the observer
sl@0: 	User::LeaveIfError(iHwDeviceObserver->FillThisHwBuffer(*iSourceBuffer));
sl@0: 	}
sl@0: 
sl@0:  /** 
sl@0:  *  BufferFilledL.  
sl@0:  *	(from MDataSink)
sl@0:  * 
sl@0:  *	called by the CMMFDataPath's MDataSource when it has filled the buffer
sl@0:  *  @internalComponent
sl@0:  *	@param aBuffer
sl@0:  *	
sl@0:  */
sl@0: void CMMFSwCodecConvertDataPath::BufferFilledL(CMMFDataBuffer& aBuffer)
sl@0: 	{	
sl@0: 	iSourceBuffer = &aBuffer;
sl@0: 	iSourceBuffer->SetStatus(EFull);
sl@0: 
sl@0: 	//need to check that the buffer size is not 0 - 
sl@0: 	//if so assume we've reached the end of the data
sl@0: 	if (!iSourceBuffer->BufferSize())
sl@0: 		{//no buffer  - could be end of source or could be that the source has no data
sl@0: 		//also need to check the sink buffer is available else there is still some
sl@0: 		//stuff to do before the sink buffer is freed
sl@0: 		if (iSinkBuffer->Status()==EAvailable)
sl@0: 			{
sl@0: 			iNoMoreSourceData = ETrue;
sl@0: 			}
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		if (iSourceBuffer->LastBuffer()) //also check last buffer flag
sl@0: 			iNoMoreSourceData = ETrue;
sl@0: 		iDataPathConverter->ChangeConvertState(CDataPathConverter::EFillingSinkBuffer);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: /* 
sl@0:  *  FillSinkBufferL
sl@0:  * 
sl@0:  *	Function to take the data from an already full source buffer and by using
sl@0:  *	a codec if necessary fills the sink buffer
sl@0:  *  @internalComponent
sl@0:  */
sl@0: void CMMFSwCodecConvertDataPath::FillSinkBufferL()
sl@0: 	{
sl@0: 	CMMFSwCodec::TCodecProcessResult codecProcessResult;
sl@0: 
sl@0: 	if (iCodec->IsNullCodec())
sl@0: 		{//no codec so data can be sent direct to sink
sl@0: 		iSinkBuffer = iSourceBuffer;
sl@0: 		iSinkBuffer->SetStatus(EFull);	//sink buffer is full
sl@0: 		}	
sl@0: 	else 
sl@0: 		{	
sl@0: 		//pass buffer to codec for processing
sl@0: 		codecProcessResult = iCodec->ProcessL(*iSourceBuffer, *iSinkBuffer);
sl@0: 		if (iSourceBuffer->LastBuffer()) //if source is last buffer so is sink
sl@0: 			iSinkBuffer->SetLastBuffer(ETrue);
sl@0: 		if ((!iSinkBuffer->BufferSize())&&(codecProcessResult.iDstBytesAdded))
sl@0: 			{//the codec has added data but not set the buffer length
sl@0: 			iSinkBuffer->Data().SetLength(codecProcessResult.iDstBytesAdded);
sl@0: 			}
sl@0: 	
sl@0: 		//only supports EProcessComplete
sl@0: 		switch (codecProcessResult.iCodecProcessStatus)
sl@0: 			{
sl@0: 		case CMMFSwCodec::TCodecProcessResult::EProcessComplete:
sl@0: 		//finished procesing source data - all data in sink buffer
sl@0: 			{
sl@0: 			iSourceBuffer->SetStatus(EAvailable); //source buffer is now avaialble
sl@0: 			iSinkBuffer->SetStatus(EFull);	//sink buffer is full	
sl@0: 			}
sl@0: 		break;
sl@0: 		case CMMFSwCodec::TCodecProcessResult::EDstNotFilled:
sl@0: 		//could be the last buffer in which case dst might not get filled
sl@0: 			{
sl@0: 			iSourceBuffer->SetStatus(EAvailable); //source buffer is now avaialble
sl@0: 			iSinkBuffer->SetStatus(EFull);	//sink buffer is full	
sl@0: 			}
sl@0: 		break;
sl@0: 		case CMMFSwCodec::TCodecProcessResult::EEndOfData:
sl@0: 			//no more data - send what we've got to the sink
sl@0: 			//note we can't always rely on this  - in many cases the codec will not know when
sl@0: 			//it has reached the end of data.
sl@0: 			{
sl@0: 			iSourceBuffer->SetStatus(EAvailable); //source buffer is now avaialble
sl@0: 			iSinkBuffer->SetStatus(EFull);//sink buffer may not really be 'full' but its as full as it going to get
sl@0: 			//doesn't matter if sink buffer is not full
sl@0: 			}
sl@0: 		break;
sl@0: 		default:
sl@0: 			Panic(EMMFSwCodecWrapperBadCodec); //should never get here - bad codec
sl@0: 			}
sl@0: 		}
sl@0: 	iDataPathConverter->ChangeConvertState(CDataPathConverter::EEmptyingSinkBuffer);
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFSwCodecConvertDataPath::EmptySinkBufferL()
sl@0: 	{
sl@0: 	User::LeaveIfError(iHwDeviceObserver->EmptyThisHwBuffer(*iSinkBuffer));
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFSwCodecConvertDataPath::BufferEmptiedL(const CMMFDataBuffer& aBuffer)
sl@0: 	{
sl@0: 	if (&aBuffer != iSinkBuffer)
sl@0: 		User::Leave(KErrArgument);
sl@0: 	if (!iNoMoreSourceData) 
sl@0: 		iDataPathConverter->ChangeConvertState(CDataPathConverter::EFillingSourceBuffer);
sl@0: 	else //no more source data so signal EOF
sl@0: 		SoundDeviceException(KErrEof);
sl@0: 	}
sl@0: 
sl@0: void CMMFSwCodecConvertDataPath::SoundDeviceException(TInt aError)
sl@0: 	{
sl@0: 	// Inform the observer of the exception condition
sl@0: 	iHwDeviceObserver->Error(aError);
sl@0: 
sl@0: 	Stop();
sl@0: 
sl@0: 	// Let the observer know we're fully stopped
sl@0:     iHwDeviceObserver->Stopped();	
sl@0: 	}
sl@0: 
sl@0: RMdaDevSound& CMMFSwCodecConvertDataPath::Device()
sl@0: 	{
sl@0: 	return iDummyDevSound;//convert doesn't have a RMdaDevSound
sl@0: 	}
sl@0: 
sl@0: /*** End of main play loop ***/
sl@0: 
sl@0: 
sl@0: 
sl@0: 
sl@0: /************************************************************************
sl@0:  *				CDataPathConverter	
sl@0:  * This class performs the main data transfer between the source and the sink
sl@0:  * This is done in a separate class as opposed to CMMFSwCodecConvertDataPath
sl@0:  * because the class needs to be an active object to avoid recursive call stacks
sl@0:  * in cases where the source and sink are not active objects - which is
sl@0:  * the case with descriptors.  Making CMMFSwCodecConvertDataPath derive
sl@0:  * from CActive is less desirable as it would involve multiple inheretence
sl@0:  ************************************************************************/
sl@0: 
sl@0: CMMFSwCodecConvertDataPath::CDataPathConverter::CDataPathConverter(CMMFSwCodecConvertDataPath& aParent, TInt aPriority)
sl@0: : CActive(aPriority), iParent(aParent)
sl@0: 	{
sl@0: 	CActiveScheduler::Add(this);
sl@0: 	iConvertState = EIdle;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: CMMFSwCodecConvertDataPath::CDataPathConverter::~CDataPathConverter()
sl@0: 	{
sl@0: 	Cancel();
sl@0: 	}
sl@0: 
sl@0: /** 
sl@0:  *  Start
sl@0:  * 
sl@0:  *	Starts active scheduler 'play' loop
sl@0:  *  @internalComponent
sl@0:  */
sl@0: void CMMFSwCodecConvertDataPath::CDataPathConverter::Start()
sl@0: 	{
sl@0: 	// If we're not already active, complete a request on ourselves to kick off the state machine
sl@0: 	if (iConvertState == EIdle)
sl@0: 		iConvertState = EFillingSourceBuffer;
sl@0: 	if (!IsActive())
sl@0: 		{
sl@0: 		TRequestStatus* stat = &iStatus;
sl@0: 		User::RequestComplete(stat, KErrNone);
sl@0: 		SetActive();
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFSwCodecConvertDataPath::CDataPathConverter::ChangeConvertState(TConvertState aNewConvertState)
sl@0: 	{
sl@0: 	TRequestStatus* stat = &iStatus;
sl@0: 	//change state
sl@0: 	iConvertState = aNewConvertState;
sl@0: 	if (!IsActive())
sl@0: 		{
sl@0: 		User::RequestComplete(stat, KErrNone);
sl@0: 		SetActive();
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: /*** Main Convert Loop ***/
sl@0: 
sl@0: void CMMFSwCodecConvertDataPath::CDataPathConverter::FillSourceBufferL()
sl@0: 	{
sl@0: 	iParent.FillSourceBufferL();
sl@0: 	}
sl@0: 
sl@0: void CMMFSwCodecConvertDataPath::CDataPathConverter::FillSinkBufferL()
sl@0: 	{
sl@0: 	iParent.FillSinkBufferL();
sl@0: 	}
sl@0: 
sl@0: void CMMFSwCodecConvertDataPath::CDataPathConverter::EmptySinkBufferL()
sl@0: 	{
sl@0: 	iParent.EmptySinkBufferL();
sl@0: 	}
sl@0: 
sl@0: /*** End of main convert loop ***/
sl@0: 
sl@0: 
sl@0: void CMMFSwCodecConvertDataPath::CDataPathConverter::RunL()
sl@0: 	{
sl@0: 	switch (iConvertState)
sl@0: 		{
sl@0: 		case EFillingSourceBuffer:
sl@0: 			FillSourceBufferL();
sl@0: 			break;
sl@0: 		case EFillingSinkBuffer:
sl@0: 			FillSinkBufferL();
sl@0: 			break;
sl@0: 		case EEmptyingSinkBuffer:
sl@0: 			EmptySinkBufferL();
sl@0: 			break;
sl@0: 		case EIdle:
sl@0: 			break;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CMMFSwCodecConvertDataPath::CDataPathConverter::DoCancel()
sl@0: 	{
sl@0: 	//don't need to do anything as we don't have any async requests to other objects
sl@0: 	}
sl@0: 
sl@0: TInt CMMFSwCodecConvertDataPath::CDataPathConverter::RunError(TInt aError)
sl@0: 	{
sl@0: 	iParent.SoundDeviceException(aError);
sl@0: 	return KErrNone;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: 
sl@0: