1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/store/TSTOR/T_BMDirectFileStore.inl Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,313 @@
1.4 +// Copyright (c) 2008-2009 Nokia Corporation and/or its subsidiary(-ies).
1.5 +// All rights reserved.
1.6 +// This component and the accompanying materials are made available
1.7 +// under the terms of "Eclipse Public License v1.0"
1.8 +// which accompanies this distribution, and is available
1.9 +// at the URL "http://www.eclipse.org/legal/epl-v10.html".
1.10 +//
1.11 +// Initial Contributors:
1.12 +// Nokia Corporation - initial contribution.
1.13 +//
1.14 +// Contributors:
1.15 +//
1.16 +// Description:
1.17 +// Demonstrates performance assesment of direct file store..
1.18 +// The file name, extension and path for the file store
1.19 +//
1.20 +//
1.21 +
1.22 +_LIT(KDirectFileStoreName,"Z:\\STOR-TST\\BMDirectFileStores.dat");
1.23 +extern TFileName TheDirectStoreFilePath;
1.24 +
1.25 +// Create objects externalizes them to a direct file store and then destroys the objects
1.26 +LOCAL_C void doStoreL(const TDesC& aName);
1.27 +
1.28 +// Constructs "empty" CDFileStoreA, ClassB and CDFileStoreC objects and restores them from the direct file store.
1.29 +LOCAL_C void doRestoreL(const TDesC& aName);
1.30 +
1.31 +#define DFSTORERUNSIZE 1000
1.32 +
1.33 +class CDFileStoreA : public CBase
1.34 + {
1.35 +public :
1.36 + static CDFileStoreA* NewLC();
1.37 + ~CDFileStoreA();
1.38 + void SetTextL(const TDesC& aData);
1.39 + void ExternalizeL(RWriteStream& aStream) const;
1.40 + void InternalizeL(RReadStream& aStream);
1.41 +public :
1.42 + HBufC* iVarBuffer;
1.43 + TInt iIntValue;
1.44 + TUint iUintValue;
1.45 + };
1.46 +
1.47 +class CDFileStoreB : public CBase
1.48 + {
1.49 +public :
1.50 + static CDFileStoreB* NewLC();
1.51 + void ExternalizeL(RWriteStream& aStream) const;
1.52 + void InternalizeL(RReadStream& aStream);
1.53 +public :
1.54 + TBuf<32> iFixBuffer;
1.55 + TUint iUintValue;
1.56 + TInt iIntValue;
1.57 + TReal iRealValue;
1.58 + };
1.59 +
1.60 +//#define KStdirectClassCGranularity 4
1.61 +
1.62 +class CDFileStoreC : public CBase
1.63 + {
1.64 +public :
1.65 + static CDFileStoreC* NewLC();
1.66 + ~CDFileStoreC();
1.67 + void ConstructL();
1.68 + //void AddNumberToArrayL(TInt aValue);
1.69 + void AddNumberToArrayL();
1.70 + void ExternalizeL(RWriteStream& aStream) const;
1.71 + void InternalizeL(RReadStream& aStream);
1.72 +public :
1.73 + TBuf<32> iFixBuffer;
1.74 + CArrayFixFlat<TInt>* iArray;
1.75 + CArrayFixFlat<TElement>* nArray;
1.76 + };
1.77 +
1.78 +
1.79 +
1.80 +/**
1.81 +@SYMTestCaseID SYSLIB-STORE-PT-1362
1.82 +@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.
1.83 +@SYMTestPriority High
1.84 +@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.
1.85 +@SYMTestExpectedResults Test must show a performance improvement
1.86 +@SYMPREQ PREQ1132
1.87 +@SYMREQ REQ4883
1.88 +*/
1.89 +LOCAL_C void doDirectFileStoresL()
1.90 + {
1.91 + TDriveUnit drive(static_cast<TUint>(RFs::GetSystemDrive()));
1.92 + TParse directFileStoreName;
1.93 + directFileStoreName.Set(drive.Name(), &KDirectFileStoreName, NULL);
1.94 + TheDirectStoreFilePath.Copy(directFileStoreName.FullName());
1.95 +
1.96 + // make sure directory exists
1.97 + TheFs.MkDirAll(directFileStoreName.DriveAndPath());
1.98 +
1.99 + TTime start;
1.100 + start.HomeTime();
1.101 + for(int i=0; i<DFSTORERUNSIZE; i++)
1.102 + {
1.103 + doStoreL(TheDirectStoreFilePath);
1.104 + }
1.105 + TTime end;
1.106 + end.HomeTime();
1.107 + TTimeIntervalMicroSeconds us = end.MicroSecondsFrom(start);
1.108 + TheTest.Printf(_L("CDirectFileStore, %d 'write' tests. Time=%ld ms\r\n"), DFSTORERUNSIZE, us.Int64() / 1000);
1.109 +
1.110 + start.HomeTime();
1.111 + for(int j=0; j<DFSTORERUNSIZE;j++)
1.112 + {
1.113 + doRestoreL(TheDirectStoreFilePath);
1.114 + }
1.115 + end.HomeTime();
1.116 + us = end.MicroSecondsFrom(start);
1.117 + TheTest.Printf(_L("CDirectFileStore, %d 'read' tests. Time=%ld ms\r\n"), DFSTORERUNSIZE, us.Int64() / 1000);
1.118 + }
1.119 +
1.120 +LOCAL_C void doStoreL(const TDesC& aName)
1.121 + {
1.122 + // Construct an object of type CDFileStoreA and put some data into it
1.123 + _LIT(KTxtForClassA,"Text for CDFileStoreA");
1.124 + CDFileStoreA* theA = CDFileStoreA::NewLC();
1.125 + theA->SetTextL(KTxtForClassA);
1.126 + theA->iIntValue = -1;
1.127 + theA->iUintValue = 2;
1.128 +
1.129 + // Construct an object of type CDFileStoreB and put some data into it
1.130 + _LIT(KTxtForClassB,"Text for CDFileStoreB");
1.131 + CDFileStoreB* theB = CDFileStoreB::NewLC();
1.132 + theB->iFixBuffer = KTxtForClassB;
1.133 + theB->iIntValue = -3;
1.134 + theB->iUintValue = 4;
1.135 + theB->iRealValue = 5.6;
1.136 +
1.137 + // Construct an object of type CDFileStoreC and put some data into it
1.138 + _LIT(KTxtForClassC,"Text for CDFileStoreC");
1.139 + CDFileStoreC* theC = CDFileStoreC::NewLC();
1.140 + theC->iFixBuffer = KTxtForClassC;
1.141 + theC->AddNumberToArrayL();
1.142 + // Create (replace) the direct file store
1.143 + CFileStore* store = CDirectFileStore::ReplaceLC(TheFs,aName,EFileWrite);
1.144 +
1.145 + // Must say what kind of file store.
1.146 + store->SetTypeL(KDirectFileStoreLayoutUid);
1.147 +
1.148 + // Construct the output stream.
1.149 + RStoreWriteStream outstream;
1.150 + TStreamId id = outstream.CreateLC(*store);
1.151 +
1.152 + // Stream out the CDFileStoreA, CDFileStoreB, and the CDFileStoreC object
1.153 + outstream << *theA << *theB << *theC;
1.154 +
1.155 + // Commit changes to the stream
1.156 + outstream.CommitL();
1.157 +
1.158 + // Cleanup the stream object
1.159 + CleanupStack::PopAndDestroy();
1.160 +
1.161 + // Set this stream id as the root
1.162 + store->SetRootL(id);
1.163 +
1.164 + // Commit changes to the store
1.165 + store->CommitL();
1.166 + // store
1.167 + // theC
1.168 + // theB
1.169 + CleanupStack::PopAndDestroy(4); // theA
1.170 + }
1.171 +
1.172 +LOCAL_C void doRestoreL(const TDesC& aName)
1.173 + {
1.174 + CDFileStoreA* theA = CDFileStoreA::NewLC();
1.175 + CDFileStoreB* theB = CDFileStoreB::NewLC();
1.176 + CDFileStoreC* theC = CDFileStoreC::NewLC();
1.177 +
1.178 + // Open the direct file store
1.179 + CFileStore* store = CDirectFileStore::OpenLC(TheFs,aName,EFileRead);
1.180 +
1.181 + // Construct and open the root stream which contains the representation of our objects.
1.182 + RStoreReadStream instream;
1.183 + instream.OpenLC(*store,store->Root());
1.184 +
1.185 + // Stream in the CDFileStoreA object, the CDFileStoreB object and the CDFileStoreC object
1.186 + instream >> *theA >> *theB >> *theC;
1.187 +
1.188 + CleanupStack::PopAndDestroy();
1.189 + CleanupStack::PopAndDestroy(4);
1.190 + }
1.191 +
1.192 +//***************************************************************
1.193 +CDFileStoreA* CDFileStoreA::NewLC()
1.194 + {
1.195 + CDFileStoreA* self = new (ELeave) CDFileStoreA;
1.196 + CleanupStack::PushL(self);
1.197 + return self;
1.198 + }
1.199 +
1.200 +CDFileStoreA::~CDFileStoreA()
1.201 + {
1.202 + delete iVarBuffer;
1.203 + }
1.204 +
1.205 +void CDFileStoreA::SetTextL(const TDesC& aData)
1.206 + {
1.207 + iVarBuffer = aData.AllocL();
1.208 + }
1.209 +
1.210 +void CDFileStoreA::ExternalizeL(RWriteStream& aStream) const
1.211 + {
1.212 + aStream.WriteInt32L(iVarBuffer->Des().MaxLength());
1.213 + aStream << *iVarBuffer;
1.214 + aStream.WriteInt32L(iIntValue);
1.215 + aStream.WriteUint32L(iUintValue);
1.216 + }
1.217 +
1.218 +void CDFileStoreA::InternalizeL(RReadStream& aStream)
1.219 + {
1.220 + TInt maxlen;
1.221 + maxlen = aStream.ReadInt32L();
1.222 + iVarBuffer = HBufC::NewL(aStream,maxlen);
1.223 + iIntValue = aStream.ReadInt32L();
1.224 + iUintValue = aStream.ReadUint32L();
1.225 + }
1.226 +
1.227 +//***************************************************************
1.228 +CDFileStoreB* CDFileStoreB::NewLC()
1.229 + {
1.230 + CDFileStoreB* self = new (ELeave) CDFileStoreB;
1.231 + CleanupStack::PushL(self);
1.232 + return self;
1.233 + }
1.234 +
1.235 +void CDFileStoreB::ExternalizeL(RWriteStream& aStream) const
1.236 + {
1.237 + aStream << iFixBuffer;
1.238 + aStream.WriteInt32L(iIntValue);
1.239 + aStream.WriteUint32L(iUintValue);
1.240 + aStream.WriteReal64L(iRealValue);
1.241 + }
1.242 +
1.243 +void CDFileStoreB::InternalizeL(RReadStream& aStream)
1.244 + {
1.245 + aStream >> iFixBuffer;
1.246 + iIntValue = aStream.ReadInt32L();
1.247 + iUintValue = aStream.ReadUint32L();
1.248 + iRealValue = aStream.ReadReal64L();
1.249 + }
1.250 +
1.251 +//***************************************************************
1.252 +CDFileStoreC* CDFileStoreC::NewLC()
1.253 + {
1.254 + CDFileStoreC* self = new (ELeave) CDFileStoreC;
1.255 + CleanupStack::PushL(self);
1.256 + self->ConstructL();
1.257 + return self;
1.258 + }
1.259 +
1.260 +void CDFileStoreC::ConstructL()
1.261 + {
1.262 + iArray = new (ELeave) CArrayFixFlat<TInt>(DFSTORERUNSIZE);
1.263 + nArray = new (ELeave) CArrayFixFlat<TElement>(DFSTORERUNSIZE);
1.264 + }
1.265 +
1.266 +void CDFileStoreC::AddNumberToArrayL(/*TInt aValue*/)
1.267 + {
1.268 + TElement theElement;
1.269 + _LIT(KFormatTxt,"BenchMarkingDirectFileStore%4u");
1.270 + TBuf<256> str(KFormatTxt);
1.271 +
1.272 + for (TInt index = 0; index < DFSTORERUNSIZE; index++)
1.273 + {
1.274 + iArray->AppendL((index+99999));
1.275 + theElement.iData.Format(KFormatTxt,index);
1.276 + nArray->AppendL(theElement);
1.277 + }
1.278 + }
1.279 +
1.280 +CDFileStoreC::~CDFileStoreC()
1.281 + {
1.282 + delete iArray;
1.283 + delete nArray;
1.284 + }
1.285 +
1.286 +void CDFileStoreC::ExternalizeL(RWriteStream& aStream) const
1.287 + {
1.288 + aStream << iFixBuffer;
1.289 +
1.290 + TInt count = iArray->Count();
1.291 + aStream.WriteInt32L(count);
1.292 + TElement theElement;
1.293 + for (TInt index = 0; index < count; index++)
1.294 + {
1.295 + aStream.WriteInt32L((*iArray)[index]);
1.296 + theElement =((*nArray)[index]);
1.297 + aStream.WriteL(theElement.iData, 31);
1.298 + }
1.299 + }
1.300 +
1.301 +void CDFileStoreC::InternalizeL(RReadStream& aStream)
1.302 + {
1.303 + aStream >> iFixBuffer;
1.304 +
1.305 + TInt count;
1.306 + count = aStream.ReadInt32L();
1.307 + TElement theElement;
1.308 + //nArray = new (ELeave) CArrayFixFlat<TElement>(10);
1.309 + nArray->Reset();
1.310 + for (TInt index = 0; index < count; index++)
1.311 + {
1.312 + iArray->AppendL(aStream.ReadInt32L());
1.313 + aStream.ReadL(theElement.iData, 31);
1.314 + nArray->AppendL(theElement);
1.315 + }
1.316 + }