1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/centralrepository/test/t_cenrep_helper.cpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,328 @@
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 "srvdefs.h"
1.21 +#include <f32file.h> // RFs
1.22 +#include <e32test.h> // RTest
1.23 +#include <hal.h>
1.24 +#include "cachemgr.h"
1.25 +#include "clirep.h"
1.26 +
1.27 +#if defined(__CENTREP_SERVER_PERFTEST__) || defined(__CENTREP_SERVER_MEMTEST__) || defined(__CENTREP_SERVER_CACHETEST__)
1.28 + #include "srvreqs.h"
1.29 + #define CONDITIONAL_PARAM(x) x
1.30 +#else
1.31 + #define CONDITIONAL_PARAM(x)
1.32 +#endif
1.33 +
1.34 +void PatchDrive(TDes& aPath)
1.35 + {
1.36 + TDriveNumber sysdrive = RFs::GetSystemDrive();
1.37 + aPath[0] = 'a' + sysdrive-EDriveA; // Replace drive letter only.
1.38 + }
1.39 +
1.40 +EXPORT_C void printDirL(const TDesC& aDirName)
1.41 + {
1.42 + CDir* fileList=NULL;
1.43 + RFs fs;
1.44 + User::LeaveIfError(fs.Connect());
1.45 + CleanupClosePushL(fs);
1.46 +
1.47 + TInt r = fs.GetDir(aDirName,KEntryAttNormal, ESortByDate, fileList);
1.48 +
1.49 + if (r==KErrPathNotFound)
1.50 + {
1.51 + RDebug::Print(_L("No directory %S"), &aDirName);
1.52 + }
1.53 + else if (r==KErrNone)
1.54 + {
1.55 + TInt fileCount=fileList->Count();
1.56 + RDebug::Print( _L("%02d files in %S\n"),fileCount, &aDirName);
1.57 + for (TInt i = 0;i < fileCount; ++i)
1.58 + {
1.59 + TEntry entry=(*fileList)[i];
1.60 +
1.61 + RDebug::Print( _L("File[%02d] - %S \n"),
1.62 + i,
1.63 + &(entry.iName)
1.64 + );
1.65 + }
1.66 + }
1.67 + else
1.68 + {
1.69 + RDebug::Print(_L("Error getting contents of directory %S"), &aDirName);
1.70 + }
1.71 + delete fileList;
1.72 + CleanupStack::PopAndDestroy(); //fs
1.73 + }
1.74 +
1.75 +EXPORT_C TInt KillProcess(const TDesC& aProcessName)
1.76 + {
1.77 + TFullName name;
1.78 +
1.79 + RDebug::Print(_L("Find and kill \"%S\" process.\n"), &aProcessName);
1.80 +
1.81 + TBuf<64> pattern(aProcessName);
1.82 + TInt length = pattern.Length();
1.83 + pattern += _L("*");
1.84 + TFindProcess procFinder(pattern);
1.85 +
1.86 + while (procFinder.Next(name) == KErrNone)
1.87 + {
1.88 + if (name.Length() > length)
1.89 + {//If found name is a string containing aProcessName string.
1.90 + TChar c(name[length]);
1.91 + if (c.IsAlphaDigit() ||
1.92 + c == TChar('_') ||
1.93 + c == TChar('-'))
1.94 + {
1.95 + // If the found name is other valid application name
1.96 + // starting with aProcessName string.
1.97 + RDebug::Print(_L(":: Process name: \"%S\".\n"), &name);
1.98 + continue;
1.99 + }
1.100 + }
1.101 + RProcess proc;
1.102 + if (proc.Open(name) == KErrNone)
1.103 + {
1.104 + proc.Kill(0);
1.105 + RDebug::Print(_L("\"%S\" process killed.\n"), &name);
1.106 + }
1.107 + proc.Close();
1.108 + }
1.109 + return KErrNone;
1.110 + }
1.111 +
1.112 +const TInt KSmallDelay = 2*1000;
1.113 +
1.114 +//File cleanup function
1.115 +EXPORT_C void CleanupCDriveL(TBool aRemoveRomCache)
1.116 + {
1.117 + RFs fs;
1.118 + User::LeaveIfError(fs.Connect());
1.119 + CleanupClosePushL(fs);
1.120 +
1.121 + CFileMan* fm = CFileMan::NewL(fs);
1.122 + CleanupStack::PushL(fm);
1.123 + HBufC* file_buf = HBufC::NewLC(KMaxFileName);
1.124 + TPtr file(file_buf->Des());
1.125 + file.Copy(KCPersistsFiles);
1.126 + PatchDrive(file);
1.127 + TInt r = fm->Delete(file);
1.128 +
1.129 + if (r != KErrNone &&
1.130 + r != KErrNotFound &&
1.131 + r != KErrPathNotFound)
1.132 + {
1.133 + User::Leave(r);
1.134 + }
1.135 +
1.136 + if(aRemoveRomCache)
1.137 + {
1.138 + //Delete cached rom version file
1.139 + file.Copy(KCRomVersionFiles);
1.140 + PatchDrive(file);
1.141 + fm->Attribs(file, 0, KEntryAttReadOnly, TTime(0), 0);
1.142 + r = fm->Delete(file);
1.143 + if (r != KErrNone &&
1.144 + r != KErrNotFound &&
1.145 + r != KErrPathNotFound &&
1.146 + r != KErrPermissionDenied)
1.147 + {
1.148 + User::Leave(r);
1.149 + }
1.150 +
1.151 + // Delete all install files
1.152 + file.Copy(KCInstallFiles);
1.153 + PatchDrive(file);
1.154 + r = fm->Delete(file);
1.155 + if (r != KErrNone &&
1.156 + r != KErrNotFound &&
1.157 + r != KErrPathNotFound)
1.158 + {
1.159 + User::Leave(r);
1.160 + }
1.161 +
1.162 + // Give SW time to handle uninstall.
1.163 + User::After(KSmallDelay);
1.164 + }
1.165 + CleanupStack::PopAndDestroy(3);
1.166 + }
1.167 +
1.168 +//Function to remove all repositories from repository cache
1.169 +//Try not to use this function because it is time consuming (129.5 seconds)
1.170 +EXPORT_C void CleanupRepositoryCache()
1.171 + {
1.172 + // So we wait here until the cache is empty to correct the behaviour.
1.173 + User::After(KDefaultEvictionTimeout+950000);
1.174 + }
1.175 +
1.176 +//Function to clean specific repository files
1.177 +EXPORT_C void CleanupFileFromCDriveL(const TUid aRepository)
1.178 + {
1.179 + RFs fs;
1.180 + User::LeaveIfError(fs.Connect());
1.181 + CleanupClosePushL(fs);
1.182 +
1.183 + CFileMan* fm = CFileMan::NewL(fs);
1.184 + CleanupStack::PushL(fm);
1.185 +
1.186 + HBufC* file_buf = HBufC::NewLC(KMaxFileName);
1.187 + TPtr filename(file_buf->Des());
1.188 + filename = KCPersistsDir;
1.189 + filename.AppendNumFixedWidth(aRepository.iUid,EHex,8);
1.190 + filename.Append(KTxtFileExt);
1.191 + PatchDrive(filename);
1.192 + // Delete txt file from persists dir
1.193 + TInt r = fm->Delete(filename);
1.194 +
1.195 + if (r != KErrNone &&
1.196 + r != KErrNotFound &&
1.197 + r != KErrPathNotFound)
1.198 + {
1.199 + User::Leave(r);
1.200 + }
1.201 +
1.202 + filename = KCPersistsDir;
1.203 + filename.AppendNumFixedWidth(aRepository.iUid,EHex,8);
1.204 + filename.Append(KCreFileExt);
1.205 + PatchDrive(filename);
1.206 + // Delete cre file from persists dir
1.207 + r = fm->Delete(filename);
1.208 +
1.209 + if (r != KErrNone &&
1.210 + r != KErrNotFound &&
1.211 + r != KErrPathNotFound)
1.212 + {
1.213 + User::Leave(r);
1.214 + }
1.215 +
1.216 + filename = KCInstallDir;
1.217 + filename.AppendNumFixedWidth(aRepository.iUid,EHex,8);
1.218 + filename.Append(KTxtFileExt);
1.219 + PatchDrive(filename);
1.220 + // Delete txt file from install dir
1.221 + r = fm->Delete(filename);
1.222 + if (r != KErrNone &&
1.223 + r != KErrNotFound &&
1.224 + r != KErrPathNotFound)
1.225 + {
1.226 + User::Leave(r);
1.227 + }
1.228 +
1.229 + filename = KCInstallDir;
1.230 + filename.AppendNumFixedWidth(aRepository.iUid,EHex,8);
1.231 + filename.Append(KCreFileExt);
1.232 + PatchDrive(filename);
1.233 + // Delete cre file from install dir
1.234 + r = fm->Delete(filename);
1.235 + if (r != KErrNone &&
1.236 + r != KErrNotFound &&
1.237 + r != KErrPathNotFound)
1.238 + {
1.239 + User::Leave(r);
1.240 + }
1.241 +
1.242 + // Give SW time to handle uninstall.
1.243 + User::After(KSmallDelay);
1.244 +
1.245 + CleanupStack::PopAndDestroy(3);
1.246 + }
1.247 +
1.248 +//This function copies files from a source folder to a target folder
1.249 +//and sets the file attributes to archive and read only
1.250 +EXPORT_C void CopyTestFilesL(CFileMan& aFm, const TDesC& aSrc, const TDesC& aDest)
1.251 + {
1.252 + TBuf<KMaxFileName> src, dest;
1.253 + src.Copy(aSrc);
1.254 + dest.Copy(aDest);
1.255 +
1.256 + PatchDrive(dest);
1.257 +
1.258 + //copy test files
1.259 + User::LeaveIfError(aFm.Copy(src, dest,CFileMan::ERecurse));
1.260 + aFm.Attribs(dest,
1.261 + KEntryAttArchive,
1.262 + KEntryAttReadOnly,
1.263 + TTime(0),
1.264 + CFileMan::ERecurse);
1.265 + }
1.266 +
1.267 +//This function prints out the recorded time in milliseconds of aTime.
1.268 +EXPORT_C void RecordPerformanceTimingL(TUint32 aTime)
1.269 + {
1.270 + TInt freq = 0;
1.271 + TInt Err = HAL::Get(HAL::EFastCounterFrequency, freq);
1.272 + if(Err != KErrNone)
1.273 + {
1.274 + RDebug::Print(_L("HAL error <%d>\r\n"), Err);
1.275 + }
1.276 + const TInt KMicroSecIn1Sec = 1000000;
1.277 + const TInt KMsIn1Sec = 1000;
1.278 +
1.279 + double v = ((double)aTime * KMicroSecIn1Sec) / (double)freq; TInt v2 = (TInt)v;
1.280 + RDebug::Print(_L("####Execution time: %d ms\r\n"), v2 / KMsIn1Sec);
1.281 + }
1.282 +
1.283 +///////////////////////////////////////////////////////////////////////////////////////
1.284 +///////////////////////////////////////////////////////////////////////////////////////
1.285 +//Test macroes and functions
1.286 +
1.287 +EXPORT_C void CheckL(RTest& aTest, TInt aValue, TInt aLine)
1.288 + {
1.289 + if (!aValue)
1.290 + {
1.291 + CleanupCDriveL();
1.292 + aTest(EFalse, aLine);
1.293 + }
1.294 + }
1.295 +EXPORT_C void CheckL(RTest& aTest, TInt aValue, TInt aExpected, TInt aLine)
1.296 + {
1.297 + if (aValue != aExpected)
1.298 + {
1.299 + RDebug::Print(_L("*** Expected error: %d, got: %d\r\n"),
1.300 + aExpected, aValue);
1.301 + CleanupCDriveL();
1.302 + aTest(EFalse, aLine);
1.303 + }
1.304 + }
1.305 +
1.306 +/**
1.307 + *Retrieves transaction state of the session.
1.308 +*/
1.309 +EXPORT_C TInt TransactionState(CRepository* aRep)
1.310 + {
1.311 + return (static_cast<CClientRepository*>(aRep))->TransactionState();
1.312 + }
1.313 +
1.314 +/**
1.315 + *Sends EGetSetParameters to server.
1.316 +*/
1.317 +EXPORT_C TInt SetGetParameters(const TIpcArgs& CONDITIONAL_PARAM(aArgs))
1.318 + {
1.319 +#if defined(__CENTREP_SERVER_PERFTEST__) || defined(__CENTREP_SERVER_MEMTEST__) || defined(__CENTREP_SERVER_CACHETEST__)
1.320 + RRepositorySession session;
1.321 + TInt ret = session.Connect();
1.322 + if (ret == KErrNone)
1.323 + {
1.324 + ret = session.SendReceive(EGetSetParameters, aArgs);
1.325 + session.Close();
1.326 + }
1.327 + return ret;
1.328 +#else
1.329 + return KErrNotSupported;
1.330 +#endif
1.331 + }