1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/dbms/tdbms/t_dbstress.cpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,625 @@
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 "t_dbstress.h"
1.20 +
1.21 +//#define __DUMP_STATE
1.22 +#if defined(__WINS__)
1.23 +//#define _INSTALL_FILE_SYSTEM
1.24 +#endif
1.25 +
1.26 +GLDEF_D RTest TheTest(_L("t_dbstress: Stress testing DBMS"));
1.27 +
1.28 +GLDEF_D TPtrC KTestDir=_S("\\DBMS-TST\\");
1.29 +GLDEF_D TPtrC KLogFile=_L("T_STRESS.LOG");
1.30 +GLDEF_D TPtrC KTestDatabase=_S("T_STRESS.DB");
1.31 +GLDEF_D TInt NewCount,OldCount;
1.32 +GLDEF_D TInt TransId;
1.33 +GLDEF_D Timer RunTimer;
1.34 +
1.35 +
1.36 +LOCAL_D RFs TheFs;
1.37 +LOCAL_D RThread TheThread;
1.38 +LOCAL_D TRequestStatus TheStatus;
1.39 +LOCAL_D RDbStoreDatabase TheDatabase;
1.40 +LOCAL_D RDbView Accs;
1.41 +LOCAL_D RDbView Trans;
1.42 +LOCAL_D RDbTable TheTable;
1.43 +LOCAL_D TInt Shot,ShotDuringCommit;
1.44 +LOCAL_D TInt64 RunningTime(1);
1.45 +LOCAL_D Timer Stopwatch;
1.46 +
1.47 +#ifdef __DUMP_STATE
1.48 +const TPtrC KDumpFile=_S("T_STRESS.DMP");
1.49 +#endif
1.50 +const TInt KTestCleanupStack=0x20;
1.51 +
1.52 +void Timer::Start()
1.53 + {
1.54 + iTime.UniversalTime();
1.55 + }
1.56 +
1.57 +TInt64 Timer::Stop()
1.58 + {
1.59 + TTime t;
1.60 + t.UniversalTime();
1.61 + return ((t.MicroSecondsFrom(iTime).Int64()) + 500)/1000;
1.62 + }
1.63 +
1.64 +void Timer::Print()
1.65 + {
1.66 + TInt64 milli=Stop();
1.67 + TheTest.Printf(_L(" %u milliseconds\n"), I64LOW(milli) );
1.68 + }
1.69 +
1.70 +class Set
1.71 + {
1.72 +public:
1.73 + struct SColDef
1.74 + {
1.75 + const TDesC* iName;
1.76 + TDbColType iType;
1.77 + TInt iAttributes;
1.78 + };
1.79 +public:
1.80 + static CDbColSet* CreateL(const SColDef* aDef);
1.81 + };
1.82 +CDbColSet* Set::CreateL(const SColDef* aDef)
1.83 + {
1.84 + CDbColSet *set=CDbColSet::NewLC();
1.85 + for (;aDef->iName!=NULL;++aDef)
1.86 + {
1.87 + TDbCol col(*aDef->iName,aDef->iType);
1.88 + col.iAttributes=aDef->iAttributes;
1.89 + set->AddL(col);
1.90 + }
1.91 + CleanupStack::Pop();
1.92 + return set;
1.93 + }
1.94 +
1.95 +// Accounts table
1.96 +const TPtrC KAccounts=_S("ACCOUNTS");
1.97 +const TPtrC KAccountsID=_S("ID");
1.98 +const TPtrC KAccountsBalance=_S("BALANCE");
1.99 +const TPtrC KAccountsStatement=_S("STATEMENT_BALANCE");
1.100 +Set::SColDef const AccountsDef[]=
1.101 + {
1.102 + {&KAccountsID,EDbColInt32,TDbCol::ENotNull},
1.103 + {&KAccountsBalance,EDbColInt32,TDbCol::ENotNull},
1.104 + {&KAccountsStatement,EDbColInt32,TDbCol::ENotNull},
1.105 + {0}
1.106 + };
1.107 +const TInt KInitialCash=100000;
1.108 +const TInt KInitialBalance=1000;
1.109 +
1.110 +// Transaction table
1.111 +const TPtrC KTransactions=_S("TRANSACTIONS");
1.112 +const TPtrC KTransactionDate=_S("T_DATE");
1.113 +const TPtrC KTransactionFrom=_S("FROM_ID");
1.114 +const TPtrC KTransactionTo=_S("TO_ID");
1.115 +const TPtrC KTransactionAmount=_S("AMOUNT");
1.116 +Set::SColDef const TransactionsDef[]=
1.117 + {
1.118 +// {&KTransactionDate,EDbColDateTime,TDbCol::ENotNull},
1.119 + {&KTransactionDate,EDbColInt32,TDbCol::ENotNull},
1.120 + {&KTransactionFrom,EDbColInt32,TDbCol::ENotNull},
1.121 + {&KTransactionTo,EDbColInt32,TDbCol::ENotNull},
1.122 + {&KTransactionAmount,EDbColInt32,TDbCol::ENotNull},
1.123 + {0}
1.124 + };
1.125 +
1.126 +LOCAL_D TInt32 TotalMonies;
1.127 +LOCAL_D TBuf<100> Buf;
1.128 +
1.129 +GLDEF_C TInt Random(TInt aRange)
1.130 + {
1.131 + return (Math::Random()>>11)%aRange;
1.132 + }
1.133 +
1.134 +///////////////////////////////////////////////////////////////////////////////////////
1.135 +///////////////////////////////////////////////////////////////////////////////////////
1.136 +
1.137 +TPtrC FileName(const TText* aFile)
1.138 + {
1.139 + TPtrC p(aFile);
1.140 + TInt ix=p.LocateReverse('\\');
1.141 + if (ix<0)
1.142 + ix=p.LocateReverse('/');
1.143 + if (ix>=0)
1.144 + p.Set(p.Mid(1+ix));
1.145 + return p;
1.146 + }
1.147 +
1.148 +//Test macros and functions
1.149 +void Check1(TInt aValue, const TText* aFile, TInt aLine)
1.150 + {
1.151 + if(!aValue)
1.152 + {
1.153 + TPtrC fname(FileName(aFile));
1.154 + TheTest.Printf(_L("*** Expression evaluated to false. %S-%d\r\n"), &fname, aLine);
1.155 + TheTest(EFalse, aLine);
1.156 + }
1.157 + }
1.158 +void Check2(TInt aValue, TInt aExpected, const TText* aFile, TInt aLine)
1.159 + {
1.160 + if(aValue != aExpected)
1.161 + {
1.162 + TPtrC fname(FileName(aFile));
1.163 + TheTest.Printf(_L("*** Expected %d, got %d. %S-%d\r\n"), aExpected, aValue, &fname, aLine);
1.164 + TheTest(EFalse, aLine);
1.165 + }
1.166 + }
1.167 +
1.168 +///////////////////////////////////////////////////////////////////////////////////////
1.169 +
1.170 +LOCAL_C void CreateIndexL(RDbDatabase& aDatabase,const TDesC& aTable,const TDesC& aColumn,TBool aUnique)
1.171 + {
1.172 + CDbKey* key=CDbKey::NewLC();
1.173 + key->AddL(aColumn);
1.174 + if (aUnique)
1.175 + key->MakeUnique();
1.176 + TEST2(aDatabase.CreateIndex(aColumn,aTable,*key),KErrNone);
1.177 + CleanupStack::PopAndDestroy();
1.178 + }
1.179 +
1.180 +//
1.181 +// Create the database
1.182 +//
1.183 +LOCAL_C void CreateDatabaseL()
1.184 + {
1.185 + CFileStore* store=CPermanentFileStore::ReplaceLC(TheFs,KTestDatabase,EFileRead|EFileWrite);
1.186 + store->SetTypeL(KPermanentFileStoreLayoutUid);
1.187 + store->SetRootL(TheDatabase.CreateL(store));
1.188 +// create the tables
1.189 + TheDatabase.Begin();
1.190 + CDbColSet* set=Set::CreateL(AccountsDef);
1.191 + TEST2(TheDatabase.CreateTable(KAccounts,*set),KErrNone);
1.192 + delete set;
1.193 + CreateIndexL(TheDatabase,KAccounts,KAccountsID,ETrue);
1.194 + CreateIndexL(TheDatabase,KAccounts,KAccountsBalance,EFalse);
1.195 + set=Set::CreateL(TransactionsDef);
1.196 + TEST2(TheDatabase.CreateTable(KTransactions,*set),KErrNone);
1.197 + delete set;
1.198 + CreateIndexL(TheDatabase,KTransactions,KTransactionDate,EFalse);
1.199 + TEST2(TheDatabase.Commit(),KErrNone);
1.200 + OldCount=NewCount=0;
1.201 +// prepare Accs table
1.202 + TheDatabase.Begin();
1.203 + TEST2(Accs.Prepare(TheDatabase,_L("select * from accounts"),Accs.EInsertOnly),KErrNone);
1.204 + Accs.InsertL();
1.205 + Accs.SetColL(1,TInt32(ECash));
1.206 + Accs.SetColL(2,KInitialCash);
1.207 + Accs.SetColL(3,KInitialCash);
1.208 + Accs.PutL();
1.209 + TotalMonies=KInitialCash;
1.210 + for (TInt ii=EJohn;ii<=EPenny;++ii)
1.211 + {
1.212 + Accs.InsertL();
1.213 + Accs.SetColL(1,ii);
1.214 + Accs.SetColL(2,KInitialBalance);
1.215 + Accs.SetColL(3,KInitialBalance);
1.216 + Accs.PutL();
1.217 + TotalMonies+=KInitialBalance;
1.218 + }
1.219 + TEST2(TheDatabase.Commit(),KErrNone);
1.220 + Accs.Close();
1.221 + TheDatabase.Close();
1.222 + CleanupStack::PopAndDestroy(); // store
1.223 + }
1.224 +
1.225 +
1.226 +#ifdef __DUMP_STATE
1.227 +LOCAL_C void DumpStateL()
1.228 + {
1.229 + RFile file;
1.230 + CleanupClosePushL(file);
1.231 + User::LeaveIfError(file.Replace(TheFs,KLogFile,EFileWrite|EFileStreamText));
1.232 + RDbRowSet::RConstraint match;
1.233 + CleanupClosePushL(match);
1.234 + for (TInt id=ECash;id<=EPenny;++id)
1.235 + {
1.236 + Buf.Format(_L("id=%d"),id);
1.237 + Accs.FirstL();
1.238 + TEST(Accs.FindL(Accs.EForwards,Buf)>=0);
1.239 + Accs.GetL();
1.240 + TInt balance=Accs.ColInt(2);
1.241 + Buf.Format(_L("\nStatement for account %d: Previous balance %d\n"),id,balance);
1.242 + User::LeaveIfError(file.Write(Buf));
1.243 + Buf.Format(_L("from_id=%d or to_id=%d"),id,id);
1.244 + User::LeaveIfError(match.Open(Trans,Buf));
1.245 + for (Trans.BeginningL();Trans.NextL();)
1.246 + {
1.247 + if (Trans.MatchL(match))
1.248 + {
1.249 + Trans.GetL();
1.250 + TInt from=Trans.ColInt(2);
1.251 + TInt amount=Trans.ColInt(4);
1.252 + Buf.Format(_L("%04d: %6s %5d\n"),Trans.ColInt(1),from==id?_S("debit"):_S("credit"),amount);
1.253 + User::LeaveIfError(file.Write(Buf));
1.254 + if (from==id)
1.255 + balance-=amount;
1.256 + else
1.257 + balance+=amount;
1.258 + }
1.259 + }
1.260 + Buf.Format(_L("Closing balance %d\n"),balance);
1.261 + User::LeaveIfError(file.Write(Buf));
1.262 + Buf.Format(_L("Account balance %d\n"),Accs.ColInt(3));
1.263 + User::LeaveIfError(file.Write(Buf));
1.264 + }
1.265 + CleanupStack::PopAndDestroy(2);
1.266 + TEST(0);
1.267 + }
1.268 +#endif
1.269 +
1.270 +//
1.271 +// Check that the database structure is fully intact
1.272 +//
1.273 +LOCAL_C void VerifyDatabaseL(CPersistentStore& aStore)
1.274 + {
1.275 + TheDatabase.OpenL(&aStore,aStore.Root());
1.276 +// check any indexes
1.277 + TEST2(TheTable.Open(TheDatabase,KAccounts,TheTable.EReadOnly),KErrNone);
1.278 + TEST2(TheTable.CountL(),KAccountIDs);
1.279 + TInt r=TheTable.SetIndex(KAccountsID);
1.280 + if (r!=KErrCorrupt)
1.281 + {
1.282 + TEST2(r,KErrNone);
1.283 + TEST2(TheTable.CountL(),KAccountIDs);
1.284 + for (TInt id=ECash;id<=EPenny;++id)
1.285 + {
1.286 + TEST(TheTable.NextL());
1.287 + TheTable.GetL();
1.288 + TEST2(TheTable.ColInt(1),id);
1.289 + }
1.290 + TEST(!TheTable.NextL());
1.291 + }
1.292 + r=TheTable.SetIndex(KAccountsBalance);
1.293 + if (r!=KErrCorrupt)
1.294 + {
1.295 + TEST2(r,KErrNone);
1.296 + TEST2(TheTable.CountL(),KAccountIDs);
1.297 + TEST(TheTable.FirstL());
1.298 + TheTable.GetL();
1.299 + TInt last=TheTable.ColInt(2);
1.300 + for (TInt ii=1;ii<KAccountIDs;++ii)
1.301 + {
1.302 + TEST(TheTable.NextL());
1.303 + TheTable.GetL();
1.304 + TInt bal=TheTable.ColInt(2);
1.305 + TEST(bal>=last);
1.306 + last=bal;
1.307 + }
1.308 + TEST(!TheTable.NextL());
1.309 + }
1.310 + TheTable.Close();
1.311 + TEST2(TheTable.Open(TheDatabase,KTransactions,TheTable.EReadOnly),KErrNone);
1.312 + TInt count=TheTable.CountL();
1.313 + r=TheTable.SetIndex(KTransactionDate);
1.314 + if (r!=KErrCorrupt)
1.315 + {
1.316 + TEST2(r,KErrNone);
1.317 + TEST2(TheTable.CountL(),count);
1.318 + if (count)
1.319 + {
1.320 + TEST(TheTable.FirstL());
1.321 + TheTable.GetL();
1.322 + TInt last=TheTable.ColInt(1);
1.323 + while (--count!=0)
1.324 + {
1.325 + TEST(TheTable.NextL());
1.326 + TheTable.GetL();
1.327 + TInt date=TheTable.ColInt(1);
1.328 + TEST(date>last);
1.329 + last=date;
1.330 + }
1.331 + TEST(!TheTable.NextL());
1.332 + }
1.333 + else
1.334 + TEST(!TheTable.FirstL());
1.335 + }
1.336 + TheTable.Close();
1.337 +// verify database integrity
1.338 + TInt balance[KAccountIDs];
1.339 + TEST2(Accs.Prepare(TheDatabase,_L("select id,statement_balance,balance from accounts"),Accs.EReadOnly),KErrNone);
1.340 + TEST2(Accs.CountL(),KAccountIDs);
1.341 + while (Accs.NextL())
1.342 + {
1.343 + Accs.GetL();
1.344 + TInt id=Accs.ColInt(1);
1.345 + balance[id]=Accs.ColInt(2);
1.346 + }
1.347 + TEST2(Trans.Prepare(TheDatabase,_L("select t_date,from_id,to_id,amount from Transactions"),Trans.EReadOnly),KErrNone);
1.348 + TInt transact=0;
1.349 + while (Trans.NextL())
1.350 + {
1.351 + ++transact;
1.352 + Trans.GetL();
1.353 + TInt from=Trans.ColInt(2);
1.354 + TInt to=Trans.ColInt(3);
1.355 + TInt amount=Trans.ColInt(4);
1.356 + balance[from]-=amount;
1.357 + balance[to]+=amount;
1.358 + }
1.359 + TEST2(transact,Trans.CountL());
1.360 + if (NewCount!=-1 && transact!=NewCount)
1.361 + {
1.362 + TEST2(transact,OldCount);
1.363 + ++ShotDuringCommit;
1.364 + }
1.365 + OldCount=NewCount=transact;
1.366 + TInt total=0;
1.367 + for (Accs.BeginningL();Accs.NextL();)
1.368 + {
1.369 + Accs.GetL();
1.370 + TInt id=Accs.ColInt(1);
1.371 +#ifdef __DUMP_STATE
1.372 + if (balance[id]!=Accs.ColInt(3))
1.373 + DumpStateL();
1.374 +#else
1.375 + TEST(balance[id]==Accs.ColInt(3));
1.376 +#endif
1.377 + total+=balance[id];
1.378 + }
1.379 + TEST2(total,TotalMonies);
1.380 + Trans.Close();
1.381 + Accs.Close();
1.382 + TheDatabase.Close();
1.383 + }
1.384 +
1.385 +LOCAL_C TInt Verify(CPersistentStore& aStore)
1.386 + {
1.387 + TRAPD(r,VerifyDatabaseL(aStore));
1.388 + return r;
1.389 + }
1.390 +
1.391 +LOCAL_C TInt Recover(CPersistentStore& aStore)
1.392 + {
1.393 + TRAPD(r,TheDatabase.OpenL(&aStore,aStore.Root()));
1.394 + if (r==KErrNone)
1.395 + {
1.396 + r=TheDatabase.Recover();
1.397 + TheDatabase.Close();
1.398 + }
1.399 + return r;
1.400 + }
1.401 +
1.402 +LOCAL_C void CompactL(CStreamStore& aStore)
1.403 + {
1.404 + TInt t=aStore.ReclaimL();
1.405 + Stopwatch.Start();
1.406 + t-=aStore.CompactL();
1.407 + TheTest.Printf(_L(" compacted %d byte(s) in"),t);
1.408 + Stopwatch.Print();
1.409 + aStore.CommitL();
1.410 + }
1.411 +
1.412 +LOCAL_C TInt Compact(CStreamStore& aStore)
1.413 + {
1.414 + TRAPD(r,CompactL(aStore));
1.415 + return r;
1.416 + }
1.417 +
1.418 +LOCAL_C TInt EndThread()
1.419 + {
1.420 + RunningTime+=RunTimer.Stop();
1.421 + if (TheStatus==KRequestPending)
1.422 + TheThread.Kill(1);
1.423 + User::WaitForRequest(TheStatus);
1.424 + TInt r;
1.425 + if (TheThread.ExitType()==EExitKill)
1.426 + r=TheThread.ExitReason();
1.427 + else
1.428 + r=TheStatus.Int();
1.429 + TheThread.Close();
1.430 + return r;
1.431 + }
1.432 +
1.433 +//aTestExecutionTime - desired test execution time in minutes
1.434 +LOCAL_C void RunTestL(TInt aTestExecutionTime = 0)
1.435 + {
1.436 + __ASSERT_ALWAYS(aTestExecutionTime >= 0, User::Invariant());
1.437 +
1.438 + RThread().SetPriority(EPriorityMore);
1.439 + TheTest.Start(_L("Create the database"));
1.440 + CreateDatabaseL();
1.441 +
1.442 + TTimeIntervalMinutes timeInterval(aTestExecutionTime);
1.443 +
1.444 + TTime timeCurrent;
1.445 + timeCurrent.UniversalTime();
1.446 + TTime timeEnd(timeCurrent);
1.447 + timeEnd += timeInterval;
1.448 +
1.449 + for (TBool condition=ETrue; condition; condition = aTestExecutionTime > 0 ? (timeCurrent < timeEnd) : ETrue)
1.450 + {
1.451 + TheTest.Next(_L("Main loop"));
1.452 + TheTest.Start(_L("Kick off the thread"));
1.453 + TEST2 (StartThread(TheThread,TheStatus),KErrNone);
1.454 + // random delay
1.455 + for (;;)
1.456 + {
1.457 + User::After(95000);
1.458 + if (TheStatus!=KRequestPending)
1.459 + break;
1.460 + if (Random(1000)<30)
1.461 + break;
1.462 + }
1.463 + TheTest.Next(_L("End the thread"));
1.464 + TInt exit=EndThread();
1.465 + if (exit!=1)
1.466 + TheTest.Printf(_L(" thread failed with error %d\n"),exit);
1.467 +//
1.468 + ++Shot;
1.469 + CFileStore* store=NULL;
1.470 + for (TInt ii=0;;++ii)
1.471 + {
1.472 + TheTest.Printf(_L("Opening %d\r"),ii);
1.473 + TRAPD(r,store=CFileStore::OpenL(TheFs,KTestDatabase,EFileRead|EFileWrite|EFileWriteDirectIO));
1.474 + if (r==KErrNone)
1.475 + break;
1.476 + TEST2(r, KErrInUse);
1.477 + User::After(100000);
1.478 + }
1.479 + TheTest.Next(_L("Verify & Recover"));
1.480 + TEST2 (Verify(*store),KErrNone);
1.481 + TInt64 tps(TransId);
1.482 + tps*=1000u;
1.483 + tps/=RunningTime;
1.484 + TheTest.Printf(_L(" Iteration %d, TPS %d, during commit %d%%\n"),Shot,I64LOW(tps),(100*ShotDuringCommit)/Shot);
1.485 + TInt r=Recover(*store);
1.486 + if (r==KErrNoMemory || r==KErrDiskFull)
1.487 + { // need to compact before completing recovery
1.488 + TheTest.Next(_L("No space, compacting"));
1.489 + TEST2 (Compact(*store),KErrNone);
1.490 + TheTest.Next(_L("Verify & Recover again"));
1.491 + TEST2 (Verify(*store),KErrNone);
1.492 + r=Recover(*store);
1.493 + }
1.494 + TEST2 (r,KErrNone);
1.495 + TheTest.Next(_L("Verify & Compact"));
1.496 +// TEST2 (Verify(*store),KErrNone);
1.497 + TEST2 (Compact(*store),KErrNone);
1.498 + TheTest.Next(_L("Verify"));
1.499 + TEST2 (Verify(*store),KErrNone);
1.500 +//
1.501 + delete store;
1.502 + TheTest.End();
1.503 +
1.504 + timeCurrent.UniversalTime();
1.505 + }
1.506 + TheTest.End();
1.507 + }
1.508 +
1.509 +/**
1.510 +@SYMTestCaseID SYSLIB-DBMS-CT-0636
1.511 +@SYMTestCaseDesc DBMS stess testing.
1.512 +@SYMTestPriority Medium
1.513 +@SYMTestActions Tests for verifying the database integrity.
1.514 +@SYMTestExpectedResults Test must not fail
1.515 +@SYMREQ REQ0000
1.516 +*/
1.517 +static void RunVerify()
1.518 + {
1.519 + TheTest.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0636 Open store "));
1.520 + CFileStore* store=NULL;
1.521 + TRAPD(r,store=CFileStore::OpenL(TheFs,KTestDatabase,EFileRead|EFileWrite|EFileWriteDirectIO));
1.522 + TEST2 (r,KErrNone);
1.523 + TheTest.Next(_L("Verify"));
1.524 + NewCount=-1;
1.525 + TotalMonies=KInitialCash + (EPenny-EJohn+1)*KInitialBalance;
1.526 + TEST2 (Verify(*store),KErrNone);
1.527 + TheTest.Next(_L("Recover"));
1.528 + TEST2 (Recover(*store),KErrNone);
1.529 + TheTest.Next(_L("Verify"));
1.530 + TEST2 (Verify(*store),KErrNone);
1.531 + delete store;
1.532 + TheTest.End();
1.533 + }
1.534 +
1.535 +//
1.536 +// Prepare the test directory.
1.537 +//
1.538 +LOCAL_C void setupTestDirectory()
1.539 + {
1.540 + TInt r=TheFs.Connect();
1.541 + TEST2(r,KErrNone);
1.542 +//
1.543 + r=TheFs.MkDir(KTestDir);
1.544 + TEST(r==KErrNone || r==KErrAlreadyExists);
1.545 + r=TheFs.SetSessionPath(KTestDir);
1.546 + TEST2(r,KErrNone);
1.547 + }
1.548 +
1.549 +//
1.550 +// Initialise the cleanup stack.
1.551 +//
1.552 +LOCAL_C CTrapCleanup* setupCleanup()
1.553 + {
1.554 + CTrapCleanup* cleanup=CTrapCleanup::New();
1.555 + TEST(cleanup!=NULL);
1.556 + TRAPD(r,\
1.557 + {\
1.558 + for (TInt i=KTestCleanupStack;i>0;i--)\
1.559 + CleanupStack::PushL((TAny*)0);\
1.560 + CleanupStack::Pop(KTestCleanupStack);\
1.561 + });
1.562 + TEST2(r,KErrNone);
1.563 + return cleanup;
1.564 + }
1.565 +
1.566 +//
1.567 +// entry point
1.568 +//
1.569 +// Parameters usage:
1.570 +// t_stress [-v]|[0]|[<positive number>]
1.571 +// Where:
1.572 +// -v - a verification test will be run;
1.573 +// 0 - a stress test will be run for indefinite time;
1.574 +// <positive number> - a stress test will be run for <positive number> minutes;
1.575 +// If the test is run without arguments, the test execution time will be 10 minutes
1.576 +// (KDefaultTestExecutionTime constant bellow).
1.577 +GLDEF_C TInt E32Main()
1.578 + {
1.579 + TheTest.Title();
1.580 + setupTestDirectory();
1.581 + CTrapCleanup* cleanup=setupCleanup();
1.582 + __UHEAP_MARK;
1.583 +//
1.584 + TBuf<100> cmd;
1.585 + User::CommandLine(cmd);
1.586 + TLex lex(cmd);
1.587 + TInt err = KErrNone;
1.588 + for(;;)
1.589 + {
1.590 + TPtrC arg(lex.NextToken());
1.591 + if(arg.Length() == 0)
1.592 + {
1.593 + const TInt KDefaultTestExecutionTime = 10;//default test execution time - minutes
1.594 + TRAP(err, RunTestL(KDefaultTestExecutionTime));
1.595 + break;
1.596 + }
1.597 + else if(arg.CompareF(_L("-v")) == 0)
1.598 + {
1.599 + RunVerify();
1.600 + break;
1.601 + }
1.602 + else
1.603 + {
1.604 + TInt32 testExecutionTime = 0;
1.605 + lex.Assign(arg);
1.606 + (void)lex.Val(testExecutionTime);
1.607 + TRAP(err, RunTestL(testExecutionTime));
1.608 + break;
1.609 + }
1.610 + }
1.611 + TInt err2 = TheFs.Delete(KTestDatabase);
1.612 + if(err2 != KErrNone)
1.613 + {
1.614 + RDebug::Print(_L("Error %d deleting \"%S\" file.\n"), err2, &KTestDatabase);
1.615 + }
1.616 + err2 = TheFs.Delete(KLogFile);
1.617 + if(err2 != KErrNone)
1.618 + {
1.619 + RDebug::Print(_L("Error %d deleting \"%S\" file.\n"), err2, &KLogFile);
1.620 + }
1.621 + TEST2(err, KErrNone);
1.622 +//
1.623 + __UHEAP_MARKEND;
1.624 + delete cleanup;
1.625 + TheFs.Close();
1.626 + TheTest.Close();
1.627 + return 0;
1.628 + }