1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/store/TFILE/t_storfrecl.cpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,265 @@
1.4 +// Copyright (c) 1998-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 +//
1.18 +
1.19 +#include <s32file.h>
1.20 +#include <e32test.h>
1.21 +#include <e32math.h>
1.22 +#include <hal.h>
1.23 +
1.24 +// This is a path specification and should not be used as is
1.25 +_LIT(KFileLocationSpec, "Z:\\STOR-TST\\T_FRECL.DAT");
1.26 +const TPtrC KTestText=_L("Reclamation testing in progress...");
1.27 +const TInt KTestStreams=1000;
1.28 +const TInt KTestReplicas=5000;
1.29 +
1.30 +TFileName TheFileName;
1.31 +
1.32 +RTest TheTest(_L("t_storfrecl"));
1.33 +RFs TheFs;
1.34 +TInt64 TheSeed;
1.35 +
1.36 +///////////////////////////////////////////////////////////////////////////////////////
1.37 +
1.38 +void DeleteDataFile(const TDesC& aFullName)
1.39 + {
1.40 + RFs fsSession;
1.41 + TInt err = fsSession.Connect();
1.42 + if(err == KErrNone)
1.43 + {
1.44 + TEntry entry;
1.45 + if(fsSession.Entry(aFullName, entry) == KErrNone)
1.46 + {
1.47 + RDebug::Print(_L("Deleting \"%S\" file.\n"), &aFullName);
1.48 + err = fsSession.SetAtt(aFullName, 0, KEntryAttReadOnly);
1.49 + if(err != KErrNone)
1.50 + {
1.51 + RDebug::Print(_L("Error %d changing \"%S\" file attributes.\n"), err, &aFullName);
1.52 + }
1.53 + err = fsSession.Delete(aFullName);
1.54 + if(err != KErrNone)
1.55 + {
1.56 + RDebug::Print(_L("Error %d deleting \"%S\" file.\n"), err, &aFullName);
1.57 + }
1.58 + }
1.59 + fsSession.Close();
1.60 + }
1.61 + else
1.62 + {
1.63 + RDebug::Print(_L("Error %d connecting file session. File: %S.\n"), err, &aFullName);
1.64 + }
1.65 + }
1.66 +
1.67 +///////////////////////////////////////////////////////////////////////////////////////
1.68 +//Test macros and functions
1.69 +void Check(TInt aValue, TInt aLine)
1.70 + {
1.71 + if(!aValue)
1.72 + {
1.73 + TheTest.Printf(_L("*** Boolean expression evaluated to false\r\n"));
1.74 + DeleteDataFile(TheFileName);
1.75 + TheTest(EFalse, aLine);
1.76 + }
1.77 + }
1.78 +void Check(TInt aValue, TInt aExpected, TInt aLine)
1.79 + {
1.80 + if(aValue != aExpected)
1.81 + {
1.82 + DeleteDataFile(TheFileName);
1.83 + TheTest.Printf(_L("*** Expected error: %d, got: %d\r\n"), aExpected, aValue);
1.84 + TheTest(EFalse, aLine);
1.85 + }
1.86 + }
1.87 +#define TEST(arg) ::Check((arg), __LINE__)
1.88 +#define TEST2(aValue, aExpected) ::Check(aValue, aExpected, __LINE__)
1.89 +
1.90 +///////////////////////////////////////////////////////////////////////////////////////
1.91 +
1.92 +static TInt TheCounterFreq = -10000000;
1.93 +const TInt KMicroSecIn1Sec = 1000000;
1.94 +
1.95 +TUint32 CalcTickDiff(TUint32 aStartTicks, TUint32 aEndTicks)
1.96 + {
1.97 + TInt64 diffTicks = (TInt64)aEndTicks - (TInt64)aStartTicks;
1.98 + if(diffTicks < 0)
1.99 + {
1.100 + diffTicks = KMaxTUint32 + diffTicks + 1;
1.101 + }
1.102 + return (TUint32)diffTicks;
1.103 + }
1.104 +
1.105 +//Prints aFastCount parameter (converted to us) and the bytes count
1.106 +void PrintFcDiffAsUs2(const TDesC& aFormatStr, TInt aBytes, TUint32 aFastCount)
1.107 + {
1.108 + if(TheCounterFreq <= 0)
1.109 + {
1.110 + TEST2(HAL::Get(HAL::EFastCounterFrequency, TheCounterFreq), KErrNone);
1.111 + TheTest.Printf(_L("Counter frequency=%d Hz\r\n"), TheCounterFreq);
1.112 + }
1.113 + double v = ((double)aFastCount * KMicroSecIn1Sec) / (double)TheCounterFreq;
1.114 + TInt v2 = (TInt)v;
1.115 + TheTest.Printf(aFormatStr, aBytes, v2);
1.116 + }
1.117 +
1.118 +///////////////////////////////////////////////////////////////////////////////////////
1.119 +
1.120 +TInt ReclaimL(CStreamStore& aStore)
1.121 + {
1.122 + TUint32 fc = User::FastCounter();
1.123 + TInt total = aStore.ReclaimL();
1.124 + TUint32 time = CalcTickDiff(fc, User::FastCounter());
1.125 + PrintFcDiffAsUs2(_L("### CStreamStore::ReclaimL(), %d bytes reclaimable, Time=%d us\r\n"), total, time);
1.126 + return total;
1.127 + }
1.128 +/**
1.129 +@SYMTestCaseID SYSLIB-STORE-CT-1159
1.130 +@SYMTestCaseDesc Tests CStreamStore::ReclaimL() function
1.131 +@SYMTestPriority High
1.132 +@SYMTestActions Tests for reclaiming the space on the store.
1.133 + Tests for an empty store,simple and a complex store.
1.134 +@SYMTestExpectedResults Test must not fail
1.135 +@SYMREQ REQ0000
1.136 +*/
1.137 +void ReclaimTestL()
1.138 + {
1.139 + TheTest.Start(_L(" @SYMTestCaseID:SYSLIB-STORE-CT-1159 CPermanentFileStore::ReclaimL()"));
1.140 +
1.141 + TheTest.Printf(_L(" Empty store\r\n"));
1.142 + CFileStore* store = CPermanentFileStore::ReplaceLC(TheFs, TheFileName, EFileRead | EFileWrite);
1.143 + store->SetTypeL(store->Layout());
1.144 + TInt bytes = ReclaimL(*store);
1.145 + TEST2(bytes, 0);
1.146 +
1.147 + TheTest.Printf(_L(" Simple store\r\n"));
1.148 + RStoreWriteStream strm;
1.149 + TStreamId id=strm.CreateLC(*store);
1.150 + strm<<KTestText;
1.151 + strm.CommitL();
1.152 + strm.Release();
1.153 + store->CommitL();
1.154 + (void)ReclaimL(*store);
1.155 +
1.156 + TheTest.Printf(_L(" Complex store\r\n"));
1.157 + TInt ii;
1.158 + for (ii=0;ii<KTestStreams;++ii)
1.159 + {
1.160 + id=strm.CreateL(*store);
1.161 + TInt val=Math::Rand(TheSeed);
1.162 + TInt len=(val>>11)%(KTestText.Length()+1);
1.163 + if (len>0)
1.164 + strm<<KTestText.Left(len-1);
1.165 + strm.CommitL();
1.166 + strm.Release();
1.167 + if ((val>>7)&1)
1.168 + store->DeleteL(id);
1.169 + }
1.170 + store->CommitL();
1.171 + (void)ReclaimL(*store);
1.172 +
1.173 + TheTest.Printf(_L(" Large stream\r\n"));
1.174 + id=strm.CreateL(*store);
1.175 + for (ii=0;ii<KTestReplicas;++ii)
1.176 + strm<<KTestText;
1.177 + strm.CommitL();
1.178 + strm.Release();
1.179 + store->CommitL();
1.180 + (void)ReclaimL(*store);
1.181 +
1.182 + TheTest.Printf(_L(" Deleted large stream\r\n"));
1.183 + store->DeleteL(id);
1.184 + store->CommitL();
1.185 + (void)ReclaimL(*store);
1.186 +
1.187 + TheTest.Printf(_L(" Mixed reclaim and commit\r\n"));
1.188 + RStoreReclaim reclaim;
1.189 + TInt step;
1.190 + reclaim.OpenLC(*store,step);
1.191 + TRequestStatus status;
1.192 + TPckgBuf<TInt> pckgStep(step);
1.193 + TRAPD(r, reclaim.NextL(pckgStep,status));
1.194 + TEST2(r, KErrNone);
1.195 + User::WaitForRequest(status);
1.196 + TEST2(status.Int(), KErrNone);
1.197 + TEST(step>0);
1.198 + strm.CreateL(*store);
1.199 + strm<<KTestText;
1.200 + strm.CommitL();
1.201 + strm.Release();
1.202 + TRAP(r, reclaim.NextL(step));
1.203 + TEST(r!=KErrNone);
1.204 + reclaim.ResetL(step);
1.205 + r = reclaim.Next(step);
1.206 + TEST(r!=KErrNone);
1.207 + store->CommitL();
1.208 + TPckgBuf<TInt> pckgStep1(step);
1.209 + reclaim.Next(pckgStep1,status) ;
1.210 + User::WaitForRequest(status);
1.211 + TEST(status.Int() != KErrNone);
1.212 + reclaim.ResetL(step);
1.213 + while (step)
1.214 + {
1.215 + r = reclaim.Next(step);
1.216 + TEST2(r, KErrNone);
1.217 + }
1.218 +
1.219 + TInt total=reclaim.Available();
1.220 + CleanupStack::PopAndDestroy();
1.221 + TheTest.Printf(_L(" %d byte(s) reclaimable\n"),total);
1.222 +
1.223 + CleanupStack::Pop(); // strm
1.224 + CleanupStack::PopAndDestroy(); // store
1.225 + }
1.226 +
1.227 +//Initialize TheFileName. RFs::Connect(). Prepare the test directory.
1.228 +void CreateTestEnv()
1.229 + {
1.230 + TDriveUnit drive(static_cast<TUint>(RFs::GetSystemDrive()));
1.231 + TParse parse;
1.232 + parse.Set(drive.Name(), &KFileLocationSpec, NULL);
1.233 + TheFileName.Copy(parse.FullName());
1.234 + TheTest.Printf(_L("### Test file: %S\r\n"), &TheFileName);
1.235 +
1.236 + TInt err = TheFs.Connect();
1.237 + TheTest(err == KErrNone);
1.238 +
1.239 + err = TheFs.MkDirAll(TheFileName);
1.240 + TEST(err == KErrNone || err == KErrAlreadyExists);
1.241 + }
1.242 +
1.243 +TInt E32Main()
1.244 + {
1.245 + TheTest.Title();
1.246 +
1.247 + CTrapCleanup* tc = CTrapCleanup::New();
1.248 + TheTest(tc != NULL);
1.249 +
1.250 + __UHEAP_MARK;
1.251 +
1.252 + CreateTestEnv();
1.253 +
1.254 + TRAPD(err, ReclaimTestL());
1.255 + ::DeleteDataFile(TheFileName);
1.256 + TheFs.Close();
1.257 + TEST2(err, KErrNone);
1.258 +
1.259 + __UHEAP_MARKEND;
1.260 +
1.261 + TheTest.End();
1.262 + TheTest.Close();
1.263 +
1.264 + delete tc;
1.265 +
1.266 + return 0;
1.267 + }
1.268 +