sl@0: // Copyright (c) 1998-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: //
sl@0: 
sl@0: #include "t_dbstress.h"
sl@0: 
sl@0: //#define __DUMP_STATE
sl@0: #if defined(__WINS__)
sl@0: //#define _INSTALL_FILE_SYSTEM
sl@0: #endif
sl@0: 
sl@0: GLDEF_D RTest TheTest(_L("t_dbstress: Stress testing DBMS"));
sl@0: 
sl@0: GLDEF_D TPtrC KTestDir=_S("\\DBMS-TST\\");
sl@0: GLDEF_D TPtrC KLogFile=_L("T_STRESS.LOG");
sl@0: GLDEF_D TPtrC KTestDatabase=_S("T_STRESS.DB");
sl@0: GLDEF_D TInt NewCount,OldCount;
sl@0: GLDEF_D TInt TransId;
sl@0: GLDEF_D Timer RunTimer;
sl@0: 
sl@0: 
sl@0: LOCAL_D RFs TheFs;
sl@0: LOCAL_D RThread TheThread;
sl@0: LOCAL_D TRequestStatus TheStatus;
sl@0: LOCAL_D RDbStoreDatabase TheDatabase;
sl@0: LOCAL_D RDbView Accs;
sl@0: LOCAL_D RDbView Trans;
sl@0: LOCAL_D RDbTable TheTable;
sl@0: LOCAL_D TInt Shot,ShotDuringCommit;
sl@0: LOCAL_D TInt64 RunningTime(1);
sl@0: LOCAL_D Timer Stopwatch;
sl@0: 
sl@0: #ifdef __DUMP_STATE
sl@0: const TPtrC KDumpFile=_S("T_STRESS.DMP");
sl@0: #endif
sl@0: const TInt KTestCleanupStack=0x20;
sl@0: 
sl@0: void Timer::Start()
sl@0: 	{
sl@0: 	iTime.UniversalTime();
sl@0: 	}
sl@0: 
sl@0: TInt64 Timer::Stop()
sl@0: 	{
sl@0: 	TTime t;
sl@0: 	t.UniversalTime();
sl@0: 	return ((t.MicroSecondsFrom(iTime).Int64()) + 500)/1000;
sl@0: 	}
sl@0: 
sl@0: void Timer::Print()
sl@0: 	{
sl@0: 	TInt64 milli=Stop();
sl@0: 	TheTest.Printf(_L("  %u milliseconds\n"), I64LOW(milli) );
sl@0: 	}
sl@0: 
sl@0: class Set
sl@0: 	{
sl@0: public:
sl@0: 	struct SColDef
sl@0: 		{
sl@0: 		const TDesC* iName;
sl@0: 		TDbColType iType;
sl@0: 		TInt iAttributes;
sl@0: 		};
sl@0: public:
sl@0: 	static CDbColSet* CreateL(const SColDef* aDef);
sl@0: 	};
sl@0: CDbColSet* Set::CreateL(const SColDef* aDef)
sl@0: 	{
sl@0: 	CDbColSet *set=CDbColSet::NewLC();
sl@0: 	for (;aDef->iName!=NULL;++aDef)
sl@0: 		{
sl@0: 		TDbCol col(*aDef->iName,aDef->iType);
sl@0: 		col.iAttributes=aDef->iAttributes;
sl@0: 		set->AddL(col);
sl@0: 		}
sl@0: 	CleanupStack::Pop();
sl@0: 	return set;
sl@0: 	}
sl@0: 
sl@0: // Accounts table
sl@0: const TPtrC KAccounts=_S("ACCOUNTS");
sl@0: const TPtrC KAccountsID=_S("ID");
sl@0: const TPtrC KAccountsBalance=_S("BALANCE");
sl@0: const TPtrC KAccountsStatement=_S("STATEMENT_BALANCE");
sl@0: Set::SColDef const AccountsDef[]=
sl@0: 	{
sl@0: 	{&KAccountsID,EDbColInt32,TDbCol::ENotNull},
sl@0: 	{&KAccountsBalance,EDbColInt32,TDbCol::ENotNull},
sl@0: 	{&KAccountsStatement,EDbColInt32,TDbCol::ENotNull},
sl@0: 	{0}
sl@0: 	};
sl@0: const TInt KInitialCash=100000;
sl@0: const TInt KInitialBalance=1000;
sl@0: 
sl@0: // Transaction table
sl@0: const TPtrC KTransactions=_S("TRANSACTIONS");
sl@0: const TPtrC KTransactionDate=_S("T_DATE");
sl@0: const TPtrC KTransactionFrom=_S("FROM_ID");
sl@0: const TPtrC KTransactionTo=_S("TO_ID");
sl@0: const TPtrC KTransactionAmount=_S("AMOUNT");
sl@0: Set::SColDef const TransactionsDef[]=
sl@0: 	{
sl@0: //	{&KTransactionDate,EDbColDateTime,TDbCol::ENotNull},
sl@0: 	{&KTransactionDate,EDbColInt32,TDbCol::ENotNull},
sl@0: 	{&KTransactionFrom,EDbColInt32,TDbCol::ENotNull},
sl@0: 	{&KTransactionTo,EDbColInt32,TDbCol::ENotNull},
sl@0: 	{&KTransactionAmount,EDbColInt32,TDbCol::ENotNull},
sl@0: 	{0}
sl@0: 	};
sl@0: 
sl@0: LOCAL_D TInt32 TotalMonies;
sl@0: LOCAL_D TBuf<100> Buf;
sl@0: 
sl@0: GLDEF_C TInt Random(TInt aRange)
sl@0: 	{
sl@0: 	return (Math::Random()>>11)%aRange;
sl@0: 	}
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: TPtrC FileName(const TText* aFile)
sl@0:     {
sl@0:     TPtrC p(aFile);
sl@0:     TInt ix=p.LocateReverse('\\');
sl@0:     if (ix<0)
sl@0:         ix=p.LocateReverse('/');
sl@0:     if (ix>=0)
sl@0:         p.Set(p.Mid(1+ix));
sl@0:     return p;
sl@0:     }
sl@0: 
sl@0: //Test macros and functions
sl@0: void Check1(TInt aValue, const TText* aFile, TInt aLine)
sl@0:     {
sl@0:     if(!aValue)
sl@0:         {
sl@0:         TPtrC fname(FileName(aFile));
sl@0:         TheTest.Printf(_L("*** Expression evaluated to false. %S-%d\r\n"), &fname, aLine);
sl@0:         TheTest(EFalse, aLine);
sl@0:         }
sl@0:     }
sl@0: void Check2(TInt aValue, TInt aExpected, const TText* aFile, TInt aLine)
sl@0:     {
sl@0:     if(aValue != aExpected)
sl@0:         {
sl@0:         TPtrC fname(FileName(aFile));
sl@0:         TheTest.Printf(_L("*** Expected %d, got %d. %S-%d\r\n"), aExpected, aValue, &fname, aLine);
sl@0:         TheTest(EFalse, aLine);
sl@0:         }
sl@0:     }
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: LOCAL_C void CreateIndexL(RDbDatabase& aDatabase,const TDesC& aTable,const TDesC& aColumn,TBool aUnique)
sl@0: 	{
sl@0: 	CDbKey* key=CDbKey::NewLC();
sl@0: 	key->AddL(aColumn);
sl@0: 	if (aUnique)
sl@0: 		key->MakeUnique();
sl@0: 	TEST2(aDatabase.CreateIndex(aColumn,aTable,*key),KErrNone);
sl@0: 	CleanupStack::PopAndDestroy();
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // Create the database
sl@0: //
sl@0: LOCAL_C void CreateDatabaseL()
sl@0: 	{
sl@0: 	CFileStore* store=CPermanentFileStore::ReplaceLC(TheFs,KTestDatabase,EFileRead|EFileWrite);
sl@0: 	store->SetTypeL(KPermanentFileStoreLayoutUid);
sl@0: 	store->SetRootL(TheDatabase.CreateL(store));
sl@0: //	create the tables
sl@0: 	TheDatabase.Begin();
sl@0: 	CDbColSet* set=Set::CreateL(AccountsDef);
sl@0: 	TEST2(TheDatabase.CreateTable(KAccounts,*set),KErrNone);
sl@0: 	delete set;
sl@0: 	CreateIndexL(TheDatabase,KAccounts,KAccountsID,ETrue);
sl@0: 	CreateIndexL(TheDatabase,KAccounts,KAccountsBalance,EFalse);
sl@0: 	set=Set::CreateL(TransactionsDef);
sl@0: 	TEST2(TheDatabase.CreateTable(KTransactions,*set),KErrNone);
sl@0: 	delete set;
sl@0: 	CreateIndexL(TheDatabase,KTransactions,KTransactionDate,EFalse);
sl@0: 	TEST2(TheDatabase.Commit(),KErrNone);
sl@0: 	OldCount=NewCount=0;
sl@0: // prepare Accs table
sl@0: 	TheDatabase.Begin();
sl@0: 	TEST2(Accs.Prepare(TheDatabase,_L("select * from accounts"),Accs.EInsertOnly),KErrNone);
sl@0: 	Accs.InsertL();
sl@0: 	Accs.SetColL(1,TInt32(ECash));
sl@0: 	Accs.SetColL(2,KInitialCash);
sl@0: 	Accs.SetColL(3,KInitialCash);
sl@0: 	Accs.PutL();
sl@0: 	TotalMonies=KInitialCash;
sl@0: 	for (TInt ii=EJohn;ii<=EPenny;++ii)
sl@0: 		{
sl@0: 		Accs.InsertL();
sl@0: 		Accs.SetColL(1,ii);
sl@0: 		Accs.SetColL(2,KInitialBalance);
sl@0: 		Accs.SetColL(3,KInitialBalance);
sl@0: 		Accs.PutL();
sl@0: 		TotalMonies+=KInitialBalance;
sl@0: 		}
sl@0: 	TEST2(TheDatabase.Commit(),KErrNone);
sl@0: 	Accs.Close();
sl@0: 	TheDatabase.Close();
sl@0: 	CleanupStack::PopAndDestroy();	// store
sl@0: 	}
sl@0: 
sl@0: 
sl@0: #ifdef __DUMP_STATE
sl@0: LOCAL_C void DumpStateL()
sl@0: 	{
sl@0: 	RFile file;
sl@0: 	CleanupClosePushL(file);
sl@0: 	User::LeaveIfError(file.Replace(TheFs,KLogFile,EFileWrite|EFileStreamText));
sl@0: 	RDbRowSet::RConstraint match;
sl@0: 	CleanupClosePushL(match);
sl@0: 	for (TInt id=ECash;id<=EPenny;++id)
sl@0: 		{
sl@0: 		Buf.Format(_L("id=%d"),id);
sl@0: 		Accs.FirstL();
sl@0: 		TEST(Accs.FindL(Accs.EForwards,Buf)>=0);
sl@0: 		Accs.GetL();
sl@0: 		TInt balance=Accs.ColInt(2);
sl@0: 		Buf.Format(_L("\nStatement for account %d: Previous balance %d\n"),id,balance);
sl@0: 		User::LeaveIfError(file.Write(Buf));
sl@0: 		Buf.Format(_L("from_id=%d or to_id=%d"),id,id);
sl@0: 		User::LeaveIfError(match.Open(Trans,Buf));
sl@0: 		for (Trans.BeginningL();Trans.NextL();)
sl@0: 			{
sl@0: 			if (Trans.MatchL(match))
sl@0: 				{
sl@0: 				Trans.GetL();
sl@0: 				TInt from=Trans.ColInt(2);
sl@0: 				TInt amount=Trans.ColInt(4);
sl@0: 				Buf.Format(_L("%04d: %6s %5d\n"),Trans.ColInt(1),from==id?_S("debit"):_S("credit"),amount);
sl@0: 				User::LeaveIfError(file.Write(Buf));
sl@0: 				if (from==id)
sl@0: 					balance-=amount;
sl@0: 				else
sl@0: 					balance+=amount;
sl@0: 				}
sl@0: 			}
sl@0: 		Buf.Format(_L("Closing balance %d\n"),balance);
sl@0: 		User::LeaveIfError(file.Write(Buf));
sl@0: 		Buf.Format(_L("Account balance %d\n"),Accs.ColInt(3));
sl@0: 		User::LeaveIfError(file.Write(Buf));
sl@0: 		}
sl@0: 	CleanupStack::PopAndDestroy(2);
sl@0: 	TEST(0);
sl@0: 	}
sl@0: #endif
sl@0: 
sl@0: //
sl@0: // Check that the database structure is fully intact
sl@0: //
sl@0: LOCAL_C void VerifyDatabaseL(CPersistentStore& aStore)
sl@0: 	{
sl@0: 	TheDatabase.OpenL(&aStore,aStore.Root());
sl@0: // check any indexes
sl@0: 	TEST2(TheTable.Open(TheDatabase,KAccounts,TheTable.EReadOnly),KErrNone);
sl@0: 	TEST2(TheTable.CountL(),KAccountIDs);
sl@0: 	TInt r=TheTable.SetIndex(KAccountsID);
sl@0: 	if (r!=KErrCorrupt)
sl@0: 		{
sl@0: 		TEST2(r,KErrNone);
sl@0: 		TEST2(TheTable.CountL(),KAccountIDs);
sl@0: 		for (TInt id=ECash;id<=EPenny;++id)
sl@0: 			{
sl@0: 			TEST(TheTable.NextL());
sl@0: 			TheTable.GetL();
sl@0: 			TEST2(TheTable.ColInt(1),id);
sl@0: 			}
sl@0: 		TEST(!TheTable.NextL());
sl@0: 		}
sl@0: 	r=TheTable.SetIndex(KAccountsBalance);
sl@0: 	if (r!=KErrCorrupt)
sl@0: 		{
sl@0: 		TEST2(r,KErrNone);
sl@0: 		TEST2(TheTable.CountL(),KAccountIDs);
sl@0: 		TEST(TheTable.FirstL());
sl@0: 		TheTable.GetL();
sl@0: 		TInt last=TheTable.ColInt(2);
sl@0: 		for (TInt ii=1;ii<KAccountIDs;++ii)
sl@0: 			{
sl@0: 			TEST(TheTable.NextL());
sl@0: 			TheTable.GetL();
sl@0: 			TInt bal=TheTable.ColInt(2);
sl@0: 			TEST(bal>=last);
sl@0: 			last=bal;
sl@0: 			}
sl@0: 		TEST(!TheTable.NextL());
sl@0: 		}
sl@0: 	TheTable.Close();
sl@0: 	TEST2(TheTable.Open(TheDatabase,KTransactions,TheTable.EReadOnly),KErrNone);
sl@0: 	TInt count=TheTable.CountL();
sl@0: 	r=TheTable.SetIndex(KTransactionDate);
sl@0: 	if (r!=KErrCorrupt)
sl@0: 		{
sl@0: 		TEST2(r,KErrNone);
sl@0: 		TEST2(TheTable.CountL(),count);
sl@0: 		if (count)
sl@0: 			{
sl@0: 			TEST(TheTable.FirstL());
sl@0: 			TheTable.GetL();
sl@0: 			TInt last=TheTable.ColInt(1);
sl@0: 			while (--count!=0)
sl@0: 				{
sl@0: 				TEST(TheTable.NextL());
sl@0: 				TheTable.GetL();
sl@0: 				TInt date=TheTable.ColInt(1);
sl@0: 				TEST(date>last);
sl@0: 				last=date;
sl@0: 				}
sl@0: 			TEST(!TheTable.NextL());
sl@0: 			}
sl@0: 		else
sl@0: 			TEST(!TheTable.FirstL());
sl@0: 		}
sl@0: 	TheTable.Close();
sl@0: // verify database integrity
sl@0: 	TInt balance[KAccountIDs];
sl@0: 	TEST2(Accs.Prepare(TheDatabase,_L("select id,statement_balance,balance from accounts"),Accs.EReadOnly),KErrNone);
sl@0: 	TEST2(Accs.CountL(),KAccountIDs);
sl@0: 	while (Accs.NextL())
sl@0: 		{
sl@0: 		Accs.GetL();
sl@0: 		TInt id=Accs.ColInt(1);
sl@0: 		balance[id]=Accs.ColInt(2);
sl@0: 		}
sl@0: 	TEST2(Trans.Prepare(TheDatabase,_L("select t_date,from_id,to_id,amount from Transactions"),Trans.EReadOnly),KErrNone);
sl@0: 	TInt transact=0;
sl@0: 	while (Trans.NextL())
sl@0: 		{
sl@0: 		++transact;
sl@0: 		Trans.GetL();
sl@0: 		TInt from=Trans.ColInt(2);
sl@0: 		TInt to=Trans.ColInt(3);
sl@0: 		TInt amount=Trans.ColInt(4);
sl@0: 		balance[from]-=amount;
sl@0: 		balance[to]+=amount;
sl@0: 		}
sl@0: 	TEST2(transact,Trans.CountL());
sl@0: 	if (NewCount!=-1 && transact!=NewCount)
sl@0: 		{
sl@0: 		TEST2(transact,OldCount);
sl@0: 		++ShotDuringCommit;
sl@0: 		}
sl@0: 	OldCount=NewCount=transact;
sl@0: 	TInt total=0;
sl@0: 	for (Accs.BeginningL();Accs.NextL();)
sl@0: 		{
sl@0: 		Accs.GetL();
sl@0: 		TInt id=Accs.ColInt(1);
sl@0: #ifdef __DUMP_STATE
sl@0: 		if (balance[id]!=Accs.ColInt(3))
sl@0: 			DumpStateL();
sl@0: #else
sl@0: 		TEST(balance[id]==Accs.ColInt(3));
sl@0: #endif
sl@0: 		total+=balance[id];
sl@0: 		}
sl@0: 	TEST2(total,TotalMonies);
sl@0: 	Trans.Close();
sl@0: 	Accs.Close();
sl@0: 	TheDatabase.Close();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C TInt Verify(CPersistentStore& aStore)
sl@0: 	{
sl@0: 	TRAPD(r,VerifyDatabaseL(aStore));
sl@0: 	return r;
sl@0: 	}
sl@0: 
sl@0: LOCAL_C TInt Recover(CPersistentStore& aStore)
sl@0: 	{
sl@0: 	TRAPD(r,TheDatabase.OpenL(&aStore,aStore.Root()));
sl@0: 	if (r==KErrNone)
sl@0: 		{
sl@0: 		r=TheDatabase.Recover();
sl@0: 		TheDatabase.Close();
sl@0: 		}
sl@0: 	return r;
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void CompactL(CStreamStore& aStore)
sl@0: 	{
sl@0: 	TInt t=aStore.ReclaimL();
sl@0: 	Stopwatch.Start();
sl@0: 	t-=aStore.CompactL();
sl@0: 	TheTest.Printf(_L("  compacted %d byte(s) in"),t);
sl@0: 	Stopwatch.Print();
sl@0: 	aStore.CommitL();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C TInt Compact(CStreamStore& aStore)
sl@0: 	{
sl@0: 	TRAPD(r,CompactL(aStore));
sl@0: 	return r;
sl@0: 	}
sl@0: 
sl@0: LOCAL_C TInt EndThread()
sl@0: 	{
sl@0: 	RunningTime+=RunTimer.Stop();
sl@0: 	if (TheStatus==KRequestPending)
sl@0: 		TheThread.Kill(1);
sl@0: 	User::WaitForRequest(TheStatus);
sl@0: 	TInt r;
sl@0: 	if (TheThread.ExitType()==EExitKill)
sl@0: 		r=TheThread.ExitReason();
sl@0: 	else
sl@0: 		r=TheStatus.Int();
sl@0: 	TheThread.Close();
sl@0: 	return r;
sl@0: 	}
sl@0: 
sl@0: //aTestExecutionTime - desired test execution time in minutes
sl@0: LOCAL_C void RunTestL(TInt aTestExecutionTime = 0)
sl@0: 	{
sl@0: 	__ASSERT_ALWAYS(aTestExecutionTime >= 0, User::Invariant());
sl@0: 
sl@0: 	RThread().SetPriority(EPriorityMore);
sl@0: 	TheTest.Start(_L("Create the database"));
sl@0: 	CreateDatabaseL();
sl@0: 
sl@0: 	TTimeIntervalMinutes timeInterval(aTestExecutionTime);
sl@0: 
sl@0: 	TTime timeCurrent;
sl@0: 	timeCurrent.UniversalTime();
sl@0: 	TTime timeEnd(timeCurrent);
sl@0: 	timeEnd += timeInterval;
sl@0: 
sl@0: 	for (TBool condition=ETrue; condition; condition = aTestExecutionTime > 0 ? (timeCurrent < timeEnd) : ETrue)
sl@0: 		{
sl@0: 		TheTest.Next(_L("Main loop"));
sl@0: 		TheTest.Start(_L("Kick off the thread"));
sl@0: 		TEST2 (StartThread(TheThread,TheStatus),KErrNone);
sl@0: 		// random delay
sl@0: 		for (;;)
sl@0: 			{
sl@0: 			User::After(95000);
sl@0: 			if (TheStatus!=KRequestPending)
sl@0: 				break;
sl@0: 			if (Random(1000)<30)
sl@0: 				break;
sl@0: 			}
sl@0: 		TheTest.Next(_L("End the thread"));
sl@0: 		TInt exit=EndThread();
sl@0: 		if (exit!=1)
sl@0: 		    TheTest.Printf(_L("  thread failed with error %d\n"),exit);
sl@0: //
sl@0: 		++Shot;
sl@0: 		CFileStore* store=NULL;
sl@0: 		for (TInt ii=0;;++ii)
sl@0: 			{
sl@0: 			TheTest.Printf(_L("Opening %d\r"),ii);
sl@0: 			TRAPD(r,store=CFileStore::OpenL(TheFs,KTestDatabase,EFileRead|EFileWrite|EFileWriteDirectIO));
sl@0: 			if (r==KErrNone)
sl@0: 				break;
sl@0: 			TEST2(r, KErrInUse);
sl@0: 			User::After(100000);
sl@0: 			}
sl@0: 		TheTest.Next(_L("Verify & Recover"));
sl@0: 		TEST2 (Verify(*store),KErrNone);
sl@0: 		TInt64 tps(TransId);
sl@0: 		tps*=1000u;
sl@0: 		tps/=RunningTime;
sl@0: 		TheTest.Printf(_L("    Iteration %d, TPS %d, during commit %d%%\n"),Shot,I64LOW(tps),(100*ShotDuringCommit)/Shot);
sl@0: 		TInt r=Recover(*store);
sl@0: 		if (r==KErrNoMemory || r==KErrDiskFull)
sl@0: 			{	// need to compact before completing recovery
sl@0: 			TheTest.Next(_L("No space, compacting"));
sl@0: 			TEST2 (Compact(*store),KErrNone);
sl@0: 			TheTest.Next(_L("Verify & Recover again"));
sl@0: 			TEST2 (Verify(*store),KErrNone);
sl@0: 			r=Recover(*store);
sl@0: 			}
sl@0: 		TEST2 (r,KErrNone);
sl@0: 		TheTest.Next(_L("Verify & Compact"));
sl@0: //		TEST2 (Verify(*store),KErrNone);
sl@0: 		TEST2 (Compact(*store),KErrNone);
sl@0: 		TheTest.Next(_L("Verify"));
sl@0: 		TEST2 (Verify(*store),KErrNone);
sl@0: //
sl@0: 		delete store;
sl@0: 		TheTest.End();
sl@0: 
sl@0: 		timeCurrent.UniversalTime();
sl@0: 		}
sl@0: 	TheTest.End();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          SYSLIB-DBMS-CT-0636
sl@0: @SYMTestCaseDesc        DBMS stess testing.
sl@0: @SYMTestPriority        Medium
sl@0: @SYMTestActions         Tests for verifying the database integrity.
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ                 REQ0000
sl@0: */
sl@0: static void RunVerify()
sl@0: 	{
sl@0: 	TheTest.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0636 Open store "));
sl@0: 	CFileStore* store=NULL;
sl@0: 	TRAPD(r,store=CFileStore::OpenL(TheFs,KTestDatabase,EFileRead|EFileWrite|EFileWriteDirectIO));
sl@0: 	TEST2 (r,KErrNone);
sl@0: 	TheTest.Next(_L("Verify"));
sl@0: 	NewCount=-1;
sl@0: 	TotalMonies=KInitialCash + (EPenny-EJohn+1)*KInitialBalance;
sl@0: 	TEST2 (Verify(*store),KErrNone);
sl@0: 	TheTest.Next(_L("Recover"));
sl@0: 	TEST2 (Recover(*store),KErrNone);
sl@0: 	TheTest.Next(_L("Verify"));
sl@0: 	TEST2 (Verify(*store),KErrNone);
sl@0: 	delete store;
sl@0: 	TheTest.End();
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // Prepare the test directory.
sl@0: //
sl@0: LOCAL_C void setupTestDirectory()
sl@0:     {
sl@0: 	TInt r=TheFs.Connect();
sl@0: 	TEST2(r,KErrNone);
sl@0: //
sl@0: 	r=TheFs.MkDir(KTestDir);
sl@0: 	TEST(r==KErrNone || r==KErrAlreadyExists);
sl@0: 	r=TheFs.SetSessionPath(KTestDir);
sl@0: 	TEST2(r,KErrNone);
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // Initialise the cleanup stack.
sl@0: //
sl@0: LOCAL_C CTrapCleanup* setupCleanup()
sl@0:     {
sl@0: 	CTrapCleanup* cleanup=CTrapCleanup::New();
sl@0: 	TEST(cleanup!=NULL);
sl@0: 	TRAPD(r,\
sl@0: 		{\
sl@0: 		for (TInt i=KTestCleanupStack;i>0;i--)\
sl@0: 			CleanupStack::PushL((TAny*)0);\
sl@0: 		CleanupStack::Pop(KTestCleanupStack);\
sl@0: 		});
sl@0: 	TEST2(r,KErrNone);
sl@0: 	return cleanup;
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // entry point
sl@0: //
sl@0: // Parameters usage:
sl@0: //	t_stress [-v]|[0]|[<positive number>]
sl@0: // Where:
sl@0: //	-v - a verification test will be run;
sl@0: //	0  - a stress test will be run for indefinite time;
sl@0: //	<positive number>  - a stress test will be run for <positive number> minutes;
sl@0: // If the test is run without arguments, the test execution time will be 10 minutes
sl@0: // (KDefaultTestExecutionTime constant bellow).
sl@0: GLDEF_C TInt E32Main()
sl@0:     {
sl@0:     TheTest.Title();
sl@0: 	setupTestDirectory();
sl@0: 	CTrapCleanup* cleanup=setupCleanup();
sl@0: 	__UHEAP_MARK;
sl@0: //
sl@0: 	TBuf<100> cmd;
sl@0:     User::CommandLine(cmd);
sl@0: 	TLex lex(cmd);
sl@0: 	TInt err = KErrNone;
sl@0: 	for(;;)
sl@0: 		{
sl@0: 		TPtrC arg(lex.NextToken());
sl@0: 		if(arg.Length() == 0)
sl@0: 			{
sl@0: 			const TInt KDefaultTestExecutionTime = 10;//default test execution time - minutes
sl@0: 			TRAP(err, RunTestL(KDefaultTestExecutionTime));
sl@0: 			break;
sl@0: 			}
sl@0: 		else if(arg.CompareF(_L("-v")) == 0)
sl@0: 			{
sl@0: 			RunVerify();
sl@0: 			break;
sl@0: 			}
sl@0: 		else
sl@0: 			{
sl@0: 			TInt32 testExecutionTime = 0;
sl@0: 			lex.Assign(arg);
sl@0: 			(void)lex.Val(testExecutionTime);
sl@0: 			TRAP(err, RunTestL(testExecutionTime));
sl@0: 			break;
sl@0: 			}
sl@0: 		}
sl@0: 	TInt err2 = TheFs.Delete(KTestDatabase);
sl@0: 	if(err2 != KErrNone)
sl@0: 		{
sl@0: 		RDebug::Print(_L("Error %d deleting \"%S\" file.\n"), err2, &KTestDatabase);
sl@0: 		}
sl@0: 	err2 = TheFs.Delete(KLogFile);
sl@0: 	if(err2 != KErrNone)
sl@0: 		{
sl@0: 		RDebug::Print(_L("Error %d deleting \"%S\" file.\n"), err2, &KLogFile);
sl@0: 		}
sl@0: 	TEST2(err, KErrNone);
sl@0: //
sl@0: 	__UHEAP_MARKEND;
sl@0: 	delete cleanup;
sl@0: 	TheFs.Close();
sl@0: 	TheTest.Close();
sl@0: 	return 0;
sl@0:     }