1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/centralrepository/test/T_CenRepTrans.cpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,705 @@
1.4 +// Copyright (c) 2005-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_cenrep_helper.h"
1.20 +#include <e32test.h>
1.21 +#include <f32file.h>
1.22 +#include "srvrepos_noc.h"
1.23 +#include "srvres.h"
1.24 +#include "cachemgr.h"
1.25 +#include <bautils.h>
1.26 +#include "setting.h"
1.27 +
1.28 +//Forward declarations
1.29 +class CTestObserver;
1.30 +
1.31 +///////////////////////////////////////////////////////////////////////////////////////
1.32 +// Globals
1.33 +
1.34 +static RTest TheTest(_L("T_CenRepTrans"));
1.35 +const TUid KTestRepositoryId = {0x00000010};
1.36 +//CentralRepository server UID
1.37 +static const TUid KCenRepServerUID = {0x10202BE9};
1.38 +
1.39 +static CTestObserver* TheObserver = NULL;
1.40 +static CServerRepository* TheServerRepository = NULL;
1.41 +
1.42 +static const TUint32 KIntSettingID = 843;
1.43 +static const TInt KIntSettingVal = 25;
1.44 +
1.45 +static const TUint32 KRealSettingID = 844;
1.46 +static const TReal KRealSettingVal = 8.76;
1.47 +static const TReal KRealSettingVal2 = 19.234;
1.48 +
1.49 +static const TUint32 KStringSettingID = 845;
1.50 +_LIT8(KStringSettingVal, "a test string");
1.51 +_LIT8(KStringSettingVal2, "another string");
1.52 +_LIT8(KEmptyString, "");
1.53 +
1.54 +_LIT(KTestFile1, "C:\\PRIVATE\\10202BE9\\PERSISTS\\00000010.TXT");
1.55 +_LIT(KCreTestFile1, "C:\\PRIVATE\\10202BE9\\PERSISTS\\00000010.CRE");
1.56 +_LIT(KTmpTestFile1, "C:\\PRIVATE\\10202BE9\\PERSISTS\\00000010.TMP");
1.57 +
1.58 +
1.59 +///////////////////////////////////////////////////////////////////////////////////////
1.60 +//
1.61 +
1.62 +//Delete file function.
1.63 +//Used by the test application to cleanup the C drive at the end of the test.
1.64 +static void DeleteFile(const TDesC& aFullName)
1.65 + {
1.66 + RFs fsSession;
1.67 + TInt err = fsSession.Connect();
1.68 + if(err == KErrNone)
1.69 + {
1.70 + TEntry entry;
1.71 + if(fsSession.Entry(aFullName, entry) == KErrNone)
1.72 + {
1.73 + RDebug::Print(_L("Deleting \"%S\" file.\n"), &aFullName);
1.74 + err = fsSession.SetAtt(aFullName, 0, KEntryAttReadOnly);
1.75 + if(err != KErrNone)
1.76 + {
1.77 + RDebug::Print(_L("Error %d changing \"%S\" file attributes.\n"), err, &aFullName);
1.78 + }
1.79 + err = fsSession.Delete(aFullName);
1.80 + if(err != KErrNone)
1.81 + {
1.82 + RDebug::Print(_L("Error %d deleting \"%S\" file.\n"), err, &aFullName);
1.83 + }
1.84 + }
1.85 + fsSession.Close();
1.86 + }
1.87 + else
1.88 + {
1.89 + RDebug::Print(_L("Error %d connecting file session. File: %S.\n"), err, &aFullName);
1.90 + }
1.91 + }
1.92 +
1.93 +static void DeleteFiles()
1.94 + {
1.95 + ::DeleteFile(KTestFile1);
1.96 + ::DeleteFile(KCreTestFile1);
1.97 + ::DeleteFile(KTmpTestFile1);
1.98 + }
1.99 +
1.100 +static TInt GetFileTimeStamp(const TDesC& aFullName, TTime& aTime)
1.101 + {
1.102 + RFs fsSession;
1.103 + TInt err = fsSession.Connect();
1.104 + if(err == KErrNone)
1.105 + {
1.106 + TEntry entry;
1.107 + if(fsSession.Entry(aFullName, entry) == KErrNone)
1.108 + {
1.109 + aTime=entry.iModified;
1.110 + }
1.111 + fsSession.Close();
1.112 + }
1.113 + else
1.114 + {
1.115 + RDebug::Print(_L("Error %d connecting file session. File: %S.\n"), err, &aFullName);
1.116 + }
1.117 + return err;
1.118 + }
1.119 +
1.120 +
1.121 +///////////////////////////////////////////////////////////////////////////////////////
1.122 +// Test macros and functions.
1.123 +
1.124 +static void Check(TInt aValue, TInt aLine)
1.125 + {
1.126 + if(!aValue)
1.127 + {
1.128 + ::DeleteFiles();
1.129 + TheTest(EFalse, aLine);
1.130 + }
1.131 + }
1.132 +static void Check(TInt aValue, TInt aExpected, TInt aLine)
1.133 + {
1.134 + if(aValue != aExpected)
1.135 + {
1.136 + ::DeleteFiles();
1.137 + RDebug::Print(_L("*** Expected error: %d, got: %d\r\n"), aExpected, aValue);
1.138 + TheTest(EFalse, aLine);
1.139 + }
1.140 + }
1.141 +#define TEST(arg) ::Check((arg), __LINE__)
1.142 +#define TEST2(aValue, aExpected) ::Check(aValue, aExpected, __LINE__)
1.143 +
1.144 +///////////////////////////////////////////////////////////////////////////////////////
1.145 +
1.146 +static void CheckTmpFileDeleted()
1.147 + {
1.148 + RFs fsSession;
1.149 + TInt err = fsSession.Connect();
1.150 + if(err == KErrNone)
1.151 + {
1.152 + // Allow time for file to be deleted
1.153 + User::After(500*1000);
1.154 + TEST2 (BaflUtils::FileExists (fsSession, KTmpTestFile1), EFalse);
1.155 + fsSession.Close();
1.156 + }
1.157 + else
1.158 + {
1.159 + RDebug::Print(_L("Error %d connecting file session.\n"), err);
1.160 + }
1.161 + }
1.162 +
1.163 +
1.164 +///////////////////////////////////////////////////////////////////////////////////////
1.165 +// CTestObserver class
1.166 +
1.167 +//It is needed for the creation of CServerRepository object.
1.168 +//Used also to track Get/Set/Create/Delete setting notifications, received
1.169 +//from CServerRepository object.
1.170 +class CTestObserver : public CBase, public MObserver
1.171 + {
1.172 +public:
1.173 + CTestObserver();
1.174 + void Notify(TUint32 aId);
1.175 +
1.176 +public:
1.177 + TBool iAssertNotification;
1.178 +
1.179 + };
1.180 +
1.181 +CTestObserver::CTestObserver() :
1.182 + iAssertNotification(EFalse)
1.183 + {
1.184 + }
1.185 +
1.186 +void CTestObserver::Notify(TUint32 aId)
1.187 + {
1.188 + RDebug::Print(_L("Notification! Id=%d.\n"), aId);
1.189 + if(iAssertNotification)
1.190 + {
1.191 + TEST(0);
1.192 + }
1.193 + }
1.194 +
1.195 +///////////////////////////////////////////////////////////////////////////////////////
1.196 +//
1.197 +
1.198 +//Deletes the global TheObserver object. Sets it to NULL.
1.199 +static void ReleaseObserver(TAny*)
1.200 + {
1.201 + delete TheObserver;
1.202 + TheObserver = NULL;
1.203 + }
1.204 +
1.205 +//Deletes the global TheServerRepository object. Sets it to NULL.
1.206 +static void ReleaseRepository(TAny*)
1.207 + {
1.208 + TheServerRepository->Close();
1.209 + delete TheServerRepository;
1.210 + TheServerRepository = NULL;
1.211 + TServerResources::iCacheManager->DisableCache(ETrue);
1.212 + TServerResources::iObserver->CloseiOpenRepositories();
1.213 + TServerResources::iCacheManager->EnableCache();
1.214 + }
1.215 +
1.216 +//This function is called from CreateSetting_OOMtestL().
1.217 +//It creates an integer, real or string setting in the repository
1.218 +//with ID=KTestRepositoryId. All this is done in an OOM loop.
1.219 +//The output from this test is: the repository file with ID = KTestRepositoryId
1.220 +//will be copied from Z to C drive;
1.221 +// An integer, real or string setting will be created in that repository.
1.222 +//Changes in the repository will be stored on C drive (in the related repository file)
1.223 +static void DoCreateSettingL(TBool aTrapping,TServerSetting::TType aSettingType)
1.224 + {
1.225 + TheObserver = new (ELeave) CTestObserver;
1.226 + TCleanupItem clnItem1(&ReleaseObserver, NULL);
1.227 + CleanupStack::PushL(clnItem1);
1.228 +
1.229 + TheServerRepository = new (ELeave) CServerRepository;
1.230 + TCleanupItem clnItem2(&ReleaseRepository, NULL);
1.231 + CleanupStack::PushL(clnItem2);
1.232 +
1.233 + // Turn OOM trapping on Repository Open on/off for testing purposes.
1.234 + TServerResources::iObserver->iTrapOOMOnOpen=aTrapping;
1.235 + // Open the repository
1.236 + TheServerRepository->OpenL(KTestRepositoryId, *TheObserver);
1.237 +
1.238 + // All write operations, including CreateL must be done in a transaction
1.239 + TheServerRepository->StartTransaction(CRepository::EConcurrentReadWriteTransaction);
1.240 + TheServerRepository->CleanupCancelTransactionPushL();
1.241 +
1.242 + //Create the appropriate setting based on aValueType
1.243 + switch(aSettingType)
1.244 + {
1.245 + case TServerSetting::EInt:
1.246 + {
1.247 + // Create setting - fails if value already there (it must not be)
1.248 + User::LeaveIfError(TheServerRepository->TransactionCreateL(KIntSettingID, KIntSettingVal, NULL));
1.249 +
1.250 + // Try to get the value from the transaction cache
1.251 + TInt val = 0;
1.252 + User::LeaveIfError(TheServerRepository->Get(KIntSettingID, val));
1.253 + TEST2(val,KIntSettingVal);
1.254 + break;
1.255 + }
1.256 +
1.257 + case TServerSetting::EReal:
1.258 + {
1.259 + // Create setting - fails if value already there (it must not be)
1.260 + User::LeaveIfError(TheServerRepository->TransactionCreateL(KRealSettingID, KRealSettingVal, NULL));
1.261 +
1.262 + // Try to get the value from the transaction cache
1.263 + TReal val = 0;
1.264 + User::LeaveIfError(TheServerRepository->Get(KRealSettingID, val));
1.265 + TEST(val == KRealSettingVal);
1.266 + break;
1.267 + }
1.268 +
1.269 + case TServerSetting::EString:
1.270 + {
1.271 + // Create setting - fails if value already there (it must not be)
1.272 + User::LeaveIfError(TheServerRepository->TransactionCreateL(KStringSettingID, KStringSettingVal, NULL));
1.273 +
1.274 + // Try to get the value from the transaction cache
1.275 + TBuf8<16> bufVal(KEmptyString);
1.276 + User::LeaveIfError(TheServerRepository->Get(KStringSettingID, bufVal));
1.277 + TEST(bufVal == KStringSettingVal);
1.278 + break;
1.279 + }
1.280 + default:
1.281 + break;
1.282 + }
1.283 +
1.284 + // Commit the changes
1.285 + CleanupStack::Pop();
1.286 + TUint32 keyInfo;
1.287 + User::LeaveIfError(TheServerRepository->CommitTransaction(keyInfo));
1.288 +
1.289 + TServerResources::iObserver->iTrapOOMOnOpen=EFalse;
1.290 + // Close the repository
1.291 + TheServerRepository->Close();
1.292 +
1.293 + CleanupStack::PopAndDestroy(2);//TheObserver & TheServerRepository
1.294 + }
1.295 +
1.296 +//This function is called from SetSetting_OOMtest().
1.297 +//It expects that the previous test (CreateSetting_OOMtestL()) had completed successfully
1.298 +//and there is a repository file (ID=0x10) on drive C and there is an integer setting
1.299 +//in that repository (ID=KIntSettingID, Value=KIntSettingVal).
1.300 +//The test will try to change the setting value in a transaction. Because the test is
1.301 +//executed in an OOM loop, CommitChangesL() - will fail when called by SetL, leaving the
1.302 +//repository content inconsistent - the in-memory repository content will be deleted
1.303 +//(no settings), but in the file the setting will exist and its value will still be KIntSettingVal.
1.304 +static void DoSetIntSettingL()
1.305 + {
1.306 + TEST(TheObserver != NULL);
1.307 + TEST(TheServerRepository != NULL);
1.308 + // Check if the setting is there - and has (or is restored to) the original value
1.309 + TInt val = 0;
1.310 + User::LeaveIfError(TheServerRepository->Get(KIntSettingID, val));
1.311 + TEST2(val,KIntSettingVal);
1.312 +
1.313 + // Change the setting value
1.314 + // All write operations, including CreateL must be done in a transaction
1.315 + TheServerRepository->StartTransaction(CRepository::EConcurrentReadWriteTransaction);
1.316 + TheServerRepository->CleanupCancelTransactionPushL();
1.317 + // Change the setting value
1.318 + User::LeaveIfError(TheServerRepository->TransactionSetL(KIntSettingID, KIntSettingVal + 1));
1.319 +
1.320 + // Check if the setting is there - it should be in transaction cache now
1.321 + User::LeaveIfError(TheServerRepository->Get(KIntSettingID, val));
1.322 + TEST2(val,(KIntSettingVal + 1));
1.323 +
1.324 + // Commit the changes
1.325 + CleanupStack::Pop();
1.326 + TUint32 keyInfo;
1.327 + User::LeaveIfError(TheServerRepository->CommitTransaction(keyInfo));
1.328 +
1.329 + // Check if the setting is there. The transaction was successful so the new value
1.330 + // should be returned.
1.331 + val = 0;
1.332 + User::LeaveIfError(TheServerRepository->Get(KIntSettingID, val));
1.333 + TEST2(val,(KIntSettingVal + 1));
1.334 + }
1.335 +
1.336 +//This function is called from SetSetting_OOMtest().
1.337 +//It expects that the previous test (CreateSetting_OOMtestL()) had completed successfully
1.338 +//and there is a repository file (ID=0x10) on drive C and there is an rea; setting
1.339 +//in that repository (ID=KRealSettingID, Value=KRealSettingVal).
1.340 +//The test will try to change the setting value in a transaction. Because the test is
1.341 +//executed in an OOM loop, CommitChangesL() - will fail when called by SetL, leaving the
1.342 +//repository content inconsistent - the in-memory repository content will be deleted
1.343 +//(no settings), but in the file the setting will exist and its value will still be KRealSettingVal.
1.344 +static void DoSetRealSettingL()
1.345 + {
1.346 + TEST(TheObserver != NULL);
1.347 + TEST(TheServerRepository != NULL);
1.348 + // Check if the setting is there - and has (or is restored to) the original value
1.349 + TReal val = 0;
1.350 + User::LeaveIfError(TheServerRepository->Get(KRealSettingID, val));
1.351 + TEST(val == KRealSettingVal);
1.352 +
1.353 + // Change the setting value
1.354 + // All write operations, including CreateL must be done in a transaction
1.355 + TheServerRepository->StartTransaction(CRepository::EConcurrentReadWriteTransaction);
1.356 + TheServerRepository->CleanupCancelTransactionPushL();
1.357 + // Change the setting value
1.358 + User::LeaveIfError(TheServerRepository->TransactionSetL(KRealSettingID, KRealSettingVal2));
1.359 +
1.360 + // Check if the setting is there - it should be in transaction cache now
1.361 + User::LeaveIfError(TheServerRepository->Get(KRealSettingID, val));
1.362 + TEST(val == KRealSettingVal2);
1.363 +
1.364 + // Commit the changes
1.365 + CleanupStack::Pop();
1.366 + TUint32 keyInfo;
1.367 + User::LeaveIfError(TheServerRepository->CommitTransaction(keyInfo));
1.368 +
1.369 + // Check if the setting is there. The transaction was successful so the new value
1.370 + // should be returned.
1.371 + val = 0;
1.372 + User::LeaveIfError(TheServerRepository->Get(KRealSettingID, val));
1.373 + TEST(val == KRealSettingVal2);
1.374 + }
1.375 +
1.376 +//This function is called from SetSetting_OOMtest().
1.377 +//It expects that the previous test (CreateSetting_OOMtestL()) had completed successfully
1.378 +//and there is a repository file (ID=0x10) on drive C and there is an string setting
1.379 +//in that repository (ID=KStringSettingID, Value=KStringSettingVal).
1.380 +//The test will try to change the setting value in a transaction. Because the test is
1.381 +//executed in an OOM loop, CommitChangesL() - will fail when called by SetL, leaving the
1.382 +//repository content inconsistent - the in-memory repository content will be deleted
1.383 +//(no settings), but in the file the setting will exist and its value will still
1.384 +//be KStringSettingVal.
1.385 +static void DoSetStringSettingL()
1.386 + {
1.387 + TEST(TheObserver != NULL);
1.388 + TEST(TheServerRepository != NULL);
1.389 +
1.390 + // Check if the setting is there - and has (or is restored to) the original value
1.391 + TBuf8<16> bufVal(KEmptyString);
1.392 + User::LeaveIfError(TheServerRepository->Get(KStringSettingID, bufVal));
1.393 + TEST(bufVal == KStringSettingVal);
1.394 +
1.395 + // Change the setting value
1.396 + // All write operations, including CreateL must be done in a transaction
1.397 + TheServerRepository->StartTransaction(CRepository::EConcurrentReadWriteTransaction);
1.398 + TheServerRepository->CleanupCancelTransactionPushL();
1.399 +
1.400 + // Change the setting value
1.401 + User::LeaveIfError(TheServerRepository->TransactionSetL(KStringSettingID, KStringSettingVal2));
1.402 +
1.403 + // Check if the setting is there - it should be in transaction cache now
1.404 + User::LeaveIfError(TheServerRepository->Get(KStringSettingID, bufVal));
1.405 + TEST(bufVal == KStringSettingVal2);
1.406 + // Commit the changes
1.407 + CleanupStack::Pop();
1.408 + TUint32 keyInfo;
1.409 + User::LeaveIfError(TheServerRepository->CommitTransaction(keyInfo));
1.410 +
1.411 + // Check if the setting is there. The transaction was successful so the new value
1.412 + // should be returned.
1.413 + bufVal = KEmptyString;
1.414 + User::LeaveIfError(TheServerRepository->Get(KStringSettingID, bufVal));
1.415 + TEST(bufVal == KStringSettingVal2);
1.416 + }
1.417 +
1.418 +//This function is called from SetSetting_OOMtest()in the case where previous
1.419 +//DoSetSettingL() call failed with KErrNoMemory, leaving the repository object
1.420 +//in inconsisten state - the in-memory presentation of the repository differs from
1.421 +//the repository file content. The function will try to repair the repository,
1.422 +//as it would have to happen in a real situation. Then it will check that
1.423 +//the repository content is consistent, which means the tested setting value should
1.424 +//be the same as it was before DoSetSettingL() call.
1.425 +static void DoRecoverRepositoryL(TServerSetting::TType aSettingType)
1.426 + {
1.427 + //Repair the repository as it happens in a real situation
1.428 + //AccessL calls RestoreConsistencyL() indirectly
1.429 + //RestoreConsistencyL() is called in the production code from the session object,
1.430 + //ServiceL() implementation. So, it will be called before any other repository call
1.431 + //and it should restore the repository content - it should repair the repository
1.432 + //consitency.
1.433 + TServerResources::iObserver->AccessL(KTestRepositoryId);
1.434 + //Check if the setting is there - the old, pre-transactional value should be
1.435 + //in-memory now.
1.436 + switch(aSettingType)
1.437 + {
1.438 + case TServerSetting::EInt:
1.439 + {
1.440 + TInt val = 0;
1.441 + User::LeaveIfError(TheServerRepository->Get(KIntSettingID, val));
1.442 + TEST2(val,KIntSettingVal);
1.443 + break;
1.444 + }
1.445 +
1.446 + case TServerSetting::EReal:
1.447 + {
1.448 + TReal val = 0;
1.449 + User::LeaveIfError(TheServerRepository->Get(KRealSettingID, val));
1.450 + TEST(val == KRealSettingVal);
1.451 + break;
1.452 + }
1.453 +
1.454 + case TServerSetting::EString:
1.455 + {
1.456 + TBuf8<16> bufVal(KEmptyString);
1.457 + User::LeaveIfError(TheServerRepository->Get(KStringSettingID, bufVal));
1.458 + TEST(bufVal == KStringSettingVal);
1.459 + break;
1.460 + }
1.461 + default:
1.462 + break;
1.463 + }
1.464 + }
1.465 +
1.466 +//Inits TServerResources object.
1.467 +//It should be called once, before the creation of CServerRepository object.
1.468 +static void InitEnvL()
1.469 + {
1.470 + TServerResources::InitialiseL();
1.471 +
1.472 + delete TServerResources::iDataDirectory; TServerResources::iDataDirectory = NULL;
1.473 + delete TServerResources::iRomDirectory; TServerResources::iRomDirectory = NULL;
1.474 + delete TServerResources::iInstallDirectory; TServerResources::iInstallDirectory = NULL;
1.475 +
1.476 + TServerResources::iDataDirectory = HBufC::NewL(KMaxFileName);
1.477 + TServerResources::iRomDirectory = HBufC::NewL(KMaxFileName);
1.478 + TServerResources::iInstallDirectory = HBufC::NewL(KMaxFileName);
1.479 +
1.480 + TBuf<32> uidName;
1.481 + uidName.Format(_L("%08X"), KCenRepServerUID.iUid);
1.482 +
1.483 + TPtr ptr1(TServerResources::iDataDirectory->Des());
1.484 + ptr1.Append(_L("C:\\PRIVATE\\"));
1.485 + ptr1.Append(uidName);
1.486 + ptr1.Append(_L("\\PERSISTS\\"));
1.487 +
1.488 + TPtr ptr2(TServerResources::iRomDirectory->Des());
1.489 + ptr2.Append(_L("Z:\\PRIVATE\\"));
1.490 + ptr2.Append(uidName);
1.491 + ptr2.Append(_L("\\"));
1.492 +
1.493 + TPtr ptr3(TServerResources::iInstallDirectory->Des());
1.494 + ptr3.Append(_L("C:\\PRIVATE\\"));
1.495 + ptr3.Append(uidName);
1.496 + ptr3.Append(_L("\\"));
1.497 + }
1.498 +
1.499 +//Destroys TServerResources object.
1.500 +//It should be called after the CServerRepository object was destroyed.
1.501 +static void ReleaseEnv()
1.502 + {
1.503 + TServerResources::Close();
1.504 + }
1.505 +
1.506 +//Creates global TheServerRepository and TheObserver objects
1.507 +//It is used in SetSetting_OOMtest()
1.508 +static void InitEnv2L()
1.509 + {
1.510 + TheObserver = new CTestObserver;
1.511 + TEST(TheObserver != NULL);
1.512 +
1.513 + TheServerRepository = new CServerRepository;
1.514 + TEST(TheServerRepository != NULL);
1.515 +
1.516 + TheServerRepository->OpenL(KTestRepositoryId, *TheObserver);
1.517 + }
1.518 +
1.519 +//Destroys global TheServerRepository and TheObserver objects
1.520 +//It is used in SetSetting_OOMtest()
1.521 +static void ReleaseEnv2()
1.522 + {
1.523 + ::ReleaseRepository(NULL);
1.524 + ::ReleaseObserver(NULL);
1.525 + }
1.526 +
1.527 +//Central repository test: it creates a setting in OOM conditions.
1.528 +static void CreateSetting_OOMtestL(TBool aTrapping,TServerSetting::TType aSettingType)
1.529 + {
1.530 + TInt err;
1.531 + TRAP(err, ::InitEnvL());
1.532 + TEST2(err, KErrNone);
1.533 + for(TInt count=1;;++count)
1.534 + {
1.535 + CleanupCDriveL();
1.536 + __UHEAP_FAILNEXT(count);
1.537 + __UHEAP_MARK;
1.538 +
1.539 + TRAP(err, ::DoCreateSettingL(aTrapping,aSettingType));
1.540 +
1.541 + TServerResources::iOwnerIdLookUpTable.Reset();
1.542 + TServerResources::iObserver->Reset();
1.543 +
1.544 + __UHEAP_MARKEND;
1.545 +
1.546 + if(err == KErrNone)
1.547 + {
1.548 + RDebug::Print(_L("The test succeeded at heap failure rate=%d.\n"), count);
1.549 + break;
1.550 + }
1.551 + else if(err != KErrNoMemory)
1.552 + {
1.553 + TEST2(err, KErrNone);
1.554 + }
1.555 + }
1.556 +
1.557 + ::ReleaseEnv();
1.558 + __UHEAP_RESET;
1.559 + }
1.560 +
1.561 +//Central repository test: it sets new setting value in OOM conditions.
1.562 +//Then ComitChangesL() is called to store the new setting's value in the repository
1.563 +//file. Because of the simulated OOM conditions ComitChangesL() can fail, leaving the
1.564 +//repository in inconsistent state.
1.565 +//DoRecoverRepositoryL() is called to repair the repository and restore the consistency.
1.566 +static void SetSetting_OOMtest(TServerSetting::TType aSettingType)
1.567 + {
1.568 + TTime before;
1.569 + TTime after;
1.570 + // Check that cre file exists and get modification time
1.571 + TEST2 (GetFileTimeStamp(KCreTestFile1, before), KErrNone);
1.572 + after=before;
1.573 +
1.574 + TInt err;
1.575 + TRAP(err, ::InitEnvL());
1.576 + TEST2(err, KErrNone);
1.577 + TRAP(err, ::InitEnv2L());
1.578 + TEST2(err, KErrNone);
1.579 + for(TInt count=1;;++count)
1.580 + {
1.581 + __UHEAP_FAILNEXT(count);
1.582 + __UHEAP_MARK;
1.583 +
1.584 + switch(aSettingType)
1.585 + {
1.586 + case TServerSetting::EInt:
1.587 + {
1.588 + TRAP(err, ::DoSetIntSettingL());
1.589 + break;
1.590 + }
1.591 + case TServerSetting::EReal:
1.592 + {
1.593 + TRAP(err, ::DoSetRealSettingL());
1.594 + break;
1.595 + }
1.596 + case TServerSetting::EString:
1.597 + {
1.598 + TRAP(err, ::DoSetStringSettingL());
1.599 + break;
1.600 + }
1.601 + default:
1.602 + break;
1.603 + }
1.604 +
1.605 + // Get timestamp of cre file. It is now possible for the commit to
1.606 + // fail with KErrNoMemory after a successful write. If filestamp
1.607 + // changes, the cre file has been written and the test is complete
1.608 + TEST2 (GetFileTimeStamp(KCreTestFile1, after), KErrNone);
1.609 + if(before!=after)
1.610 + {
1.611 + err=KErrNone;
1.612 + }
1.613 +
1.614 + if(err == KErrNoMemory)
1.615 + {
1.616 + __UHEAP_MARKEND;
1.617 + //DoSetSettingL() call failed (so the transaction). Try to recover.
1.618 + TInt err2;
1.619 + TRAP(err2, ::DoRecoverRepositoryL(aSettingType));
1.620 + TEST2(err2, KErrNone);
1.621 + }
1.622 + else if(err == KErrNone)
1.623 + {
1.624 + //The heap cannot be checked at this point because memory may have been
1.625 + //allocated which must be freed by a call to ReleaseEnv2.
1.626 + //It is checked outside the loop instead
1.627 + RDebug::Print(_L("The test succeeded at heap failure rate=%d.\n"), count);
1.628 + break;
1.629 + }
1.630 + else
1.631 + {
1.632 + __UHEAP_MARKEND;
1.633 + TEST2(err, KErrNone);
1.634 + }
1.635 + // Check that tmp file generated by attempted commit is deleted
1.636 + // by RestoreConsistencyL() in DoRecoverRepositoryL().
1.637 + ::CheckTmpFileDeleted();
1.638 + }
1.639 + // Check that no tmp file is left over
1.640 + ::ReleaseEnv2();
1.641 + ::ReleaseEnv();
1.642 + //This __UHEAP_MARKEND checks the heap after the call to DoSetxSettings
1.643 + //succeeds as calls to CommitTRansactions can allocate memory which must be freed
1.644 + //by calling ReleaseEnv2
1.645 + __UHEAP_MARKEND;
1.646 + __UHEAP_RESET;
1.647 + }
1.648 +
1.649 +///////////////////////////////////////////////////////////////////////////////////////
1.650 +
1.651 +void RunTestsL(TServerSetting::TType aSettingType)
1.652 + {
1.653 +
1.654 + TheTest.Next(_L("Create setting - OOM test - OOM Trapping off"));
1.655 + ::CreateSetting_OOMtestL(EFalse,aSettingType);
1.656 +
1.657 + TheTest.Next(_L("Create setting - OOM test - OOM Trapping on"));
1.658 + ::CreateSetting_OOMtestL(ETrue,aSettingType);
1.659 +
1.660 + TheTest.Next(_L("Set setting - transaction - OOM test"));
1.661 + ::SetSetting_OOMtest(aSettingType);
1.662 +
1.663 + }
1.664 +
1.665 +static void MainL()
1.666 + {
1.667 + // create and install the active scheduler we need for the cache manager in TServerResources::InitialiseL
1.668 + CActiveScheduler* cacheManagerAS=new(ELeave) CActiveScheduler;
1.669 + CleanupStack::PushL(cacheManagerAS);
1.670 + CActiveScheduler::Install(cacheManagerAS);
1.671 +
1.672 + ::DeleteFiles();
1.673 +
1.674 + TheTest.Start(_L(" @SYMTestCaseID:SYSLIB-CENTRALREPOSITORY-LEGACY-T_CENREPTRANS-0001 Int Setting Tests "));
1.675 + RunTestsL(TServerSetting::EInt);
1.676 +
1.677 + TheTest.Next(_L("Real Setting Tests"));
1.678 + RunTestsL(TServerSetting::EReal);
1.679 +
1.680 + TheTest.Next(_L("String Setting Tests"));
1.681 + RunTestsL(TServerSetting::EString);
1.682 +
1.683 + TheTest.End();
1.684 + TheTest.Close();
1.685 +
1.686 + CleanupStack::PopAndDestroy(cacheManagerAS);
1.687 + }
1.688 +
1.689 +TInt E32Main()
1.690 + {
1.691 + __UHEAP_MARK;
1.692 +
1.693 + CTrapCleanup* tc = CTrapCleanup::New();
1.694 + TEST(tc != NULL);
1.695 +
1.696 + TheTest.Title();
1.697 + TRAPD(err, ::MainL());
1.698 + TEST2(err, KErrNone);
1.699 +
1.700 + ::DeleteFiles();
1.701 +
1.702 + delete tc;
1.703 +
1.704 + __UHEAP_MARKEND;
1.705 +
1.706 + User::Heap().Check();
1.707 + return KErrNone;
1.708 + }