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\mmfswcodecplaydatapath.cpp
sl@0: // 
sl@0: //
sl@0: 
sl@0: #include "mmfSwCodecPlayDataPath.h"
sl@0: #include <mmf/server/mmfswcodecwrapper.h>
sl@0: #include <mmf/server/mmfswcodecwrappercustominterfacesuids.hrh>
sl@0: #include <mmf/common/mmfpaniccodes.h>
sl@0: #include "mmfSwCodecUtility.h"
sl@0: 
sl@0: const TInt KBytesPerSample = 2;
sl@0: const TInt KMaxBytesInSec = 192000; //considering maximum samplerate 96KHz
sl@0: CMMFSwCodecPlayDataPath* CMMFSwCodecPlayDataPath::NewL()
sl@0: 	{
sl@0: 	CMMFSwCodecPlayDataPath* self = new(ELeave) CMMFSwCodecPlayDataPath;
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 CMMFSwCodecPlayDataPath::ConstructL()
sl@0: 	{
sl@0: 	iAudioPlayer = new (ELeave) CDataPathPlayer(*this,CActive::EPriorityUserInput);
sl@0: 	iSoundDeviceErrorReceiver = new (ELeave) CSoundDevPlayErrorReceiver(*this, CActive::EPriorityUserInput);
sl@0: 	iUtility = CMMFSwCodecUtility::NewL();
sl@0: 	iVbrFlag = EFalse;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: CMMFSwCodecPlayDataPath::~CMMFSwCodecPlayDataPath()
sl@0: 	{
sl@0: 	delete iAudioPlayer;
sl@0: 	delete iSoundDeviceErrorReceiver;
sl@0: 	delete iUtility;
sl@0: 
sl@0: 	iSoundDevice.Close();
sl@0: 
sl@0: 	if (iCodec)
sl@0: 		{
sl@0: 		delete iSourceBuffer;
sl@0: 		if (!iCodec->IsNullCodec()) 
sl@0: 			{
sl@0: 			delete iSoundDeviceBuffer;
sl@0: 			}
sl@0: 		}
sl@0: 
sl@0: #ifdef __USE_MMF_TRANSFERBUFFERS__
sl@0: 	delete iTransferWindow;
sl@0: 
sl@0: 	if(iTransferBuffer)
sl@0: 		{
sl@0: 		iTransferBuffer->Close();
sl@0: 		delete iTransferBuffer;
sl@0: 		}
sl@0: #endif
sl@0: 
sl@0: #ifdef __USE_MMF_PTRBUFFERS__
sl@0: 	delete iPtrBufferMemoryBlock;
sl@0: #endif
sl@0: 	}
sl@0: 
sl@0: 
sl@0: TInt CMMFSwCodecPlayDataPath::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 CMMFSwCodecPlayDataPath::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: 	
sl@0: 	iCodec = &aCodec;
sl@0: 
sl@0: 	// Allocate data buffer
sl@0: 	iSourceBufferSize = iCodec->SourceBufferSize();
sl@0: 	iSoundDevBufferSize = iCodec->SinkBufferSize();
sl@0: 
sl@0: 	if ((!iSourceBufferSize)||(!iSoundDevBufferSize))
sl@0: 		err = KErrArgument; //codec plugin has not specified buffer size
sl@0: 
sl@0: 	if (err == KErrNone)
sl@0: 		{
sl@0: #ifdef __USE_MMF_TRANSFERBUFFERS__
sl@0: 		TRAP(err,iSourceBuffer = CreateTransferBufferL(iSourceBufferSize, static_cast<CMMFTransferBuffer*>(iSourceBuffer)));
sl@0: #endif
sl@0: #ifdef __USE_MMF_PTRBUFFERS__
sl@0: 		TRAP(err,iSourceBuffer = CreatePtrBufferL(iSourceBufferSize));
sl@0: #else
sl@0: 		TRAP(err,iSourceBuffer = CMMFDataBuffer::NewL(iSourceBufferSize));
sl@0: #endif
sl@0: 		}
sl@0: 	
sl@0: 	if (err == KErrNone)
sl@0: 		{
sl@0: 		if (iCodec->IsNullCodec())
sl@0: 			{//use source buffer for sound device buffer	
sl@0: 			iSoundDeviceBuffer = NULL;
sl@0: 			}
sl@0: 		else
sl@0: 			{//codec needs separate source and sound device buffers
sl@0: 			TRAP(err,iSoundDeviceBuffer = CMMFDataBuffer::NewL(iSoundDevBufferSize));
sl@0: 			}
sl@0: 		}
sl@0: 	return err;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: TInt CMMFSwCodecPlayDataPath::Start()
sl@0: 	{
sl@0: 	TInt startError = KErrNone;
sl@0: 
sl@0: 	if (!iCodec) 
sl@0: 		{//check that a codec has been added
sl@0: 		startError = KErrNotReady;
sl@0: 		}
sl@0: 	if ((!iSoundDevice.Handle())&&(!startError))
sl@0:     	{//check that the sound drivers can be opened
sl@0:    		startError = iSoundDevice.Open();
sl@0: 		}
sl@0: 
sl@0: 	if (iState == EPaused)
sl@0: 		{//we are paused so need to resume play
sl@0: 		if (!startError)
sl@0: 			{
sl@0: #ifdef _SCW_DEBUG
sl@0: 			RDebug::Print(_L("CMMFSwCodecPlayDataPath::Start-Resume"));
sl@0: #endif
sl@0: 			iAudioPlayer->ResumePlaying();
sl@0: 			iState = EPlaying;
sl@0: 			}
sl@0: 		}
sl@0: 	else if (!startError)
sl@0: 		{
sl@0: #ifdef _SCW_DEBUG
sl@0: 		RDebug::Print(_L("CMMFSwCodecPlayDataPath::Start-Normal"));
sl@0: #endif
sl@0: 		// get sample rate and channels from RMdaDevSound
sl@0: 		RMdaDevSound::TCurrentSoundFormatBuf format;
sl@0: 		iSoundDevice.GetPlayFormat(format);
sl@0: 		iSampleRate = format().iRate;
sl@0: 		iChannels = format().iChannels;
sl@0: 		
sl@0: 		iNoMoreSourceData = EFalse;
sl@0: 		iNoMoreSoundDeviceData = EFalse;
sl@0: 		iSourceBuffer->SetLastBuffer(EFalse);
sl@0: 		iBytesPlayed = 0;
sl@0: 		iState = EPlaying;
sl@0: 		iSoundDeviceErrorReceiver->Start();
sl@0: 		TRAP(startError,FillSourceBufferL()); //get initial buffer of audio data
sl@0: 		if (startError == KErrNone)
sl@0: 			{
sl@0: 			// Start the player objects
sl@0: 			iAudioPlayer->Start();
sl@0: 			}
sl@0: 		else
sl@0: 			{//failed to start up correctly go back to stopped state
sl@0: 			iState = EStopped;
sl@0: 			iSoundDeviceErrorReceiver->Stop();
sl@0: 			}
sl@0:    		}
sl@0: 	return startError;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: // *** Main Play Loop ***
sl@0: 
sl@0: void CMMFSwCodecPlayDataPath::FillSourceBufferL()
sl@0: 	{//asks observer to fill the source buffer          
sl@0:     // Ask immediately for data from the observer
sl@0: #ifdef __CYCLE_MMF_DATABUFFERS__
sl@0: 	// Create a new buffer to replicate INC021405 Play-EOF-Play on HwAccelerated solution Panics
sl@0: 	// If the creation fails, we carry on regardless as the original buffer will not have been 
sl@0: 	// destroyed. Must do this as alloc fail tests will not run.
sl@0: 	if(iSourceBuffer)
sl@0: 		{
sl@0: 		iSourceBuffer = CycleAudioBuffer(iSourceBuffer);
sl@0: 		}
sl@0: #endif // __CYCLE_MMF_DATABUFFERS__	
sl@0: 	User::LeaveIfError(iHwDeviceObserver->FillThisHwBuffer(*iSourceBuffer));
sl@0: 	
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFSwCodecPlayDataPath::BufferFilledL(CMMFDataBuffer& aBuffer)
sl@0: 	{//call back from observer to indicate buffer has been filled
sl@0: 	if (iState == EStopped)
sl@0: 		User::Leave(KErrNotReady);//ok if paused?
sl@0: 
sl@0: 	iSourceBuffer = &aBuffer;
sl@0: 	iSourceBuffer->SetStatus(EFull);
sl@0: #ifdef _SCW_DEBUG
sl@0: 	RDebug::Print(_L("CMMFSwCodecPlayDataPath::BufferFilledL"));
sl@0: #endif
sl@0: 
sl@0: 	//need to check that the buffer size is not 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: 		iNoMoreSourceData = ETrue;
sl@0: #ifdef _SCW_DEBUG
sl@0: 		RDebug::Print(_L("CMMFSwCodecPlayDataPath::BufferFilledL-NoMoreSourceData"));
sl@0: #endif
sl@0: 		}
sl@0: 	//even if the buffer size is 0 we still 
sl@0: 	//need to perform the following to get the sound device callback
sl@0: 	FillSoundDeviceBufferL(); //get buffer in pcm16 format for sound device	
sl@0: 
sl@0:     /* iVbrFlag is added to datapath to avail the alternative dataflow wherein datapath makes sure that 
sl@0:     destinationbuffer is filled to its maximum length before sending it to the sound driver. 
sl@0:     Sending the buffer directly to the device causes underflow incase of Vorbis codecs.*/
sl@0:     if (iVbrFlag)
sl@0:     	{
sl@0:     	/*There are two cases we need to deal here
sl@0:       	1. When the output of the codec is 0 for header data.
sl@0:            in that case, repeat till actual decoding of ogg packets and pages.
sl@0:         2. When destination buffer is not filled even to its half length, get next source buffer
sl@0:            and decode it. This is to avoid underflows when ever we receive little pcm for a 
sl@0:            a given source buffer.
sl@0:            */
sl@0: 	    if (iSoundDeviceBuffer->Data().Length() < iSoundDeviceBuffer->Data().MaxLength()/2 && !(iSoundDeviceBuffer->LastBuffer()))
sl@0: 			{
sl@0: 	    	iSourceBuffer->SetStatus(EAvailable); //source buffer is now available
sl@0: 	    	iSoundDeviceBuffer->SetPosition(iSoundDeviceBuffer->Data().Length());//this indicates the available space in the buffer to the codec
sl@0: 	    	FillSourceBufferL();	
sl@0: 	    	return;
sl@0: 	    	}
sl@0: 		else //data is sufficient to avoid underflows
sl@0: 			{
sl@0: 			iSoundDeviceBuffer->SetPosition(0);
sl@0: 			if(iSoundDeviceBuffer->Data().Length()==0 && iSoundDeviceBuffer->LastBuffer())
sl@0: 				{
sl@0: 				iNoMoreSoundDeviceData = ETrue;
sl@0: 				}
sl@0: 			}	
sl@0:     	}
sl@0: 
sl@0:     // attenuate the amplitude of the samples if volume ramping has been changed
sl@0: 	// and is non-zero
sl@0: 	if (iCustomInterface)
sl@0: 		{
sl@0: 		TTimeIntervalMicroSeconds volumeRamp = iCustomInterface->VolumeRamp();
sl@0: 		if (volumeRamp != iVolumeRamp)
sl@0: 			{
sl@0: 			iVolumeRamp = volumeRamp;
sl@0: 			if (iVolumeRamp.Int64() != 0)
sl@0: 				{
sl@0: 				iUtility->ConfigAudioRamper(
sl@0: 					iVolumeRamp.Int64(), 
sl@0: 					iSampleRate, 
sl@0: 					iChannels);
sl@0: 				iRampAudioSample = ETrue;
sl@0: 				}
sl@0: 			else
sl@0: 				{
sl@0: 				iRampAudioSample = EFalse;
sl@0: 				}
sl@0: 
sl@0: 			}
sl@0: 			if (iRampAudioSample)
sl@0: 				iRampAudioSample = iUtility->RampAudio(iSoundDeviceBuffer);
sl@0: 		}
sl@0: 
sl@0: 	iAudioPlayer->PlayData(*iSoundDeviceBuffer); //play data to sound drivers
sl@0: 
sl@0: 	if (iSourceBuffer->LastBuffer())//check last buffer flag
sl@0: 		{
sl@0: 		iNoMoreSourceData = ETrue;
sl@0: #ifdef _SCW_DEBUG
sl@0: 		RDebug::Print(_L("CMMFSwCodecPlayDataPath::BufferFilledL-LBNoMoreSourceData"));
sl@0: #endif
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFSwCodecPlayDataPath::FillSoundDeviceBufferL()
sl@0: 	{//use CMMFSwCodec to fill the sound device buffer
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: 		iSoundDeviceBuffer = iSourceBuffer;
sl@0: 		iSoundDeviceBuffer->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, *iSoundDeviceBuffer);
sl@0: 		
sl@0: 		if (iSourceBuffer->LastBuffer()) //if source is last buffer so is sound dev
sl@0: 			iSoundDeviceBuffer->SetLastBuffer(ETrue);
sl@0: 		if ((!iSoundDeviceBuffer->BufferSize())&&(codecProcessResult.iDstBytesAdded))
sl@0: 			{//the codec has added data but not set the buffer length
sl@0: 			iSoundDeviceBuffer->Data().SetLength(codecProcessResult.iDstBytesAdded);
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: 			iSoundDeviceBuffer->SetStatus(EFull);	//sink buffer is full	
sl@0: 			}
sl@0: 		break;
sl@0: #ifdef SYMBIAN_VARIABLE_BITRATE_CODEC
sl@0: 		case CMMFSwCodec::TCodecProcessResult::EProcessIncomplete:
sl@0: 		//finished procesing source data - all data in sink buffer
sl@0: 			{
sl@0: 			iSoundDeviceBuffer->SetStatus(EFull);	//sink buffer is full	
sl@0: 			}
sl@0: 		break;
sl@0: #endif
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: 			iSoundDeviceBuffer->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: 			iSoundDeviceBuffer->SetStatus(EFull);//sink buffer may not really be 'full' but its as full as it going to get
sl@0: 			iNoMoreSourceData = ETrue;
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: 	}
sl@0: 
sl@0: 
sl@0: void CMMFSwCodecPlayDataPath::BufferEmptiedL(const CMMFDataBuffer& aBuffer)
sl@0: 	{//call back from CDataPathPlayer when the sound device buffer has been emptied
sl@0: 	if (&aBuffer != iSoundDeviceBuffer) 
sl@0: 		Panic(EMMFSwCodecWrapperBadBuffer);
sl@0: 	if(iVbrFlag && (iSourceBuffer->Status() == EUnAvailable || iNoMoreSourceData))
sl@0: 		{//No more source data. Play rest of the decoded data.Inform codec not to consider the source buffer
sl@0: 		if(iSourceBuffer->Status()!=EUnAvailable)
sl@0: 			{
sl@0: 			iSourceBuffer->SetStatus(EUnAvailable);
sl@0: 			}
sl@0: 		FillSoundDeviceBufferL();
sl@0: 		if(iSoundDeviceBuffer->BufferSize() > 0)
sl@0: 			{
sl@0: 			// attenuate the amplitude of the samples if volume ramping has been changed
sl@0: 			// and is non-zero
sl@0: 			if (iCustomInterface)
sl@0: 				{
sl@0: 				TTimeIntervalMicroSeconds volumeRamp = iCustomInterface->VolumeRamp();
sl@0: 				if (volumeRamp != iVolumeRamp)
sl@0: 					{
sl@0: 					iVolumeRamp = volumeRamp;
sl@0: 					if (iVolumeRamp.Int64() != 0)
sl@0: 						{
sl@0: 						iUtility->ConfigAudioRamper(iVolumeRamp.Int64(), iSampleRate, iChannels);
sl@0: 						iRampAudioSample = ETrue;
sl@0: 						}
sl@0: 					else
sl@0: 						{
sl@0: 						iRampAudioSample = EFalse;
sl@0: 						}
sl@0: 
sl@0: 					}
sl@0: 				if (iRampAudioSample)
sl@0: 					{
sl@0: 					iRampAudioSample = iUtility->RampAudio(iSoundDeviceBuffer);
sl@0: 					}
sl@0: 					
sl@0: 				}
sl@0: 			iAudioPlayer->PlayData(*iSoundDeviceBuffer); //play data to sound drivers
sl@0: 			return;
sl@0: 			}
sl@0: 		else
sl@0: 			{
sl@0: 			if(iNoMoreSourceData)
sl@0: 				{
sl@0: 				iNoMoreSoundDeviceData = ETrue;
sl@0: 				}
sl@0: 			iSourceBuffer->SetStatus(EAvailable);
sl@0: 			}
sl@0: 		}
sl@0: 	if (!iNoMoreSourceData) 
sl@0: 		FillSourceBufferL();
sl@0: 	}
sl@0: 
sl@0: //*** End of Main Play Loop ***
sl@0: 
sl@0: 
sl@0: void CMMFSwCodecPlayDataPath::Stop()
sl@0: 	{
sl@0: 	iAudioPlayer->Cancel();
sl@0: 	iSoundDeviceErrorReceiver->Cancel();
sl@0:     iSoundDevice.Close();
sl@0: 
sl@0: #ifdef __CYCLE_MMF_DATABUFFERS__
sl@0: 	// Create a new buffer to replicate INC021405 Play-EOF-Play on HwAccelerated solution Panics
sl@0: 	// If the creation fails, we carry on regardless as the original buffer will not have been 
sl@0: 	// destroyed. Must do this as alloc fail tests will not run.
sl@0: 	if(iSourceBuffer)
sl@0: 		{
sl@0: 		iSourceBuffer = CycleAudioBuffer(iSourceBuffer);
sl@0: 		}
sl@0: #endif // __CYCLE_MMF_DATABUFFERS__	
sl@0: 
sl@0: 	iState = EStopped;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFSwCodecPlayDataPath::Pause()
sl@0: 	{
sl@0: 	//since a pause can happen anyway in the datatransfer -need to set to a known 
sl@0: 	//state so that when play is resumed the behaviour is predictable
sl@0: 	if (iSoundDevice.Handle())
sl@0: 		{
sl@0: 		iSoundDevice.PausePlayBuffer(); //needs new LDD
sl@0: 		iState = EPaused;
sl@0: #ifdef _SCW_DEBUG
sl@0: 		RDebug::Print(_L("Pause"));
sl@0: #endif
sl@0: 		}
sl@0: 	else
sl@0: 		{//an error must have occured 
sl@0: 		iState = EStopped;
sl@0: 		}
sl@0: 	}
sl@0: 	
sl@0: 	
sl@0: TInt CMMFSwCodecPlayDataPath::EmptyBuffers()
sl@0: 	{
sl@0: 	TInt error = KErrNone;
sl@0: 	if (iSoundDevice.Handle() == 0)
sl@0: 		{
sl@0: 		error = KErrNotReady;
sl@0: 		}
sl@0: 	else
sl@0: 		{ 
sl@0: 		iAudioPlayer->Cancel();
sl@0: 		iSoundDevice.CancelPlayData();
sl@0: 		iSoundDeviceErrorReceiver->Stop();
sl@0: 		iState = EStopped;
sl@0: 		}
sl@0: 	return error;
sl@0: 	}	
sl@0: 
sl@0: 
sl@0: RMdaDevSound& CMMFSwCodecPlayDataPath::Device()
sl@0: 	{
sl@0: 	return iSoundDevice;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFSwCodecPlayDataPath::SoundDeviceException(TInt aError)
sl@0: 	{
sl@0: 	if(iIgnoreUnderflow)
sl@0: 		{
sl@0: 		if(!iVbrFlag && aError==KErrUnderflow && !iNoMoreSourceData)
sl@0: 			{
sl@0: 			//ignore underflow
sl@0: 			return;
sl@0: 			}
sl@0: 		//for VBR codec data,no more source does not mean that no more sounddevice data
sl@0: 		//so ignore underflows till the last buffer is played from the codec
sl@0: 		else if(iVbrFlag && aError==KErrUnderflow && !iNoMoreSoundDeviceData)
sl@0: 			{
sl@0: 			//ignore underflow
sl@0: 			return;
sl@0: 			}	
sl@0: 		}
sl@0: 	
sl@0: 	//this sends a request to the hw device observer usually Devsound
sl@0: 	//to update the bytes played
sl@0: 	//it is done here so that the sound driver can be closed prior to
sl@0: 	//updating the plicy and sending the error back
sl@0: 	TUid uidUpdateBytesPlayed;
sl@0: 	uidUpdateBytesPlayed.iUid = KMmfHwDeviceObserverUpdateBytesPlayed;
sl@0: 	TPtrC8 dummy(0,0);
sl@0: 	iHwDeviceObserver->MsgFromHwDevice(uidUpdateBytesPlayed,dummy);
sl@0: 
sl@0: 	//this closes RMdaDevSound.
sl@0: 	Stop(); 
sl@0: 
sl@0: 	//inform devsound so it can update policy
sl@0: 	iHwDeviceObserver->Stopped(); 
sl@0: 
sl@0: 	// Inform the observer of the exception condition
sl@0: 	// We inform the hw device observer after the policy has been
sl@0: 	// updated incase the observer relied on the error to assume
sl@0: 	// the policy has been updated
sl@0: 	iHwDeviceObserver->Error(aError);
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CMMFSwCodecPlayDataPath::SetPlayCustomInterface(MPlayCustomInterface& aCustomInterface)
sl@0: 	{
sl@0: 	iCustomInterface = &aCustomInterface;
sl@0: 	}
sl@0: 	
sl@0: /**
sl@0: Retrieves a custom interface to the device.
sl@0: The reference CMMFSwCodecWrapper supports two  custom interfaces,
sl@0: MEmptyBuffersCustomInterface and MSetVbrFlagCustomInterface
sl@0: 
sl@0: @param	aInterface
sl@0: 		Interface UID, defined with the custom interface.
sl@0: 		aInterface = KMmfUidEmptyBuffersCustomInterface for MEmptyBuffersCustomInterface,
sl@0: 					 KSetVbrFlagCustomInterfaceTypeUid for MSetVbrFlagCustomInterface
sl@0: 		
sl@0: @return A pointer to the interface implementation, or NULL if the device can not
sl@0: 		implement the interface requested. The return value must be cast to the
sl@0: 		correct type by the user.
sl@0: */
sl@0: TAny* CMMFSwCodecPlayDataPath::CustomInterface(TUid aInterface)
sl@0: 	{
sl@0: 	TAny* ret = NULL;
sl@0: 	if (aInterface.iUid == KMmfUidEmptyBuffersCustomInterface)
sl@0: 		{
sl@0: 		MEmptyBuffersCustomInterface* result = static_cast<MEmptyBuffersCustomInterface*> (this);
sl@0: 		ret = static_cast<TAny*>(result);
sl@0: 		}
sl@0: 	else if(aInterface.iUid == KSetVbrFlagCustomInterfaceTypeUid)
sl@0: 		{
sl@0: 		SetVbrFlag();
sl@0: 		}
sl@0: 	if (aInterface == KTimePlayedCustomInterfaceTypeUid)
sl@0: 		{
sl@0: 		MTimePlayedCustomInterface* result = static_cast<MTimePlayedCustomInterface*> (this);
sl@0: 		ret = static_cast<TAny*>(result);
sl@0: 		}
sl@0: 	if (aInterface == KIgnoreUnderflowCustomInterfaceTypeUid)
sl@0: 		{
sl@0: 		MIgnoreUnderflowEventsCustomInterface* result = static_cast<MIgnoreUnderflowEventsCustomInterface*> (this);
sl@0: 		ret = static_cast<TAny*>(result);
sl@0: 		}
sl@0: 	return ret;
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: Used to set iVbrFlag on the datapath.
sl@0: 
sl@0: This method is used to set the iVbrFlag in datapath. This flag is added to datapath to avail the 
sl@0: alternative dataflow wherein datapath makes sure that destinationbuffer is filled to its maximum length
sl@0: before sending it to the sound driver. Sending the buffer directly to the device causes underflow incase of VBR codecs.
sl@0: */		
sl@0: void CMMFSwCodecPlayDataPath::SetVbrFlag()
sl@0: 	{
sl@0: 	iVbrFlag = ETrue;
sl@0: 	}
sl@0: 
sl@0: TInt CMMFSwCodecPlayDataPath::GetTimePlayed(TTimeIntervalMicroSeconds& aTime)
sl@0: 	{
sl@0: 	if(iSoundDevice.Handle())
sl@0: 		{
sl@0: 		TInt bytes = iSoundDevice.BytesPlayed();
sl@0: 		//Work around for overflow of bytes played from driver.
sl@0: 		//This code will be removed when Base provides the TimePlayed() API which returns the play time
sl@0: 		//Assuming GetTimePlayed() gets called in an interval not more than 3 secs, reset driver's bytes played when it is near KMaxInt
sl@0: 		if(bytes > (KMaxTInt - 3*KMaxBytesInSec))
sl@0: 			{
sl@0: 			iBytesPlayed = iBytesPlayed+bytes;
sl@0: 			iSoundDevice.ResetBytesPlayed();
sl@0: 			bytes = 0;
sl@0: 			}
sl@0: 		TInt64 samplesPlayed = (iBytesPlayed+bytes)/(KBytesPerSample*iChannels);
sl@0: 		aTime = (samplesPlayed*1000000)/iSampleRate;
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		aTime = 0;
sl@0: 		}
sl@0: 		
sl@0: 	return KErrNone;
sl@0: 	}
sl@0: 
sl@0: void CMMFSwCodecPlayDataPath::IgnoreUnderflowEvents()
sl@0: 	{
sl@0: 	iIgnoreUnderflow = ETrue;
sl@0: 	}
sl@0: /************************************************************************
sl@0:  *				CDataPathPlayer											*
sl@0:  ************************************************************************/
sl@0: 
sl@0: CDataPathPlayer::CDataPathPlayer(CMMFSwCodecPlayDataPath& aParent, TInt aPriority)
sl@0: : CActive(aPriority), iParent(aParent)
sl@0: 	{
sl@0: 	CActiveScheduler::Add(this);
sl@0: 	}
sl@0: 
sl@0: 
sl@0: CDataPathPlayer::~CDataPathPlayer()
sl@0: 	{
sl@0: 	Cancel();
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CDataPathPlayer::Start()
sl@0: 	{
sl@0: 	// No implementation
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CDataPathPlayer::ResumePlaying()
sl@0: 	{
sl@0: 	if (iParent.Device().Handle())
sl@0: 		{
sl@0: 		//should be ok to call this even if we are active
sl@0: 		iParent.Device().ResumePlaying(); 
sl@0: 		iResumePlaying = ETrue;
sl@0: 		}
sl@0: #ifdef _SCW_DEBUG
sl@0: 	RDebug::Print(_L("Playing Resumed"));
sl@0: #endif
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CDataPathPlayer::PlayData(const CMMFDataBuffer& aData)
sl@0: 	{
sl@0: 	iDataFromSource = &aData;
sl@0: 	if (!IsActive())
sl@0: 		{
sl@0: #ifdef _SCW_DEBUG
sl@0: 		RDebug::Print(_L("CDataPathPlayer::PlayData"));
sl@0: #endif
sl@0: 		iParent.Device().PlayData(iStatus,(STATIC_CAST(const CMMFDataBuffer*, iDataFromSource))->Data());
sl@0: 		SetActive();
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CDataPathPlayer::Stop()
sl@0: 	{
sl@0: 	if (!IsActive())	
sl@0: 		iParent.Device().FlushPlayBuffer(); // Otherwise won't be flushed
sl@0: 	Cancel();
sl@0: 	iParent.SoundDeviceException(KErrCancel);
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CDataPathPlayer::RunL()
sl@0: 	{
sl@0: #ifdef _SCW_DEBUG
sl@0: 	RDebug::Print(_L("CDataPathPlayer::RunL error[%d]"), iStatus.Int());
sl@0: #endif
sl@0: 	if (iStatus.Int()!=KErrNone)
sl@0: 		{ 	
sl@0: 		iParent.SoundDeviceException(iStatus.Int());
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		iParent.BufferEmptiedL(static_cast<const CMMFDataBuffer&>(*iDataFromSource));
sl@0: 		iResumePlaying = EFalse;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: 
sl@0: TInt CDataPathPlayer::RunError(TInt aError)
sl@0: 	{
sl@0: 	Error(aError);
sl@0: 	return KErrNone;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CDataPathPlayer::DoCancel()
sl@0: 	{
sl@0: 	if (iParent.Device().Handle())
sl@0: 		{
sl@0: 		iParent.Device().CancelPlayData();
sl@0: 		iParent.Device().FlushPlayBuffer();
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CDataPathPlayer::Error(TInt aError)
sl@0: 	{ 
sl@0: 	iParent.SoundDeviceException(aError);
sl@0: 	}
sl@0: 
sl@0: 
sl@0: /************************************************************************
sl@0:  *				CSoundDevPlayErrorReceiver											*
sl@0:  ************************************************************************/
sl@0: 
sl@0: CSoundDevPlayErrorReceiver::CSoundDevPlayErrorReceiver(CMMFSwCodecPlayDataPath& aParent, TInt aPriority)
sl@0: : CActive(aPriority), iParent(aParent)
sl@0: 	{
sl@0: 	CActiveScheduler::Add(this);
sl@0: 	}
sl@0: 
sl@0: CSoundDevPlayErrorReceiver::~CSoundDevPlayErrorReceiver()
sl@0: 	{
sl@0: 	Cancel();
sl@0: 	}
sl@0: 
sl@0: void CSoundDevPlayErrorReceiver::Start()
sl@0: 	{
sl@0: 	iParent.Device().NotifyPlayError(iStatus);
sl@0: 	SetActive();
sl@0: 	}
sl@0: 
sl@0: void CSoundDevPlayErrorReceiver::Stop()
sl@0: 	{
sl@0: 	Cancel();
sl@0: 	}
sl@0: 
sl@0: void CSoundDevPlayErrorReceiver::RunL()
sl@0: 	{
sl@0: 	TInt reason = iStatus.Int();
sl@0: 	Start();
sl@0: 	// An error has been returned
sl@0: #ifdef _SCW_DEBUG
sl@0: 	RDebug::Print(_L("CSoundDevPlayErrorReceiver::RunL[%d]"), reason);
sl@0: #endif
sl@0: 	iParent.SoundDeviceException(reason);
sl@0: 	}
sl@0: 
sl@0: void CSoundDevPlayErrorReceiver::DoCancel()
sl@0: 	{
sl@0: 	iParent.Device().CancelNotifyPlayError();
sl@0: 	}
sl@0: 
sl@0: