FCL/sf/os/kernelhwsrv: comparison kerneltest/e32test/resmanus/t

equal deleted inserted replaced

-:c7a0ce20c48c
+:a77889bee936
 _LIT(testName,"t_resmanus");
 #endif
 TBuf<16> gTestName(testName);
-GLDEF_D RTest gTest(testName);
 GLDEF_D RBusDevResManUs gChannel;
 TUint8 KNoOfGetStateRequests = 5;
 TUint8 KNoOfSetStateRequests = 4;
 TUint8 KNoOfNotifyRequests = 7;
 TBool gHaveSharedRes = ETrue;
 TInt gSharedResStateDelta = -1;
 #endif
 TBool gUseCached = EFalse;
+class RTestSafe: public RTest
+	{
+public:
+	RTestSafe(const TDesC &aTitle) :
+		RTest(aTitle), iCleanUpLevelMask (0), iFailHdnFunc(NULL)
+		{
+		}
+	RTestSafe(const TDesC &aTitle, void(*func)(RTestSafe &aTest)) :
+		RTest(aTitle), iFailHdnFunc(func)
+		{
+		}
+	// new version of operator(int), which calls our cleanup handler if check has failed
+	void operator()(TInt aResult)
+		{
+		if(!aResult && iFailHdnFunc)
+			iFailHdnFunc(*this);
+		RTest::operator ()(aResult);
+		}
+	void operator()(TInt aResult, TInt aLineNum)
+		{
+		if(!aResult && iFailHdnFunc)
+			iFailHdnFunc(*this);
+		RTest::operator ()(aResult, aLineNum);
+		}
+	void operator()(TInt aResult, TInt aLineNum, const TText* aFileName)
+		{
+		if(!aResult && iFailHdnFunc)
+			iFailHdnFunc(*this);
+		RTest::operator ()(aResult, aLineNum, aFileName);
+		}
+	// new version of End, which calls handler before exit..
+	void End()
+		{
+		if(iFailHdnFunc)
+			iFailHdnFunc(*this);
+		RTest::End();
+		}
+	void SetCleanupFlag(TUint aFlag)
+		{
+		iCleanUpLevelMask |= 1 << aFlag;
+		}
+	TBool CleanupNeeded(TUint aFlag)
+		{
+		return (iCleanUpLevelMask & (1 << aFlag)) >> aFlag;
+		}
+	TUint iCleanUpLevelMask;
+	void (*iFailHdnFunc)(RTestSafe &aTest);
+	};
+// cleanup handler
+enum TCleanupLevels
+	{
+	EPddLoaded = 0,
+	ELddLoaded,
+	EChannelOpened
+	};
+void TestCleanup(RTestSafe &aTest)
+	{
+	// cleanup for all 3 levels..
+	if(aTest.CleanupNeeded(EChannelOpened))
+		{
+		gChannel.Close();
+		}
+	if(aTest.CleanupNeeded(ELddLoaded))
+		{
+		User::FreeLogicalDevice(KLddRootName);
+		}
+	if(aTest.CleanupNeeded(EPddLoaded))
+		{
+		User::FreePhysicalDevice(PDD_NAME);
+		}
+	}
+// global gTest object..
+RTestSafe gTest(testName, &TestCleanup);
+LOCAL_C TInt CheckCaps()
+	{
+	TInt r = KErrNone;
+	RDevice d;
+	TPckgBuf<TCapsDevResManUs> caps;
+	r = d.Open(KLddRootName);
+	if(r == KErrNone)
+		{
+		d.GetCaps(caps);
+		d.Close();
+		TVersion ver = caps().version;
+		if(ver.iMajor != 1 || ver.iMinor != 0 || ver.iBuild != KE32BuildVersionNumber)
+			{
+			gTest.Printf(_L("Capabilities returned wrong version"));
+			gTest.Printf(_L("Expected(1, 0, %d), got (%d , %d, %d)"),
+			                KE32BuildVersionNumber, ver.iMajor, ver.iMinor, ver.iBuild);
+			r = KErrGeneral;
+			}
+		}
+	return r;
+	}
 LOCAL_C TInt OpenChannel(TDesC16& aName, RBusDevResManUs& aChannel)
 	{
 	TInt r = KErrNone;
 	// API accepts 8-bit descriptors, only - so convert name accordingly
 		if((r=HelperGetClientResourceInfo())!=KErrNone)
 			return r;
 		}
-	// Fourth invocation - examine effect of orignal client requesting a level for
+	// Fourth invocation - examine effect of oryginal client requesting a level for
 	// the Shared resource
 	if(gHaveSharedRes)
 		{
 		TRequestStatus status;
 		TBool cached = gUseCached;
 			gTest.Printf(_L("TestGetClientGetResourceInfo, attempt to reset shareable resource state returned %d\n"),r);
 			return r;
 			}
 		}
 	// Close the temporary channels
 	channelTwo.Close();
 	channelThree.Close();
 	channelFour.Close();
 //
 	{
 	TInt r = KErrNone;
 	TRequestStatus status;
+	TRequestStatus status2;
 	TBool cached = gUseCached;
 	TInt readValue = 0;
+	TInt readValue2 = 0;
 	TInt levelOwnerId = 0;
 	TInt testNo = 0;
 #ifdef _DEBUG
 	// Ensure we have a resource we can use
 		return r;
 		}
 	// 8) Call API to get the state of a long latency resource then call API without operation-type qualifier to cancel the request.
 	gTest.Printf(_L("TestGetSetResourceStateOps, starting test %d\n"),testNo++);
+	// NOTE: Cancel operation can only remove request which is still inside the resource controller
+	// message queue. If the queue is empty, the resource controller may process the request very quickly
+	// after it is sent. It may cause the test fail. To solve this, two get long latency resource state
+	// requests are submitted. So that the second one must be inside the resource controller.
+	// And we will always test the second request
 	gChannel.GetResourceState(status,gLongLatencyResource,cached,&readValue,&levelOwnerId);
+	gChannel.GetResourceState(status2,gLongLatencyResource,cached,&readValue2,&levelOwnerId);
 	gChannel.CancelAsyncOperation(&status);
+	gChannel.CancelAsyncOperation(&status2);
 	User::WaitForRequest(status);
-	if(status.Int() != KErrCancel)
+	User::WaitForRequest(status2);
+	if(status2.Int() != KErrCancel)
 		{
 		gTest.Printf(_L("TestGetSetResourceStateOps, cancelled get state status = %d\n"),r);
 		return r;
 		}
 	// 9) Call API to modify the state of the long latency resource then call API without operation-type qualifier to cancel the request.
 	gTest.Printf(_L("TestGetSetResourceStateOps, starting test %d\n"),testNo++);
+	// NOTE: Cancel operation can only remove request which is still inside the resource controller
+	// message queue. If the queue is empty, the resource controller may process the request very quickly
+	// after it is sent. It may cause the test fail. To solve this, two get long latency resource state
+	// requests are submitted. So that the second one must be inside the resource controller.
+	// And we will always test the second request
 	newLevel = (TUint)(readValue + gAsyncResStateDelta);
 	gChannel.ChangeResourceState(status,gLongLatencyResource,newLevel);
+	gChannel.ChangeResourceState(status2,gLongLatencyResource,newLevel);
 	gChannel.CancelAsyncOperation(&status);
+	gChannel.CancelAsyncOperation(&status2);
 	User::WaitForRequest(status);
-	if(status.Int() != KErrCancel)
+	User::WaitForRequest(status2);
+	if(status2.Int() != KErrCancel)
 		{
 		gTest.Printf(_L("TestGetSetResourceStateOps, cancelled change state status = %d\n"),r);
 		return r;
 		}
 		}
 	gChannel.CancelGetResourceStateRequests(gLongLatencyResource);
 	for(i=0;i<KLoopVarN;i++)
 		{
 		User::WaitForRequest(getReqStatus[i]);
-		if((r=getReqStatus[i].Int()) != KErrCancel)
+	// NOTE: Cancel operation can only remove request which is still inside the resource controller
+	// message queue. If the queue is empty, the resource controller may process the request very quickly
+	// after it is sent. It may cause the test fail. To solve this, we skip the test for request 0.
+		if(i>0 && ((r=getReqStatus[i].Int()) != KErrCancel))
 			{
 			gTest.Printf(_L("TestGetSetResourceStateOps, cancelled get state status[%d] = %d\n"),i,r);
 			return r;
 			}
 		}
 		}
 	gChannel.CancelChangeResourceStateRequests(gLongLatencyResource);
 	for(i=0;i<KLoopVarM;i++)
 		{
 		User::WaitForRequest(setReqStatus[i]);
-		if((r=setReqStatus[i].Int()) != KErrCancel)
+	// NOTE: Cancel operation can only remove request which is still inside the resource controller
+	// message queue. If the queue is empty, the resource controller may process the request very quickly
+	// after it is sent. It may cause the test fail. To solve this, we skip the test for request 0.
+		if(i>0 && ((r=setReqStatus[i].Int()) != KErrCancel))
 			{
 			gTest.Printf(_L("TestGetSetResourceStateOps, cancelled change state status[%d] = %d\n"),i,r);
 			return r;
 			}
 		}
 		}
 	gChannel.CancelGetResourceStateRequests(gLongLatencyResource);
 	for(i=0;i<KLoopVarN;i++)
 		{
 		User::WaitForRequest(getReqStatus[i]);
-		if((r=getReqStatus[i].Int()) != KErrCancel)
+	// NOTE: Cancel operation can only remove request which is still inside the resource controller
+	// message queue. If the queue is empty, the resource controller may process the request very quickly
+	// after it is sent. It may cause the test fail. To solve this, we skip the test for request 0.
+		if(i>0 && ((r=getReqStatus[i].Int()) != KErrCancel))
 			{
 			gTest.Printf(_L("TestGetSetResourceStateOps, cancelled get state status[%d] = %d\n"),i,r);
 			return r;
 			}
 		}
 	for(i=0;i<KLoopVarN;i+=2)
 		{
 		r=gChannel.CancelGetResourceState(getReqStatus[i]);
 		if(r!=KErrNone)
 			{
-			gTest.Printf(_L("TestGetSetResourceStateOps, CancelGetResourceState for index %d returned %d\n"),i,r);
-			return r;
+	// NOTE: Cancel operation can only remove request which is still inside the resource controller
+	// message queue. If the queue is empty, the resource controller may process the request very quickly
+	// after it is sent. It may cause the test fail. To solve this, we skip the test for request 0.
+			if(i!=0)
+				{
+				gTest.Printf(_L("TestGetSetResourceStateOps, CancelGetResourceState for index %d returned %d\n"),i,r);
+				return r;
+				}
 			}
 		}
 	for(i=0;i<KLoopVarM;i++)
 		{
 		User::WaitForRequest(setReqStatus[i]);
 			}
 		}
 	for(i=0;i<KLoopVarN;i++)
 		{
 		User::WaitForRequest(getReqStatus[i]);
-		if((r=getReqStatus[i].Int()) != KErrCancel)
+	// NOTE: Cancel operation can only remove request which is still inside the resource controller
+	// message queue. If the queue is empty, the resource controller may process the request very quickly
+	// after it is sent. It may cause the test fail. To solve this, we skip the test for request 0.
+		if(i>0 && ((r=getReqStatus[i].Int()) != KErrCancel))
 			{
 			gTest.Printf(_L("TestGetSetResourceStateOps, cancelled get state status[%d] = %d\n"),i,r);
 			return r;
 			}
 		if(++i >= KLoopVarN)
 	if((r=pirateChannel.Duplicate(RThread(),EOwnerProcess))!=KErrAccessDenied)
 		{
 		gTest.Printf(_L("TestThreadExclusiveAccess: Duplicate with EOwnerProcess returned %d\n"),r);
 		if(r==KErrNone)
 			r=KErrGeneral;
-		return r;
+		return r; // return error which is neither KErrNone nor KErrAccessDenied
 		}
 	pirateChannel = gChannel;
 	if((r=pirateChannel.Duplicate(RThread(),EOwnerThread))!=KErrNone)
 		{
 		gTest.Printf(_L("TestThreadExclusiveAccess: Duplicate with EOwnerThread returned %d\n"),r);
 #else
 	if((r=secThrdChannel.GetNamesAllClients(&infoPtrs, numClients, ETrue)) != KErrPermissionDenied)
 		{
 		if(r==KErrNone)
 			r=KErrGeneral;
-		return r;
+		return r; // return error which is neither KErrPermissionDenied nor KErrGeneral
 		}
 	else
 		r=KErrNone; // Ensure misleading result is not propagated
 #endif
 	infoPtrs.Close();
 #else
 		if((r=secThrdChannel.GetNamesAllClients(&infoPtrs, numClients, ETrue)) != KErrPermissionDenied)
 			{
 			if(r==KErrNone)
 				r=KErrGeneral;
-			return r;
+			return r; // return error which is neither KErrPermissionDenied nor KErrGeneral
 			}
 		else
 			r=KErrNone; // Ensure misleading result is not propagated
 #endif
 		infoPtrs.Close();
 			return KErrGeneral;
 			}
 		if((r=gChannel.GetInfoOnClientsUsingResource(gSharedResource, numClients, &infoPtrs, EFalse))!=KErrNotReady)
 			{
 			gTest.Printf(_L("TestTransientHandling: GetInfoOnClientsUsingResource (for gSharedResource) returned %d\n"),r);
-			return r;
+			return KErrGeneral;
 			}
 		infoPtrs.Close();
 		}
 EXPORT_C TInt E32Main()
 //
 // Main
 //
-{
+	{
+	gTest.Title();
 	gTest.Start(_L("Test Power Resource Manager user side API\n"));
-	TInt r = KErrNone;
 	// Test attempted load of PDD
-gTest.Next(_L("**Load PDD\n"));
+	gTest.Next(_L("**Load PDD\n"));
-r=User::LoadPhysicalDevice(PDD_NAME);
+	TInt r = User::LoadPhysicalDevice(PDD_NAME);
-if((r!=KErrNone)&&(r!=KErrAlreadyExists))
+	gTest((r == KErrNone) || (r == KErrAlreadyExists));
-		{
+	gTest.SetCleanupFlag(EPddLoaded);
-		gTest.Printf(_L("User::LoadPhysicalDevice error %d\n"),r);
-		}
+	// Test attempted load of LDD
-	else
+	gTest.Next(_L("**Load LDD\n"));
-		{
+	r = User::LoadLogicalDevice(LDD_NAME);
-		// Test attempted load of LDD
+	gTest((r == KErrNone) || (r == KErrAlreadyExists));
-		gTest.Next(_L("**Load LDD\n"));
+	r = KErrNone; // Re-initialise in case set to KErrAlreadyExists
-		r=User::LoadLogicalDevice(LDD_NAME);
+	gTest.SetCleanupFlag(ELddLoaded);
-		if((r!=KErrNone)&&(r!=KErrAlreadyExists))
-			gTest.Printf(_L("User::LoadLogicalDevice error - expected %d, got %d\n"),KErrAlreadyExists,r);
+	// test caps
-		}
+	gTest(CheckCaps() == KErrNone);
-if((r==KErrNone)||(r==KErrAlreadyExists))
-		{
+	// Need a channel open for the following tests
-		r = KErrNone; // Re-initialise in case set to KErrAlreadyExists
+	gTest.Next(_L("**OpenAndRegisterChannel\n"));
-		//
+	r = OpenAndRegisterChannel();
-		// Need a channel open for the following tests
+	gTest(r == KErrNone);
-		gTest.Next(_L("**OpenAndRegisterChannel\n"));
+	gTest.SetCleanupFlag(EChannelOpened);
-		r=OpenAndRegisterChannel();
-		if (r==KErrNone)
+	// Get the version of the ResourceController
-			{
+	TUint version;
-			// Get the version of the ResourceController
+	r = gChannel.GetResourceControllerVersion(version);
-			TUint version;
+	gTest.Printf(_L("TestTransientHandling: ResourceController version =0x%x\n"), version);
-			if((r=gChannel.GetResourceControllerVersion(version))!=KErrNone)
+	gTest(r == KErrNone);
-				{
-				gTest.Printf(_L("TestTransientHandling: GetResourceControllerVersion returned %d\n"),r);
+	gTest.Next(_L("**TestThreadExclusiveAccess\n"));
-				return r;
+	r = TestThreadExclusiveAccess();
-				}
+	gTest(r == KErrNone);
-			gTest.Printf(_L("TestTransientHandling: ResourceController version =0x%x\n"),version);
-			}
+	gTest.Next(_L("**TestGetClientGetResourceInfo - initial state\n"));
-		if (r==KErrNone)
+	r = TestGetClientGetResourceInfo();
-			{
+	gTest(r == KErrNone);
-			gTest.Next(_L("**TestThreadExclusiveAccess\n"));
-			r=TestThreadExclusiveAccess();
+	gTest.Next(_L("**TestGetSetResourceStateOps\n"));
-			}
+	r = TestGetSetResourceStateOps();
-		if (r==KErrNone)
+	gTest(r == KErrNone);
-			{
-			gTest.Next(_L("**TestGetClientGetResourceInfo - initial state\n"));
+	gTest.Next(_L("**TestGetClientGetResourceInfo - after changing stateof Async resource\n"));
-			r=TestGetClientGetResourceInfo();
+	r = TestGetClientGetResourceInfo();
-			}
+	gTest(r == KErrNone);
-		if (r==KErrNone)
-			{
+	gTest.Next(_L("**TestGetSetResourceStateQuota\n"));
-			gTest.Next(_L("**TestGetSetResourceStateOps\n"));
+	r = TestGetSetResourceStateQuota();
-			r=TestGetSetResourceStateOps();
+	gTest(r == KErrNone);
-			}
-		if (r==KErrNone)
+	gTest.Next(_L("**TestNotificationOps\n"));
-			{
+	r = TestNotificationOps();
-			gTest.Next(_L("**TestGetClientGetResourceInfo - after changing stateof Async resource\n"));
+	gTest(r == KErrNone);
-			r=TestGetClientGetResourceInfo();
-			}
+	gTest.Next(_L("**TestNotificationQuota\n"));
-		if (r==KErrNone)
+	r = TestNotificationQuota();
-			{
+	gTest(r == KErrNone);
-			gTest.Next(_L("**TestGetSetResourceStateQuota\n"));
-			r=TestGetSetResourceStateQuota();
+	// Should be no change since last invocation (assuming that
-			}
+	// no clients other than those in this test)
-		if (r==KErrNone)
+	gTest.Next(_L("**TestGetClientGetResourceInfo - last invocation\n"));
-			{
+	r = TestGetClientGetResourceInfo();
-			gTest.Next(_L("**TestNotificationOps\n"));
+	gTest(r == KErrNone);
-			r=TestNotificationOps();
-			}
+	gTest.Next(_L("**TestAdditionalThread\n"));
-		if (r==KErrNone)
+	r = TestAdditionalThread();
-			{
+	gTest(r == KErrNone);
-			gTest.Next(_L("**TestNotificationQuota\n"));
-			r=TestNotificationQuota();
+	gTest.Next(_L("**TestTransientHandling\n"));
-			}
+	r = TestTransientHandling();
-		if (r==KErrNone)
+	gTest(r == KErrNone);
-			{
-			// Should be no change since last invocation (assuming that
-			// no clients other than those in this test)
-			gTest.Next(_L("**TestGetClientGetResourceInfo - last invocation\n"));
-			r=TestGetClientGetResourceInfo();
-			}
-		if (r==KErrNone)
-			{
-			gTest.Next(_L("**TestAdditionalThread\n"));
-			r=TestAdditionalThread();
-			}
-		if (r==KErrNone)
-			{
-			gTest.Next(_L("**TestTransientHandling\n"));
-			r=TestTransientHandling();
-			}
-		}
-	gChannel.Close();
-User::FreeLogicalDevice(KLddRootName);
-User::FreePhysicalDevice(PDD_NAME);
-	User::After(100000);	// Allow idle thread to run for driver unloading
 	gTest.End();
-	return r;
+	return KErrNone;
-}
+	}

changeset 244	a77889bee936
parent 0	a41df078684a
child 257	3e88ff8f41d5
child 279	957c583b417b