--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/kerneltest/e32test/resourceman/d_rescontrolcli.cpp	Mon Oct 19 15:55:17 2009 +0100
@@ -0,0 +1,1330 @@
+// Copyright (c) 2007-2009 Nokia Corporation and/or its subsidiary(-ies).
+// All rights reserved.
+// This component and the accompanying materials are made available
+// under the terms of the License "Eclipse Public License v1.0"
+// which accompanies this distribution, and is available
+// at the URL "http://www.eclipse.org/legal/epl-v10.html".
+//
+// Initial Contributors:
+// Nokia Corporation - initial contribution.
+//
+// Contributors:
+//
+// Description:
+// e32test\resourceman\d_rescontrol_cli.cpp
+// 
+//
+
+#include <kernel/kern_priv.h>
+#include <drivers/resource_extend.h>
+#include <drivers/resourceman.h>
+#include "d_rescontrolcli.h"
+#ifdef PRM_ENABLE_EXTENDED_VERSION
+#include "dynamicresource.h"
+#endif
+#include "./resourceman_psl/rescontrol_psl.h"
+
+#ifndef PRM_ENABLE_EXTENDED_VERSION
+_LIT(KTestPowerRCName, "D_RESCONTROLCLI.LDD");
+#else
+_LIT(KTestPowerRCName, "D_EXTENDEDRESCONTROLCLI.LDD");
+#endif
+
+const TInt KTestResManLddThreadPriority  = 0x5;
+_LIT(KTestResManLddThread, "TestResManLddThread");
+
+#ifdef PRM_ENABLE_EXTENDED_VERSION
+#define EXPECTED_POST_NOTI_COUNT 6 //Expected number of notifications as a result of post boot level setting. 
+#else
+#define EXPECTED_POST_NOTI_COUNT 5
+#endif
+#define MAX_DYNAMIC_RES_NUM 5
+/** 
+Structure for holding resource information
+*/
+struct SClientInfo
+	{
+	HBuf8* pName;
+	TUint iClientId;
+	};
+/**
+The logical device (factory class) for the resource manager client side test.
+*/
+class DTestResManLddFactory : public DLogicalDevice
+	{
+public:
+	DTestResManLddFactory();
+	~DTestResManLddFactory();
+	virtual TInt Install();
+	virtual void GetCaps(TDes8 &aDes) const;
+	virtual TInt Create(DLogicalChannelBase*& aChannel);
+	static void PostBootNotificationFunc(TUint aClientId, TUint aResId, TInt aLevel, TInt aLevelOwnerId, TInt aResult, TAny* aParam);
+	void SetPostBootLevelAndRequestNotification(TUint aClientId, TUint aResId, TInt aPostBootLevel);
+	TDynamicDfcQue* iDfcQ;
+	DStaticPowerResource *iStaticRes;
+	DStaticPowerResource *iStaticResArray[3];
+	static SClientInfo iClient; //Need to be static to access them in PostBootNotificationFunc (callback function).
+	static TUint iPostBootNotiCount;
+	};
+
+/** Logical channel class for Resource manager test LDD */
+class DTestResManLdd : public DLogicalChannel
+	{
+public:
+	DTestResManLdd();
+	virtual ~DTestResManLdd();
+	// Inherited from DLogicalChannel
+	virtual TInt DoCreate(TInt aUnit, const TDesC8* anInfo, const TVersion& aVer);
+	virtual void HandleMsg(TMessageBase* aMsg);
+private:
+	TInt DoControl(TInt aFunction, TAny* a1, TAny* a2);
+	TInt DoRequest(TInt aFunction, TRequestStatus* aStatus, TAny* a1, TAny* a2);
+	TInt DoCancel(TUint aMask);
+	static void CallbackFunc(TUint aClientId, TUint aResId, TInt aLevel, TInt aLevelOwnerId, TInt aResult, TAny* aParam);
+	static void CondNotificationFunc(TUint aClientId, TUint aResId, TInt aLevel, TInt aLevelOwnerId, TInt aResult, TAny* aParam);
+	static void UnCondNotificationFunc(TUint aClientId, TUint aResId, TInt aLevel, TInt aLevelOwnerId, TInt aResult, TAny* aParam);
+private:
+   	DThread* iClientThreadPtr;
+   	TPowerResourceCb iAsyncResourceCallback; //Callback object for handling long latency resources.
+	//Structure for storing the notification information
+	struct SNotificationList
+		{
+		TUint iClientId;
+		TUint iResourceId;
+		TUint iCount;
+		DPowerResourceNotification *iNoti;
+		SNotificationList *iNext;
+		};
+	SNotificationList *iCondList; //List for maintaining conditional notification
+	SNotificationList *iUnCondList; //List for maintaining unconditional notification
+	TRequestStatus *iStatus; //Store the status and complete on callback function.
+	TBool iCallbackCancel; 
+	TInt iClientId; //ID of the client that requested long latency operation, to compare in callback and notifications.
+	TUint iResourceId; //Id of the resource of long latency operation, to compare in callback and notifications.
+	//Below 2 variables are used only for asynchronous get resource state operation
+	TInt *iStatePtr; //Pointer to hold the address of state variable, where state is updated in callback function.
+	TInt *iLevelOwnerIdPtr; //Pointer to hold the address of level owner Id variable, where owner Id is updated in callback function.
+	HBuf *pBuf; //Buffer for testing caching of resource information for Idle power management 
+	SClientInfo clientInfo[MAX_CLIENTS];
+#ifdef PRM_ENABLE_EXTENDED_VERSION
+	TUint iTestParallelResourceId; //Variable to hold the long latency resource id, this is used only in test parallel execution of DFC's
+	static void TestParallelExecutionCallback(TUint aClientId, TUint aResId, TInt aLevel, TInt aLevelOwnerId, TInt aResult, TAny* aParam);
+	TBool iCallbackReceived;
+	TBool iValidateCallbackReceived;
+	TPowerResourceCb iAsyncTestParallelCallback; //Callback object for handling long latency resources change state while deregistering non-dependency resource.
+	RArray <DDynamicPowerResource*> iDynamicArray; //Array to hold dynamic resources. This includes dynamic dependent resource
+#endif
+	};
+
+//class definition for multilevel single instantaneous positive resource
+class DLaterRegisterStaticResource : public DStaticPowerResource
+	{
+public:
+	DLaterRegisterStaticResource();
+	TInt DoRequest(TPowerRequest &req);
+	TInt GetInfo(TDes8* aInfo) const;
+private:
+	TInt iMinLevel;
+	TInt iMaxLevel;
+	TInt iCurrentLevel;
+	};
+
+//Constructors of the resource
+_LIT(KLaterRegisterStaticResource, "LaterRegisterStaticResource");
+DLaterRegisterStaticResource::DLaterRegisterStaticResource() : DStaticPowerResource(KLaterRegisterStaticResource, E_OFF), iMinLevel(0), iMaxLevel(1), iCurrentLevel(0)
+	{
+	iFlags = KBinary;
+	}
+
+TInt DLaterRegisterStaticResource::DoRequest(TPowerRequest& req)
+	{
+	Kern::Printf("DLaterRegisterStaticResource::DoRequest\n");
+	if(req.ReqType() == TPowerRequest::EGet)
+		{
+		req.Level() = iCurrentLevel;
+		}
+	else if(req.ReqType() == TPowerRequest::EChange)
+		{
+		iCurrentLevel = req.Level();
+		}
+	else if(req.ReqType() == TPowerRequest::ESetDefaultLevel)
+		{
+		req.Level() = iDefaultLevel;
+		iCurrentLevel = iDefaultLevel;
+		}
+	else
+		return KErrNotSupported;
+	return KErrNone;
+	}
+
+TInt DLaterRegisterStaticResource::GetInfo(TDes8* info) const
+	{
+	DStaticPowerResource::GetInfo((TDes8*)info);
+	TPowerResourceInfoV01 *buf1 = (TPowerResourceInfoV01*)info;
+	buf1->iDefaultLevel = iDefaultLevel;
+	buf1->iMinLevel = iMinLevel;
+	buf1->iMaxLevel = iMaxLevel;
+	return KErrNone;
+	}
+
+//class definition for multilevel single instantaneous positive resource
+class DLaterRegisterStaticResource1 : public DStaticPowerResource
+	{
+public:
+	DLaterRegisterStaticResource1();
+	TInt DoRequest(TPowerRequest &req);
+	TInt GetInfo(TDes8* aInfo) const;
+private:
+	TInt iMinLevel;
+	TInt iMaxLevel;
+	TInt iCurrentLevel;
+	};
+
+//Constructors of the resource
+_LIT(KLaterRegisterStaticResource1, "LaterRegisterStaticResource1");
+DLaterRegisterStaticResource1::DLaterRegisterStaticResource1() : DStaticPowerResource(KLaterRegisterStaticResource1, E_OFF), iMinLevel(0), iMaxLevel(1), iCurrentLevel(0)
+	{
+	iFlags = KBinary;
+	}
+
+TInt DLaterRegisterStaticResource1::DoRequest(TPowerRequest& req)
+	{
+	Kern::Printf("DLaterRegisterStaticResource1::DoRequest\n");
+	if(req.ReqType() == TPowerRequest::EGet)
+		{
+		req.Level() = iCurrentLevel;
+		}
+	else if(req.ReqType() == TPowerRequest::EChange)
+		{
+		iCurrentLevel = req.Level();
+		}
+	else if(req.ReqType() == TPowerRequest::ESetDefaultLevel)
+		{
+		req.Level() = iDefaultLevel;
+		iCurrentLevel = iDefaultLevel;
+		}
+	else
+		return KErrNotSupported;
+	return KErrNone;
+	}
+
+TInt DLaterRegisterStaticResource1::GetInfo(TDes8* info) const
+	{
+	DStaticPowerResource::GetInfo((TDes8*)info);
+	TPowerResourceInfoV01 *buf1 = (TPowerResourceInfoV01*)info;
+	buf1->iDefaultLevel = iDefaultLevel;
+	buf1->iMinLevel = iMinLevel;
+	buf1->iMaxLevel = iMaxLevel;
+	return KErrNone;
+	}
+
+//class definition for multilevel single instantaneous positive resource
+class DLaterRegisterStaticResource2 : public DStaticPowerResource
+	{
+public:
+	DLaterRegisterStaticResource2();
+	TInt DoRequest(TPowerRequest &req);
+	TInt GetInfo(TDes8* aInfo) const;
+private:
+	TInt iMinLevel;
+	TInt iMaxLevel;
+	TInt iCurrentLevel;
+	};
+
+//Constructors of the resource
+_LIT(KLaterRegisterStaticResource2, "LaterRegisterStaticResource2");
+DLaterRegisterStaticResource2::DLaterRegisterStaticResource2() : DStaticPowerResource(KLaterRegisterStaticResource2, E_OFF), iMinLevel(0), iMaxLevel(1), iCurrentLevel(0)
+	{
+	iFlags = KBinary;
+	}
+
+TInt DLaterRegisterStaticResource2::DoRequest(TPowerRequest& req)
+	{
+	Kern::Printf("DLaterRegisterStaticResource2::DoRequest\n");
+	if(req.ReqType() == TPowerRequest::EGet)
+		{
+		req.Level() = iCurrentLevel;
+		}
+	else if(req.ReqType() == TPowerRequest::EChange)
+		{
+		iCurrentLevel = req.Level();
+		}
+	else if(req.ReqType() == TPowerRequest::ESetDefaultLevel)
+		{
+		req.Level() = iDefaultLevel;
+		iCurrentLevel = iDefaultLevel;
+		}
+	else
+		return KErrNotSupported;
+	return KErrNone;
+	}
+
+TInt DLaterRegisterStaticResource2::GetInfo(TDes8* info) const
+	{
+	DStaticPowerResource::GetInfo((TDes8*)info);
+	TPowerResourceInfoV01 *buf1 = (TPowerResourceInfoV01*)info;
+	buf1->iDefaultLevel = iDefaultLevel;
+	buf1->iMinLevel = iMinLevel;
+	buf1->iMaxLevel = iMaxLevel;
+	return KErrNone;
+	}
+
+TUint DTestResManLddFactory::iPostBootNotiCount = 0;
+SClientInfo DTestResManLddFactory::iClient = {NULL, 0};
+DTestResManLddFactory::DTestResManLddFactory()
+	{
+	iParseMask=0; // Allow info and pdd, but not units
+	iUnitsMask=0;
+	// Set version number for this device
+	iVersion=RTestResMan::VersionRequired();
+	}
+
+DTestResManLddFactory::~DTestResManLddFactory()
+	{
+	if(iDfcQ)
+	  iDfcQ->Destroy();
+	if(iStaticRes)
+		delete iStaticRes;
+	if(iStaticResArray[0])
+		delete iStaticResArray[0];
+	if(iStaticResArray[2])
+		delete iStaticResArray[2];
+	}
+
+/** Entry point for this driver */
+DECLARE_STANDARD_LDD()
+	{
+	DTestResManLddFactory* p = new DTestResManLddFactory;
+	if(!p)
+		return NULL;
+	TInt r = Kern::DynamicDfcQCreate(p->iDfcQ, KTestResManLddThreadPriority, KTestResManLddThread);
+	if(r != KErrNone)
+		{
+		Kern::Printf("Memory not allocated");
+		p->AsyncDelete();
+		return NULL;
+		}
+	//Register client with Resource Controller
+	TBuf8<32> ClientName(_L8("Client"));
+	p->iClient.pName = HBuf::New((const TDesC&)ClientName);
+	if(!p->iClient.pName)
+		{
+		p->iDfcQ->Destroy();
+		p->AsyncDelete();
+		return NULL;
+		}
+	//Allocating memory earlier so that during failure conditions can cleanup easily
+	p->iStaticRes = new DLaterRegisterStaticResource();
+	if(!p->iStaticRes)
+		{
+		delete p->iClient.pName;
+		p->iDfcQ->Destroy();
+		p->AsyncDelete();
+		return NULL;
+		}
+	p->iStaticResArray[0] = new DLaterRegisterStaticResource1();
+	if(!p->iStaticResArray[0])
+		{
+		delete p->iStaticRes;
+		delete p->iClient.pName;
+		p->iDfcQ->Destroy();
+		p->AsyncDelete();
+		return NULL;
+		}	
+	p->iStaticResArray[2] = new DLaterRegisterStaticResource2();
+	if(!p->iStaticResArray[2])
+		{
+		delete p->iStaticRes;
+		delete p->iStaticResArray[0];
+		delete p->iClient.pName;
+		p->iDfcQ->Destroy();
+		p->AsyncDelete();
+		return NULL;
+		}
+	r = PowerResourceManager::RegisterClient(DTestResManLddFactory::iClient.iClientId, (const TDesC&)*DTestResManLddFactory::iClient.pName);
+	if(r != KErrNone)
+		{
+		Kern::Printf("RegisterClient Failed\n");
+		Kern::Fault("PRM REGISTER CLIENT FAILED", __LINE__);
+		}
+	//Set postbootlevel for these resources.
+	p->SetPostBootLevelAndRequestNotification(DTestResManLddFactory::iClient.iClientId, 1, 0);
+	p->SetPostBootLevelAndRequestNotification(DTestResManLddFactory::iClient.iClientId, 6, 12);
+	p->SetPostBootLevelAndRequestNotification(DTestResManLddFactory::iClient.iClientId, 7, 1);
+	p->SetPostBootLevelAndRequestNotification(DTestResManLddFactory::iClient.iClientId, 12, 10);
+	p->SetPostBootLevelAndRequestNotification(DTestResManLddFactory::iClient.iClientId, 15, 0);
+#ifdef PRM_ENABLE_EXTENDED_VERSION
+	p->SetPostBootLevelAndRequestNotification(DTestResManLddFactory::iClient.iClientId, 65537, -50);
+#endif
+	//Test the later registration of static resources.
+	r = DPowerResourceController::RegisterStaticResource(DTestResManLddFactory::iClient.iClientId, p->iStaticRes);
+	if(r != KErrNone)
+		Kern::Fault("PRM REGISTER STATIC RESOURCE FAILED", __LINE__);
+	DStaticPowerResource **resPtr = &p->iStaticResArray[0];
+	r = DPowerResourceController::RegisterArrayOfStaticResources(DTestResManLddFactory::iClient.iClientId, resPtr, 3);
+	if(r != KErrNone)
+		Kern::Fault("PRM REGISTER STATIC RESOURCE FAILED", __LINE__);
+	r = DSimulatedPowerResourceController::CompleteResourceControllerInitialisation();
+	if(r != KErrNone)
+		Kern::Fault("PRM INIT FAILED", __LINE__);
+	return p;
+	}
+
+void DTestResManLddFactory::SetPostBootLevelAndRequestNotification(TUint aClientId, TUint aResId, TInt aPostBootLevel)
+	{
+	DPowerResourceController::PostBootLevel(aResId, aPostBootLevel);
+	DPowerResourceNotification* iNoti = new DPowerResourceNotification(PostBootNotificationFunc, (TAny*)NULL, Kern::DfcQue0(), 3);
+	if(!iNoti)
+		{
+		Kern::Fault("PRM NOTI FAILED", __LINE__);
+		}
+	//Passing the address of the object so that it could be deleted in callback function
+	new (iNoti) DPowerResourceNotification(PostBootNotificationFunc, iNoti, Kern::DfcQue0(), 3);
+	TInt r = PowerResourceManager::RequestNotification(aClientId, aResId, *iNoti);
+	if(r != KErrNone)
+		Kern::Fault("PRM REQ NOTI FAILED", __LINE__);
+	}
+
+
+/** Second stage constuctor */
+TInt DTestResManLddFactory::Install()
+	{
+   	return(SetName(&KTestPowerRCName));
+	}
+
+/** Device capabilities */
+void DTestResManLddFactory::GetCaps(TDes8& aDes)const
+	{
+	// Create a capabilities object
+	RTestResMan::TCaps caps;
+	caps.iVersion = iVersion;
+	// Write it back to user memory
+	Kern::InfoCopy(aDes,(TUint8*)&caps,sizeof(caps));
+	}
+
+/** Create logical channel, only open of one channel is allowed */
+TInt DTestResManLddFactory::Create(DLogicalChannelBase*& aChannel)
+	{
+   	if (iOpenChannels != 0) //A Channel is already open
+		return KErrInUse;
+	//Deregister the client registered in ldd init. 
+	TInt r = PowerResourceManager::DeRegisterClient(DTestResManLddFactory::iClient.iClientId);
+	if(r != KErrNone)
+		Kern::Fault("PRM CLIENT DEREGISTER FAILED", __LINE__);
+	delete DTestResManLddFactory::iClient.pName;
+	DTestResManLddFactory::iClient.pName = NULL;
+	DTestResManLddFactory::iClient.iClientId = 0;
+	aChannel = new DTestResManLdd;
+	if(!aChannel)
+		return KErrNoMemory;
+	return KErrNone;
+	}
+
+/** Constructor */
+DTestResManLdd::DTestResManLdd(): iAsyncResourceCallback(CallbackFunc, this, 3)
+#ifdef PRM_ENABLE_EXTENDED_VERSION
+				, iAsyncTestParallelCallback(TestParallelExecutionCallback, this, 3)
+#endif
+	{
+	iCondList = NULL;
+	iUnCondList = NULL;
+	iCallbackCancel = EFalse;
+	iClientId = 0;
+	iResourceId = 0;
+	iStatePtr = NULL;
+	iLevelOwnerIdPtr = NULL;
+	for(TUint c = 0; c < MAX_CLIENTS; c++)
+		{
+		clientInfo[c].iClientId = 0;
+		clientInfo[c].pName = NULL;
+		}
+	iClientThreadPtr=&Kern::CurrentThread();
+	// Increase the DThread's ref count so that it does not close without us
+	((DObject*)iClientThreadPtr)->Open();;
+	}
+
+/** Destructor */
+DTestResManLdd::~DTestResManLdd()
+	{
+	if(pBuf) //Buffer created for storing idle resource information
+		delete pBuf;
+#ifdef PRM_ENABLE_EXTENDED_VERSION
+	for(TInt c = 0; c < iDynamicArray.Count(); c++)
+		{
+		delete iDynamicArray[c]; //Delete the dynamic array. This includes dynamic dependent resource.
+		}
+	iDynamicArray.Close();
+#endif
+	// Close our reference on the client thread
+	Kern::SafeClose((DObject*&)iClientThreadPtr,NULL);
+	}
+
+/** Second stage constructor. */
+TInt DTestResManLdd::DoCreate(TInt /*aUnit*/, const TDesC8* /*aInfo*/, const TVersion& aVer)
+	{
+   	// Check version
+	if (!Kern::QueryVersionSupported(RTestResMan::VersionRequired(),aVer))
+		return KErrNotSupported;
+	SetDfcQ(((DTestResManLddFactory*)iDevice)->iDfcQ);
+	iAsyncResourceCallback.SetDfcQ(iDfcQ);
+#ifdef PRM_ENABLE_EXTENDED_VERSION
+	iAsyncTestParallelCallback.SetDfcQ(iDfcQ);
+#endif
+ 	iMsgQ.Receive();
+	return KErrNone;
+	}
+
+/** Process a message for this logical channel */
+void DTestResManLdd::HandleMsg(TMessageBase* aMsg)
+	{
+	TThreadMessage& m=*(TThreadMessage*)aMsg;
+	TInt id=m.iValue;
+
+	if (id==(TInt)ECloseMsg)
+		{
+		// Channel close.
+		m.Complete(KErrNone,EFalse);
+		return;
+		}
+	else if (id==KMaxTInt)
+		{
+		// DoCancel
+		m.Complete(KErrNone,ETrue);
+		return;
+		}
+	else if (id<0)
+		{
+		// DoRequest
+		TRequestStatus* pS=(TRequestStatus*)m.Ptr0();
+		TInt r=DoRequest(~id,pS,m.Ptr1(),m.Ptr2());
+		if (r!=KErrNone)
+			Kern::RequestComplete(iClientThreadPtr,pS,r);
+		m.Complete(KErrNone,ETrue);
+		}
+	else
+		{
+		// DoControl
+		TInt r=DoControl(id,m.Ptr0(),m.Ptr1());
+		m.Complete(r,ETrue);
+		}
+	}
+
+
+/**
+  Process synchronous 'control' requests
+*/
+TInt DTestResManLdd::DoControl(TInt aFunction, TAny* a1, TAny* a2)
+	{
+	TInt r = KErrNone;
+	TParameterListInfo ptr = {0, 0, 0, 0, 0};
+	//Copy parameter structure from user space.
+	if((aFunction != RTestResMan::EDeRegisterClient) && (aFunction != RTestResMan::ERequestNotificationUncond) && 
+		   (aFunction != RTestResMan::ERegisterForIdleResourcesInfo) && (aFunction != RTestResMan::EGetIdleResourcesInfo) 
+		   && (aFunction != RTestResMan::EDeRegisterClientLevelFromResource) && (aFunction != RTestResMan::ECheckPostBootLevelNotifications)
+		   && (aFunction != RTestResMan::EGetControllerVersion)
+#ifdef PRM_ENABLE_EXTENDED_VERSION
+		   && (aFunction != RTestResMan::ERegisterDynamicResource))
+#else
+		   )
+#endif
+		{
+		r = Kern::ThreadRawRead(iClientThreadPtr, (TParameterListInfo*)a1, &ptr, sizeof(TParameterListInfo));
+		if(r != KErrNone)
+			return r;
+		}
+	switch(aFunction)
+		{
+		case RTestResMan::ERegisterClient:
+			{
+			TBuf8<256> aName;
+			TUint c;
+			//Copy name from user address space
+			r = Kern::ThreadDesRead(iClientThreadPtr, (const TDesC*)ptr.iPtr2, (TDes8&)aName, 0);
+			if(r != KErrNone)
+				{
+				Kern::Printf("RTestResMan::ERegisterClient ThreadDesRead failed with %d", r);
+				break;
+				}
+			for(c = 0; c < MAX_CLIENTS; c++)
+				{
+				if(clientInfo[c].pName == NULL)
+					break;
+				if(!clientInfo[c].pName->Compare(aName))
+					return KErrAlreadyExists;
+				}
+			if(c == MAX_CLIENTS)
+				return KErrOverflow;
+			clientInfo[c].pName = HBuf::New((const TDesC8&)aName);
+			if(!clientInfo[c].pName)
+				return KErrNoMemory;
+			r = PowerResourceManager::RegisterClient(clientInfo[c].iClientId, (const TDesC&)*clientInfo[c].pName, (TOwnerType)(TInt)ptr.iPtr3);
+			if(r != KErrNone)
+				{
+				delete clientInfo[c].pName;
+				clientInfo[c].pName = NULL;
+				clientInfo[c].iClientId = 0;
+				}
+			if(r == KErrNone)
+				{
+				r = Kern::ThreadRawWrite(iClientThreadPtr, ptr.iPtr1, &clientInfo[c].iClientId, sizeof(TUint));
+				if(r != KErrNone)
+					Kern::Printf("RTestResMan::ERegisterClient ThreadRawWrite failed with %d", r);
+				}
+			break;
+			}
+		case RTestResMan::EDeRegisterClient: //Deregister client from RM
+			{
+			//Cancel all notification pending for this client
+			SNotificationList *pL;
+			SNotificationList* pN = iCondList;
+			while(pN != NULL)
+				{
+				if(pN->iClientId == (TUint)a1)
+					{
+					PowerResourceManager::CancelNotification(pN->iClientId, pN->iResourceId, *pN->iNoti);
+					pL = pN;
+					pN = pN->iNext;
+					LIST_REMOVE(iCondList, pL, iNext, SNotificationList);
+					delete pL->iNoti;
+					delete pL;
+					}
+				else
+					pN = pN->iNext;
+				}
+			pN = iUnCondList;
+			while(pN != NULL)
+				{
+				if(pN->iClientId == (TUint)a1)
+					{
+					PowerResourceManager::CancelNotification(pN->iClientId, pN->iResourceId, *pN->iNoti);
+					pL = pN;
+					pN = pN->iNext;
+					LIST_REMOVE(iUnCondList, pL, iNext, SNotificationList);
+					delete pL->iNoti;
+					delete pL;
+					}
+				else
+				   pN = pN->iNext;
+				}
+			iClientId = -1;
+			r = PowerResourceManager::DeRegisterClient((TUint)a1);
+			if(r != KErrNone)
+				break;
+			r = KErrNotFound;
+			for(TUint c = 0; c < MAX_CLIENTS; c++)
+				{
+				if(clientInfo[c].iClientId == (TUint)a1)
+					{
+					delete clientInfo[c].pName;
+					clientInfo[c].pName = 0;
+					clientInfo[c].iClientId = 0;
+					r = KErrNone;
+					break;
+					}
+				}
+
+			break;
+			}
+		case RTestResMan::EGetClientName: //Get Client Name
+			{
+			TBuf8<32> aName; 
+			r = PowerResourceManager::GetClientName((TUint)ptr.iClientId, (TUint)ptr.iPtr1, (TDes &)aName);
+			if(r== KErrNone)
+				{
+				r = Kern::ThreadDesWrite(iClientThreadPtr, ptr.iPtr2, (const TDesC8&)aName, 0);
+				if(r != KErrNone)
+					Kern::Printf("RTestResMan::EGetClientName ThreadDesWrite failed with %d", r);
+				}
+			break;
+			}
+		case RTestResMan::EGetClientId: //Get Client Id
+			{
+			TBuf8<256> aName;
+			TUint aClientId; 
+			r = Kern::ThreadDesRead(iClientThreadPtr, (const TDesC*)ptr.iPtr1, (TDes8&)aName, 0,KChunkShiftBy0);
+			if(r != KErrNone)
+				{
+				Kern::Printf("RTestResMan::EGetClientId ThreadDesRead failed with %d", r);
+				break;
+				}
+			r = PowerResourceManager::GetClientId(ptr.iClientId, (TDesC&)aName, aClientId);
+			if(r == KErrNone)
+				{
+				r = Kern::ThreadRawWrite(iClientThreadPtr, ptr.iPtr2, &aClientId, sizeof(TUint));
+				if(r != KErrNone)
+					Kern::Printf("RTestResMan::EGetClientId ThreadRawWrite failed with %d", r);
+				}
+			break;
+			}
+		case RTestResMan::EGetResourceId: //Get Resource Id
+			{
+			TBuf8<256> aName; 
+			TUint aResourceId;
+			r = Kern::ThreadDesRead(iClientThreadPtr, (const TDesC*)ptr.iPtr1, (TDes8&)aName, 0,KChunkShiftBy0);
+			if(r != KErrNone)
+				{
+				Kern::Printf("RTestResMan::EGetResourceId ThreadDesRead failed with %d", r);
+				break;
+				}
+			r = PowerResourceManager::GetResourceId(ptr.iClientId, (TDesC&)aName, aResourceId);
+			if(r == KErrNone)
+				{
+				r = Kern::ThreadRawWrite(iClientThreadPtr, ptr.iPtr2, &aResourceId, sizeof(TUint));
+				if(r != KErrNone)
+					Kern::Printf("RTestResMan::EGetResourceId ThreadRawWrite failed with %d", r);
+				}
+			break;
+			}
+		case RTestResMan::EGetResourceInfo: //Get resource information
+			{
+			NKern::ThreadEnterCS();
+			HBuf *info = HBuf::New(sizeof(TPowerResourceInfoV01));
+			NKern::ThreadLeaveCS();
+			r = PowerResourceManager::GetResourceInfo(ptr.iClientId, (TUint)ptr.iPtr1, (TAny*)info);
+			if(r == KErrNone)
+				{
+				r = Kern::ThreadDesWrite(iClientThreadPtr, ptr.iPtr2, (const TDesC8&)*info, 0);
+				if(r != KErrNone)
+					Kern::Printf("RTestResMan::EGetResourceInfo ThreadRawWrite failed with %d", r);
+				}
+			Kern::Free(info);
+			break;
+			} 
+		case RTestResMan::EGetNumResourcesInUseByClient: 
+			{
+			TUint numResource;
+			r = PowerResourceManager::GetNumResourcesInUseByClient(ptr.iClientId, (TUint)ptr.iPtr1, numResource);
+			if(r == KErrNone)
+				{
+				r = Kern::ThreadRawWrite(iClientThreadPtr, ptr.iPtr2, &numResource, sizeof(TUint));
+				if(r != KErrNone)
+					Kern::Printf("RTestResMan::EGetNumResourcesInUseByClient ThreadRawWrite failed with %d", r);
+				}
+			 break;
+			}
+		case RTestResMan::EGetInfoOnResourcesInUseByClient:
+			{
+			TUint numResource;
+			HBuf* info = NULL;
+			r = Kern::ThreadRawRead(iClientThreadPtr, ptr.iPtr2, &numResource, sizeof(TUint));
+			if(r != KErrNone)
+				{
+				Kern::Printf("RTestResMan::GetInfoOnResourceInUseByClient ThreadRawRead failed with %d", r);
+				break;
+				}
+			if(ptr.iPtr3 != NULL)
+				{
+				NKern::ThreadEnterCS();
+				info = HBuf::New(numResource * sizeof(TPowerResourceInfoV01));
+				NKern::ThreadLeaveCS();
+				}
+			r = PowerResourceManager::GetInfoOnResourcesInUseByClient(ptr.iClientId, (TUint)ptr.iPtr1, numResource, (TAny*)info);
+			if(r == KErrNone)
+				{
+				r = Kern::ThreadRawWrite(iClientThreadPtr, ptr.iPtr2, &numResource, sizeof(TUint));
+				if(r !=KErrNone)
+					{
+					Kern::Printf("RTestResMan::GetInfoOnResourceInUseByClient ThreadRawWrite failed with %d", r);
+					Kern::Free(info);
+					break;
+					}
+				if(ptr.iPtr3)
+					r = Kern::ThreadDesWrite(iClientThreadPtr, ptr.iPtr3, (const TDesC8&)*info, 0);
+				}
+			Kern::Free(info);
+			break;
+			}
+		case RTestResMan::EGetNumClientsUsingResource:
+			{
+			TUint numClient;
+			r = PowerResourceManager::GetNumClientsUsingResource(ptr.iClientId, (TUint)ptr.iPtr1, numClient);
+			if(r == KErrNone)
+				{
+				r = Kern::ThreadRawWrite(iClientThreadPtr, ptr.iPtr2, &numClient, sizeof(TUint));
+				if(r != KErrNone)
+					Kern::Printf("RTestResMan::EGetNumResourcesInUseByClient ThreadRawWrite failed with %d", r);
+				}
+			break;
+			}
+		case RTestResMan::EGetInfoOnClientsUsingResource:
+			{
+			TUint numClient;
+			HBuf* info = NULL;
+			r = Kern::ThreadRawRead(iClientThreadPtr, ptr.iPtr2, &numClient, sizeof(TUint));
+			if(r != KErrNone)
+				{
+				Kern::Printf("RTestResMan::GetInfoOnResourceInUseByClient ThreadRawRead failed with %d", r);
+				break;
+				}
+			if(ptr.iPtr3 != NULL)
+				{
+				NKern::ThreadEnterCS();
+				info = HBuf::New(numClient * sizeof(TPowerClientInfoV01));
+				NKern::ThreadLeaveCS();
+				}
+			r = PowerResourceManager::GetInfoOnClientsUsingResource(ptr.iClientId, (TUint)ptr.iPtr1, numClient, (TAny*)info);
+			if(r == KErrNone)
+				{
+				r = Kern::ThreadRawWrite(iClientThreadPtr, ptr.iPtr2, &numClient, sizeof(TUint));
+				if(r !=KErrNone)
+					{
+					Kern::Printf("RTestResMan::GetInfoOnResourceInUseByClient ThreadRawWrite failed with %d", r);
+					Kern::Free(info);
+					break;
+					}
+				 if(ptr.iPtr3)
+					r = Kern::ThreadDesWrite(iClientThreadPtr, ptr.iPtr3, (const TDesC8&)*info, 0);
+				}
+			Kern::Free(info);
+			break;
+			}
+		case RTestResMan::EAllocReserve:
+			{
+			r = PowerResourceManager::AllocReserve(ptr.iClientId, (TUint8)(TUint)ptr.iPtr1, (TUint8)(TUint)ptr.iPtr2);
+			break;
+			}
+		case RTestResMan::EChangeResourceStateSync:
+			{
+			SNotificationList* pN; 
+			//Zero the conditional notification count for the resource id.
+			for(pN=iCondList; pN != NULL; pN=pN->iNext)
+				{
+				if(pN->iResourceId == (TUint)ptr.iPtr1)
+					{
+					pN->iCount = 0;
+					break;
+					}
+				}
+			//Zero the unconditional notification count for the resource id.
+			for(pN=iUnCondList; pN != NULL; pN=pN->iNext)
+				{
+				if(pN->iResourceId == (TUint)ptr.iPtr1)
+					{
+					pN->iCount = 0;
+					break;
+					}
+				}
+			iClientId = ptr.iClientId;
+			iResourceId = (TUint)ptr.iPtr1;
+			r = PowerResourceManager::ChangeResourceState(ptr.iClientId, (TUint)ptr.iPtr1, (TInt)ptr.iPtr2);
+			break;
+			}
+		case RTestResMan::EGetResourceStateSync:
+			{
+			TInt newState, levelOwnerId;
+			r = PowerResourceManager::GetResourceState(ptr.iClientId, (TUint)ptr.iPtr1, (TBool)ptr.iPtr2, newState, levelOwnerId);
+			if(r == KErrNone)
+				{
+				r = Kern::ThreadRawWrite(iClientThreadPtr, ptr.iPtr3, (TAny*)&newState, sizeof(TInt));
+				if(r != KErrNone)
+					{
+					Kern::Printf("RTestResMan::GetResourceStateSync ThreadRawWrite failed with %d", r);
+					break;
+					}
+				r = Kern::ThreadRawWrite(iClientThreadPtr, ptr.iPtr4, (TAny*)&levelOwnerId, sizeof(TInt));
+				if(r != KErrNone)
+					Kern::Printf("RTestResMan::GetResourceStateSync ThreadRawWrite failed with %d", r);
+				}
+			break;
+			}
+		case RTestResMan::ERequestNotificationUncond:
+			{
+			SNotificationList *notiList;
+			notiList = new SNotificationList; //Create new notification list
+			if(!notiList)
+				{
+				r = KErrNoMemory;
+				break;
+				}
+			//Create notification object to pass to RM
+			notiList->iNoti = new DPowerResourceNotification(UnCondNotificationFunc, this, ((DTestResManLddFactory*)iDevice)->iDfcQ, 3);
+			if(!notiList->iNoti)
+				{
+				delete notiList;
+				r = KErrNoMemory;
+				break;
+				}
+			notiList->iClientId = (TUint)a1;
+			notiList->iResourceId = (TUint)a2;
+			notiList->iCount = 0;
+			LIST_PUSH(iUnCondList, notiList, iNext); //Add to unconditional list.							 
+			r = PowerResourceManager::RequestNotification((TUint)a1, (TUint)a2, *notiList->iNoti);
+			break;
+			}
+		case RTestResMan::ERequestNotificationCond:
+			{
+			SNotificationList *notiList;
+			notiList = new SNotificationList; // Create new notification list
+			if(!notiList)
+				{
+				r = KErrNoMemory;
+				break;
+				}
+			//Create notification object to pass to RM
+			notiList->iNoti = new DPowerResourceNotification(CondNotificationFunc, this, ((DTestResManLddFactory*)iDevice)->iDfcQ, 3);
+			if(!notiList->iNoti)
+				{
+				delete notiList;
+				r = KErrNoMemory;
+				break;
+				}
+			notiList->iClientId = ptr.iClientId;
+			notiList->iResourceId = (TUint)ptr.iPtr1;
+			notiList->iCount = 0;
+			LIST_PUSH(iCondList, notiList, iNext); //Add to conditional list.
+			r = PowerResourceManager::RequestNotification((TUint)ptr.iClientId, (TUint)ptr.iPtr1, *notiList->iNoti, (TInt)ptr.iPtr2, (TBool)ptr.iPtr3);
+			break;
+			}
+		case RTestResMan::EDeRegisterClientLevelFromResource:	
+			{
+				r = PowerResourceManager::DeRegisterClientLevelFromResource((TUint)a1, (TUint)a2);
+				break;
+			} 
+		case RTestResMan::ECancelNotification:
+			{
+			r = KErrNotFound;
+			if(ptr.iPtr2) //Check for notification in conditional list if it is true.
+				{ 
+				for(SNotificationList* pN=iCondList; pN != NULL; pN=pN->iNext)
+					{
+					if((pN->iClientId == ptr.iClientId) && (pN->iResourceId == (TUint)ptr.iPtr1))
+						{
+						r = PowerResourceManager::CancelNotification(pN->iClientId, pN->iResourceId, *pN->iNoti);
+						LIST_REMOVE(iCondList, pN, iNext, SNotificationList);
+						delete pN->iNoti;
+						delete pN;
+						break;
+						}
+					}
+				}
+			else //Check for notification in unconditional list.
+				{
+				for(SNotificationList* pN=iUnCondList; pN != NULL; pN=pN->iNext)
+					{
+					if((pN->iClientId == ptr.iClientId) && (pN->iResourceId == (TUint)ptr.iPtr1))
+						{
+						r = PowerResourceManager::CancelNotification(pN->iClientId, pN->iResourceId, *pN->iNoti);
+						LIST_REMOVE(iUnCondList, pN, iNext, SNotificationList);
+						delete pN->iNoti;
+						delete pN;
+						break;
+						}
+					}
+				}
+			break;
+			}
+		case RTestResMan::ECheckNotifications:
+			{
+			NKern::Sleep(NKern::TimerTicks(300)); //This is required as sometimes check is done before callback is called.
+			TUint countCond = 0, countUncond = 0;
+			SNotificationList* pN; 
+			//Get the conditional notification callback functions called for the resource id.
+			for(pN=iCondList; pN != NULL; pN=pN->iNext)
+				{
+				if(pN->iResourceId == (TUint)ptr.iPtr1)
+					{
+					countCond = pN->iCount;
+					pN->iCount = 0;
+					break;
+					}
+				}
+			//Get the unconditional notification callback functions called for the resource id.
+			for(pN=iUnCondList; pN != NULL; pN=pN->iNext)
+				{
+				if(pN->iResourceId == (TUint)ptr.iPtr1)
+					{
+					countUncond = pN->iCount;
+					pN->iCount = 0;
+					break;
+					}
+				}
+			//If the notifications count is not as expected return error.
+			if((countCond != (TUint)ptr.iPtr3) || (countUncond != (TUint)ptr.iPtr2))
+				r = KErrUnderflow;
+			break;
+			}
+		case RTestResMan::ERegisterForIdleResourcesInfo:
+			{	
+			if(pBuf)
+				{
+				r = KErrAlreadyExists;
+				break;
+				}
+			NKern::ThreadEnterCS();
+			pBuf = HBuf::New((TUint)a2 * sizeof(SIdleResourceInfo)); //Allocate buffer for requested resources
+			NKern::ThreadLeaveCS();
+			if(!pBuf)
+				return KErrNoMemory;
+			SIdleResourceInfo* pI = (SIdleResourceInfo*)pBuf->Ptr();
+			for(TUint c = 0; c < (TUint)a2; c++)
+				pI[c].iResourceId = c+1; //Update resource id
+			//Below function calls RegisterForResourceIdle resource controller virtual function, 
+			//This is for testing purposes only.
+
+			r =DSimulatedPowerResourceController::CaptureIdleResourcesInfo((TUint)a1, (TUint)a2, (TPtr*)pI);
+			if( r == KErrInUse)
+			   delete pBuf;
+			break;
+			}
+		case RTestResMan::EGetIdleResourcesInfo:
+			{
+			//Pass the buffer for comparision
+			if(!pBuf)
+				{
+				r = KErrNotFound;
+				break;
+				}
+			pBuf->SetLength(sizeof(SIdleResourceInfo) * (TUint)a1);
+			r = Kern::ThreadDesWrite(iClientThreadPtr, a2, (const TDesC8&)*pBuf, 0);
+			break;
+			}
+		case RTestResMan::ECheckPostBootLevelNotifications:
+			{
+				if(DTestResManLddFactory::iPostBootNotiCount != EXPECTED_POST_NOTI_COUNT)
+				{
+				r = KErrUnderflow;
+				break;
+				}
+			r = KErrNone;
+			break;
+			}
+		case RTestResMan::EGetControllerVersion:
+			{
+			TUint Version;
+			r = PowerResourceManager::GetResourceControllerVersion((TUint)a1, Version);
+			if(r == KErrNone)
+				{
+				r = Kern::ThreadRawWrite(iClientThreadPtr, a2, &Version, sizeof(TUint));
+				if(r != KErrNone)
+					Kern::Printf("RTestResMan::EGetControllerVersion ThreadRawWrite failed with %d", r);
+				}
+			break;
+			}
+#ifdef PRM_ENABLE_EXTENDED_VERSION
+		case RTestResMan::ERegisterDynamicResource:
+			{
+			TUint resId;
+			r = Kern::ThreadRawRead(iClientThreadPtr, a2, (TAny*)&resId, sizeof(TUint));
+			if(r != KErrNone)
+				{
+				Kern::Printf("RTestResMan::RegisterDynamicResource ThreadRawRead failed with %d", r);
+				break;
+				}			
+			DDynamicPowerResource* pDR = NULL;
+			switch(resId) //Create the dynamic resource
+				{
+				case 1:
+					pDR = new (DBIGISSPDynamicResource);
+					break;
+				case 2:
+					pDR = new (DMLIGLSSHNDynamicResource);
+					break;
+				case 3: 
+					pDR = new (DBLGLSSHNDynamicResource);
+					break;
+				case 4:
+					pDR = new (DMLLGLSSHPDynamicResource);
+					break;
+				case 5:
+					pDR = (DDynamicPowerResource*) new (DDynamicResourceD01);
+					break;
+				case 6:
+					pDR = (DDynamicPowerResource*) new (DDynamicResourceD02);
+					break;
+				case 7:
+					pDR = (DDynamicPowerResource*) new (DDynamicResourceD03);
+					break;
+				case 8:
+					pDR = (DDynamicPowerResource*) new (DDynamicResourceD04);
+					break;
+				}
+			if(!pDR)
+				return KErrNoMemory;
+			iDynamicArray.Append(pDR);
+			r = PowerResourceManager::RegisterDynamicResource((TUint)a1, pDR, resId);
+			if(r == KErrNone)
+				{
+				r = Kern::ThreadRawWrite(iClientThreadPtr, a2, (TAny*)&resId, sizeof(TUint));
+				if(r != KErrNone)
+					Kern::Printf("RTestResMan::RegisterDynamicResource ThreadRawWrite failed with %d", r);
+				}
+			break;
+			}
+		case RTestResMan::EDeRegisterDynamicResource: //Deregister dynamic resource
+			{
+			if(ptr.iPtr2)
+				{
+				TInt level;
+				r = Kern::ThreadRawRead(iClientThreadPtr, ptr.iPtr2, &level, sizeof(TInt));
+				if(r != KErrNone)
+					{
+					Kern::Printf("RTestResMan::DeRegisterDynamicResource ThreadRawRead failed with %d", r);
+					break;
+					}	
+				r = PowerResourceManager::DeRegisterDynamicResource(ptr.iClientId, (TUint)ptr.iPtr1, &level);
+				}
+			else
+				r = PowerResourceManager::DeRegisterDynamicResource(ptr.iClientId, (TUint)ptr.iPtr1, NULL);
+			break;
+			}
+		case RTestResMan::ERegisterResourceDependency: //Register resource dependency
+			{
+			SResourceDependencyInfo info1, info2;
+			r = Kern::ThreadRawRead(iClientThreadPtr, ptr.iPtr1, &info1, sizeof(SResourceDependencyInfo));
+			if(r != KErrNone)
+				{
+				Kern::Printf("RTestResMan::RegisterResourceDependency ThreadRawRead failed with %d", r);
+				break;
+				}
+			r = Kern::ThreadRawRead(iClientThreadPtr, ptr.iPtr2, &info2, sizeof(SResourceDependencyInfo));
+			if(r != KErrNone)
+				{
+				Kern::Printf("RTestResMan::RegisterResourceDependency ThreadRawRead failed with %d", r);
+				break;
+				}
+			r = PowerResourceManager::RegisterResourceDependency(ptr.iClientId, &info1, &info2);
+			break;
+			}
+		case RTestResMan::EDeRegisterResourceDependency: //Deregister resource dependency
+			{
+			r = PowerResourceManager::DeRegisterResourceDependency(ptr.iClientId, (TUint)ptr.iPtr1, (TUint)ptr.iPtr2);
+			break;
+			}
+		case RTestResMan::EGetNumDependentsForResource:
+			{
+			TUint numDepResources;
+			r = PowerResourceManager::GetNumDependentsForResource(ptr.iClientId, (TUint)ptr.iPtr1, numDepResources);
+			if(r == KErrNone)
+				{
+				r = Kern::ThreadRawWrite(iClientThreadPtr, ptr.iPtr2, (TAny*)&numDepResources, sizeof(TUint));
+				if(r != KErrNone)
+					Kern::Printf("RTestResMan::RegisterDynamicResource ThreadRawWrite failed with %d", r);
+				}
+			break;
+			}
+		case RTestResMan::EGetDependentsIdForResource:
+			{
+			TUint numDepResources;
+			HBuf* sResDepInfo = NULL;
+			r = Kern::ThreadRawRead(iClientThreadPtr, ptr.iPtr3, (TAny*)&numDepResources, sizeof(TUint));
+			if(r != KErrNone)
+				{
+				Kern::Printf("RTestResMan::GetDependentsIdForResource ThreadRawRead failed with %d", r);
+				break;
+				}
+			if(ptr.iPtr2 != NULL)
+				{
+				NKern::ThreadEnterCS();
+				sResDepInfo = HBuf::New(numDepResources * sizeof(SResourceDependencyInfo));
+				NKern::ThreadLeaveCS();
+				if(!sResDepInfo)
+					return KErrNoMemory;
+				}
+			
+			r = PowerResourceManager::GetDependentsIdForResource(ptr.iClientId, (TUint)ptr.iPtr1, (TAny*)sResDepInfo, numDepResources);
+			if(r == KErrNone)
+				{
+				if(ptr.iPtr2)
+					r = Kern::ThreadDesWrite(iClientThreadPtr, ptr.iPtr2, (const TDesC8&)*sResDepInfo, 0);
+				if(r != KErrNone)
+					{
+					Kern::Printf("RTestResMan::GetDepedentsIdForResource ThreadDesWrite failed with %d", r);
+					Kern::Free(sResDepInfo);
+					break;
+					}
+				r = Kern::ThreadRawWrite(iClientThreadPtr, ptr.iPtr3, (TAny*)&numDepResources, sizeof(TUint));
+				if(r != KErrNone)
+					{
+					Kern::Printf("RTestResMan::GetDependentsIdForResource ThreadRawWrite failed with %d", r);
+					Kern::Free(sResDepInfo);
+					break;
+					}
+				}
+			Kern::Free(sResDepInfo);
+			break;
+			}
+
+#endif
+		default:
+			r = KErrNotSupported;
+			break;
+		}
+	return r;
+	}
+
+TInt DTestResManLdd::DoRequest(TInt aReqNo, TRequestStatus* aStatus, TAny* a1, TAny* /*a2*/)
+	{
+	TInt r = KErrNone;
+	TParameterListInfo ptr;
+	r = Kern::ThreadRawRead(iClientThreadPtr, (TParameterListInfo*)a1, &ptr, sizeof(TParameterListInfo));
+	if(r != KErrNone)
+		Kern::RequestComplete(iClientThreadPtr, aStatus, r);
+	switch(aReqNo)
+		{
+		case RTestResMan::EChangeResourceStateAsync:
+#ifdef PRM_ENABLE_EXTENDED_VERSION
+		case RTestResMan::EChangeResStateAndDeregisterDynamicRes:
+		case RTestResMan::ECheckParallelExecutionForChangeResState:
+#endif
+			SNotificationList* pN; 
+			//Zero the conditional notification count for the resource id.
+			for(pN=iCondList; pN != NULL; pN=pN->iNext)
+				{
+				if(pN->iResourceId == (TUint)ptr.iPtr1)
+					{
+					pN->iCount = 0;
+					break;
+					}
+				}
+			//Zero the unconditional notification count for the resource id.
+			for(pN=iUnCondList; pN != NULL; pN=pN->iNext)
+				{
+				if(pN->iResourceId == (TUint)ptr.iPtr1)
+					{
+					pN->iCount = 0;
+					break;
+					}
+				}
+			iLevelOwnerIdPtr = NULL;
+			iStatePtr = (TInt*)ptr.iPtr2;
+			TInt state;
+			r = Kern::ThreadRawRead(iClientThreadPtr, iStatePtr, &state, sizeof(TInt)); 
+			if(r != KErrNone)
+				Kern::RequestComplete(iClientThreadPtr, aStatus, r);
+			iStatus = aStatus;
+			iClientId = ptr.iClientId;
+			iResourceId = (TUint)ptr.iPtr1;
+			iCallbackCancel = EFalse;
+			r = PowerResourceManager::ChangeResourceState(ptr.iClientId, (TUint)ptr.iPtr1, state, &iAsyncResourceCallback);
+#ifdef PRM_ENABLE_EXTENDED_VERSION
+			if(aReqNo == RTestResMan::EChangeResStateAndDeregisterDynamicRes) //Try to delete the dynamic while resource change
+				{
+				r = PowerResourceManager::DeRegisterDynamicResource(ptr.iClientId, (TUint)ptr.iPtr1, NULL);
+				if(r == KErrInUse) //Wait for the request to complete
+					r = KErrNone; 
+				break;
+				}
+			if(aReqNo == RTestResMan::ECheckParallelExecutionForChangeResState)
+				{
+				r = PowerResourceManager::ChangeResourceState(ptr.iClientId, (TUint)ptr.iPtr3, (TInt)ptr.iPtr4, &iAsyncTestParallelCallback);
+				iTestParallelResourceId = (TUint)ptr.iPtr3;
+				iValidateCallbackReceived = ETrue;
+				break;
+				}
+#endif
+			if(ptr.iPtr3) //Cancel the asynchronous operation if true.
+				{
+				r = PowerResourceManager::CancelAsyncRequestCallBack(ptr.iClientId, (TUint)ptr.iPtr1, iAsyncResourceCallback);
+				if(r == KErrInUse) //Wait for the request to complete
+					r = KErrNone;
+				else
+					iCallbackCancel = ETrue;
+				}
+			break;
+		case RTestResMan::EGetResourceStateAsync:
+			iStatus = aStatus;
+			iCallbackCancel = EFalse;
+			iClientId = ptr.iClientId;
+			iResourceId = (TUint)ptr.iPtr1;
+			iStatePtr = (TInt*)ptr.iPtr4;
+			iLevelOwnerIdPtr = (TInt*)ptr.iPtr5;
+			r = PowerResourceManager::GetResourceState(ptr.iClientId, (TUint)ptr.iPtr1, (TBool)ptr.iPtr2, iAsyncResourceCallback);
+			if(ptr.iPtr3) //Cancel the asynchronous operation if true.
+				{
+				r = PowerResourceManager::CancelAsyncRequestCallBack(ptr.iClientId, (TUint)ptr.iPtr1, iAsyncResourceCallback);
+				if(r == KErrInUse)
+					r = KErrNone;
+				else 
+					iCallbackCancel = ETrue;
+				}
+			break;
+		}
+	return r;
+	}
+
+//Function called on Asynchronous operation
+void DTestResManLdd::CallbackFunc(TUint aClientId, TUint aResId, TInt aLevel, TInt aLevelOwnerId, TInt aResult, TAny* aParam)
+	{
+	TInt r;
+	DTestResManLdd *pC = (DTestResManLdd*)aParam;
+	//Check for correctnes of clientId and resourceId
+	if((TUint)pC->iClientId != aClientId || pC->iResourceId != aResId)
+		Kern::RequestComplete(pC->iClientThreadPtr, pC->iStatus, KErrCorrupt);
+	if(!pC->iCallbackCancel)
+		{
+		if(pC->iStatePtr) 
+			{
+			r = Kern::ThreadRawWrite(pC->iClientThreadPtr, pC->iStatePtr, (TAny*)&aLevel, sizeof(TInt));
+			if(r != KErrNone)
+				Kern::Printf("RTestResManLdd::CallbackFunc ThreadRawWrite failed with %d", r);
+			}
+		if(pC->iLevelOwnerIdPtr)
+			{
+			r = Kern::ThreadRawWrite(pC->iClientThreadPtr, pC->iLevelOwnerIdPtr, (TAny*)&aLevelOwnerId, sizeof(TInt));
+			if(r != KErrNone)
+				Kern::Printf("RTestResManLdd::CallbackFunc ThreadRawWrite failed with %d", r);
+			}
+		#ifdef PRM_ENABLE_EXTENDED_VERSION
+		if(pC->iValidateCallbackReceived)
+			{
+			if(!pC->iCallbackReceived)
+				aResult = KErrCompletion;
+			}
+		#endif
+		Kern::RequestComplete(pC->iClientThreadPtr, pC->iStatus, aResult);
+		}
+	pC->iCallbackCancel = EFalse;
+	pC->iStatus = NULL;
+	}
+
+#ifdef PRM_ENABLE_EXTENDED_VERSION
+//Function called on completion of asynchronous long latency resource, used only to check parallel execution of DFC's
+void DTestResManLdd::TestParallelExecutionCallback(TUint aClientId, TUint aResId, TInt /*aLevel*/, TInt /*aLevelOwnerId*/, TInt /*aResult*/, TAny* aParam)
+	{
+	Kern::Printf("DTestResManLdd::TestParallelExecutionCallback:: called");
+	DTestResManLdd *pC = (DTestResManLdd*)aParam;
+	//Check for correctness of clientId and resourceId
+	if((TUint)pC->iClientId == aClientId && pC->iTestParallelResourceId == aResId)
+		{
+		pC->iCallbackReceived = ETrue;
+		}
+	}
+#endif
+
+//Function called on Conditional notification
+void DTestResManLdd::CondNotificationFunc(TUint /*aClientId*/, TUint aResId, TInt /*aLevel*/, TInt /*aLevelOwnerId*/, TInt /*aResult*/, TAny* aParam)
+	{
+	DTestResManLdd *pC = (DTestResManLdd*)aParam;
+	for(SNotificationList *pN = pC->iCondList; pN!= NULL; pN=pN->iNext)
+		{
+		if((pN->iResourceId == aResId))
+			{
+			pN->iCount++; //Increment the count, as same callback function for all conditioanl notifications.
+			break;
+			}
+		}
+	}
+
+//Function called on UnConditional notification
+void DTestResManLdd::UnCondNotificationFunc(TUint /*aClientId*/, TUint aResId, TInt /*aLevel*/, TInt /*aLevelOwnerId*/, TInt /*aResult*/, TAny* aParam)
+	{
+	DTestResManLdd *pC = (DTestResManLdd*)aParam;
+	for(SNotificationList *pN = pC->iUnCondList; pN!= NULL; pN=pN->iNext)
+		{
+		if((pN->iResourceId == aResId) && (pC->iCallbackCancel == EFalse))
+			{
+			pN->iCount++; //Increment the count as same callback function for all unconditioanl notifications.
+			break;
+			}
+		}
+	}
+
+//Function called on postbootvalueset. 
+void DTestResManLddFactory::PostBootNotificationFunc(TUint /*aClientId*/, TUint aResId, TInt /*aLevel*/, TInt /*aLevelOwnerId*/, TInt /*aResult*/, TAny* aParam)
+	{
+	iPostBootNotiCount++;
+	DPowerResourceNotification *ptr = (DPowerResourceNotification*)aParam;
+	TInt r = PowerResourceManager::CancelNotification(iClient.iClientId, aResId, *ptr);
+	if(r == KErrNone)
+		delete ptr;
+	}