sl@0: // Copyright (c) 2008-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: /**
sl@0:  @file
sl@0:  @test
sl@0:  @internalComponent
sl@0: */
sl@0:   
sl@0: 
sl@0: #include "utils.h"
sl@0: #include "panic.h"
sl@0: 
sl@0: /*************************************************************************************
sl@0:  class TRnd
sl@0:  */
sl@0: 
sl@0: /**
sl@0: Math::Rand() degenerates to approx seed*3.3+38 for the first numbers generated 
sl@0: with a low seed, which isn't very random. To illustrate: The random numbers generated 
sl@0: by the seeds {0..9} are {38, 41, 45, 48, 51, 54, 58, 61, 64, 68}.
sl@0: */
sl@0: const TInt64 KMinSeed = 1000000000;
sl@0: 
sl@0: TInt64 TRnd::iSeed = KMinSeed; // Need to change CComparison::StartL() to use this value
sl@0: 
sl@0: CExecutionContext::CLogMediator* TRnd::iMediator 			= NULL;
sl@0: CExecutionContext* 				 TRnd::iExecutionContext	= NULL;
sl@0: 
sl@0: TInt64 TRnd::Seed()
sl@0: 	{
sl@0: 	return iSeed;
sl@0: 	}
sl@0: 
sl@0: void TRnd::SetSeed(TInt64 aSeed)
sl@0: 	{
sl@0: 	iSeed = aSeed;
sl@0: 	}
sl@0: 
sl@0: void TRnd::SetLogMediator(CExecutionContext::CLogMediator* aMediator)
sl@0: 	{
sl@0: 	iMediator = aMediator;
sl@0: 	}
sl@0: 
sl@0: void TRnd::SetExecutionContext(CExecutionContext* aExecutionContext)
sl@0: 	{
sl@0: 	iExecutionContext = aExecutionContext;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: TInt TRnd::GenRand(TInt x)
sl@0: 	{
sl@0: 	TInt res = Math::Rand( iSeed );
sl@0: 	if (x)
sl@0: 		{
sl@0: 		res = res % x;
sl@0: 		}
sl@0: 	return res;
sl@0: 	}
sl@0: 
sl@0: TInt TRnd::rnd(TInt x)
sl@0: 	{
sl@0: 	TInt res;
sl@0: 	
sl@0: 	switch ( iExecutionContext->ContextMode() )
sl@0: 	{
sl@0: 	case CExecutionContext::ECtxPlayback:	
sl@0: 		res = iMediator->PlaybackInt();
sl@0: 		break;
sl@0: 		
sl@0: 	case CExecutionContext::ECtxRandomAndRecord:
sl@0: 		res = GenRand(x);
sl@0: 		iMediator->RecordInt( res );
sl@0: 		break;
sl@0: 		
sl@0: 	case CExecutionContext::ECtxRandom:		// fallthrough
sl@0: 	default:
sl@0: 		res = GenRand(x);
sl@0: 		break;
sl@0: 	}
sl@0: 	
sl@0: 	return res; 
sl@0: 	}
sl@0: 
sl@0: /*************************************************************************************
sl@0:  class CExecutionContext
sl@0:  */
sl@0: TInt CExecutionContext::CLogMediator::PlaybackInt()
sl@0: 	{
sl@0: 	
sl@0: 	TInt res = 0;
sl@0: 	
sl@0: 	if ( !iStalled )
sl@0: 		{
sl@0: 	
sl@0: 		TBool failed = ETrue;
sl@0: 		
sl@0: 		TBuf8<1024> logRec;
sl@0: 	
sl@0: 		TInt readRes;
sl@0: 		
sl@0: 		readRes = iLog.Read( logRec, 3 ); // 'Num'
sl@0: 	
sl@0: 		
sl@0: 		
sl@0: 		if ( readRes == KErrNone && logRec == _L8("Num") )
sl@0: 			{
sl@0: 			iLog.Read( logRec, 16 ); // EntryNo, 16 characters	
sl@0: 			TLex8 strLex;		
sl@0: 			strLex.Assign( logRec );		
sl@0: 			TInt64 readVal64 = 0;		
sl@0: 			readRes = strLex.Val( readVal64, EDecimal );		
sl@0: 			if ( KErrNone == readRes && readVal64 == iEntryNo )
sl@0: 				{
sl@0: 							
sl@0: 				readRes = iLog.Read( logRec, 3 ); // ' = '
sl@0: 				
sl@0: 				if ( readRes == KErrNone && logRec == _L8(" = ")  )
sl@0: 					{
sl@0: 	
sl@0: 					readRes = iLog.Read( logRec, 13 ); // value 12 + eol
sl@0: 					strLex.Assign( logRec );		
sl@0: 					
sl@0: 					TUint32 readVal32;
sl@0: 	
sl@0: 					readRes = strLex.Val( readVal32, EDecimal );		
sl@0: 					
sl@0: 					if ( KErrNone == readRes )
sl@0: 						{  // finally we got a number
sl@0: 						
sl@0: 						res = (TInt) readVal32;
sl@0: 						
sl@0: 						failed = EFalse;
sl@0: 						}
sl@0: 					
sl@0: 					}							
sl@0: 				}
sl@0: 			
sl@0: 			}
sl@0: 		
sl@0: 		if ( failed )
sl@0: 			{
sl@0: 			iExecutionContext.MediatorEmptied( this );
sl@0: 			res = 0;
sl@0: 			iStalled = ETrue;
sl@0: 			}
sl@0: 		
sl@0: 		}
sl@0: 	
sl@0: 	iEntryNo++;
sl@0: 	
sl@0: 	return res;
sl@0: 	}
sl@0: 
sl@0: void CExecutionContext::CLogMediator::RecordInt(TInt aIntToBeRecorded)
sl@0: 	{
sl@0: 	if ( !iStalled )
sl@0: 		{
sl@0: 		TBuf8<1024> logRec;
sl@0: 		logRec.Format( _L8("Num%016Ld = %012d\n"), iEntryNo, aIntToBeRecorded );
sl@0: 		iLog.Write( logRec );	
sl@0: 		}
sl@0: 	
sl@0: 	iEntryNo++;
sl@0: 	}
sl@0: 
sl@0: CExecutionContext::CLogMediator::CLogMediator(CExecutionContext&	aExecutionContext):
sl@0: 	iExecutionContext( aExecutionContext )
sl@0: 	{ }
sl@0: 
sl@0: CExecutionContext::CLogMediator::~CLogMediator()
sl@0: 	{
sl@0: 	iLog.Close();
sl@0: 	iExecutionContext.MediatorDestroyed ( this );
sl@0: 	}
sl@0: 
sl@0: void CExecutionContext::CLogMediator::ConstructL( RFs& aFs, const TDesC& aFileName )
sl@0: 	{
sl@0: 	TInt fileErr;
sl@0: 	
sl@0: 	switch ( iExecutionContext.ContextMode() )
sl@0: 	{
sl@0: 	case CExecutionContext::ECtxPlayback:
sl@0: 		fileErr = iLog.Open( aFs, aFileName, EFileRead );
sl@0: 		break;
sl@0: 	
sl@0: 	case CExecutionContext::ECtxRandomAndRecord:
sl@0: 		fileErr = iLog.Create( aFs, aFileName, EFileWrite );
sl@0: 		if(fileErr == KErrAlreadyExists)
sl@0: 			{
sl@0: 			fileErr = iLog.Replace( aFs, aFileName, EFileWrite );		
sl@0: 			}
sl@0: 		else if(fileErr == KErrPathNotFound)
sl@0: 			{
sl@0: 			User::LeaveIfError(aFs.CreatePrivatePath(EDriveC));
sl@0: 			fileErr = iLog.Create( aFs, aFileName, EFileWrite );
sl@0: 			}
sl@0: 		__ASSERT_ALWAYS(KErrNone == fileErr, User::Panic(_L("t_stress utils.cpp"), EPanic2));
sl@0: 		break;
sl@0: 	
sl@0: 	default:										
sl@0: 		fileErr = KErrGeneral;
sl@0: 		break;
sl@0: 	}
sl@0: 	
sl@0: 	User::LeaveIfError( fileErr );
sl@0: 	
sl@0: 	}
sl@0: 		
sl@0: CExecutionContext::CLogMediator* CExecutionContext::CLogMediator::NewLC(CExecutionContext& aExecutionContext, RFs& aFs, const TDesC& aFileName )
sl@0: 	{
sl@0: 	CExecutionContext::CLogMediator* self = new (ELeave) CExecutionContext::CLogMediator( aExecutionContext );
sl@0: 	CleanupStack::PushL ( self );
sl@0: 	self->ConstructL( aFs, aFileName );
sl@0: 	return self; 
sl@0: 	}
sl@0: 		
sl@0: CExecutionContext* CExecutionContext::NewL(CExecutionContext::TExecutionMode aExecutionMode, CTestExecWatchCat&	aWatchCat)
sl@0: 	{
sl@0: 	CExecutionContext* self = new (ELeave) CExecutionContext( aExecutionMode, aWatchCat );
sl@0: 	CleanupStack::PushL ( self );
sl@0: 	self->ConstructL( );
sl@0: 	CleanupStack::Pop( self );
sl@0: 	return self;
sl@0: 	}
sl@0: 	
sl@0: CExecutionContext::TExecutionMode CExecutionContext::ContextMode()
sl@0: 	{
sl@0: 	return iContextMode;
sl@0: 	}
sl@0: 
sl@0: CExecutionContext::CLogMediator&	CExecutionContext::CreateLogMediatorL(const TDesC& aLogName)
sl@0: 	{
sl@0: 	CExecutionContext::CLogMediator* mediator = CExecutionContext::CLogMediator::NewLC( *this, iFs, aLogName );
sl@0: 	iMediators.AppendL( mediator );
sl@0: 	CleanupStack::Pop(mediator);
sl@0: 	return *mediator;
sl@0: 	}
sl@0: 
sl@0: void CExecutionContext::MediatorDestroyed(CLogMediator* aMediator)
sl@0: 	{
sl@0: 	TInt pos = iMediators.Find( aMediator );
sl@0: 	iMediators.Remove ( pos );
sl@0: 	}
sl@0: 
sl@0: void CExecutionContext::MediatorEmptied(CLogMediator* aMediator)
sl@0: 	{
sl@0: 	(void)aMediator;
sl@0: 	iWatchCat.ExecutionContextRunOut( this );
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CExecutionContext::ConstructL()
sl@0: 	{
sl@0: 	TInt conResult = iFs.Connect();
sl@0: 	User::LeaveIfError( conResult );	
sl@0: 	}
sl@0: 	
sl@0: 
sl@0: CExecutionContext::CExecutionContext(CExecutionContext::TExecutionMode aExecutionMode, CTestExecWatchCat&	aWatchCat):
sl@0: 	iWatchCat(aWatchCat),
sl@0: 	iContextMode(aExecutionMode)
sl@0: 	{ } // empty
sl@0: 
sl@0: CExecutionContext::~CExecutionContext()
sl@0: 	{
sl@0: 	while ( iMediators.Count() > 0 )
sl@0: 		{
sl@0: 			delete iMediators[0]; // this will remove the mediator from the list
sl@0: 		}
sl@0: 	
sl@0: 	iMediators.Close();
sl@0: 	iFs.Close();
sl@0: 	}
sl@0: 
sl@0: /*************************************************************************************
sl@0:  class CTestExecWatchCat
sl@0:  */
sl@0: CTestExecWatchCat* CTestExecWatchCat::NewL(CExecutionContext::TExecutionMode aExecutionMode)
sl@0: 	{
sl@0: 	CTestExecWatchCat* self = new (ELeave) CTestExecWatchCat();
sl@0: 	CleanupStack::PushL( self );	
sl@0: 	self->ConstructL( aExecutionMode );
sl@0: 	
sl@0: 	// finally hook into TRnd
sl@0: 	TRnd::SetExecutionContext(self->iExecutionContext);
sl@0: 	
sl@0: 	CleanupStack::Pop(self); 
sl@0: 	return self;
sl@0: 	}
sl@0: 
sl@0: void CTestExecWatchCat::ConstructL( CExecutionContext::TExecutionMode aExecutionMode )
sl@0: 	{
sl@0: 	iExecutionContext = CExecutionContext::NewL( aExecutionMode, *this );
sl@0: 	}
sl@0: 
sl@0: 
sl@0: CTestExecWatchCat::CTestExecWatchCat()
sl@0: 	{ } // empty
sl@0: 
sl@0: CTestExecWatchCat::~CTestExecWatchCat()
sl@0: 	{
sl@0: 	delete iExecutionContext;
sl@0: 	}
sl@0: 	
sl@0: void CTestExecWatchCat::ExecutionContextRunOut(CExecutionContext* /*aContext*/)
sl@0: 	{ }
sl@0: 
sl@0: /**
sl@0:  Sets the path where the logging file will be created, then constructs the mediator
sl@0:  */
sl@0: void CTestExecWatchCat::SetLoggingPathL(const TDesC& aPath)
sl@0: 	{
sl@0: 	RBuf path;
sl@0: 	path.CleanupClosePushL();
sl@0: 	path.CreateL(aPath.Length() + 16);
sl@0: 	if (aPath.Length())
sl@0: 		{
sl@0: 		path.Copy(aPath);
sl@0: 		if (aPath[aPath.Length()-1] != '\\')
sl@0: 			{
sl@0: 			path.Append('\\');
sl@0: 			}
sl@0: 		}
sl@0: 	path.Append(KLogFileName);
sl@0: 	// now construct log mediator
sl@0: 	CExecutionContext::CLogMediator& mediator = iExecutionContext->CreateLogMediatorL( path );
sl@0: 	TRnd::SetLogMediator(&mediator);
sl@0: 	CleanupStack::PopAndDestroy(&path);
sl@0: 	}
sl@0: 
sl@0: /*************************************************************************************
sl@0:  class TTickUtils
sl@0:  */
sl@0: TUint32 TTickUtils::CalcTickDelta(TUint32 tick1, TUint32 tick2)
sl@0: 	{
sl@0: 	TInt32 res;
sl@0: 	if ( tick1 > tick2 )
sl@0: 		{
sl@0: 		res = tick1 - tick2;
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		res = tick2 - tick1;		
sl@0: 		}
sl@0: 	return res;
sl@0: 	}