// Copyright (c) 1997-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 <f32file.h>

#include <e32std.h>

#include <mmf/server/mmfdatabuffer.h>

#include <mmf/common/mmfutilities.h>

#include <mmf/common/mmfcontroller.h>

#include <mmf/common/mmfpaniccodes.h>

#include <mmf/server/mmffile.h>

#include "MmffilePriv.h"

#include "FileAccess.h"

void Panic(TMMFFilePanicCode aPanicCode)

	{

	_LIT(KMMFFilePanicCategory, "MMFFile");

	User::Panic(KMMFFilePanicCategory, aPanicCode);

	}

/**

 * Constructs a CTransferBufferCopy

 *

 * @return CTransferBufferCopy*

 */

CTransferBufferCopy* CTransferBufferCopy::NewL(TInt aMaxLength)

	{

	CTransferBufferCopy* self = new (ELeave) CTransferBufferCopy(aMaxLength);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	}

/**

 * Second phase constructor for CTransferBufferCopy

 *

 * @return void

 */

void CTransferBufferCopy::ConstructL()

	{

	iBuffer = static_cast<TUint8*>(User::AllocL(iMaxLength));

	iBufferDes.Set(iBuffer,0,iMaxLength);

	}

/**

Destructor.

*/

CMMFFile::~CMMFFile() 

	{

	delete iFile;

	iHandle.Close();

	iFsSession.Close();

	delete iFileName;

	delete iFileExt;

	delete iFilePath;

	delete iFileDrive;

	delete iMmfFileEventHandler;

	delete iCAFParameters;

	// Get rid of everything in RArray's & close them.

	iRequests.ResetAndDestroy();

	iTransferBufferCopies.ResetAndDestroy();

	}

/**

Protected constructor.

The default implementation is empty.

*/

CMMFFile::CMMFFile() : CMMFClip( KUidMmfFileSource, KUidMmfFileSink ), iFileSize(-1)

	{

	iSinkNotStopped = EFalse;

	}

/**

Constructs an CMMFFile MDataSource.

@return A pointer to the new CMMFFile data source.

*/

MDataSource* CMMFFile::NewSourceL() 

	{

	CMMFFile* self = new (ELeave) CMMFFile ;

	return STATIC_CAST( MDataSource*, self ) ;

	}

/**

Constructs a CMMFFile MDataSink

@return A pointer to the new CMMFFile data sink.

*/

MDataSink* CMMFFile::NewSinkL()

	{

	CMMFFile* self = new (ELeave) CMMFFile ;

	return STATIC_CAST( MDataSink*, self ) ;

	}

/**

Perform source construction dependant on the source construction

initialisation data aInitData.

@param  aInitData

        The TPckg<TMMFFileParams> descriptor package containing the file name and full path.

*/

void CMMFFile::ConstructSourceL(const TDesC8& aInitData ) 

	{

	ConstructL(aInitData, ESourceMode);

	}

/**

Performs sink construction dependant on the sink construction

initialisation data aInitData.

@param  aInitData

        The TPckg<TMMFFileParams> descriptor package containing the file name and full path.

*/

void CMMFFile::ConstructSinkL(const TDesC8& aInitData)

	{

	ConstructL(aInitData, ESinkMode);

	}

/**

Protected constructor.

Extracts the initialisation data provided by the calling functions: ConstructSourceL() and 

ConstructSinkL(). Creates a file server session and sets up file name. If there is a file name and 

it cannot be found this function leaves. If there is no file name the function leaves. Does not 

attempt to open the file or check whether the file exists.

If aInitData contains a TMMFFileHandleParams instead of TMMFFileParams, the source/sink is constructed from 

the file handle provided by the caller

@param  aInitData

        Initialisation data packaged in a TMMFFileParams or in a TMMFFileHandleParams (File Handle)

*/

void CMMFFile::ConstructL(const TDesC8& aInitData,TMMFileMode aFileMode)

	{

	User::LeaveIfError(iFsSession.Connect());

#ifdef __IPC_V2_PRESENT__

	// on IPCv2 we auto attach

	User::LeaveIfError(iFsSession.ShareAuto());

#else

	// on IPCv1 we use explicit - more efficient

	User::LeaveIfError(iFsSession.Share(RSessionBase::EExplicitAttach));

#endif

	User::LeaveIfError(iFsSession.ShareProtected());

	HBufC* filename = NULL; 

	iCAFParameters = new (ELeave) CCAFParameters;

	TBool drmContent = EFalse;

	RDesReadStream stream(aInitData);

	CleanupClosePushL(stream);

	TUid initUid = TUid::Uid(stream.ReadInt32L());

	if (initUid == KMMFileHandleSourceUid)

		{

		TPckgBuf<RFile*> fileptr;

		stream.ReadL(fileptr);

		iHandle.Duplicate(*fileptr());

		TInt length = stream.ReadInt32L();

		if (length>0)

			{

			iCAFParameters->iUniqueId = HBufC::NewL(length);

			TPtr16 ptr = iCAFParameters->iUniqueId->Des();

			stream.ReadL(ptr, length);

			}

		iFileHandle = ETrue;

		filename = HBufC::NewMaxLC(KMaxFileName);

		TPtr ptr = filename->Des();

		User::LeaveIfError(iHandle.FullName(ptr));

		drmContent = ETrue;

		iCAFParameters->iEnableUI = stream.ReadInt32L();

		}

	else if (initUid == KMMFileSourceUid)

		{

		TInt length = stream.ReadInt32L();

		filename = HBufC::NewMaxLC(length);

		TPtr ptr = filename->Des();

		stream.ReadL(ptr, length);

		length = stream.ReadInt32L();

		if (length>0)

			{

			iCAFParameters->iUniqueId = HBufC::NewMaxL(length);

			ptr.Set(iCAFParameters->iUniqueId->Des());

			stream.ReadL(ptr, length);

			}

		drmContent = ETrue;

		iCAFParameters->iEnableUI = stream.ReadInt32L();

		}

	else

		{

//		XXX If the UID is unknown we should reject, but  currently

//		code also used for older calls that just supply filename.

//		User::Leave(KErrNotSupported);

		}

	if ((filename == NULL) && aInitData.Length() == sizeof(TMMFFileHandleParams))

		{

		TMMFFileHandleParams params;

		TPckgC<TMMFFileHandleParams> config(params);

		config.Set(aInitData);

		params = config();

		if (params.iUid == KFileHandleUid)

			{

			User::LeaveIfError(iHandle.Duplicate(*params.iFile));

			TInt pos = 0;

			// make sure the duplicate handle is at the start of the file - the usage of the file handle really requires this

			User::LeaveIfError(iHandle.Seek(ESeekStart, pos));

			iFileHandle = ETrue;

			ASSERT(filename == NULL);

			filename = HBufC::NewMaxLC(KMaxFileName);

			TPtr ptr = filename->Des();

			User::LeaveIfError(iHandle.FullName(ptr));

			}

		}

	if (filename == NULL) // do old case as last resort

		{

		TMMFFileParams params;

		TPckgC<TMMFFileParams> config(params);

		config.Set(aInitData);

		params = config();

		filename = params.iPath.AllocLC();

		}

	ASSERT(filename != NULL);

	TParse parser ;

	User::LeaveIfError(parser.Set(*filename, NULL, NULL));

	CleanupStack::PopAndDestroy(2, &stream); //filename, stream

	if ( !( parser.NamePresent() ) && !( parser.ExtPresent() ) )

		{

		User::Leave( KErrBadName ) ;

		}

	iFullFileName.Copy( parser.FullName() ) ;	

	iFileName = parser.Name().AllocL() ;

	iFileExt = parser.Ext().AllocL() ;

	iFilePath = parser.Path().AllocL() ;

	iFileDrive = parser.Drive().AllocL() ;

	// in order to simulate old behaviour we are not passing error out

	// but will try to create Content again during PrimeL()

	if (drmContent && aFileMode==ESourceMode)

		{

		TInt contentError;

		if (iFileHandle)

			{

			TRAP(contentError, 

				iFile = CContentFile::NewL(iHandle, UniqueId(), iCAFParameters->iEnableUI);

				);

			}

		else

			{

			// Open for read-only access

			TRAP(contentError,

				iFile = CContentFile::NewL(iFsSession, iFullFileName, UniqueId(), EFileShareReadersOnly, iCAFParameters->iEnableUI);

			);

			}

		}

	}

/**

@deprecated - Replaced by CMMFFile::Data()

Returns an RFile handle to the current file.

If there is no current file, one is created. If the file exists then it is opened with read access 

if it is read only, write access otherwise. If the file does not exist then it is opened with

write access.

@leave KErrNotReady

       The file is not open.

@return A handle to the current file.

@see CMMFFile::Data()

*/

RFile& CMMFFile::FileL()

	{

	if (!iFile)

		User::Leave(KErrNotReady);

	if (iFileHandle)

		return iHandle;

	else

		return iFile->FileL();

	}

/** 

Returns the file name of the current file.

Note: This will give the wrong answer if the file is renamed!

@return The FileName (without extension).

*/

const TDesC& CMMFFile::FileName() const

	{

	return *iFileName ;

	}

/**

Returns the extension of the current file.

Note: This will give the wrong answer if the file is renamed!

@return The File Extension.

*/

const TDesC& CMMFFile::Extension() const 

	{

	return *iFileExt ;

	}

/** 

Returns the path of the current file.

Note: This will give the wrong answer if the file is renamed!

@return The FilePath (without filename and extension)

*/

const TDesC& CMMFFile::FilePath() const 

	{

	return *iFilePath ;

	}

/** 

Returns the drive on which the current file is located.

Note: This will give the wrong answer if the file is renamed!

@return The FileDrive (drive letter only, without path, filename and extension).

*/

const TDesC& CMMFFile::FileDrive() const 

	{

	return *iFileDrive ;

	}

/** 

Returns the full name of the current file.

Note: This will give the wrong answer if the file is renamed!

@return The file name (full filename including drive letter, without path, filename and extension).

*/

const TFileName CMMFFile::FullName() const

	{

	return iFullFileName;

	}

/** 

Returns the uniqueID associated with this content. If no uniqueID has been provided, a null

descriptor will be provided

@return The UniqueID

*/

const TDesC& CMMFFile::UniqueId() const

	{

	if (iCAFParameters->iUniqueId)

		return *(iCAFParameters->iUniqueId);

	else

		return KNullDesC;

	}

/**

Deletes the file.

Closes the currently open file, then deletes it. If the file source is accessing a file handle, 

the file is truncated to 0 bytes instead.

@return An error code indicating if the function call was successful. KErrNone on success, otherwise

        another of the system-wide error codes.

*/

TInt CMMFFile::Delete()				

	{

	TInt result = KErrNone;

	if (!iFileHandle)

		{

		delete iFile;

		iFile = NULL;

		iFileSize=-1;

		iPosition=0;

		result = iFsSession.Delete(iFullFileName);

		}

	else

		{

		iFileSize=-1;

		iPosition=0;

		if (iFile)

			{

			result = iFile->SetSize(0);

			}

		}

	return result;

	}

/** 

Sets the file size.

@param  aSize

        The size of the file.

@return An error code indicating if the function call was successful. KErrNone on success, otherwise

        another of the system-wide error codes.

*/

TInt CMMFFile::SetSize(TInt aSize)

	{

	if ( !iFile )

		return KErrNotReady;

	TInt err =  iFile->SetSize(aSize);

	if(err == KErrNone)

		iFileSize = aSize;

	else

		iFileSize = -1;

	return err;

	}

/**

Obtains a CTransferBufferCopy from iTransferBufferCopies that is

at least as big as that required.

There is no need to put the pointer returned by this method onto the CleanupStack

as it will have already been placed into iTransferBufferCopies.

@param  aMaxLength

        The size required.

@return A pointer to a valid CTransferBufferCopy.

*/

CTransferBufferCopy* CMMFFile::ObtainCopyOfTransferBufferL(TInt aMaxLength)

	{

	//find a free transfer buffer copy of the right size

	TInt firstFree = -1;

	CTransferBufferCopy* transBufCopyToUse = NULL;

	for(TInt cnt=0; cnt < iTransferBufferCopies.Count(); cnt++)

		{

		if(!iTransferBufferCopies[cnt]->InUse())

			{

			//record the first free entry, we may remove this

			//if entries in iTransferBufferCopies > KAcceptableTransferBufferCopiesSize

			if(firstFree == -1) 

				firstFree = cnt;

			if(iTransferBufferCopies[cnt]->MaxLength() >= aMaxLength)

				{

				transBufCopyToUse = iTransferBufferCopies[cnt];

				//Set the MaxLength. This will ensure that the copy acts the same as

				//the original Transfer buffer, eg. file server will throw KErrOverflow

				transBufCopyToUse->ReUse(aMaxLength);

				break;

				}

			}

		}

	//If we failed to find a suitable entry, we need to create a new one

	if(!transBufCopyToUse)

		{

		//Firstly, should we re-cycle an existing entry?

		//There must be entries in the array, a free entry must have been found,

		//the size of the array must be beyond the water mark where we want to start

		//cycling free entries.

		if((iTransferBufferCopies.Count() > 0) &&

			(firstFree != -1) &&

			(iTransferBufferCopies.Count() > KAcceptableTransferBufferCopiesSize))

			{

			delete iTransferBufferCopies[firstFree];

			iTransferBufferCopies.Remove(firstFree);

			transBufCopyToUse = CTransferBufferCopy::NewL(aMaxLength);

			CleanupStack::PushL(transBufCopyToUse);

			User::LeaveIfError(iTransferBufferCopies.Insert(transBufCopyToUse,firstFree));

			CleanupStack::Pop();

			}

		else

			{

#ifdef _DEBUG

			if(iTransferBufferCopies.Count() > KMaximumTransferBufferCopiesSize)

				{

				User::Panic(_L("iTransferBufferCopies grew too large in CMMFFile"),KErrTooBig);

				}

#endif

			transBufCopyToUse = CTransferBufferCopy::NewL(aMaxLength);

			CleanupStack::PushL(transBufCopyToUse);

			User::LeaveIfError(iTransferBufferCopies.Append(transBufCopyToUse));

			CleanupStack::Pop();

			}

		}

	return transBufCopyToUse;

	}

/** 

Loads aBuffer from iFile.

The file must already be open for reading. File read is asynchronous. CReadRequest is created to 

respond to completion.

@param  aBuffer

        The buffer to be filled from the file.

@param  aConsumer

        The data sink consumer of the buffer.

*/

void CMMFFile::FillBufferL( CMMFBuffer* aBuffer, MDataSink* aConsumer, TMediaId /*aMediaId*/ )

	{

	// Requires that iFile is open for read.

	// Reads data from iFile into aBuffer

	if ((aConsumer == NULL) || (aBuffer == NULL))

		User::Leave(KErrArgument);

	if (!iFile || (iMmfFileEventHandler == NULL))

		User::Leave(KErrNotReady);

	if (CMMFBuffer::IsSupportedDataBuffer(aBuffer->Type()))

		{

		CTransferBufferCopy* transBufCopy = NULL;

		CReadRequest* request = NULL;

		TDes8& aBufferDes = STATIC_CAST( CMMFDataBuffer*, aBuffer )->Data();

		TInt requestSize;

		if(aBuffer->RequestSize())

			requestSize = aBuffer->RequestSize();

		else

			requestSize = aBufferDes.MaxLength();

		//check whether buffer is safe to send to file server

		//if not, eg for a transfer buffer, then it needs to be copied

		if (!CMMFBuffer::IsFileServerSafe(aBuffer->Type()))

			{

			//NB: failure in this method will NOT cause transBufCopy to leak as it will be 

			//inserted into iTransferBufferCopies by ObtainCopyOfTransferBufferL.

			transBufCopy = ObtainCopyOfTransferBufferL(aBufferDes.MaxLength());

			request = new(ELeave) CReadRequest(STATIC_CAST(TAny*, aConsumer), aBuffer, transBufCopy, iPosition, Size(), iMmfFileEventHandler);

			}

		else

			{

			request = new(ELeave) CReadRequest(STATIC_CAST(TAny*, aConsumer), aBuffer, iPosition, Size(), iMmfFileEventHandler);

			}

		CleanupStack::PushL( request );

		StoreRequestL(request); // transfers ownership

		CleanupStack::Pop() ; // request

		iFile->Read(request->BufferDes(), requestSize, request->iStatus);

		iPosition += requestSize;

		if (iPosition >= iFileSize)

			{

			aBuffer->SetLastBuffer(ETrue);

			}

		request->SetActive();

		}

	else // if (CMMFBuffer::IsSupportedDataBuffer(aBuffer->Type()))

		User::Leave( KErrNotSupported ) ;

	}

/** 

Empties aBuffer into iFile. The file must be already open for writing.

@param  aBuffer

        The buffer to be written to the file.

@param  aSupplier

        The data source supplier of the buffer.

*/

void CMMFFile::EmptyBufferL( CMMFBuffer* aBuffer, MDataSource* aSupplier, TMediaId /*aMediaId*/ )

	{

	// Requires that iFile is open for write.

	// Writes data from iFile into aBuffer

	if ((aSupplier == NULL) || (aBuffer == NULL))

		User::Leave(KErrArgument);

	if (!iFile || (iMmfFileEventHandler == NULL))

		User::Leave(KErrNotReady);

	CTransferBufferCopy* transBufCopy = NULL;

	if (CMMFBuffer::IsSupportedDataBuffer(aBuffer->Type()))

		{

		CWriteRequest* request = NULL;

		TDes8& aBufferDes = STATIC_CAST( CMMFDataBuffer*, aBuffer )->Data();

		//check whether buffer is safe to send to file server

		//if not, eg for a transfer buffer, then it needs to be copied

		if (!CMMFBuffer::IsFileServerSafe(aBuffer->Type()))

			{

			//Obtain a normal buffer to send to the file server

			//NB: failure in this method will NOT cause transBufCopy to leak as it will be 

			//inserted into iTransferBufferCopies by ObtainCopyOfTransferBufferL.

			transBufCopy = ObtainCopyOfTransferBufferL(aBufferDes.MaxLength());

			//Copy the data into the buffer we will send to the file server

			transBufCopy->Des().Copy(aBufferDes);

			request = new(ELeave) CWriteRequest(STATIC_CAST(TAny*, aSupplier), aBuffer, transBufCopy, iMmfFileEventHandler);

			}

		else

			{

			request = new(ELeave) CWriteRequest(STATIC_CAST(TAny*, aSupplier), aBuffer, iMmfFileEventHandler);

			}

		CleanupStack::PushL( request );

		StoreRequestL(request);  // transfers ownership

		CleanupStack::Pop(); // request

		iFile->Write(request->BufferDes(), request->BufferDes().Length(), request->iStatus);

		request->SetActive();

		}

	else  // if (CMMFBuffer::IsSupportedDataBuffer(aBuffer->Type()))

		{

		User::Leave( KErrNotSupported ) ;

		}

	}

/** 

Loads aLength number of bytes into aBuffer from specified point in iFile.

@param  aLength

        The number of bytes to be read into buffer.

@param  aBuffer

        The buffer to be filled from the file.

@param  aPosition

        The offset into the file at which to start reading.

@param  aConsumer

        The data sink consumer of the buffer.

*/

void CMMFFile::ReadBufferL(TInt aLength, CMMFBuffer* aBuffer, TInt aPosition, MDataSink* aConsumer)

	{

	// Requires that iFile is open for read.

	// Reads data from iFile into aBuffer

	if ((aLength < 0) || (aPosition<0) || (aConsumer == NULL) || (aBuffer == NULL))

		User::Leave(KErrArgument);

	if (!iFile || (iMmfFileEventHandler == NULL))

		User::Leave(KErrNotReady);

	CTransferBufferCopy* transBufCopy = NULL;

	if (CMMFBuffer::IsSupportedDataBuffer(aBuffer->Type()))

		{

		CReadRequest* request = NULL;

		TDes8& aBufferDes = STATIC_CAST( CMMFDataBuffer*, aBuffer )->Data();

		//check whether buffer is safe to send to file server

		//if not, eg for a transfer buffer, then it needs to be copied

		if (!CMMFBuffer::IsFileServerSafe(aBuffer->Type()))

			{

			//Obtain a normal buffer to send to the file server

			//NB: failure in this method will NOT cause transBufCopy to leak as it will be 

			//inserted into iTransferBufferCopies by ObtainCopyOfTransferBufferL.

			transBufCopy = ObtainCopyOfTransferBufferL(aBufferDes.MaxLength());

			request = new(ELeave) CReadRequest(STATIC_CAST(TAny*, aConsumer), aBuffer, transBufCopy, aPosition, Size(), iMmfFileEventHandler);

			}

		else

			{

			request = new(ELeave) CReadRequest(STATIC_CAST(TAny*, aConsumer), aBuffer, aPosition, Size(), iMmfFileEventHandler);

			}

		CleanupStack::PushL( request );

		StoreRequestL(request) ;  //transfers ownership

		CleanupStack::Pop() ; //request

		TInt err = iFile->Read(aPosition, request->BufferDes(), aLength, request->iStatus);

		if (err == KErrCANotSupported)

			{

			err = KErrNone;

			if (aPosition != iPosition)

				{

				err = iFile->Seek(ESeekStart, aPosition);

				}

			if (err==KErrNone)

				{

				iFile->Read(request->BufferDes(), aLength, request->iStatus);

				}

			}

		if (err != KErrNone)

			{

			TRequestStatus* status = &request->iStatus;

			User::RequestComplete(status, err);

			}

		iPosition = aPosition + aLength;

		if (iPosition >= iFileSize)

			{

			aBuffer->SetLastBuffer(ETrue);

			}

		request->SetActive();

		}

	else // if (CMMFBuffer::IsSupportedDataBuffer(aBuffer->Type()))

		User::Leave( KErrNotSupported ) ;

	}

/**

Loads aBuffer from specified point in iFile.

The file must already be open for reading.

@param  aBuffer

        The buffer to be filled from the file.

@param  aPosition

        The offset into file at which to start reading.

@param  aConsumer

        The data sink consumer of the buffer.

*/

void CMMFFile::ReadBufferL(CMMFBuffer* aBuffer, TInt aPosition, MDataSink* aConsumer)

	{

	// Requires that iFile is open for read.

	// Reads data from iFile into aBuffer

	if ((aPosition<0) || (aConsumer == NULL) || (aBuffer == NULL))

		User::Leave(KErrArgument);

	if (CMMFBuffer::IsSupportedDataBuffer(aBuffer->Type()))

		{

		TInt requestSize;

		if(aBuffer->RequestSize())

			requestSize = aBuffer->RequestSize();

		else

			requestSize = STATIC_CAST( CMMFDataBuffer*, aBuffer )->Data().MaxLength();

		ReadBufferL(requestSize, aBuffer, aPosition, aConsumer);

		}

	else // if (CMMFBuffer::IsSupportedDataBuffer(aBuffer->Type()))

		User::Leave(KErrNotSupported);

	}

/**

Loads aBuffer from specified point in iFile.  Note that this is a synchronous read.

@param  aBuffer

        The buffer to be filled from the file.

@param  aPosition

        The offset into file at which to start reading.

*/

void CMMFFile::ReadBufferL( CMMFBuffer* aBuffer, TInt aPosition)

	{

	// Requires that iFile is open for read.

	// Reads data from iFile into aBuffer

	if ((aPosition<0) || (aBuffer == NULL))

		User::Leave(KErrArgument);

	if (!iFile)

		User::Leave(KErrNotReady);

	if (CMMFBuffer::IsSupportedDataBuffer(aBuffer->Type()))

		{

		TDes8& aBufferDes = STATIC_CAST( CMMFDataBuffer*, aBuffer )->Data();

		TInt requestSize;

		if(aBuffer->RequestSize())

			requestSize = aBuffer->RequestSize();

		else

			requestSize = aBufferDes.MaxLength();

		//check whether buffer is safe to send to file server

		//if not, eg for a transfer buffer, then it needs to be copied

		if (!CMMFBuffer::IsFileServerSafe(aBuffer->Type()))

			{

			//NB: failure in this method will NOT cause transBufCopy to leak as it will be 

			//inserted into iTransferBufferCopies by ObtainCopyOfTransferBufferL.

			CTransferBufferCopy* transBufCopy = ObtainCopyOfTransferBufferL(aBufferDes.MaxLength());

			User::LeaveIfError(iFile->Seek(ESeekStart, aPosition));

			User::LeaveIfError(iFile->Read(transBufCopy->Des(), requestSize));

			aBufferDes.Copy(transBufCopy->Des().Left(aBufferDes.MaxLength()));

			}

		else

			{

			User::LeaveIfError(iFile->Seek(ESeekStart, aPosition));

			User::LeaveIfError(iFile->Read(aBufferDes, requestSize));

			}

		iPosition = aPosition + aBufferDes.Length();

		//check if the buffer is the last buffer and if so set the last buffer flag on the CMMFDataBuffer

		//NB: setting last buffer is the done by the formatter, but this is a hang over to account for 

		//existing formatters that may fail if this is removed.

		if (iPosition >= Size())

			{

			aBuffer->SetLastBuffer(ETrue);

			}

		}

	else  // if (CMMFBuffer::IsSupportedDataBuffer(aBuffer->Type()))

		User::Leave(KErrNotSupported); 

	}

/** 

Empties aLength bytes from aBuffer into iFile at specified location.

@param  aLength

        The number of bytes to be emptied from buffer.

@param  aBuffer

        The data buffer containing bytes to be written.

@param  aPosition

        The offset into file at which to start writing.

@param  aSupplier

        The data source to be notified when the write has been completed.

@leave  KErrNotReady 

        SinkPrimeL() and SinkThreadLogon() have not been called.

@leave  KErrArgument 

        aLength<0 or aPosition<0 or aSupplier is NULL.

@leave  KErrNotSupported 

        aBuffer is not a supported CMMFDataBuffer

*/

void CMMFFile::WriteBufferL(TInt aLength, CMMFBuffer* aBuffer, TInt aPosition, MDataSource* aSupplier)

	{

	if ((aLength<0) || (aPosition<0) || (aSupplier == NULL) || (aBuffer == NULL))

		User::Leave(KErrArgument);

	if (!iFile || (iMmfFileEventHandler == NULL))

		User::Leave(KErrNotReady);

	if (CMMFBuffer::IsSupportedDataBuffer(aBuffer->Type()))

		{

		CWriteRequest* request = NULL;

		TDes8& aBufferDes = STATIC_CAST( CMMFDataBuffer*, aBuffer )->Data();

		//check whether buffer is safe to send to file server

		//if not, eg for a transfer buffer, then it needs to be copied

		if (!CMMFBuffer::IsFileServerSafe(aBuffer->Type()))

			{

			//NB: failure in this method will NOT cause transBufCopy to leak as it will be 

			//inserted into iTransferBufferCopies by ObtainCopyOfTransferBufferL.

			CTransferBufferCopy* transBufCopy = ObtainCopyOfTransferBufferL(aBufferDes.MaxLength());

			transBufCopy->Des().Copy(aBufferDes);

			request = new(ELeave) CWriteRequest(STATIC_CAST(TAny*, aSupplier), aBuffer, transBufCopy, iMmfFileEventHandler);

			}

		else

			{

			request = new(ELeave) CWriteRequest(STATIC_CAST(TAny*, aSupplier), aBuffer, iMmfFileEventHandler);

			}

		CleanupStack::PushL( request );

		StoreRequestL(request);  // transfers ownership

		CleanupStack::Pop(); // request

		User::LeaveIfError(iFile->Seek(ESeekStart, aPosition));		

		iFile->Write(request->BufferDes(), aLength, request->iStatus);

		iFileSize = -1; //reset cached size

		request->SetActive();

		}

	else // if (!CMMFBuffer::IsFileServerSafe(aBuffer->Type()))

		{

		//write bitmap to file

		User::Leave(KErrNotSupported);

		}

	}

/**

Empties aBuffer into iFile at the specified location.

@param  aBuffer

        The data buffer containing bytes to be written.

@param  aPosition

        The offset into file at which to start writing.

@param  aSupplier

        The data source to be notified when the write has been completed.

@leave  KErrNotReady 

        SinkPrimeL() and SinkThreadLogon() have not been called.

@leave  KErrArgument 

        aSupplier is NULL.

@leave  KErrNotSupported 

        The aBuffer is not of type KMMFDataBuffer.

*/

void CMMFFile::WriteBufferL( CMMFBuffer* aBuffer, TInt aPosition, MDataSource* aSupplier)

	{

	// Requires that iFile is open for write.

	// Writes data from iFile into aBuffer

	if ((aPosition<0) || (aSupplier == NULL) || (aBuffer == NULL))

		User::Leave(KErrArgument);

	if (CMMFBuffer::IsSupportedDataBuffer(aBuffer->Type()))

		{

		TUint requestSize = STATIC_CAST( CMMFDataBuffer*, aBuffer )->Data().Length();

		WriteBufferL(requestSize, aBuffer, aPosition, aSupplier);

		}

	else  // if (CMMFBuffer::IsSupportedDataBuffer(aBuffer->Type()))

		{

		//write bitmap to file

		User::Leave( KErrNotSupported ) ;

		}

	}

/**

Empties aBuffer into iFile at specified location.  Note that this is a synchronous write.

@param  aBuffer

        The data buffer containing bytes to be written.

@param  aPosition

        The offset into file at which to start writing.

@return The error code from RFile.

*/

void CMMFFile::WriteBufferL( CMMFBuffer* aBuffer, TInt aPosition ) 

	{

	if ((aPosition<0) || (aBuffer == NULL))

		User::Leave(KErrArgument);

	if (!iFile)

		User::Leave(KErrNotReady);

	TInt err(KErrNone) ;

	//check whether buffer is safe to send to file server

	//if not, eg for a transfer buffer, then it needs to be copied

	if ((!CMMFBuffer::IsFileServerSafe(aBuffer->Type()))

		&& (CMMFBuffer::IsSupportedDataBuffer(aBuffer->Type())))

		{

		TDes8& aBufferDes = STATIC_CAST( CMMFDataBuffer*, aBuffer )->Data();

		//NB: failure in this method will NOT cause transBufCopy to leak as it will be 

		//inserted into iTransferBufferCopies by ObtainCopyOfTransferBufferL.

		CTransferBufferCopy* transBufCopy = ObtainCopyOfTransferBufferL(aBufferDes.MaxLength());

		transBufCopy->Des().Copy(aBufferDes);

		err = iFile->Seek(ESeekStart, aPosition);

		if (err==KErrNone)

			err = iFile->Write(transBufCopy->Des(),transBufCopy->Des().Length()); 

		iFileSize = -1; //reset cached size

		}

	else if (CMMFBuffer::IsSupportedDataBuffer(aBuffer->Type()))

		{

		TDes8& aBufferDes = STATIC_CAST( CMMFDataBuffer*, aBuffer )->Data();

		err = iFile->Seek(ESeekStart, aPosition);

		if (err==KErrNone)

			err = iFile->Write(aBufferDes, aBufferDes.Length()); 

		iFileSize = -1; //reset cached size

		}

	else // if (CMMFBuffer::IsSupportedDataBuffer(aBuffer->Type()))

		{

		User::Leave(KErrNotSupported);

		}

	User::LeaveIfError(err);

	}

/**

Gets the number of free bytes in the device's file system.

@return The number of free bytes.

*/

TInt64 CMMFFile::BytesFree()

	{