sl@0: // Copyright (c) 2008-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: // Demonstrates performance assesment of direct file store..
sl@0: // The file name, extension and path for the file store
sl@0: // 
sl@0: //
sl@0: 
sl@0: _LIT(KDirectFileStoreName,"Z:\\STOR-TST\\BMDirectFileStores.dat");
sl@0: extern TFileName TheDirectStoreFilePath;
sl@0: 
sl@0: // Create objects externalizes them to a direct file store and then destroys the objects
sl@0: LOCAL_C void doStoreL(const TDesC& aName);
sl@0: 
sl@0: // Constructs "empty" CDFileStoreA, ClassB and CDFileStoreC objects and restores them from the direct file store.
sl@0: LOCAL_C void doRestoreL(const TDesC& aName);
sl@0: 
sl@0: #define DFSTORERUNSIZE	1000
sl@0: 
sl@0: class CDFileStoreA : public CBase
sl@0: 	{
sl@0: public :
sl@0: 	static CDFileStoreA* NewLC();
sl@0: 	~CDFileStoreA();
sl@0: 	void     SetTextL(const TDesC& aData);
sl@0: 	void     ExternalizeL(RWriteStream& aStream) const;
sl@0: 	void     InternalizeL(RReadStream& aStream);
sl@0: public :
sl@0: 	HBufC*   iVarBuffer;
sl@0: 	TInt     iIntValue;
sl@0: 	TUint    iUintValue;
sl@0: 	};
sl@0: 
sl@0: class CDFileStoreB : public CBase
sl@0: 	{
sl@0: public :
sl@0: 	static CDFileStoreB* NewLC();
sl@0: 	void ExternalizeL(RWriteStream& aStream) const;
sl@0: 	void InternalizeL(RReadStream& aStream);
sl@0: public :
sl@0: 	TBuf<32> iFixBuffer;
sl@0: 	TUint    iUintValue;
sl@0: 	TInt     iIntValue;
sl@0: 	TReal    iRealValue;
sl@0: 	};
sl@0: 
sl@0: //#define KStdirectClassCGranularity 4
sl@0: 
sl@0: class CDFileStoreC : public CBase
sl@0: 	{
sl@0: public :
sl@0: 	static CDFileStoreC* NewLC();
sl@0: 	~CDFileStoreC();
sl@0: 	void     ConstructL();
sl@0: 	//void     AddNumberToArrayL(TInt aValue);
sl@0: 	void     AddNumberToArrayL();
sl@0: 	void     ExternalizeL(RWriteStream& aStream) const;
sl@0: 	void     InternalizeL(RReadStream& aStream);
sl@0: public :
sl@0: 	TBuf<32> iFixBuffer;
sl@0: 	CArrayFixFlat<TInt>* iArray;
sl@0: 	CArrayFixFlat<TElement>* nArray;
sl@0: 	};
sl@0: 
sl@0: 
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          SYSLIB-STORE-PT-1362
sl@0: @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.
sl@0: @SYMTestPriority 	High
sl@0: @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.
sl@0: @SYMTestExpectedResults Test must show a performance improvement
sl@0: @SYMPREQ                PREQ1132
sl@0: @SYMREQ			REQ4883
sl@0: */
sl@0: LOCAL_C void doDirectFileStoresL()
sl@0:     {
sl@0:     TDriveUnit drive(static_cast<TUint>(RFs::GetSystemDrive()));	
sl@0: 	TParse directFileStoreName;
sl@0: 	directFileStoreName.Set(drive.Name(), &KDirectFileStoreName, NULL);
sl@0: 	TheDirectStoreFilePath.Copy(directFileStoreName.FullName());
sl@0:     
sl@0:     // make sure directory exists
sl@0: 	TheFs.MkDirAll(directFileStoreName.DriveAndPath());
sl@0: 	
sl@0: 	TTime start;
sl@0: 	start.HomeTime();
sl@0: 	for(int i=0; i<DFSTORERUNSIZE; i++)
sl@0: 		{
sl@0: 		doStoreL(TheDirectStoreFilePath);	
sl@0: 		}
sl@0: 	TTime end;
sl@0: 	end.HomeTime();
sl@0: 	TTimeIntervalMicroSeconds us = end.MicroSecondsFrom(start);
sl@0: 	TheTest.Printf(_L("CDirectFileStore, %d 'write' tests. Time=%ld ms\r\n"), DFSTORERUNSIZE, us.Int64() / 1000);
sl@0: 
sl@0: 	start.HomeTime();
sl@0: 	for(int j=0; j<DFSTORERUNSIZE;j++)
sl@0: 		{
sl@0: 		doRestoreL(TheDirectStoreFilePath);
sl@0: 		}
sl@0: 	end.HomeTime();
sl@0: 	us = end.MicroSecondsFrom(start);
sl@0: 	TheTest.Printf(_L("CDirectFileStore, %d 'read' tests.  Time=%ld ms\r\n"), DFSTORERUNSIZE, us.Int64() / 1000);
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void doStoreL(const TDesC& aName)
sl@0: 	{
sl@0: 	// Construct an object of type CDFileStoreA and put some data into it
sl@0: 	_LIT(KTxtForClassA,"Text for CDFileStoreA");
sl@0: 	CDFileStoreA* theA = CDFileStoreA::NewLC();
sl@0: 	theA->SetTextL(KTxtForClassA);	
sl@0: 	theA->iIntValue  = -1;
sl@0: 	theA->iUintValue = 2;
sl@0: 
sl@0: 	// Construct an object of type CDFileStoreB and put some data into it
sl@0: 	_LIT(KTxtForClassB,"Text for CDFileStoreB");
sl@0: 	CDFileStoreB* theB = CDFileStoreB::NewLC();
sl@0: 	theB->iFixBuffer = KTxtForClassB;
sl@0: 	theB->iIntValue  = -3;
sl@0: 	theB->iUintValue = 4; 
sl@0: 	theB->iRealValue = 5.6;
sl@0: 
sl@0: 	// Construct an object of type CDFileStoreC and put some data into it
sl@0: 	_LIT(KTxtForClassC,"Text for CDFileStoreC");
sl@0: 	CDFileStoreC* theC = CDFileStoreC::NewLC();
sl@0: 	theC->iFixBuffer = KTxtForClassC;	
sl@0: 	theC->AddNumberToArrayL();
sl@0: 	// Create (replace) the direct file store
sl@0: 	CFileStore* store = CDirectFileStore::ReplaceLC(TheFs,aName,EFileWrite);
sl@0: 
sl@0: 	// Must say what kind of file store.
sl@0: 	store->SetTypeL(KDirectFileStoreLayoutUid);
sl@0:     	
sl@0: 	// Construct the output stream.
sl@0: 	RStoreWriteStream outstream;
sl@0: 	TStreamId id = outstream.CreateLC(*store);
sl@0: 
sl@0: 	// Stream out the CDFileStoreA, CDFileStoreB, and the CDFileStoreC object
sl@0: 	outstream  << *theA << *theB << *theC; 
sl@0: 
sl@0: 	// Commit changes to the stream
sl@0: 	outstream.CommitL();
sl@0: 
sl@0:     // Cleanup the stream object
sl@0:     CleanupStack::PopAndDestroy();
sl@0: 
sl@0: 	// Set this stream id as the root
sl@0: 	store->SetRootL(id);
sl@0: 
sl@0: 	// Commit changes to the store
sl@0: 	store->CommitL();
sl@0: 									// store
sl@0: 									// theC
sl@0: 									// theB
sl@0: 	CleanupStack::PopAndDestroy(4); // theA
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void doRestoreL(const TDesC& aName)
sl@0: 	{
sl@0: 	CDFileStoreA* theA = CDFileStoreA::NewLC();
sl@0: 	CDFileStoreB* theB = CDFileStoreB::NewLC();
sl@0: 	CDFileStoreC* theC = CDFileStoreC::NewLC();
sl@0: 					
sl@0: 	// Open the direct file store
sl@0: 	CFileStore* store = CDirectFileStore::OpenLC(TheFs,aName,EFileRead);
sl@0: 
sl@0: 	// Construct and open the root stream which contains the representation of our objects.
sl@0: 	RStoreReadStream instream;
sl@0: 	instream.OpenLC(*store,store->Root());
sl@0: 	
sl@0: 	// Stream in the CDFileStoreA object, the CDFileStoreB object and the CDFileStoreC object
sl@0: 	instream  >> *theA >> *theB >> *theC; 
sl@0: 
sl@0: 	CleanupStack::PopAndDestroy();
sl@0: 	CleanupStack::PopAndDestroy(4);
sl@0: 	}
sl@0: 
sl@0: //***************************************************************
sl@0: CDFileStoreA* CDFileStoreA::NewLC()
sl@0: 	{
sl@0: 	CDFileStoreA* self = new (ELeave) CDFileStoreA;
sl@0: 	CleanupStack::PushL(self);
sl@0: 	return self;
sl@0: 	}
sl@0: 	
sl@0: CDFileStoreA::~CDFileStoreA()
sl@0: 	{
sl@0: 	delete iVarBuffer;
sl@0: 	}
sl@0: 
sl@0: void CDFileStoreA::SetTextL(const TDesC& aData)
sl@0: 	{
sl@0: 	iVarBuffer = aData.AllocL();	
sl@0: 	}
sl@0: 
sl@0: void CDFileStoreA::ExternalizeL(RWriteStream& aStream) const
sl@0: 	{
sl@0: 	aStream.WriteInt32L(iVarBuffer->Des().MaxLength());
sl@0: 	aStream << *iVarBuffer;
sl@0: 	aStream.WriteInt32L(iIntValue);
sl@0: 	aStream.WriteUint32L(iUintValue);
sl@0: 	}  
sl@0:  
sl@0: void CDFileStoreA::InternalizeL(RReadStream& aStream)
sl@0: 	{
sl@0: 	TInt maxlen;
sl@0: 	maxlen     = aStream.ReadInt32L();
sl@0: 	iVarBuffer = HBufC::NewL(aStream,maxlen);
sl@0: 	iIntValue  = aStream.ReadInt32L();
sl@0: 	iUintValue = aStream.ReadUint32L();
sl@0: 	}  
sl@0: 
sl@0: //***************************************************************
sl@0: CDFileStoreB* CDFileStoreB::NewLC()
sl@0: 	{
sl@0: 	CDFileStoreB* self = new (ELeave) CDFileStoreB;
sl@0: 	CleanupStack::PushL(self);
sl@0: 	return self;
sl@0: 	}
sl@0: 
sl@0: void CDFileStoreB::ExternalizeL(RWriteStream& aStream) const
sl@0: 	{
sl@0: 	aStream << iFixBuffer;
sl@0: 	aStream.WriteInt32L(iIntValue);
sl@0: 	aStream.WriteUint32L(iUintValue);
sl@0: 	aStream.WriteReal64L(iRealValue);
sl@0: 	}  
sl@0:  
sl@0: void CDFileStoreB::InternalizeL(RReadStream& aStream)
sl@0: 	{
sl@0: 	aStream >> iFixBuffer;
sl@0: 	iIntValue  = aStream.ReadInt32L();
sl@0: 	iUintValue = aStream.ReadUint32L();
sl@0: 	iRealValue = aStream.ReadReal64L();
sl@0: 	}  
sl@0: 
sl@0: //***************************************************************
sl@0: CDFileStoreC* CDFileStoreC::NewLC()
sl@0: 	{
sl@0: 	CDFileStoreC* self = new (ELeave) CDFileStoreC;
sl@0: 	CleanupStack::PushL(self);
sl@0: 	self->ConstructL();
sl@0: 	return self;
sl@0: 	}
sl@0: 	
sl@0: void CDFileStoreC::ConstructL()
sl@0: 	{
sl@0: 	iArray = new (ELeave) CArrayFixFlat<TInt>(DFSTORERUNSIZE);
sl@0: 	nArray = new (ELeave) CArrayFixFlat<TElement>(DFSTORERUNSIZE);
sl@0: 	}
sl@0: 
sl@0: void CDFileStoreC::AddNumberToArrayL(/*TInt aValue*/)
sl@0: 	{
sl@0: 	TElement theElement;
sl@0: 	_LIT(KFormatTxt,"BenchMarkingDirectFileStore%4u");
sl@0: 	TBuf<256> str(KFormatTxt);
sl@0: 		
sl@0: 	for (TInt index = 0; index < DFSTORERUNSIZE; index++)
sl@0: 		{
sl@0: 		iArray->AppendL((index+99999));
sl@0: 		theElement.iData.Format(KFormatTxt,index);
sl@0: 		nArray->AppendL(theElement);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: CDFileStoreC::~CDFileStoreC()
sl@0: 	{
sl@0: 	delete iArray;
sl@0: 	delete nArray;
sl@0: 	}
sl@0: 
sl@0: void CDFileStoreC::ExternalizeL(RWriteStream& aStream) const
sl@0: 	{
sl@0: 	aStream << iFixBuffer;
sl@0: 
sl@0: 	TInt count = iArray->Count();
sl@0: 	aStream.WriteInt32L(count);
sl@0: 	TElement theElement;
sl@0: 	for (TInt index = 0; index < count; index++)
sl@0: 		{
sl@0: 		aStream.WriteInt32L((*iArray)[index]);
sl@0: 		theElement =((*nArray)[index]);
sl@0: 		aStream.WriteL(theElement.iData, 31);
sl@0: 		}
sl@0: 	}  
sl@0:  
sl@0: void CDFileStoreC::InternalizeL(RReadStream& aStream)
sl@0: 	{
sl@0: 	aStream >> iFixBuffer;
sl@0: 
sl@0: 	TInt count;
sl@0: 	count  = aStream.ReadInt32L();
sl@0: 	TElement theElement;
sl@0: 	//nArray = new (ELeave) CArrayFixFlat<TElement>(10);
sl@0: 	nArray->Reset();
sl@0: 	for (TInt index = 0; index < count; index++)
sl@0: 		{
sl@0: 		iArray->AppendL(aStream.ReadInt32L());
sl@0: 		aStream.ReadL(theElement.iData, 31);
sl@0: 		nArray->AppendL(theElement);
sl@0: 		}
sl@0: 	}