1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/store/TSTOR/T_BMStreams.inl Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,296 @@
1.4 +// Copyright (c) 2008-2010 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 +// This is the file name, extension and path specification for the file store
1.18 +// and should not be used as is
1.19 +//
1.20 +//
1.21 +
1.22 +_LIT(KStreamsName, "Z:\\STOR-TST\\BMStreams.dat");
1.23 +extern TFileName TheStreamsFilePath;
1.24 +
1.25 +// Construct CCompound object and externalize it to a single stream
1.26 +LOCAL_C void doExternalizeL(const TDesC& aName);
1.27 +
1.28 +// Internalize CCompound object from the stream
1.29 +LOCAL_C void doInternalizeL(const TDesC& aName);
1.30 +
1.31 +#define STREAMRUNSIZE 500
1.32 +// Declare a class used by the example
1.33 +class CStreamA
1.34 + {
1.35 +public :
1.36 + void ExternalizeL(RWriteStream& aStream) const;
1.37 + void InternalizeL(RReadStream& aStream);
1.38 +public :
1.39 + TBuf<32> iBufferA;
1.40 + TInt iXA;
1.41 + TUint iYA;
1.42 + };
1.43 +
1.44 +class TStream
1.45 + {
1.46 +public :
1.47 + void ExternalizeL(RWriteStream& aStream) const;
1.48 + void InternalizeL(RReadStream& aStream);
1.49 +public :
1.50 + TReal iZC;
1.51 + };
1.52 +
1.53 +class CCompound : public CBase
1.54 + {
1.55 +public :
1.56 + ~CCompound();
1.57 + static CCompound* NewLC();
1.58 + static CCompound* NewLC(CStreamStore& aStore,TStreamId anId);
1.59 + static CCompound* NewL(CStreamStore& aStore,TStreamId anId);
1.60 + TStreamId StoreL(CStreamStore& store);
1.61 + void RestoreL(CStreamStore& aStore,TStreamId anId);
1.62 + void InternalizeL(RReadStream& aStream);
1.63 + void ExternalizeL(RWriteStream& aStream) const;
1.64 +private:
1.65 + void ConstructL();
1.66 + void ConstructL(CStreamStore& aStore,TStreamId anId);
1.67 +public :
1.68 + CStreamA* iCa;
1.69 + TStream iTc;
1.70 + CArrayFixFlat<TElement>* iArray;
1.71 + };
1.72 +
1.73 +
1.74 +/**
1.75 +@SYMTestCaseID SYSLIB-STORE-PT-1369
1.76 +@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.77 +@SYMTestPriority High
1.78 +@SYMTestActions The test creates a set of test objects, externalizes them STREAMRUNSIZE times and prints the execution time. Then internalizes them STREAMRUNSIZE times and prints the execution time.
1.79 +STREAMRUNSIZE is a constant, defined in the source file.
1.80 +@SYMTestExpectedResults Test must show a performance improvement
1.81 +@SYMPREQ PREQ1132
1.82 +@SYMREQ REQ4883
1.83 +*/
1.84 +LOCAL_C void doStreamingL()
1.85 + {
1.86 + TDriveUnit drive(static_cast<TUint>(RFs::GetSystemDrive()));
1.87 + TParse streamsName;
1.88 + streamsName.Set(drive.Name(), &KStreamsName, NULL);
1.89 + TheStreamsFilePath.Copy(streamsName.FullName());
1.90 +
1.91 + // make sure directory exists
1.92 + TheFs.MkDirAll(streamsName.DriveAndPath());
1.93 + TTime start;
1.94 + start.HomeTime();
1.95 + for(int i=0; i<STREAMRUNSIZE;i++)
1.96 + {
1.97 + doExternalizeL(TheStreamsFilePath);
1.98 + }
1.99 + TTime end;
1.100 + end.HomeTime();
1.101 + TTimeIntervalMicroSeconds us = end.MicroSecondsFrom(start);
1.102 + TheTest.Printf(_L("CDirectFileStore, externalise %d streams. Time=%ld ms\r\n"), STREAMRUNSIZE, us.Int64() / 1000);
1.103 +
1.104 + start.HomeTime();
1.105 + for(int j=0; j<STREAMRUNSIZE;j++)
1.106 + {
1.107 + doInternalizeL(TheStreamsFilePath);
1.108 + }
1.109 + end.HomeTime();
1.110 + us = end.MicroSecondsFrom(start);
1.111 + TheTest.Printf(_L("CDirectFileStore, internalise %d streams. Time=%ld ms\r\n"), STREAMRUNSIZE, us.Int64() / 1000);
1.112 + }
1.113 +
1.114 +LOCAL_C void doExternalizeL(const TDesC& aName)
1.115 + {
1.116 + // construct file store object - the file to contain the store
1.117 + CFileStore* store = CDirectFileStore::ReplaceLC(TheFs,aName,EFileWrite);
1.118 +
1.119 + // Must say what kind of file store
1.120 + store->SetTypeL(KDirectFileStoreLayoutUid);
1.121 +
1.122 + // Construct an object of type CCompound and prepare some data into it
1.123 + CCompound* thecompound = CCompound::NewLC();
1.124 +
1.125 + _LIT(KTxtClassAText,"CStreamA text");
1.126 +
1.127 + thecompound->iCa->iBufferA = KTxtClassAText;
1.128 + thecompound->iCa->iXA = -1;
1.129 + thecompound->iCa->iYA = 2;
1.130 + thecompound->iTc.iZC = 3.456;
1.131 +
1.132 + TElement theElement;
1.133 + _LIT(KFormatTxt,"BenchMarkingTheStream%4u");
1.134 + TBuf<256> str(KFormatTxt);
1.135 +
1.136 + for (TInt index = 0; index < STREAMRUNSIZE; index++)
1.137 + {
1.138 + theElement.iData.Format(KFormatTxt,index);
1.139 + thecompound->iArray->AppendL(theElement);
1.140 + }
1.141 +
1.142 + // Store the compound object to a single stream and save the stream id as the root id
1.143 + TStreamId id = thecompound->StoreL(*store);
1.144 +
1.145 + // Set the stream id as the root
1.146 + store->SetRootL(id);
1.147 +
1.148 + // Commit changes to the store
1.149 + store->CommitL();
1.150 + // thecompound
1.151 + CleanupStack::PopAndDestroy(2); // store
1.152 + }
1.153 +
1.154 +LOCAL_C void doInternalizeL(const TDesC& aName)
1.155 + {
1.156 + //Create file store object - specifying the file containing the store.
1.157 + CFileStore* store = CDirectFileStore::OpenLC(TheFs,aName,EFileRead);
1.158 +
1.159 + // Construct a CCompound object from the root stream created earlier.
1.160 + CCompound* thecompound = CCompound::NewL(*store,store->Root());
1.161 +
1.162 + // destroy the store object (this also closes the file containing the store)
1.163 + CleanupStack::PopAndDestroy();
1.164 + // Now destroy the CCompound object
1.165 + delete thecompound;
1.166 + }
1.167 +
1.168 +//***************************************************************
1.169 +
1.170 +// The CCompound destructor
1.171 +CCompound::~CCompound()
1.172 + {
1.173 + delete iCa;
1.174 + delete iArray;
1.175 + }
1.176 +
1.177 +CCompound* CCompound::NewLC()
1.178 + {
1.179 + CCompound* self=new (ELeave) CCompound;
1.180 + CleanupStack::PushL(self);
1.181 + self->ConstructL();
1.182 + return self;
1.183 + }
1.184 +
1.185 +void CCompound::ConstructL()
1.186 + {
1.187 + iCa = new (ELeave) CStreamA;
1.188 + iArray = new (ELeave) CArrayFixFlat<TElement>(10);
1.189 + }
1.190 +
1.191 +// Construct a new CCompound object from the input stream.
1.192 +CCompound* CCompound::NewL(CStreamStore& aStore,TStreamId anId)
1.193 + {
1.194 + CCompound* self=CCompound::NewLC(aStore,anId);
1.195 + CleanupStack::Pop();
1.196 + return self;
1.197 + }
1.198 +
1.199 +// Construct CCompound object from the root stream of the store
1.200 +CCompound* CCompound::NewLC(CStreamStore& aStore,TStreamId anId)
1.201 + {
1.202 + CCompound* self=new (ELeave) CCompound;
1.203 + CleanupStack::PushL(self);
1.204 + self->ConstructL(aStore,anId);
1.205 + return self;
1.206 + }
1.207 +
1.208 +void CCompound::ConstructL(CStreamStore& aStore,TStreamId anId)
1.209 + {
1.210 + iCa = new (ELeave) CStreamA;
1.211 + // Restore here at construction
1.212 + RestoreL(aStore,anId);
1.213 + }
1.214 +
1.215 +void CCompound::RestoreL(CStreamStore& aStore,TStreamId anId)
1.216 + {
1.217 + RStoreReadStream instream;
1.218 + instream.OpenLC(aStore,anId);
1.219 + InternalizeL(instream);
1.220 + // Cleanup the stream object
1.221 + CleanupStack::PopAndDestroy();
1.222 + }
1.223 +
1.224 +// Read the components and data members of the CCompound object from stream
1.225 +void CCompound::InternalizeL(RReadStream& aStream)
1.226 + {
1.227 + aStream >> *iCa;
1.228 + aStream >> iTc;
1.229 +
1.230 + TElement theElement;
1.231 + iArray = new (ELeave) CArrayFixFlat<TElement>(STREAMRUNSIZE);
1.232 +// iArray->Count();
1.233 +// iArray->Reset();
1.234 + for (TInt index = 0; index < STREAMRUNSIZE ; index++)
1.235 + {
1.236 + aStream.ReadL(theElement.iData, 25);
1.237 + iArray->AppendL(theElement);
1.238 + }
1.239 + }
1.240 +
1.241 +TStreamId CCompound::StoreL(CStreamStore& aStore)
1.242 + {
1.243 + RStoreWriteStream outstream;
1.244 + TStreamId id = outstream.CreateLC(aStore);
1.245 + // Stream out this CCompound object
1.246 + ExternalizeL(outstream);
1.247 + // Commit changes to the stream
1.248 + outstream.CommitL();
1.249 + // Cleanup the stream object.
1.250 + CleanupStack::PopAndDestroy();
1.251 + return id;
1.252 + }
1.253 +
1.254 +// Write the components and data members of the CCompound object to stream
1.255 +void CCompound::ExternalizeL(RWriteStream& aStream) const
1.256 + {
1.257 + aStream << *iCa;
1.258 + aStream << iTc;
1.259 +
1.260 + TElement theElement;
1.261 + TInt count = iArray->Count();
1.262 + for (TInt index = 0; index < count; index++)
1.263 + {
1.264 + theElement =((*iArray)[index]);
1.265 + aStream.WriteL(theElement.iData, 25);
1.266 + }
1.267 + }
1.268 +
1.269 +//***************************************************************
1.270 +
1.271 +// Read the data members of the CStreamA object from the stream.
1.272 +void CStreamA::InternalizeL(RReadStream& aStream)
1.273 + {
1.274 + aStream >> iBufferA;
1.275 + iXA = aStream.ReadInt32L();
1.276 + iYA = aStream.ReadUint32L();
1.277 + }
1.278 +// Write the data members of the CStreamA object to the stream
1.279 +void CStreamA::ExternalizeL(RWriteStream& aStream)const
1.280 + {
1.281 + aStream << iBufferA;
1.282 + aStream.WriteInt32L(iXA);
1.283 + aStream.WriteUint32L(iYA);
1.284 + }
1.285 +
1.286 +//***************************************************************
1.287 +
1.288 +// Write the data member(s) of the TStream object to the stream
1.289 +void TStream::ExternalizeL(RWriteStream& aStream) const
1.290 + {
1.291 + aStream.WriteReal64L(iZC);
1.292 + }
1.293 +
1.294 +// Read the data member(s) of the TStream object from the stream.
1.295 +void TStream::InternalizeL(RReadStream& aStream)
1.296 + {
1.297 + iZC = aStream.ReadReal64L();
1.298 + }
1.299 +