sl@0: // Copyright (c) 2005-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_cenrep_helper.h"
sl@0: #include <e32test.h>
sl@0: #include <f32file.h>
sl@0: #include "srvrepos_noc.h"
sl@0: #include "srvres.h"
sl@0: #include "cachemgr.h"
sl@0: #include <bautils.h>
sl@0: #include "setting.h"
sl@0: 
sl@0: //Forward declarations
sl@0: class CTestObserver;
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: // Globals
sl@0: 
sl@0: static RTest TheTest(_L("T_CenRepTrans"));
sl@0: const TUid KTestRepositoryId = {0x00000010};
sl@0: //CentralRepository server UID
sl@0: static const TUid KCenRepServerUID = {0x10202BE9};
sl@0: 
sl@0: static CTestObserver* TheObserver = NULL;
sl@0: static CServerRepository* TheServerRepository = NULL;
sl@0: 
sl@0: static const TUint32 KIntSettingID = 843;
sl@0: static const TInt KIntSettingVal = 25;
sl@0: 
sl@0: static const TUint32 KRealSettingID = 844;
sl@0: static const TReal KRealSettingVal = 8.76;
sl@0: static const TReal KRealSettingVal2 = 19.234;
sl@0: 
sl@0: static const TUint32 KStringSettingID = 845;
sl@0: _LIT8(KStringSettingVal, "a test string");
sl@0: _LIT8(KStringSettingVal2, "another string");
sl@0: _LIT8(KEmptyString, "");
sl@0: 
sl@0: _LIT(KTestFile1,	"C:\\PRIVATE\\10202BE9\\PERSISTS\\00000010.TXT");
sl@0: _LIT(KCreTestFile1,	"C:\\PRIVATE\\10202BE9\\PERSISTS\\00000010.CRE");
sl@0: _LIT(KTmpTestFile1,	"C:\\PRIVATE\\10202BE9\\PERSISTS\\00000010.TMP");
sl@0: 
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: //
sl@0: 
sl@0: //Delete file function.
sl@0: //Used by the test application to cleanup the C drive at the end of the test.
sl@0: static void DeleteFile(const TDesC& aFullName)
sl@0: 	{
sl@0: 	RFs fsSession;
sl@0: 	TInt err = fsSession.Connect();
sl@0: 	if(err == KErrNone)
sl@0: 		{
sl@0: 		TEntry entry;
sl@0: 		if(fsSession.Entry(aFullName, entry) == KErrNone)
sl@0: 			{
sl@0: 			RDebug::Print(_L("Deleting \"%S\" file.\n"), &aFullName);
sl@0: 			err = fsSession.SetAtt(aFullName, 0, KEntryAttReadOnly);
sl@0: 			if(err != KErrNone)
sl@0: 				{
sl@0: 				RDebug::Print(_L("Error %d changing \"%S\" file attributes.\n"), err, &aFullName);
sl@0: 				}
sl@0: 			err = fsSession.Delete(aFullName);
sl@0: 			if(err != KErrNone)
sl@0: 				{
sl@0: 				RDebug::Print(_L("Error %d deleting \"%S\" file.\n"), err, &aFullName);
sl@0: 				}
sl@0: 			}
sl@0: 		fsSession.Close();
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		RDebug::Print(_L("Error %d connecting file session. File: %S.\n"), err, &aFullName);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: static void DeleteFiles()
sl@0: 	{
sl@0: 	::DeleteFile(KTestFile1);
sl@0: 	::DeleteFile(KCreTestFile1);
sl@0: 	::DeleteFile(KTmpTestFile1);
sl@0: 	}
sl@0: 
sl@0: static TInt GetFileTimeStamp(const TDesC& aFullName, TTime& aTime)
sl@0: 	{
sl@0: 	RFs fsSession;
sl@0: 	TInt err = fsSession.Connect();
sl@0: 	if(err == KErrNone)
sl@0: 		{
sl@0: 		TEntry entry;
sl@0: 		if(fsSession.Entry(aFullName, entry) == KErrNone)
sl@0: 			{
sl@0: 			aTime=entry.iModified;
sl@0: 			}
sl@0: 		fsSession.Close();
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		RDebug::Print(_L("Error %d connecting file session. File: %S.\n"), err, &aFullName);
sl@0: 		}
sl@0: 	return err;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: // Test macros and functions.
sl@0: 
sl@0: static void Check(TInt aValue, TInt aLine)
sl@0: 	{
sl@0: 	if(!aValue)
sl@0: 		{
sl@0: 		::DeleteFiles();
sl@0: 		TheTest(EFalse, aLine);
sl@0: 		}
sl@0: 	}
sl@0: static  void Check(TInt aValue, TInt aExpected, TInt aLine)
sl@0: 	{
sl@0: 	if(aValue != aExpected)
sl@0: 		{
sl@0: 		::DeleteFiles();
sl@0: 		RDebug::Print(_L("*** Expected error: %d, got: %d\r\n"), aExpected, aValue);
sl@0: 		TheTest(EFalse, aLine);
sl@0: 		}
sl@0: 	}
sl@0: #define TEST(arg) ::Check((arg), __LINE__)
sl@0: #define TEST2(aValue, aExpected) ::Check(aValue, aExpected, __LINE__)
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: static void CheckTmpFileDeleted()
sl@0: 	{
sl@0: 	RFs fsSession;
sl@0: 	TInt err = fsSession.Connect();
sl@0: 	if(err == KErrNone)
sl@0: 		{
sl@0: 		// Allow time for file to be deleted
sl@0: 		User::After(500*1000);
sl@0: 		TEST2 (BaflUtils::FileExists (fsSession, KTmpTestFile1), EFalse);
sl@0: 		fsSession.Close();
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		RDebug::Print(_L("Error %d connecting file session.\n"), err);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: // CTestObserver class
sl@0: 
sl@0: //It is needed for the creation of CServerRepository object.
sl@0: //Used also to track Get/Set/Create/Delete setting notifications, received
sl@0: //from CServerRepository object.
sl@0: class CTestObserver : public CBase, public MObserver
sl@0: 	{
sl@0: public:
sl@0: 	CTestObserver();
sl@0: 	void Notify(TUint32 aId);
sl@0: 
sl@0: public:
sl@0: 	TBool iAssertNotification;
sl@0: 
sl@0: 	};
sl@0: 
sl@0: CTestObserver::CTestObserver() :
sl@0: 	iAssertNotification(EFalse)
sl@0: 	{
sl@0: 	}
sl@0: 
sl@0: void CTestObserver::Notify(TUint32 aId)
sl@0: 	{
sl@0: 	RDebug::Print(_L("Notification! Id=%d.\n"), aId);
sl@0: 	if(iAssertNotification)
sl@0: 		{
sl@0: 		TEST(0);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: //
sl@0: 
sl@0: //Deletes the global TheObserver object. Sets it to NULL.
sl@0: static void ReleaseObserver(TAny*)
sl@0: 	{
sl@0: 	delete TheObserver;
sl@0: 	TheObserver = NULL;
sl@0: 	}
sl@0: 
sl@0: //Deletes the global TheServerRepository object. Sets it to NULL.
sl@0: static void ReleaseRepository(TAny*)
sl@0: 	{
sl@0: 	TheServerRepository->Close();
sl@0: 	delete TheServerRepository;
sl@0: 	TheServerRepository = NULL;
sl@0: 	TServerResources::iCacheManager->DisableCache(ETrue);
sl@0: 	TServerResources::iObserver->CloseiOpenRepositories();
sl@0: 	TServerResources::iCacheManager->EnableCache();
sl@0: 	}
sl@0: 
sl@0: //This function is called from CreateSetting_OOMtestL().
sl@0: //It creates an integer, real or string setting in the repository
sl@0: //with ID=KTestRepositoryId. All this is done in an OOM loop.
sl@0: //The output from this test is: the repository file with ID = KTestRepositoryId
sl@0: //will be copied from Z to C drive;
sl@0: // An integer, real or string setting will be created in that repository.
sl@0: //Changes in the repository will be stored on C drive (in the related repository file)
sl@0: static void DoCreateSettingL(TBool aTrapping,TServerSetting::TType aSettingType)
sl@0: 	{
sl@0: 	TheObserver = new (ELeave) CTestObserver;
sl@0: 	TCleanupItem clnItem1(&ReleaseObserver, NULL);
sl@0: 	CleanupStack::PushL(clnItem1);
sl@0: 
sl@0: 	TheServerRepository = new (ELeave) CServerRepository;
sl@0: 	TCleanupItem clnItem2(&ReleaseRepository, NULL);
sl@0: 	CleanupStack::PushL(clnItem2);
sl@0: 
sl@0: 	// Turn OOM trapping on Repository Open on/off for testing purposes.
sl@0: 	TServerResources::iObserver->iTrapOOMOnOpen=aTrapping;
sl@0: 	// Open the repository
sl@0: 	TheServerRepository->OpenL(KTestRepositoryId, *TheObserver);
sl@0: 
sl@0: 	// All write operations, including CreateL must be done in a transaction
sl@0: 	TheServerRepository->StartTransaction(CRepository::EConcurrentReadWriteTransaction);
sl@0: 	TheServerRepository->CleanupCancelTransactionPushL();
sl@0: 
sl@0: 	//Create the appropriate setting based on aValueType
sl@0: 	switch(aSettingType)
sl@0: 		{
sl@0: 		case TServerSetting::EInt:
sl@0: 			{
sl@0: 			// Create setting - fails if value already there (it must not be)
sl@0: 			User::LeaveIfError(TheServerRepository->TransactionCreateL(KIntSettingID, KIntSettingVal, NULL));
sl@0: 
sl@0: 			// Try to get the value from the transaction cache
sl@0: 			TInt val = 0;
sl@0: 			User::LeaveIfError(TheServerRepository->Get(KIntSettingID, val));
sl@0: 			TEST2(val,KIntSettingVal);
sl@0: 			break;
sl@0: 			}
sl@0: 
sl@0: 		case TServerSetting::EReal:
sl@0: 			{
sl@0: 			// Create setting - fails if value already there (it must not be)
sl@0: 			User::LeaveIfError(TheServerRepository->TransactionCreateL(KRealSettingID, KRealSettingVal, NULL));
sl@0: 
sl@0: 			// Try to get the value from the transaction cache
sl@0: 			TReal val = 0;
sl@0: 			User::LeaveIfError(TheServerRepository->Get(KRealSettingID, val));
sl@0: 			TEST(val == KRealSettingVal);
sl@0: 			break;
sl@0: 			}
sl@0: 
sl@0: 		case TServerSetting::EString:
sl@0: 			{
sl@0: 			// Create setting - fails if value already there (it must not be)
sl@0: 			User::LeaveIfError(TheServerRepository->TransactionCreateL(KStringSettingID, KStringSettingVal, NULL));
sl@0: 
sl@0: 			// Try to get the value from the transaction cache
sl@0: 			TBuf8<16> bufVal(KEmptyString);
sl@0: 			User::LeaveIfError(TheServerRepository->Get(KStringSettingID, bufVal));
sl@0: 			TEST(bufVal == KStringSettingVal);
sl@0: 			break;
sl@0: 			}
sl@0: 		default:
sl@0: 			break;
sl@0: 		}
sl@0: 
sl@0: 	// Commit the changes
sl@0: 	CleanupStack::Pop();
sl@0: 	TUint32 keyInfo;
sl@0: 	User::LeaveIfError(TheServerRepository->CommitTransaction(keyInfo));
sl@0: 
sl@0: 	TServerResources::iObserver->iTrapOOMOnOpen=EFalse;
sl@0: 	// Close the repository
sl@0: 	TheServerRepository->Close();
sl@0: 
sl@0: 	CleanupStack::PopAndDestroy(2);//TheObserver & TheServerRepository
sl@0: 	}
sl@0: 
sl@0: //This function is called from SetSetting_OOMtest().
sl@0: //It expects that the previous test (CreateSetting_OOMtestL()) had completed successfully
sl@0: //and there is a repository file (ID=0x10) on drive C and there is an integer setting
sl@0: //in that repository (ID=KIntSettingID, Value=KIntSettingVal).
sl@0: //The test will try to change the setting value in a transaction. Because the test is
sl@0: //executed in an OOM loop, CommitChangesL() - will fail when called by SetL, leaving the
sl@0: //repository content inconsistent - the in-memory repository content will be deleted
sl@0: //(no settings), but in  the file the setting will exist and its value will still be KIntSettingVal.
sl@0: static void DoSetIntSettingL()
sl@0: 	{
sl@0: 	TEST(TheObserver != NULL);
sl@0: 	TEST(TheServerRepository != NULL);
sl@0: 	// Check if the setting is there - and has (or is restored to) the original value
sl@0: 	TInt val = 0;
sl@0: 	User::LeaveIfError(TheServerRepository->Get(KIntSettingID, val));
sl@0: 	TEST2(val,KIntSettingVal);
sl@0: 
sl@0: 	// Change the setting value
sl@0: 	// All write operations, including CreateL must be done in a transaction
sl@0: 	TheServerRepository->StartTransaction(CRepository::EConcurrentReadWriteTransaction);
sl@0: 	TheServerRepository->CleanupCancelTransactionPushL();
sl@0: 	// Change the setting value
sl@0: 	User::LeaveIfError(TheServerRepository->TransactionSetL(KIntSettingID, KIntSettingVal + 1));
sl@0: 
sl@0: 	// Check if the setting is there - it should be in transaction cache now
sl@0: 	User::LeaveIfError(TheServerRepository->Get(KIntSettingID, val));
sl@0: 	TEST2(val,(KIntSettingVal + 1));
sl@0: 
sl@0: 	// Commit the changes
sl@0: 	CleanupStack::Pop();
sl@0: 	TUint32 keyInfo;
sl@0: 	User::LeaveIfError(TheServerRepository->CommitTransaction(keyInfo));
sl@0: 
sl@0: 	// Check if the setting is there. The transaction was successful so the new value
sl@0: 	// should be returned.
sl@0: 	val = 0;
sl@0: 	User::LeaveIfError(TheServerRepository->Get(KIntSettingID, val));
sl@0: 	TEST2(val,(KIntSettingVal + 1));
sl@0: 	}
sl@0: 
sl@0: //This function is called from SetSetting_OOMtest().
sl@0: //It expects that the previous test (CreateSetting_OOMtestL()) had completed successfully
sl@0: //and there is a repository file (ID=0x10) on drive C and there is an rea; setting
sl@0: //in that repository (ID=KRealSettingID, Value=KRealSettingVal).
sl@0: //The test will try to change the setting value in a transaction. Because the test is
sl@0: //executed in an OOM loop, CommitChangesL() - will fail when called by SetL, leaving the
sl@0: //repository content inconsistent - the in-memory repository content will be deleted
sl@0: //(no settings), but in  the file the setting will exist and its value will still be KRealSettingVal.
sl@0: static void DoSetRealSettingL()
sl@0: 	{
sl@0: 	TEST(TheObserver != NULL);
sl@0: 	TEST(TheServerRepository != NULL);
sl@0: 	// Check if the setting is there - and has (or is restored to) the original value
sl@0: 	TReal val = 0;
sl@0: 	User::LeaveIfError(TheServerRepository->Get(KRealSettingID, val));
sl@0: 	TEST(val == KRealSettingVal);
sl@0: 
sl@0: 	// Change the setting value
sl@0: 	// All write operations, including CreateL must be done in a transaction
sl@0: 	TheServerRepository->StartTransaction(CRepository::EConcurrentReadWriteTransaction);
sl@0: 	TheServerRepository->CleanupCancelTransactionPushL();
sl@0: 	// Change the setting value
sl@0: 	User::LeaveIfError(TheServerRepository->TransactionSetL(KRealSettingID, KRealSettingVal2));
sl@0: 
sl@0: 	// Check if the setting is there - it should be in transaction cache now
sl@0: 	User::LeaveIfError(TheServerRepository->Get(KRealSettingID, val));
sl@0: 	TEST(val == KRealSettingVal2);
sl@0: 
sl@0: 	// Commit the changes
sl@0: 	CleanupStack::Pop();
sl@0: 	TUint32 keyInfo;
sl@0: 	User::LeaveIfError(TheServerRepository->CommitTransaction(keyInfo));
sl@0: 
sl@0: 	// Check if the setting is there. The transaction was successful so the new value
sl@0: 	// should be returned.
sl@0: 	val = 0;
sl@0: 	User::LeaveIfError(TheServerRepository->Get(KRealSettingID, val));
sl@0: 	TEST(val == KRealSettingVal2);
sl@0: 	}
sl@0: 
sl@0: //This function is called from SetSetting_OOMtest().
sl@0: //It expects that the previous test (CreateSetting_OOMtestL()) had completed successfully
sl@0: //and there is a repository file (ID=0x10) on drive C and there is an string setting
sl@0: //in that repository (ID=KStringSettingID, Value=KStringSettingVal).
sl@0: //The test will try to change the setting value in a transaction. Because the test is
sl@0: //executed in an OOM loop, CommitChangesL() - will fail when called by SetL, leaving the
sl@0: //repository content inconsistent - the in-memory repository content will be deleted
sl@0: //(no settings), but in  the file the setting will exist and its value will still
sl@0: //be KStringSettingVal.
sl@0: static void DoSetStringSettingL()
sl@0: 	{
sl@0: 	TEST(TheObserver != NULL);
sl@0: 	TEST(TheServerRepository != NULL);
sl@0: 
sl@0: 	// Check if the setting is there - and has (or is restored to) the original value
sl@0: 	TBuf8<16> bufVal(KEmptyString);
sl@0: 	User::LeaveIfError(TheServerRepository->Get(KStringSettingID, bufVal));
sl@0: 	TEST(bufVal == KStringSettingVal);
sl@0: 
sl@0: 	// Change the setting value
sl@0: 	// All write operations, including CreateL must be done in a transaction
sl@0: 	TheServerRepository->StartTransaction(CRepository::EConcurrentReadWriteTransaction);
sl@0: 	TheServerRepository->CleanupCancelTransactionPushL();
sl@0: 
sl@0: 	// Change the setting value
sl@0: 	User::LeaveIfError(TheServerRepository->TransactionSetL(KStringSettingID, KStringSettingVal2));
sl@0: 
sl@0: 	// Check if the setting is there - it should be in transaction cache now
sl@0: 	User::LeaveIfError(TheServerRepository->Get(KStringSettingID, bufVal));
sl@0: 	TEST(bufVal == KStringSettingVal2);
sl@0: 	// Commit the changes
sl@0: 	CleanupStack::Pop();
sl@0: 	TUint32 keyInfo;
sl@0: 	User::LeaveIfError(TheServerRepository->CommitTransaction(keyInfo));
sl@0: 
sl@0: 	// Check if the setting is there. The transaction was successful so the new value
sl@0: 	// should be returned.
sl@0: 	bufVal = KEmptyString;
sl@0: 	User::LeaveIfError(TheServerRepository->Get(KStringSettingID, bufVal));
sl@0: 	TEST(bufVal == KStringSettingVal2);
sl@0: 	}
sl@0: 
sl@0: //This function is called from SetSetting_OOMtest()in the case where previous
sl@0: //DoSetSettingL() call failed with KErrNoMemory, leaving the repository object
sl@0: //in inconsisten state - the in-memory presentation of the repository differs from
sl@0: //the repository file content. The function will try to repair the repository,
sl@0: //as it would have to happen in a real situation. Then it will check that
sl@0: //the repository content is consistent, which means the tested setting value should
sl@0: //be the same as it was before DoSetSettingL() call.
sl@0: static void DoRecoverRepositoryL(TServerSetting::TType aSettingType)
sl@0: 	{
sl@0: 	//Repair the repository as it happens in a real situation
sl@0: 	//AccessL calls RestoreConsistencyL() indirectly
sl@0: 	//RestoreConsistencyL() is called in the production code from the session object,
sl@0: 	//ServiceL() implementation. So, it will be called before any other repository call
sl@0: 	//and it should restore the repository content - it should repair the repository
sl@0: 	//consitency.
sl@0: 	TServerResources::iObserver->AccessL(KTestRepositoryId);
sl@0: 	//Check if the setting is there - the old, pre-transactional value should be
sl@0: 	//in-memory now.
sl@0: 	switch(aSettingType)
sl@0: 		{
sl@0: 		case TServerSetting::EInt:
sl@0: 			{
sl@0: 			TInt val = 0;
sl@0: 			User::LeaveIfError(TheServerRepository->Get(KIntSettingID, val));
sl@0: 			TEST2(val,KIntSettingVal);
sl@0: 			break;
sl@0: 			}
sl@0: 
sl@0: 		case TServerSetting::EReal:
sl@0: 			{
sl@0: 			TReal val = 0;
sl@0: 			User::LeaveIfError(TheServerRepository->Get(KRealSettingID, val));
sl@0: 			TEST(val == KRealSettingVal);
sl@0: 			break;
sl@0: 			}
sl@0: 
sl@0: 		case TServerSetting::EString:
sl@0: 			{
sl@0: 			TBuf8<16> bufVal(KEmptyString);
sl@0: 			User::LeaveIfError(TheServerRepository->Get(KStringSettingID, bufVal));
sl@0: 			TEST(bufVal == KStringSettingVal);
sl@0: 			break;
sl@0: 			}
sl@0: 		default:
sl@0: 			break;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: //Inits TServerResources object.
sl@0: //It should be called once, before the creation of CServerRepository object.
sl@0: static void InitEnvL()
sl@0: 	{
sl@0: 	TServerResources::InitialiseL();
sl@0: 
sl@0: 	delete TServerResources::iDataDirectory; TServerResources::iDataDirectory = NULL;
sl@0: 	delete TServerResources::iRomDirectory; TServerResources::iRomDirectory = NULL;
sl@0: 	delete TServerResources::iInstallDirectory; TServerResources::iInstallDirectory = NULL;
sl@0: 
sl@0: 	TServerResources::iDataDirectory = HBufC::NewL(KMaxFileName);
sl@0: 	TServerResources::iRomDirectory = HBufC::NewL(KMaxFileName);
sl@0: 	TServerResources::iInstallDirectory = HBufC::NewL(KMaxFileName);
sl@0: 
sl@0: 	TBuf<32> uidName;
sl@0: 	uidName.Format(_L("%08X"), KCenRepServerUID.iUid);
sl@0: 
sl@0: 	TPtr ptr1(TServerResources::iDataDirectory->Des());
sl@0: 	ptr1.Append(_L("C:\\PRIVATE\\"));
sl@0: 	ptr1.Append(uidName);
sl@0: 	ptr1.Append(_L("\\PERSISTS\\"));
sl@0: 
sl@0: 	TPtr ptr2(TServerResources::iRomDirectory->Des());
sl@0: 	ptr2.Append(_L("Z:\\PRIVATE\\"));
sl@0: 	ptr2.Append(uidName);
sl@0: 	ptr2.Append(_L("\\"));
sl@0: 
sl@0: 	TPtr ptr3(TServerResources::iInstallDirectory->Des());
sl@0: 	ptr3.Append(_L("C:\\PRIVATE\\"));
sl@0: 	ptr3.Append(uidName);
sl@0: 	ptr3.Append(_L("\\"));
sl@0: 	}
sl@0: 
sl@0: //Destroys TServerResources object.
sl@0: //It should be called after the CServerRepository object was destroyed.
sl@0: static void ReleaseEnv()
sl@0: 	{
sl@0: 	TServerResources::Close();
sl@0: 	}
sl@0: 
sl@0: //Creates global TheServerRepository and TheObserver objects
sl@0: //It is used in SetSetting_OOMtest()
sl@0: static void InitEnv2L()
sl@0: 	{
sl@0: 	TheObserver = new CTestObserver;
sl@0: 	TEST(TheObserver != NULL);
sl@0: 
sl@0: 	TheServerRepository = new CServerRepository;
sl@0: 	TEST(TheServerRepository != NULL);
sl@0: 
sl@0: 	TheServerRepository->OpenL(KTestRepositoryId, *TheObserver);
sl@0: 	}
sl@0: 
sl@0: //Destroys global TheServerRepository and TheObserver objects
sl@0: //It is used in SetSetting_OOMtest()
sl@0: static void ReleaseEnv2()
sl@0: 	{
sl@0: 	::ReleaseRepository(NULL);
sl@0: 	::ReleaseObserver(NULL);
sl@0: 	}
sl@0: 
sl@0: //Central repository test: it creates a setting in OOM conditions.
sl@0: static void CreateSetting_OOMtestL(TBool aTrapping,TServerSetting::TType aSettingType)
sl@0: 	{
sl@0: 	TInt err;
sl@0: 	TRAP(err, ::InitEnvL());
sl@0: 	TEST2(err, KErrNone);
sl@0: 	for(TInt count=1;;++count)
sl@0: 		{
sl@0: 		CleanupCDriveL();
sl@0: 		__UHEAP_FAILNEXT(count);
sl@0: 		__UHEAP_MARK;
sl@0: 
sl@0: 		TRAP(err, ::DoCreateSettingL(aTrapping,aSettingType));
sl@0: 
sl@0: 		TServerResources::iOwnerIdLookUpTable.Reset();
sl@0: 		TServerResources::iObserver->Reset();
sl@0: 
sl@0: 		__UHEAP_MARKEND;
sl@0: 
sl@0: 		if(err == KErrNone)
sl@0: 			{
sl@0: 			RDebug::Print(_L("The test succeeded at heap failure rate=%d.\n"), count);
sl@0: 			break;
sl@0: 			}
sl@0: 		else if(err != KErrNoMemory)
sl@0: 			{
sl@0: 			TEST2(err, KErrNone);
sl@0: 			}
sl@0: 		}
sl@0: 
sl@0: 	::ReleaseEnv();
sl@0: 	__UHEAP_RESET;
sl@0: 	}
sl@0: 
sl@0: //Central repository test: it sets new setting value in OOM conditions.
sl@0: //Then ComitChangesL() is called to store the new setting's value in the repository
sl@0: //file. Because of the simulated OOM conditions ComitChangesL() can fail, leaving the
sl@0: //repository in inconsistent state.
sl@0: //DoRecoverRepositoryL() is called to repair the repository and restore the consistency.
sl@0: static void SetSetting_OOMtest(TServerSetting::TType aSettingType)
sl@0: 	{
sl@0: 	TTime before;
sl@0: 	TTime after;
sl@0: 	// Check that cre file exists and get modification time
sl@0: 	TEST2 (GetFileTimeStamp(KCreTestFile1, before), KErrNone);
sl@0: 	after=before;
sl@0: 
sl@0: 	TInt err;
sl@0: 	TRAP(err, ::InitEnvL());
sl@0: 	TEST2(err, KErrNone);
sl@0: 	TRAP(err, ::InitEnv2L());
sl@0: 	TEST2(err, KErrNone);	
sl@0: 	for(TInt count=1;;++count)
sl@0: 		{
sl@0: 		__UHEAP_FAILNEXT(count);
sl@0: 		__UHEAP_MARK;
sl@0: 
sl@0: 	switch(aSettingType)
sl@0: 		{
sl@0: 		case TServerSetting::EInt:
sl@0: 			{
sl@0: 			TRAP(err, ::DoSetIntSettingL());
sl@0: 			break;
sl@0: 			}
sl@0: 		case TServerSetting::EReal:
sl@0: 			{
sl@0: 			TRAP(err, ::DoSetRealSettingL());
sl@0: 			break;
sl@0: 			}
sl@0: 		case TServerSetting::EString:
sl@0: 			{
sl@0: 			TRAP(err, ::DoSetStringSettingL());
sl@0: 			break;
sl@0: 			}
sl@0: 		default:
sl@0: 			break;
sl@0: 		}
sl@0: 
sl@0: 		// Get timestamp of cre file. It is now possible for the commit to
sl@0: 		// fail with KErrNoMemory after a successful write. If filestamp
sl@0: 		// changes, the cre file has been written and the test is complete
sl@0: 		TEST2 (GetFileTimeStamp(KCreTestFile1, after), KErrNone);
sl@0: 		if(before!=after)
sl@0: 			{
sl@0: 			err=KErrNone;
sl@0: 			}
sl@0: 
sl@0: 		if(err == KErrNoMemory)
sl@0: 			{
sl@0: 			__UHEAP_MARKEND;
sl@0: 			//DoSetSettingL() call failed (so the transaction). Try to recover.
sl@0: 			TInt err2;
sl@0: 			TRAP(err2, ::DoRecoverRepositoryL(aSettingType));
sl@0: 			TEST2(err2, KErrNone);
sl@0: 			}
sl@0: 		else if(err == KErrNone)
sl@0: 			{
sl@0: 			//The heap cannot be checked at this point because memory may have been
sl@0: 			//allocated which must be freed by a call to ReleaseEnv2.
sl@0: 			//It is checked outside the loop instead
sl@0: 			RDebug::Print(_L("The test succeeded at heap failure rate=%d.\n"), count);
sl@0: 			break;
sl@0: 			}
sl@0: 		else
sl@0: 			{
sl@0: 			__UHEAP_MARKEND;
sl@0: 			TEST2(err, KErrNone);
sl@0: 			}
sl@0: 		// Check that tmp file generated by attempted commit is deleted
sl@0: 		// by RestoreConsistencyL() in DoRecoverRepositoryL().
sl@0: 		::CheckTmpFileDeleted();
sl@0: 		}
sl@0: 	// Check that no tmp file is left over
sl@0: 	::ReleaseEnv2();
sl@0: 	::ReleaseEnv();
sl@0: 	//This __UHEAP_MARKEND checks the heap after the call to DoSetxSettings
sl@0: 	//succeeds as calls to CommitTRansactions can allocate memory which must be freed
sl@0: 	//by calling ReleaseEnv2
sl@0: 	__UHEAP_MARKEND;
sl@0: 	__UHEAP_RESET;
sl@0: 	}
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: void RunTestsL(TServerSetting::TType aSettingType)
sl@0: 	{
sl@0: 
sl@0: 	TheTest.Next(_L("Create setting - OOM test - OOM Trapping off"));
sl@0: 	::CreateSetting_OOMtestL(EFalse,aSettingType);
sl@0: 
sl@0: 	TheTest.Next(_L("Create setting - OOM test - OOM Trapping on"));
sl@0: 	::CreateSetting_OOMtestL(ETrue,aSettingType);
sl@0: 
sl@0: 	TheTest.Next(_L("Set setting - transaction - OOM test"));
sl@0: 	::SetSetting_OOMtest(aSettingType);
sl@0: 
sl@0: 	}
sl@0: 
sl@0: static void MainL()
sl@0: 	{
sl@0: 	// create and install the active scheduler we need for the cache manager in TServerResources::InitialiseL
sl@0: 	CActiveScheduler* cacheManagerAS=new(ELeave) CActiveScheduler;
sl@0: 	CleanupStack::PushL(cacheManagerAS);
sl@0: 	CActiveScheduler::Install(cacheManagerAS);
sl@0: 
sl@0: 	::DeleteFiles();
sl@0: 
sl@0: 	TheTest.Start(_L(" @SYMTestCaseID:SYSLIB-CENTRALREPOSITORY-LEGACY-T_CENREPTRANS-0001 Int Setting Tests "));
sl@0: 	RunTestsL(TServerSetting::EInt);
sl@0: 
sl@0: 	TheTest.Next(_L("Real Setting Tests"));
sl@0: 	RunTestsL(TServerSetting::EReal);
sl@0: 
sl@0: 	TheTest.Next(_L("String Setting Tests"));
sl@0: 	RunTestsL(TServerSetting::EString);
sl@0: 
sl@0: 	TheTest.End();
sl@0: 	TheTest.Close();
sl@0: 
sl@0: 	CleanupStack::PopAndDestroy(cacheManagerAS);
sl@0: 	}
sl@0: 
sl@0: TInt E32Main()
sl@0: 	{
sl@0: 	__UHEAP_MARK;
sl@0: 
sl@0: 	CTrapCleanup* tc = CTrapCleanup::New();
sl@0: 	TEST(tc != NULL);
sl@0: 
sl@0: 	TheTest.Title();
sl@0: 	TRAPD(err, ::MainL());
sl@0: 	TEST2(err, KErrNone);
sl@0: 
sl@0: 	::DeleteFiles();
sl@0: 
sl@0: 	delete tc;
sl@0: 
sl@0: 	__UHEAP_MARKEND;
sl@0: 
sl@0: 	User::Heap().Check();
sl@0: 	return KErrNone;
sl@0: 	}