/*
* Copyright (c) 2004 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:  Progressive Download Utility
*
*/


#ifndef __MMFFILEPRIV_H_
#define __MMFFILEPRIV_H_

#include <f32file.h>

#include <mmf/server/mmfclip.h>
#include <mmf/server/mmfdatabuffer.h>


/**
 *  @publishedAll
 *
 *  Represents a copy of a KUidMmfTransferBuffer used for reading/writting to the file server
 */

class CTransferBufferCopy : public CBase
	{
public:
	static CTransferBufferCopy* NewL(TInt aMaxLength);

	virtual ~CTransferBufferCopy()
		{delete iBuffer;}


	TDes8& Des() {return iBufferDes;}

	TInt MaxLength() {return iBufferDes.MaxLength();}

	void ReUse(TInt aMaxLength) {iBufferDes.Set(iBuffer,0, Min(aMaxLength, iMaxLength));}

	TBool InUse() {return iInUse;}

	void SetInUse(TBool aInUse) {iInUse=aInUse;}

private:
	CTransferBufferCopy(TInt aMaxLength) : CBase(), iMaxLength(aMaxLength), iBufferDes(0,0,0), iInUse(EFalse){}

	void ConstructL();

private:
	TUint8*	iBuffer;

	//Holds the original MaxLength when class constructed.
	//May be larger than MaxLength of iBufferDes
	TInt	iMaxLength;

	TPtr8	iBufferDes;

	TBool	iInUse;
	};




/**
 * @internalComponent
 *
 * A request is created when an external object requests or supplies data.  Calls to the File Server are
 * made asynchronously and a CReadWriteRequest created to notify the caller on completion.
 *
 * CReadWriteRequest is an abstract class.  Concrete instances are of CReadRequest & CWriteRequest.
 * Concrete instances need to know whether to call MDataSink::BufferFilledL() or MDataSource::BufferEmptiedL()
 */
class CReadWriteRequest : public CActive
	{
public:
	CReadWriteRequest(TAny* aSinkOrSource, CMMFBuffer* aBuffer,MAsyncEventHandler* aEventHandler)
	: CActive(EPriorityStandard),
	iSinkOrSource(aSinkOrSource),
	iBuffer(aBuffer),
	iEventHandler(aEventHandler)
		{
		CActiveScheduler::Add( this );
		}

	CReadWriteRequest(TAny* aSinkOrSource, CMMFBuffer* aBuffer, CTransferBufferCopy* aOptionalDataBuffer, MAsyncEventHandler* aEventHandler)
	: CActive(EPriorityStandard),
	iSinkOrSource(aSinkOrSource),
	iBuffer(aBuffer),
	iTransferBufferCopy(aOptionalDataBuffer),
	iEventHandler(aEventHandler)
		{
		CActiveScheduler::Add( this );
		iTransferBufferCopy->SetInUse(ETrue);
		}

	CReadWriteRequest(CReadWriteRequest& aRequest)
	: CActive(EPriorityStandard),
	iSinkOrSource(aRequest.iSinkOrSource),
	iBuffer(aRequest.iBuffer),
	iTransferBufferCopy(aRequest.iTransferBufferCopy),
	iEventHandler(aRequest.iEventHandler)
		{
		CActiveScheduler::Add( this );
		iTransferBufferCopy->SetInUse(ETrue);
		}


	TBool Completed() ;
	TDes8& BufferDes() ;
	const TDesC8& BufferDesC() ;

	~CReadWriteRequest() ;


	// CActive functions.
	//
	void SetActive() ;
	void DoCancel() ;
	virtual void RunL() = 0 ;
	virtual TInt RunError( TInt aError ) ;


protected :
	TAny* iSinkOrSource;
	CMMFBuffer* iBuffer;
	CTransferBufferCopy* iTransferBufferCopy;

	MAsyncEventHandler* iEventHandler;
	TBool iCompleted ;
	TDes8* iBufferDes ;
	TInt iError ;
	TBool iUseTransferBuffer ;
	void SetTransferBuffer (TBool aTBuffer) ;
	TBool CanUseTransferBuffer () ;
	} ;

/**
 * @internalComponent
 */
class CReadRequest : public CReadWriteRequest
	{
public :
	CReadRequest(TAny* aSinkOrSource, CMMFBuffer* aBuffer, TUint aPosition, TUint aFileSize, TInt aBytesDownloaded,MAsyncEventHandler* aEventHandler)
	: CReadWriteRequest(aSinkOrSource, aBuffer, aEventHandler),
	iPosition(aPosition), iFileSize(aFileSize),iBytesDownloaded(aBytesDownloaded)
	{ }

	CReadRequest(TAny* aSinkOrSource, CMMFBuffer* aBuffer, CTransferBufferCopy* aOptionalDataBuffer, TUint aPosition, TUint aFileSize,TInt aBytesDownloaded, MAsyncEventHandler* aEventHandler)
	: CReadWriteRequest(aSinkOrSource, aBuffer, aOptionalDataBuffer,aEventHandler),
	iPosition(aPosition), iFileSize(aFileSize),iBytesDownloaded(aBytesDownloaded)
	{ }

	void RunL();
private:
	TUint iPosition;
	TUint iFileSize;
	TInt iBytesDownloaded;
	};

/**
 * @internalComponent
 */
class CWriteRequest : public CReadWriteRequest
	{
public :
	CWriteRequest(TAny* aSinkOrSource, CMMFBuffer* aBuffer, MAsyncEventHandler* aEventHandler)
	: CReadWriteRequest(aSinkOrSource, aBuffer, aEventHandler)
	{ }

	CWriteRequest(TAny* aSinkOrSource, CMMFBuffer* aBuffer, CTransferBufferCopy* aOptionalDataBuffer, MAsyncEventHandler* aEventHandler)
	: CReadWriteRequest(aSinkOrSource, aBuffer, aOptionalDataBuffer, aEventHandler)
	{ }

	void RunL();
	};


#endif