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 the License "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: // e32test\demandpaging\d_pagestrss.cpp
sl@0: // 
sl@0: //
sl@0: 
sl@0: #include <kernel/kern_priv.h>
sl@0: #include <kernel/cache.h>
sl@0: #include "d_pagestress.h"
sl@0: 
sl@0: //
sl@0: // Class definitions
sl@0: //
sl@0: 
sl@0: class DPageStressTestFactory : public DLogicalDevice
sl@0: 	{
sl@0: public:
sl@0: 	~DPageStressTestFactory();
sl@0: 	virtual TInt Install();
sl@0: 	virtual void GetCaps(TDes8& aDes) const;
sl@0: 	virtual TInt Create(DLogicalChannelBase*& aChannel);
sl@0: 	};
sl@0: 
sl@0: class DPageStressTestChannel : public DLogicalChannelBase
sl@0: 	{
sl@0: public:
sl@0: 	DPageStressTestChannel();
sl@0: 	~DPageStressTestChannel();
sl@0: 	virtual TInt DoCreate(TInt aUnit, const TDesC8* anInfo, const TVersion& aVer);
sl@0: 	virtual TInt Request(TInt aFunction, TAny* a1, TAny* a2);
sl@0: 
sl@0: 	TInt DoConsumeRamSetup(TInt aNumPagesLeft, TInt aPagesInBlock);
sl@0: 	TInt DoConsumeRamFinish(void);
sl@0: 	TInt DoConsumeSomeRam(TInt aBlocks);
sl@0: 	TInt DoReleaseSomeRam(TInt aBlocks);
sl@0: 	TInt FreeRam();
sl@0: 	TInt DoSetDebugFlag(TInt aState);
sl@0: public:
sl@0: 	DPageStressTestFactory*	iFactory;
sl@0: 	
sl@0: private:
sl@0: 	TBool		 iRamAllocd;
sl@0: 	TInt		 iInitialFreeRam;
sl@0: 	TInt		 iTotalBlocks;
sl@0: 	TInt		 iBlockSize;
sl@0: 	TInt		 iLastBlockAllocd;
sl@0: 	TPhysAddr*	 iAddrArray;
sl@0: 	TInt		 iDebug;
sl@0: 	DMutex*      iMutex;
sl@0: 	TInt		 iThreadCounter;
sl@0: 	TPhysAddr	 iAddrMin;
sl@0: 	TPhysAddr	 iAddrMax;
sl@0: 	TBool		 iDemandPaging;
sl@0: 	};
sl@0: 
sl@0: //
sl@0: // DPageStressTestFactory
sl@0: //
sl@0: 
sl@0: TInt DPageStressTestFactory::Install()
sl@0: 	{
sl@0: 	return SetName(&KPageStressTestLddName);
sl@0: 	}
sl@0: 
sl@0: DPageStressTestFactory::~DPageStressTestFactory()
sl@0: 	{
sl@0: 	}
sl@0: 
sl@0: void DPageStressTestFactory::GetCaps(TDes8& /*aDes*/) const
sl@0: 	{
sl@0: 	// Not used but required as DLogicalDevice::GetCaps is pure virtual
sl@0: 	}
sl@0: 
sl@0: TInt DPageStressTestFactory::Create(DLogicalChannelBase*& aChannel)
sl@0: 	{
sl@0: 	aChannel = NULL;
sl@0: 	DPageStressTestChannel* channel=new DPageStressTestChannel;
sl@0: 	if(!channel)
sl@0: 		return KErrNoMemory;
sl@0: 	channel->iFactory = this;
sl@0: 	aChannel = channel;
sl@0: 	return KErrNone;
sl@0: 	}
sl@0: 
sl@0: DECLARE_STANDARD_LDD()
sl@0: 	{
sl@0: 	return new DPageStressTestFactory;
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // DPageStressTestChannel
sl@0: //
sl@0: 
sl@0: TInt DPageStressTestChannel::DoCreate(TInt /*aUnit*/, const TDesC8* /*aInfo*/, const TVersion& /*aVer*/)
sl@0: 	{
sl@0: 	return KErrNone;
sl@0: 	}
sl@0: 
sl@0: DPageStressTestChannel::DPageStressTestChannel()
sl@0: 	: iRamAllocd(EFalse), iInitialFreeRam(0), iTotalBlocks(0), iBlockSize(0), iLastBlockAllocd(0), 
sl@0: 	iAddrArray(NULL), iDebug(0), iThreadCounter(1), iAddrMin(0), iAddrMax(0), iDemandPaging(ETrue)
sl@0: 	{
sl@0: 	_LIT(KMutexName,"TPageStressMutex");
sl@0: 	NKern::ThreadEnterCS();
sl@0: 	Kern::MutexCreate(iMutex, KMutexName,KMutexOrdNone);
sl@0: 	NKern::ThreadLeaveCS();
sl@0: 	SVMCacheInfo tempPages;
sl@0: 	if (Kern::HalFunction(EHalGroupVM,EVMHalGetCacheSize,&tempPages,0) != KErrNone)
sl@0: 		{
sl@0: 		iDemandPaging = EFalse;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: DPageStressTestChannel::~DPageStressTestChannel()
sl@0: 	{
sl@0: 	if (iRamAllocd)
sl@0: 		{
sl@0: 		DoConsumeRamFinish();
sl@0: 		}
sl@0: 	if (iMutex)
sl@0:         {
sl@0: 		iMutex->Close(NULL);
sl@0: 		iMutex = NULL;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: TInt DPageStressTestChannel::Request(TInt aFunction, TAny* a1, TAny* a2)
sl@0: 	{
sl@0: 	TInt threadCount = __e32_atomic_tas_ord32(&iThreadCounter, 1, 1, 0);
sl@0: 	if (threadCount >= 2)
sl@0: 		{
sl@0: 		Kern::Printf("DPageStressTestChannel::Request threadCount = %d\n", threadCount);
sl@0: 		}
sl@0: 	NKern::ThreadEnterCS();
sl@0: 	Kern::MutexWait(*iMutex);
sl@0: 	TInt retVal = KErrNotSupported;
sl@0: 	switch(aFunction)
sl@0: 		{
sl@0: 		case RPageStressTestLdd::EDoConsumeRamSetup:
sl@0: 			{
sl@0: 			retVal = DPageStressTestChannel::DoConsumeRamSetup((TInt)a1, (TInt)a2);
sl@0: 			}
sl@0: 		break;
sl@0: 
sl@0: 		case RPageStressTestLdd::EDoConsumeRamFinish:
sl@0: 			{
sl@0: 			retVal = DPageStressTestChannel::DoConsumeRamFinish();
sl@0: 			}
sl@0: 		break;
sl@0: 
sl@0: 		case RPageStressTestLdd::EDoConsumeSomeRam:
sl@0: 			{
sl@0: 			retVal = DPageStressTestChannel::DoConsumeSomeRam((TInt)a1);
sl@0: 			}
sl@0: 		break;
sl@0: 
sl@0: 		case RPageStressTestLdd::EDoReleaseSomeRam:
sl@0: 			{
sl@0: 			retVal = DPageStressTestChannel::DoReleaseSomeRam((TInt)a1);
sl@0: 			}
sl@0: 		break;
sl@0: 		
sl@0: 		case RPageStressTestLdd::EDoSetDebugFlag:
sl@0: 			{
sl@0: 			retVal = DoSetDebugFlag((TInt) a1);
sl@0: 			}
sl@0: 		break;
sl@0: 		
sl@0: 		default: break;
sl@0: 		}
sl@0: 	Kern::MutexSignal(*iMutex);
sl@0: 	NKern::ThreadLeaveCS();
sl@0: 	__e32_atomic_tas_ord32(&iThreadCounter, 1, -1, 0);
sl@0: 	return retVal;
sl@0: 	}
sl@0: 
sl@0: // 
sl@0: // DPageStressTestChannel::DoConsumeRamSetup
sl@0: //
sl@0: // This test attempts to consume most of the available Contiguous Ram until we need to ask the 
sl@0: // demand paging code to release memory for it.
sl@0: // 
sl@0: // 
sl@0: //
sl@0: #define CHECK(c) { if(!(c)) { Kern::Printf("Fail  %d", __LINE__); ; retVal = __LINE__;} }
sl@0: 
sl@0: TInt DPageStressTestChannel::DoConsumeRamSetup(TInt aNumPagesLeft, TInt aPagesInBlock)
sl@0: 	{
sl@0: 	if (iRamAllocd)
sl@0: 		{
sl@0: 		Kern::Printf("DPageStressTestChannel trying to start again when RAM alloc'd\n");
sl@0: 		DoConsumeRamFinish();
sl@0: 		}
sl@0: 
sl@0: 	TInt retVal = KErrNone;
sl@0: 
sl@0: 	TInt pageSize = 0;
sl@0: 	CHECK(Kern::HalFunction(EHalGroupKernel,EKernelHalPageSizeInBytes,&pageSize,0)==KErrNone);
sl@0: 	
sl@0: 	iBlockSize = aPagesInBlock * pageSize;
sl@0: 	iInitialFreeRam = FreeRam();
sl@0: 	iTotalBlocks = (iInitialFreeRam/iBlockSize) + 10;
sl@0: 	
sl@0: 	iAddrArray = (TPhysAddr *)Kern::AllocZ(sizeof(TPhysAddr) * iTotalBlocks);
sl@0: 
sl@0: 	CHECK(iAddrArray);
sl@0: 	if(!iAddrArray)
sl@0: 		{
sl@0: 		return KErrNoMemory;
sl@0: 		}
sl@0: 	
sl@0: 	SVMCacheInfo tempPages;
sl@0: 
sl@0: 	iRamAllocd = ETrue;
sl@0: 
sl@0: 	// get the initial free ram again as the heap may have grabbed a page during the alloc
sl@0: 	iInitialFreeRam = FreeRam();
sl@0: 
sl@0: 
sl@0: 	if (iDemandPaging)
sl@0: 		{
sl@0: 		CHECK(Kern::HalFunction(EHalGroupVM,EVMHalGetCacheSize,&tempPages,0) == KErrNone);
sl@0: 		if (iDebug)
sl@0: 			{
sl@0: 			Kern::Printf("Start : min %d max %d current %d maxFree %d freeRam %d",
sl@0: 						 tempPages.iMinSize, tempPages.iMaxSize, tempPages.iCurrentSize ,tempPages.iMaxFreeSize, FreeRam());
sl@0: 			}
sl@0: 		}
sl@0: 	// allocate blocks to use up RAM until we fail to allocate any further...
sl@0: 	TInt index;
sl@0: 	// only alloc upto the point where we have a number of pages left.
sl@0: 	iLastBlockAllocd = iTotalBlocks - (aNumPagesLeft / aPagesInBlock);
sl@0: 	for (index = 0; index < iLastBlockAllocd; index ++)
sl@0: 		{
sl@0: 		if (iDemandPaging)
sl@0: 			{
sl@0: 			CHECK(Kern::HalFunction(EHalGroupVM,EVMHalGetCacheSize,&tempPages,0) == KErrNone);
sl@0: 			}
sl@0: 
sl@0: 		if (KErrNone != Epoc::AllocPhysicalRam(iBlockSize, iAddrArray[index], 0))
sl@0: 			{
sl@0: 			iAddrArray[index] = NULL;
sl@0: 			break;
sl@0: 			}
sl@0: 
sl@0: 		if ((iAddrMin == 0) || (iAddrMin > iAddrArray[index]))
sl@0: 			{
sl@0: 			iAddrMin = iAddrArray[index];
sl@0: 			}
sl@0: 		
sl@0: 		if (iAddrMax < iAddrArray[index])
sl@0: 			{
sl@0: 			iAddrMax = iAddrArray[index];
sl@0: 			}
sl@0: 
sl@0: 		if (iDemandPaging)
sl@0: 			{
sl@0: 			CHECK(Kern::HalFunction(EHalGroupVM,EVMHalGetCacheSize,&tempPages,0) == KErrNone);
sl@0: 			}
sl@0: 		}
sl@0: 	iLastBlockAllocd = index - 1;
sl@0: 
sl@0: 	if (iDemandPaging)
sl@0: 		{
sl@0: 		CHECK(Kern::HalFunction(EHalGroupVM,EVMHalGetCacheSize,&tempPages,0) == KErrNone);
sl@0: 		if (iDebug)
sl@0: 			{
sl@0: 			Kern::Printf("Alloc'd : min %d max %d current %d maxFree %d freeRam %d lastIndex %d addrMin 0x%08x addrMax 0x%08x",
sl@0: 						 tempPages.iMinSize, tempPages.iMaxSize, tempPages.iCurrentSize ,tempPages.iMaxFreeSize, FreeRam(), iLastBlockAllocd, iAddrMin, iAddrMax);
sl@0: 			}
sl@0: 		}
sl@0: 	return retVal;
sl@0: 	}
sl@0: 
sl@0: TInt DPageStressTestChannel::DoConsumeRamFinish(void)
sl@0: 	{
sl@0: 	TInt retVal = KErrNone;
sl@0: 	if (iRamAllocd)
sl@0: 		{
sl@0: 		SVMCacheInfo tempPages;
sl@0: 
sl@0: 		if (iDemandPaging)
sl@0: 			{
sl@0: 			CHECK(Kern::HalFunction(EHalGroupVM,EVMHalGetCacheSize,&tempPages,0) == KErrNone);
sl@0: 			if (iDebug)
sl@0: 				{
sl@0: 				Kern::Printf("Cleanup cache info: iMinSize %d iMaxSize %d iCurrentSize %d iMaxFreeSize %d",
sl@0: 							 tempPages.iMinSize, tempPages.iMaxSize, tempPages.iCurrentSize ,tempPages.iMaxFreeSize);
sl@0: 				}
sl@0: 			}
sl@0: 		TInt index = iTotalBlocks - 1;
sl@0: 
sl@0: 		TBool firstTime = ETrue;
sl@0: 
sl@0: 		// free the memory we allocated...
sl@0: 		while(index >= 0)
sl@0: 			{
sl@0: 			if (iAddrArray[index])
sl@0: 				{
sl@0: 				if ((iAddrArray[index] < iAddrMin) || (iAddrArray[index] > iAddrMax))
sl@0: 					{
sl@0: 					Kern::Printf("ERROR: DoConsumeRamFinish : index %d addr 0x%08x min 0x%08x max 0x%08x\n     : firstTime %d iLastBlockAllocd %d iTotalBlock %d", index, iAddrArray[index], iAddrMin, iAddrMax, firstTime, iLastBlockAllocd, iTotalBlocks);
sl@0: 					TInt tempIndex = index - 8;
sl@0: 					while (tempIndex < (index + 8))
sl@0: 						{
sl@0: 						Kern::Printf("      --> index %d addr 0x%08x", tempIndex, iAddrArray[tempIndex]);
sl@0: 						tempIndex ++;
sl@0: 						}
sl@0: 					
sl@0: 					iAddrArray[index] = NULL;
sl@0: 					}
sl@0: 				else
sl@0: 					{
sl@0: 					TInt r = Epoc::FreePhysicalRam(iAddrArray[index], iBlockSize);
sl@0: 					iAddrArray[index] = NULL;
sl@0: 					CHECK(r==KErrNone);
sl@0: 					}
sl@0: 				}
sl@0: 
sl@0: 			firstTime = EFalse;
sl@0: 			--index;
sl@0: 			}
sl@0: 
sl@0: 		if (iDebug)
sl@0: 			{
sl@0: 			Kern::Printf("DoConsumeRamFinish : FreeRam Initial 0x%x now 0x%x",iInitialFreeRam, FreeRam());
sl@0: 			}
sl@0: 		//CHECK(FreeRam() == iInitialFreeRam)
sl@0: 		if (FreeRam() != iInitialFreeRam)
sl@0: 			{
sl@0: 			Kern::Printf("DoConsumeRamFinish : FreeRam Initial 0x%x now 0x%x NOT EQUAL!",iInitialFreeRam, FreeRam());
sl@0: 			}
sl@0: 
sl@0: 		Kern::Free(iAddrArray);
sl@0: 		iAddrArray = NULL;
sl@0: 		iAddrMin = 0;
sl@0: 		iAddrMax = 0;
sl@0: 		iLastBlockAllocd = -1;
sl@0: 		iTotalBlocks = 0;
sl@0: 		iRamAllocd = EFalse;
sl@0: 
sl@0: 		if (iDemandPaging)
sl@0: 			{
sl@0: 			CHECK(Kern::HalFunction(EHalGroupVM,EVMHalGetCacheSize,&tempPages,0) == KErrNone);
sl@0: 			if (iDebug)
sl@0: 				{
sl@0: 				Kern::Printf("End cache info: iMinSize %d iMaxSize %d iCurrentSize %d iMaxFreeSize %d",
sl@0: 							 tempPages.iMinSize, tempPages.iMaxSize, tempPages.iCurrentSize ,tempPages.iMaxFreeSize);
sl@0: 				}
sl@0: 			}
sl@0: 		}	
sl@0: 	return retVal;
sl@0: 	}
sl@0: 
sl@0: TInt DPageStressTestChannel::DoConsumeSomeRam(TInt aBlocks)
sl@0: 	{
sl@0: 	TInt retVal = KErrNone;
sl@0: 
sl@0: 	return retVal;
sl@0: 	}
sl@0: 
sl@0: TInt DPageStressTestChannel::DoReleaseSomeRam(TInt aBlocks)
sl@0: 	{
sl@0: 	if(iLastBlockAllocd<0)
sl@0: 		return KErrUnderflow;
sl@0: 
sl@0: 	TInt retVal = KErrNone;
sl@0: 	if (iRamAllocd)
sl@0: 		{
sl@0: 		SVMCacheInfo tempPages;
sl@0: 
sl@0: 		if (iDemandPaging)
sl@0: 			{
sl@0: 			CHECK(Kern::HalFunction(EHalGroupVM,EVMHalGetCacheSize,&tempPages,0) == KErrNone);
sl@0: 			if (iDebug)
sl@0: 				{
sl@0: 				Kern::Printf("Release  : min %d max %d current %d maxFree %d freeRam %d lastIndex %d",
sl@0: 							 tempPages.iMinSize, tempPages.iMaxSize, tempPages.iCurrentSize ,tempPages.iMaxFreeSize, FreeRam(), iLastBlockAllocd);
sl@0: 				}
sl@0: 			}
sl@0: 		
sl@0: 		TInt index = iLastBlockAllocd;
sl@0: 		iLastBlockAllocd -= aBlocks;
sl@0: 		
sl@0: 		TBool firstTime = ETrue;
sl@0: 
sl@0: 		// free the memory we allocated...
sl@0: 		while((index >= 0) && (index > iLastBlockAllocd))
sl@0: 			{
sl@0: 			if (iAddrArray[index])
sl@0: 				{
sl@0: 				//Kern::Printf("DoReleaseSomeRam : index %d addr 0x%08x size %d", index, iAddrArray[index], iBlockSize);
sl@0: 				if ((iAddrArray[index] < iAddrMin) || (iAddrArray[index] > iAddrMax))
sl@0: 					{
sl@0: 					Kern::Printf("ERROR: DoReleaseSomeRam : index %d addr 0x%08x min 0x%08x max 0x%08x\n     : firstTime %d iLastBlockAllocd %d iTotalBlock %d", index, iAddrArray[index], iAddrMin, iAddrMax, firstTime, iLastBlockAllocd + aBlocks, iTotalBlocks);
sl@0: 					TInt tempIndex = index - 8;
sl@0: 					while (tempIndex < (index + 8))
sl@0: 						{
sl@0: 						Kern::Printf("      --> index %d addr 0x%08x", tempIndex, iAddrArray[tempIndex]);
sl@0: 						tempIndex ++;
sl@0: 						}
sl@0: 
sl@0: 					iAddrArray[index] = NULL;
sl@0: 					}
sl@0: 				else
sl@0: 					{
sl@0: 					TInt r = Epoc::FreePhysicalRam(iAddrArray[index], iBlockSize);
sl@0: 					iAddrArray[index] = NULL;
sl@0: 					CHECK(r==KErrNone);
sl@0: 					}
sl@0: 				}
sl@0: 			else
sl@0: 				{
sl@0: 				Kern::Printf("ERROR: DoReleaseSomeRam : trying to free NULL index %d", index, iAddrArray[index], iAddrMin, iAddrMax);
sl@0: 				TInt tempIndex = index - 8;
sl@0: 				while (tempIndex < (index + 8))
sl@0: 					{
sl@0: 					Kern::Printf("      --> index %d addr 0x%08x", tempIndex, iAddrArray[tempIndex]);
sl@0: 					tempIndex ++;
sl@0: 					}
sl@0: 
sl@0: 				}
sl@0: 			firstTime = EFalse;
sl@0: 			--index;
sl@0: 			}
sl@0: 		if (index <= 0)
sl@0: 			{
sl@0: 			Kern::Printf("WARNING : DoReleaseSomeRam : index %d !!!!!", index);
sl@0: 			}
sl@0: 
sl@0: 		if (iDemandPaging)
sl@0: 			{
sl@0: 			CHECK(Kern::HalFunction(EHalGroupVM,EVMHalGetCacheSize,&tempPages,0) == KErrNone);
sl@0: 			if (iDebug)
sl@0: 				{
sl@0: 				Kern::Printf("Released : min %d max %d current %d maxFree %d freeRam %d lastIndex %d",
sl@0: 							 tempPages.iMinSize, tempPages.iMaxSize, tempPages.iCurrentSize ,tempPages.iMaxFreeSize, FreeRam(), iLastBlockAllocd);
sl@0: 				}	
sl@0: 			}
sl@0: 		}
sl@0: 	return retVal;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: TInt DPageStressTestChannel::FreeRam()
sl@0: 	{
sl@0: 	return Kern::FreeRamInBytes();
sl@0: 	}
sl@0: 
sl@0: TInt DPageStressTestChannel::DoSetDebugFlag(TInt aState)
sl@0: 	{
sl@0: 	iDebug = aState;
sl@0: 	return KErrNone;
sl@0: 	}