// 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_RecordHwDevObserver.h"

CTestRecordMMFHwDeviceObserver::CTestRecordMMFHwDeviceObserver(CMMFHwDevice* aHwDevice) : CTestMMFHwDeviceObserver(aHwDevice)

	{

	}

CTestRecordMMFHwDeviceObserver::~CTestRecordMMFHwDeviceObserver()

	{

	iSinkFile.Close();

	delete iFileWriter;

	}

TInt CTestRecordMMFHwDeviceObserver::WriteBufferDirectToFileAsync(const TDesC& aFileName, TUint aNumberOfBuffers)

	{

	TInt error = KErrNone;

	if (!iFileServerSession.Handle())

		{//open a handle to the file server

		error = iFileServerSession.Connect();

		}

	if (!error)

		{

		//make sure file to be recorded is deleted before we start

		error = iFileServerSession.Delete(aFileName); 

		if (error == KErrNotFound)

			error = KErrNone; //KErrNotFound is not an error, means file doesn't exist

		if (!error)

			{

			error = iSinkFile.Create(iFileServerSession, aFileName, EFileWrite);

			if (!error)

				{

				if (!iFileWriter)

					TRAP(error,iFileWriter = new(ELeave) CTestFileWriter(iSinkFile, this));	

				}

			if (!error)

				{

				iNumberOfBuffers = aNumberOfBuffers;

				}

			}

		}	

	return error; 

	}

void CTestRecordMMFHwDeviceObserver::FileWriteComplete(TInt aError)

	{

	if (aError == KErrNone)

		{

		TInt error = KErrNone;

		if (iCurrentBufferNumber >= iNumberOfBuffers)

			{

			error = iHwDevice->Stop();

			StopActiveScheduler();

			}

        else if (iCurrentHwDeviceDataBuffer->LastBuffer() || iCurrentHwDeviceDataBuffer->BufferSize()==0)

            {

            error = iHwDevice->Stop();

            StopActiveScheduler();

            }

		else

			{//tell hw device we've emptied it and get another buffer

			error = iHwDevice->ThisHwBufferEmptied(*iCurrentHwDeviceDataBuffer);

			}

		if (!iError) 

			iError = error; //log error in observer error

		}

	else

		{

		iError = aError;

		}

	}

TInt CTestRecordMMFHwDeviceObserver::EmptyThisHwBuffer(CMMFBuffer& aHwDataBuffer)

	{

	//called on recording when buffer needs to be written to file

	TInt error = KErrNone;

	iCurrentBufferNumber++;

	iCurrentHwDeviceDataBuffer = &(static_cast<CMMFDataBuffer&>(aHwDataBuffer));

	if (iCurrentBufferNumber <= iNumberOfBuffers)

		{

		error = iFileWriter->Write(*iCurrentHwDeviceDataBuffer);

		}

	if (!iError) 

			iError = error; //log error in observer error

	return error;

	}

void CTestRecordMMFHwDeviceObserver::Stopped()

	{

	}

RFile& CTestRecordMMFHwDeviceObserver::WriteFile()

	{

	return iSinkFile;

	}