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_ramsterss.cpp
sl@0: // 
sl@0: //
sl@0: 
sl@0: #include <kernel/kern_priv.h>
sl@0: #include <kernel/cache.h>
sl@0: 
sl@0: #include "t_ramstress.h"
sl@0: 
sl@0: //
sl@0: // Class definitions
sl@0: //
sl@0: 
sl@0: class DRamStressTestFactory : public DLogicalDevice
sl@0: 	{
sl@0: public:
sl@0: 	~DRamStressTestFactory();
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 DRamStressTestChannel : public DLogicalChannelBase
sl@0: 	{
sl@0: public:
sl@0: 	DRamStressTestChannel();
sl@0: 	~DRamStressTestChannel();
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 FreeRam();
sl@0: 	TInt DoSetDebugFlag(TInt aState);
sl@0: 	TInt DoSetEndFlag(TInt aState);
sl@0: public:
sl@0: 	DRamStressTestFactory*	iFactory;
sl@0: 	
sl@0: private:
sl@0: 	TInt DoMovePagesInZone(TUint aZoneIndex);
sl@0: 	TInt DoPageMove(TLinAddr aAddr);
sl@0: 	TInt DoAllocPagesInZone(TUint aZoneIndex);
sl@0: 
sl@0: private:
sl@0: 	TInt		 iDebug;
sl@0: 	TInt		 iFinish;
sl@0: 	TInt		 iThreadCounter;
sl@0: 	TInt		 iPageSize;
sl@0: 	};
sl@0: 
sl@0: //
sl@0: // DRamStressTestFactory
sl@0: //
sl@0: 
sl@0: TInt DRamStressTestFactory::Install()
sl@0: 	{
sl@0: 	return SetName(&KRamStressTestLddName);
sl@0: 	}
sl@0: 
sl@0: DRamStressTestFactory::~DRamStressTestFactory()
sl@0: 	{
sl@0: 	}
sl@0: 
sl@0: void DRamStressTestFactory::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 DRamStressTestFactory::Create(DLogicalChannelBase*& aChannel)
sl@0: 	{
sl@0: 	aChannel = NULL;
sl@0: 	DRamStressTestChannel* channel=new DRamStressTestChannel;
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 DRamStressTestFactory;
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // DRamStressTestChannel
sl@0: //
sl@0: 
sl@0: TInt DRamStressTestChannel::DoCreate(TInt /*aUnit*/, const TDesC8* /*aInfo*/, const TVersion& /*aVer*/)
sl@0: 	{
sl@0: 	return KErrNone;
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // DRamStressTestChannel::DRamStressTestChannel()
sl@0: //
sl@0: 
sl@0: DRamStressTestChannel::DRamStressTestChannel()
sl@0: 	: iDebug(0), iFinish(0), iThreadCounter(1), iPageSize(0)
sl@0: 	{
sl@0: 	TInt pageSize = 0;
sl@0: 	if (Kern::HalFunction(EHalGroupKernel,EKernelHalPageSizeInBytes,&pageSize,0) == KErrNone)
sl@0: 		{
sl@0: 		iPageSize = pageSize;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // DRamStressTestChannel::~DRamStressTestChannel()
sl@0: //
sl@0: 
sl@0: DRamStressTestChannel::~DRamStressTestChannel()
sl@0: 	{
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // DRamStressTestChannel::Request
sl@0: //
sl@0: TInt DRamStressTestChannel::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: 		if (iDebug)
sl@0: 			Kern::Printf("DRamStressTestChannel::Request threadCount = %d\n", threadCount);
sl@0: 	NKern::ThreadEnterCS();
sl@0: 	TInt retVal = KErrNotSupported;
sl@0: 	switch(aFunction)
sl@0: 		{
sl@0: 		case RRamStressTestLdd::EDoMovePagesInZone:
sl@0: 			{
sl@0: 			retVal = DoMovePagesInZone((TUint)a1);
sl@0: 			}
sl@0: 		break;
sl@0: 	
sl@0: 		case RRamStressTestLdd::EDoSetDebugFlag:
sl@0: 			{
sl@0: 			retVal = DoSetDebugFlag((TInt) a1);
sl@0: 			}
sl@0: 		break;
sl@0: 
sl@0: 		case RRamStressTestLdd::EDoSetEndFlag:
sl@0: 			{
sl@0: 			retVal = DoSetEndFlag((TInt) a1);
sl@0: 			}
sl@0: 		break;
sl@0: 		
sl@0: 		default: break;
sl@0: 		}
sl@0: 	NKern::ThreadLeaveCS();
sl@0: 	__e32_atomic_tas_ord32(&iThreadCounter, 1, -1, 0);
sl@0: 	return retVal;
sl@0: 	}
sl@0: 
sl@0: TInt DRamStressTestChannel::DoAllocPagesInZone(TUint aZoneIndex)
sl@0: 	{
sl@0: 	TInt retVal = KErrNone;
sl@0: 
sl@0: 
sl@0: 
sl@0: 	return retVal;
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // DRamStressTestChannel::DoMovePagesInZone
sl@0: //
sl@0: 
sl@0: TInt DRamStressTestChannel::DoMovePagesInZone(TUint aZoneIndex)
sl@0: 	{
sl@0: 	if (iDebug)
sl@0: 		{
sl@0: 		Kern::Printf("DRamStressTestChannel::DoMovePagesInZone(%d)", aZoneIndex);
sl@0: 		}
sl@0: 
sl@0: 	// first get info on the 2 zones....
sl@0: 	struct SRamZoneConfig	zoneConfig;
sl@0: 	TInt retVal;
sl@0: 	if (KErrNone != Kern::HalFunction(EHalGroupRam,ERamHalGetZoneConfig,(TAny*)aZoneIndex, (TAny*)&zoneConfig))
sl@0: 		{
sl@0: 		Kern::Printf("Error ::: DoMovePagesInZone : bad zone %d", aZoneIndex); 
sl@0: 		retVal = KErrArgument;
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		//Kern::Printf("DoMovePagesInZone : zone %d", aZoneIndex); 
sl@0: 		TPhysAddr addr = zoneConfig.iPhysBase;
sl@0: 		TUint moved = 0;
sl@0: 		TUint failed = 0;
sl@0: 		TUint unused = 0;
sl@0: 		TUint bad = 0;
sl@0: 		TUint nosupport = 0;
sl@0: 		retVal = KErrNone;
sl@0: 		while (addr < zoneConfig.iPhysEnd)
sl@0: 			{
sl@0: 			//Kern::Printf("DoMovePagesInZone(%d) moving 0x%08x", aZoneIndex, addr);
sl@0: 			retVal = DoPageMove(addr);
sl@0: 			if (retVal == KErrNone)
sl@0: 				{
sl@0: 				moved ++;
sl@0: 				}
sl@0: 			else
sl@0: 				{
sl@0: 				switch (retVal)
sl@0: 					{
sl@0: 					case KErrArgument:
sl@0: 						bad ++;		
sl@0: 					break;
sl@0: 
sl@0: 					case KErrNotFound:
sl@0: 						unused ++;	
sl@0: 					break;
sl@0: 
sl@0: 					case KErrNotSupported:
sl@0: 						nosupport ++;
sl@0: 					break;
sl@0: 
sl@0: 					case KErrGeneral:
sl@0: 					default:
sl@0: 						failed ++;
sl@0: 						if (iDebug)
sl@0: 							{
sl@0: 							Kern::Printf("DRamStressTestChannel::DoMovePagesInZone(%d) failed 0x%08x err=%d", aZoneIndex, addr, retVal);
sl@0: 							}
sl@0: 					break;
sl@0: 					}
sl@0: 				}
sl@0: 			addr += iPageSize;
sl@0: 			NKern::Sleep(1);
sl@0: 			if (iFinish)
sl@0: 				{
sl@0: 				Kern::Printf("DRamStressTestChannel::DoMovePagesInZone(%d) Finishing", aZoneIndex);
sl@0: 				break;
sl@0: 				}
sl@0: 			}
sl@0: 		if (iDebug)
sl@0: 			{
sl@0: 			Kern::Printf("DRamStressTestChannel::DoMovePagesInZone(%d) moved %u failed %u bad %u unused %u nosupport %u", aZoneIndex, moved, failed, bad, unused, nosupport);
sl@0: 			}
sl@0: 		retVal = (failed==0) ? KErrNone : KErrGeneral;
sl@0: 		}
sl@0: 	return retVal;
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // DRamStressTestChannel::DoPageMove
sl@0: //
sl@0: 
sl@0: TInt DRamStressTestChannel::DoPageMove(TPhysAddr aAddr)
sl@0: 	{
sl@0: 	aAddr = _ALIGN_DOWN(aAddr, iPageSize);
sl@0: 
sl@0: 	TInt r;
sl@0: 	TPhysAddr aNew;
sl@0: 	r=Epoc::MovePhysicalPage(aAddr, aNew);
sl@0: 	if ((r==KErrNone) && (aNew == aAddr))
sl@0: 		{
sl@0: 		Kern::Printf("DRamStressTestChannel::DoPageMove moved bad 0x%08x now 0x%08x ", aAddr, aNew);
sl@0: 		r=KErrGeneral;
sl@0: 		}
sl@0: 	return r;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: TInt DRamStressTestChannel::FreeRam()
sl@0: 	{
sl@0: 	return Kern::FreeRamInBytes();
sl@0: 	}
sl@0: 
sl@0: TInt DRamStressTestChannel::DoSetDebugFlag(TInt aState)
sl@0: 	{
sl@0: 	iDebug = aState;
sl@0: 	return KErrNone;
sl@0: 	}
sl@0: 
sl@0: TInt DRamStressTestChannel::DoSetEndFlag(TInt aState)
sl@0: 	{
sl@0: 	iFinish = aState;
sl@0: 	return KErrNone;
sl@0: 	}