// Copyright (c) 2003-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:
//

// Test system includes
#include "TSU_MMF_SWCDWRAP_PlayHwDevObserver.h"

CTestPlayMMFHwDeviceObserver::CTestPlayMMFHwDeviceObserver(CMMFHwDevice* aHwDevice) : CTestMMFHwDeviceObserver(aHwDevice)
	{
	iStopActiveSchedulerOnStop = ETrue;
	iCallPauseAndResumeAfterSendingLastBuffer = EFalse;
	}

CTestPlayMMFHwDeviceObserver::~CTestPlayMMFHwDeviceObserver()
	{
	iSourceFile.Close();
	delete iDataBuffer;
	delete iFileReader;
	}


TInt CTestPlayMMFHwDeviceObserver::FillBufferFromFileSync(const TDesC& aFileName, TUint aBufferSize)
	{
	TInt error = KErrNone;
	iStopped = EFalse;

	if (!iFileServerSession.Handle())
		{//open a handle to the file server
		error = iFileServerSession.Connect();
		}

	if (!error)
		{//have a file server session so open file
		error = iSourceFile.Open(iFileServerSession, aFileName, EFileRead);
		}
	
	if (!error)
		{//create buffer to store source data
		if (iDataBuffer) 
			{
			delete iDataBuffer;
			iDataBuffer = NULL;
			}
		TRAP(error, iDataBuffer = HBufC8::NewL(aBufferSize));
		}

	if (!error)
		{//read file into the source buffer
		TPtr8 dataBufferDes(const_cast<TUint8*>(iDataBuffer->Ptr()), aBufferSize);
		iSourceFile.Read(dataBufferDes);
		iAsyncMode = EFalse;
		}

	return error; 
	}


TInt CTestPlayMMFHwDeviceObserver::ReadBufferDirectFromFileAsync(const TDesC& aFileName, TUint aNumberOfBuffers)
	{
	TInt error = KErrNone;
	iStopped = EFalse;

	if (!iFileServerSession.Handle())
		{//open a handle to the file server
		error = iFileServerSession.Connect();
		}

	if (!error)
		{//have a file server session so open file
		error = iSourceFile.Open(iFileServerSession, aFileName, EFileRead);
		}

	if (!error)
		{
		if (!iFileReader)
			TRAP(error,iFileReader = new(ELeave) CTestFileReader(iSourceFile, this));
		}

	if (!error)
		{
		iNumberOfBuffers = aNumberOfBuffers;
		iAsyncMode = ETrue;
		}
	
	return error; 
	}


TInt CTestPlayMMFHwDeviceObserver::FillThisHwBuffer(CMMFBuffer& aHwDataBuffer)
	{
	//called on playing when buffer needs to be filled with data to play
	TInt error = KErrNone;
	iCurrentBufferNumber++; //first buffer is buffer #1
	iCurrentHwDeviceDataBuffer = &(static_cast<CMMFDataBuffer&>(aHwDataBuffer));

	if (iAsyncMode)
		error = FillThisHwBufferFromFile(*iCurrentHwDeviceDataBuffer);
	else 
		error = FillThisHwBufferFromDes(*iCurrentHwDeviceDataBuffer);
	if (!iError) 
		iError = error; //log error in observer error
	return error;
	}


TInt CTestPlayMMFHwDeviceObserver::FillThisHwBufferFromDes(CMMFDataBuffer& aHwDataBuffer)
	{
	CMMFDataBuffer* dataBuffer = static_cast<CMMFDataBuffer*>(&aHwDataBuffer);

	TUint bufferSize = 0;
	if (dataBuffer->RequestSize())
		bufferSize = dataBuffer->RequestSize();
	else bufferSize = dataBuffer->Data().MaxLength();

	TUint sourceDataLength = static_cast<TUint>(iDataBuffer->Des().MaxLength());

	if (iBufferPosition < sourceDataLength)
		{
		if ((sourceDataLength - iBufferPosition) <= bufferSize)
			{//reached end of data
			bufferSize = (sourceDataLength - iBufferPosition); 
			dataBuffer->SetLastBuffer(ETrue);
			}
		dataBuffer->Data().Copy((iDataBuffer->Ptr()+iBufferPosition), bufferSize);
		iBufferPosition+=bufferSize;
		}
	else
		{//have exceeded length of data
		dataBuffer->SetLastBuffer(ETrue);
		}

	return iHwDevice->ThisHwBufferFilled(*dataBuffer);
	}


TInt CTestPlayMMFHwDeviceObserver::FillThisHwBufferFromFile(CMMFDataBuffer& aHwDataBuffer)
	{
	return iFileReader->Read(aHwDataBuffer);
	}


void CTestPlayMMFHwDeviceObserver::FileReadComplete(TInt aError)
	{
	if (aError == KErrNone)
		{
		if (iCurrentBufferNumber >= iNumberOfBuffers)
			{
			iCurrentHwDeviceDataBuffer->SetLastBuffer(ETrue);
			}
		if (iCurrentHwDeviceDataBuffer->BufferSize()
			< static_cast<TUint>(iCurrentHwDeviceDataBuffer->Data().MaxLength()))
			{//EOF
			iCurrentHwDeviceDataBuffer->SetLastBuffer(ETrue);
			}
		TInt error = iHwDevice->ThisHwBufferFilled(*iCurrentHwDeviceDataBuffer);
		if (iCallPauseAndResumeAfterSendingLastBuffer&&iCurrentHwDeviceDataBuffer->LastBuffer())
			{
			TInt err = iHwDevice->Pause();
			iCallPauseAndResumeAfterSendingLastBuffer = EFalse;//only call pause once
			if (!err)//resume
				err = iHwDevice->Start(EDevDecode, EDevOutFlow);		
			if (!error)//note could potentialy have 2 errors here err & error
				error = err; //if so swallow the second error err and keep first
			}
		if (!iError) 
			iError = error; //log error in observer error
		}
	else
		{
		iError = aError;
		}
	}


void CTestPlayMMFHwDeviceObserver::Stopped()
	{
	if (iStopActiveSchedulerOnStop)
		{
		StopActiveScheduler();
		}
	iStopped = ETrue;
	}


RFile& CTestPlayMMFHwDeviceObserver::ReadFile()
	{
	return iSourceFile;
	}

void CTestPlayMMFHwDeviceObserver::CancelFileRead()
	{
	iFileReader->Cancel();
	}

TBool CTestPlayMMFHwDeviceObserver::IsStopped()
	{
	return iStopped;
	}

void CTestPlayMMFHwDeviceObserver::StopActiveSchedulerOnStop(TBool aStopActiveSchedulerOnStop)
	{
	iStopActiveSchedulerOnStop = aStopActiveSchedulerOnStop;
	}

void CTestPlayMMFHwDeviceObserver::CallPauseAndResumeAfterSendingLastBuffer()
	{
	iCallPauseAndResumeAfterSendingLastBuffer = ETrue;
	}