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

// Demonstrates performance assesment of direct file store..

// The file name, extension and path for the file store

// 

//

_LIT(KDirectFileStoreName,"Z:\\STOR-TST\\BMDirectFileStores.dat");

extern TFileName TheDirectStoreFilePath;

// Create objects externalizes them to a direct file store and then destroys the objects

LOCAL_C void doStoreL(const TDesC& aName);

// Constructs "empty" CDFileStoreA, ClassB and CDFileStoreC objects and restores them from the direct file store.

LOCAL_C void doRestoreL(const TDesC& aName);

#define DFSTORERUNSIZE	1000

class CDFileStoreA : public CBase

	{

public :

	static CDFileStoreA* NewLC();

	~CDFileStoreA();

	void     SetTextL(const TDesC& aData);

	void     ExternalizeL(RWriteStream& aStream) const;

	void     InternalizeL(RReadStream& aStream);

public :

	HBufC*   iVarBuffer;

	TInt     iIntValue;

	TUint    iUintValue;

	};

class CDFileStoreB : public CBase

	{

public :

	static CDFileStoreB* NewLC();

	void ExternalizeL(RWriteStream& aStream) const;

	void InternalizeL(RReadStream& aStream);

public :

	TBuf<32> iFixBuffer;

	TUint    iUintValue;

	TInt     iIntValue;

	TReal    iRealValue;

	};

//#define KStdirectClassCGranularity 4

class CDFileStoreC : public CBase

	{

public :

	static CDFileStoreC* NewLC();

	~CDFileStoreC();

	void     ConstructL();

	//void     AddNumberToArrayL(TInt aValue);

	void     AddNumberToArrayL();

	void     ExternalizeL(RWriteStream& aStream) const;

	void     InternalizeL(RReadStream& aStream);

public :

	TBuf<32> iFixBuffer;

	CArrayFixFlat<TInt>* iArray;

	CArrayFixFlat<TElement>* nArray;

	};

/**

@SYMTestCaseID          SYSLIB-STORE-PT-1362

@SYMTestCaseDesc	CR MRLM-6A9DF7. Tests the impact of RFileBuf cache size on CDirectFileStore performance. RFileBuf cache size must be set at a build time in EStor_Template.mmh file, DEFAULT_FILE_BUF_SIZE macro definition.

@SYMTestPriority 	High

@SYMTestActions  	The test creates a set of test objects, externalizes them DFSTORERUNSIZE times and prints the execution time. Then internalizes them DFSTORERUNSIZE times and prints the execution time. DFSTORERUNSIZE is a constant, defined in the source file.

@SYMTestExpectedResults Test must show a performance improvement

@SYMPREQ                PREQ1132

@SYMREQ			REQ4883

*/

LOCAL_C void doDirectFileStoresL()

    {

    TDriveUnit drive(static_cast<TUint>(RFs::GetSystemDrive()));	

	TParse directFileStoreName;

	directFileStoreName.Set(drive.Name(), &KDirectFileStoreName, NULL);

	TheDirectStoreFilePath.Copy(directFileStoreName.FullName());

    // make sure directory exists

	TheFs.MkDirAll(directFileStoreName.DriveAndPath());

	TTime start;

	start.HomeTime();

	for(int i=0; i<DFSTORERUNSIZE; i++)

		{

		doStoreL(TheDirectStoreFilePath);	

		}

	TTime end;

	end.HomeTime();

	TTimeIntervalMicroSeconds us = end.MicroSecondsFrom(start);

	TheTest.Printf(_L("CDirectFileStore, %d 'write' tests. Time=%ld ms\r\n"), DFSTORERUNSIZE, us.Int64() / 1000);

	start.HomeTime();

	for(int j=0; j<DFSTORERUNSIZE;j++)

		{

		doRestoreL(TheDirectStoreFilePath);

		}

	end.HomeTime();

	us = end.MicroSecondsFrom(start);

	TheTest.Printf(_L("CDirectFileStore, %d 'read' tests.  Time=%ld ms\r\n"), DFSTORERUNSIZE, us.Int64() / 1000);

	}

LOCAL_C void doStoreL(const TDesC& aName)

	{

	// Construct an object of type CDFileStoreA and put some data into it

	_LIT(KTxtForClassA,"Text for CDFileStoreA");

	CDFileStoreA* theA = CDFileStoreA::NewLC();

	theA->SetTextL(KTxtForClassA);	

	theA->iIntValue  = -1;

	theA->iUintValue = 2;

	// Construct an object of type CDFileStoreB and put some data into it

	_LIT(KTxtForClassB,"Text for CDFileStoreB");

	CDFileStoreB* theB = CDFileStoreB::NewLC();

	theB->iFixBuffer = KTxtForClassB;

	theB->iIntValue  = -3;

	theB->iUintValue = 4; 

	theB->iRealValue = 5.6;

	// Construct an object of type CDFileStoreC and put some data into it

	_LIT(KTxtForClassC,"Text for CDFileStoreC");

	CDFileStoreC* theC = CDFileStoreC::NewLC();

	theC->iFixBuffer = KTxtForClassC;	

	theC->AddNumberToArrayL();

	// Create (replace) the direct file store

	CFileStore* store = CDirectFileStore::ReplaceLC(TheFs,aName,EFileWrite);

	// Must say what kind of file store.

	store->SetTypeL(KDirectFileStoreLayoutUid);

	// Construct the output stream.

	RStoreWriteStream outstream;

	TStreamId id = outstream.CreateLC(*store);

	// Stream out the CDFileStoreA, CDFileStoreB, and the CDFileStoreC object

	outstream  << *theA << *theB << *theC; 

	// Commit changes to the stream

	outstream.CommitL();

    // Cleanup the stream object

    CleanupStack::PopAndDestroy();

	// Set this stream id as the root

	store->SetRootL(id);

	// Commit changes to the store

	store->CommitL();

									// store

									// theC

									// theB

	CleanupStack::PopAndDestroy(4); // theA

	}

LOCAL_C void doRestoreL(const TDesC& aName)

	{

	CDFileStoreA* theA = CDFileStoreA::NewLC();

	CDFileStoreB* theB = CDFileStoreB::NewLC();

	CDFileStoreC* theC = CDFileStoreC::NewLC();

	// Open the direct file store

	CFileStore* store = CDirectFileStore::OpenLC(TheFs,aName,EFileRead);

	// Construct and open the root stream which contains the representation of our objects.

	RStoreReadStream instream;

	instream.OpenLC(*store,store->Root());

	// Stream in the CDFileStoreA object, the CDFileStoreB object and the CDFileStoreC object

	instream  >> *theA >> *theB >> *theC; 

	CleanupStack::PopAndDestroy();

	CleanupStack::PopAndDestroy(4);

	}

//***************************************************************

CDFileStoreA* CDFileStoreA::NewLC()

	{

	CDFileStoreA* self = new (ELeave) CDFileStoreA;

	CleanupStack::PushL(self);

	return self;

	}

CDFileStoreA::~CDFileStoreA()

	{

	delete iVarBuffer;

	}

void CDFileStoreA::SetTextL(const TDesC& aData)

	{

	iVarBuffer = aData.AllocL();	

	}

void CDFileStoreA::ExternalizeL(RWriteStream& aStream) const

	{

	aStream.WriteInt32L(iVarBuffer->Des().MaxLength());

	aStream << *iVarBuffer;

	aStream.WriteInt32L(iIntValue);

	aStream.WriteUint32L(iUintValue);

	}  

void CDFileStoreA::InternalizeL(RReadStream& aStream)

	{

	TInt maxlen;

	maxlen     = aStream.ReadInt32L();

	iVarBuffer = HBufC::NewL(aStream,maxlen);

	iIntValue  = aStream.ReadInt32L();

	iUintValue = aStream.ReadUint32L();

	}  

//***************************************************************

CDFileStoreB* CDFileStoreB::NewLC()

	{

	CDFileStoreB* self = new (ELeave) CDFileStoreB;

	CleanupStack::PushL(self);

	return self;

	}

void CDFileStoreB::ExternalizeL(RWriteStream& aStream) const

	{

	aStream << iFixBuffer;

	aStream.WriteInt32L(iIntValue);

	aStream.WriteUint32L(iUintValue);

	aStream.WriteReal64L(iRealValue);

	}  

void CDFileStoreB::InternalizeL(RReadStream& aStream)

	{

	aStream >> iFixBuffer;

	iIntValue  = aStream.ReadInt32L();

	iUintValue = aStream.ReadUint32L();

	iRealValue = aStream.ReadReal64L();

	}  

//***************************************************************

CDFileStoreC* CDFileStoreC::NewLC()

	{

	CDFileStoreC* self = new (ELeave) CDFileStoreC;

	CleanupStack::PushL(self);

	self->ConstructL();

	return self;

	}

void CDFileStoreC::ConstructL()

	{

	iArray = new (ELeave) CArrayFixFlat<TInt>(DFSTORERUNSIZE);

	nArray = new (ELeave) CArrayFixFlat<TElement>(DFSTORERUNSIZE);

	}

void CDFileStoreC::AddNumberToArrayL(/*TInt aValue*/)

	{

	TElement theElement;

	_LIT(KFormatTxt,"BenchMarkingDirectFileStore%4u");

	TBuf<256> str(KFormatTxt);

	for (TInt index = 0; index < DFSTORERUNSIZE; index++)

		{

		iArray->AppendL((index+99999));

		theElement.iData.Format(KFormatTxt,index);

		nArray->AppendL(theElement);

		}

	}

CDFileStoreC::~CDFileStoreC()

	{

	delete iArray;

	delete nArray;

	}

void CDFileStoreC::ExternalizeL(RWriteStream& aStream) const

	{

	aStream << iFixBuffer;

	TInt count = iArray->Count();

	aStream.WriteInt32L(count);

	TElement theElement;

	for (TInt index = 0; index < count; index++)

		{

		aStream.WriteInt32L((*iArray)[index]);

		theElement =((*nArray)[index]);

		aStream.WriteL(theElement.iData, 31);

		}

	}  

void CDFileStoreC::InternalizeL(RReadStream& aStream)

	{

	aStream >> iFixBuffer;

	TInt count;

	count  = aStream.ReadInt32L();

	TElement theElement;

	//nArray = new (ELeave) CArrayFixFlat<TElement>(10);

	nArray->Reset();

	for (TInt index = 0; index < count; index++)

		{

		iArray->AppendL(aStream.ReadInt32L());

		aStream.ReadL(theElement.iData, 31);

		nArray->AppendL(theElement);

		}

	}