diff -r 2717213c588a -r 171fae344dd4 windowing/windowserver/tauto/TMESSAGE.CPP
--- a/windowing/windowserver/tauto/TMESSAGE.CPP	Tue Jun 22 15:21:29 2010 +0300
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -1,471 +0,0 @@
-// Copyright (c) 1996-2009 Nokia Corporation and/or its subsidiary(-ies).
-// All rights reserved.
-// This component and the accompanying materials are made available
-// under the terms of "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:
-//
-
-/**
- @file
- @test
- @internalComponent - Internal Symbian test code
-*/
-
-
-#include "TMESSAGE.H"
-
-const TInt KTotalNumberOfTestMessages=5;
-const TInt KMaxNumOfMessagesInActiveQueue=21;
-const TInt KMaxNumOfSyncMessages=25;
-const TInt KNumOfTestCases=7;
-TInt MsgCountCheck=0;
-TInt SyncSendReceiveCount=0;
-TUid UidAtFirstLocation;
-TUid UidAtLastLocation;
-TBool TestNeedsExtraCheck=EFalse;
-
-CTMessage::CTMessage(CTestStep* aStep) : CTWsGraphicsBase(aStep), iSyncSendReceiveFlag(EFalse), iCounter(-1), iState(0)
-	{
-	}
-
-TInt CTMessage::CreateAndSendMessages(TInt aCount,TInt aNoOfMessages)
-	{
-	CMessageReceiver* msgReceiver=(*iMessageReceiver)[iState];
-	TInt identifer=msgReceiver->GroupWin()->Identifier();
-	TInt length=aCount*2;
-	TUint8 modificationFactor=(TUint8 )(aCount*3+1);
-	TUint8 msgValue=0;
-	if(!iSyncSendReceiveFlag && TestNeedsExtraCheck)
-		{
-		if(aCount==0)
-			{
-			UidAtFirstLocation=TUid::Uid(length+(modificationFactor<<24));
-			}
-		else if(aCount==(aNoOfMessages-1))
-			{
-			UidAtLastLocation=TUid::Uid(length+(modificationFactor<<24));
-			}
-		}
-	iMsg->Des().Zero();
-	for(TInt index=0;index<length;index++)
-		{
-		msgValue=(TUint8)(msgValue+modificationFactor);
-		iMsg->Des().Append(msgValue);
-		}
-	return TheClient->iWs.SendMessageToWindowGroup(identifer, TUid::Uid(length+(modificationFactor<<24)), *iMsg);
-	}
-
-TInt CTMessage::CallbackLowPriority(TAny* aMessageTest)
-	{
-	return static_cast<CTMessage*>(aMessageTest)->SendSyncMessages();
-	}
-
-TInt CTMessage::SendSyncMessages()
-	{
-	if(iSyncSendReceiveFlag && iCounter++<SyncSendReceiveCount)
-		{
-		TEST(CreateAndSendMessages(iCounter,SyncSendReceiveCount)==KErrNone);
-		return ETrue;
-		}
-	TheClient->iWs.NumWindowGroups();		//Make sure all asyncronus calls have been processed
-	CTEventBase& eventHandler=*TheClient->EventHandler();
-	if (eventHandler.iStatus.Int()==KRequestPending)
-		CActiveScheduler::Stop();
-	else
-		return ETrue;
-	return EFalse;
-	}
-
-CTMessage::~CTMessage()
-	{
-	iMessageReceiver->ResetAndDestroy();
-	iMessageReceiver->Close();
-	delete iMessageReceiver;
- 	iLowPriorityObject->Cancel();
-	delete iLowPriorityObject;
-	iLowPriorityObject=NULL;
-	delete iMsg;
-	}
-
-void CTMessage::ConstructL()
-	{
-	iLowPriorityObject= new(ELeave) CLowPriorityIdle();
-	iMessageReceiver=new(ELeave) RPointerArray<CMessageReceiver>(KNumOfTestCases);
-	iMsg=HBufC8::NewL(KMaxNumOfSyncMessages*2);
-	for(TInt index=0;index<KNumOfTestCases;index++)
-		{
-		CMessageReceiver* messageReceiver=new(ELeave) CMessageReceiver(TheClient, this);
-		messageReceiver->ConstructL();
-		iMessageReceiver->AppendL(messageReceiver);
-		}
-	}
-
-
-CLowPriorityIdle::CLowPriorityIdle() : CIdle(EPriorityIdle)
-	{
-	CActiveScheduler::Add(this);
-	}
-
-TInt CLowPriorityIdle::RunError(TInt /*aError*/)
-	{
-	CActiveScheduler::Stop();
-	return KErrNone;
-	}
-
-LOCAL_C TInt DoPanicTest(TInt aInt, TAny *)
-	{
-	switch(aInt)
-		{
-		case 1:
-			User::Panic(KWSERV,EWservPanicGcActive);
-			break;
-		}
-	return(EWsExitReasonBad);
-	}
-
-CMessageReceiver::CMessageReceiver(CTClient *aClient, CTMessage *aTMessage) : CTWindowGroup(aClient), iMsgCount(0)
-	{
-	iTMessage = aTMessage;
-	}
-
-#define MESSAGES_READ 1		//Change to 2 to test the 16-bit functions too.
-void CMessageReceiver::MessageReady(const TWsEvent& aEvent)
-	{
-	iTMessage->OnMessageReceived(aEvent, iMsgCount);
-	}
-
-void CTMessage::OnMessageReceived(const TWsEvent& aEvent, TInt& aMsgCount)
-	{
-	aMsgCount++;
-	if(aMsgCount>MsgCountCheck)
-		{
-		return;
-		}
-	if (MESSAGES_READ*(aMsgCount/MESSAGES_READ)<aMsgCount)
-		{
-		return;
-		}
-	TPtr8 msgPtr(NULL,0);
-	//TPtr16 msgPtr2(NULL,0);
-	TUid uid;
-	TInt retValue=TheClient->iWs.FetchMessage(uid, msgPtr, aEvent);
-	TEST(retValue==KErrNone);
-	//GroupWin()->FetchMessage(uid, msgPtr2);
-	if(TestNeedsExtraCheck)
-		{
-		TEST(uid==(aMsgCount==1?UidAtFirstLocation:UidAtLastLocation));
-		}
-	TInt msgLength=(uid.iUid)&0xFFFFFF;
-	TUint8 uidFactor=(TUint8)((uid.iUid&0xFF000000)>>24);
-	TBool retVal = msgPtr.Length()==msgLength;
-	TEST(retVal);
-	if (!retVal)
-		INFO_PRINTF3(_L("msgPtr.Length()==msgLength  - Expected: %d, Actual: %d"), msgLength, msgPtr.Length());
-
-	TUint8 check=0;
-	for(TInt index=0;index<msgLength;index++)
-		{
-		check=(TUint8)(check+uidFactor);
-		retVal = msgPtr[index]==check;
-		TEST(retVal);
-		if (!retVal)
-			INFO_PRINTF3(_L("msgPtr[index]==check  - Expected: %d, Actual: %d"), check, msgPtr[index]);
-
-		}
-	/*CTestBase::Test(msgPtr.Length()/2==msgPtr2.Length());
-	TPtrC8 data2((const TUint8*) msgPtr2.Ptr(),msgPtr2.Size());
-	CTestBase::Test(data2==msgPtr.Left(msgPtr2.Size()));*/
-	User::Free((TAny *)msgPtr.Ptr());
-	//User::Free((TAny *)msgPtr2.Ptr());
-	}
-
-void CTMessage::TestPanicsL()
-	{	
-	TEST(iTest->TestWsPanicL(&DoPanicTest,EWservPanicGcActive,1));
-	iTest->CloseAllPanicWindows();
-	}
-
-void CTMessage::MessageTests(TInt aNoOfMessages,TInt aMsgCountCheck,TBool aSyncSendReceiveFlag,TBool aTestNeedsExtraCheck)
-	{
-	iSyncSendReceiveFlag=aSyncSendReceiveFlag;
-	TestNeedsExtraCheck=aTestNeedsExtraCheck;
-	MsgCountCheck=aMsgCountCheck;
-	iLowPriorityObject->Start(TCallBack(CallbackLowPriority,this));
-
-	if(iSyncSendReceiveFlag)
-		{
-		//Messages will be sent and received one by one using the function SendSyncMessages().
-		CActiveScheduler::Start();
-		}
-	else
-		{
-		for(TInt count=0;count<aNoOfMessages;count++)
-			{
-			TInt err=CreateAndSendMessages(count,aNoOfMessages);
-			TEST(err==KErrNone);
-			if (err!=KErrNone)
-				{
-				_LIT(KLog,"Error %d when trying to send Messages");
-				LOG_MESSAGE2(KLog,err);
-				}
-			}
-		CActiveScheduler::Start();
-		TInt msgCount=(*iMessageReceiver)[iState]->MessageCount();
-		TEST(msgCount==MsgCountCheck);
-		if (msgCount!=MsgCountCheck)
-			{
-			_LIT(KLog,"Number of messages recieved=%d expected=%d");
-			LOG_MESSAGE3(KLog,msgCount,MsgCountCheck);
-			}
-		}
-	}
-
-/**
- Test delivery group messages in case when event queue is overflow
- */
-void CTMessage::TestMessageQueueOverflowL()
-	{
-	const TInt numMaxMessages = 60;
-	TInt numWasteMessages = 0;
-	TInt numWgMessages = 5;
-
-	TInt gotRealWasteMessages = 0;
-	TInt gotRealWgMessages = 0;
-
-	const TInt oneSecond = 1000000;
-	const TInt allPossibleMessages = 500;
-
-	RWsSession senderWsSession;
-	RWindowGroup senderGroupWin;
-	TInt sndrHanGrpWin = 7777;
-
-	RWsSession receiverWsSession;
-	RWindowGroup receiverGroupWin;
-	TInt rcvrHanGrpWin = 8888;
-
-	TRequestStatus testStatus;
-	TRequestStatus timerStatus;
-	TWsEvent wasteEvent;
-	TWsEvent event;
-
-	RTimer timer;
-	timer.CreateLocal();
-	CleanupClosePushL(timer);
-
-	// Create sender WsSession and the window group
-	User::LeaveIfError(senderWsSession.Connect());
-	CleanupClosePushL(senderWsSession);
-
-	senderGroupWin = RWindowGroup(senderWsSession);
-	User::LeaveIfError(senderGroupWin.Construct(sndrHanGrpWin));
-	CleanupClosePushL(senderGroupWin);
-
-	// Create reciever WsSession and the window group
-	User::LeaveIfError(receiverWsSession.Connect());
-	CleanupClosePushL(receiverWsSession);
-
-	receiverGroupWin = RWindowGroup(receiverWsSession);
-	User::LeaveIfError(receiverGroupWin.Construct(rcvrHanGrpWin));
-	CleanupClosePushL(receiverGroupWin);
-
-	TInt err = KErrNone;
-
-	// Send waste events to the receiver and overflow the event queue
-	for (TInt ind = 0; ind < numMaxMessages; ind++)
-		{
-		wasteEvent.SetType(sndrHanGrpWin);
-		err = senderWsSession.SendEventToWindowGroup(receiverGroupWin.Identifier(), wasteEvent);
-		if (err != KErrNone)
-			{
-			numWasteMessages = ind; // Real number waste messages that was sent
-			break;
-			}
-		}
-
-	// Send messages to the receiver
-	for (TInt ind = 0; ind < numWgMessages; ind++)
-		{
-		TInt uidData = ind + sndrHanGrpWin;
-		TPtr8 msg((unsigned char*) &uidData, sizeof(uidData));
-		err = senderWsSession.SendMessageToWindowGroup(receiverGroupWin.Identifier(), TUid::Uid(uidData), msg);
-		if (err != KErrNone)
-			{
-			LOG_MESSAGE2(_L("UnExpected Error Code = %d"),err);
-			numWgMessages = ind; // Real number window group messages that was sent
-			}
-		}
-
-	// Check and count sent messages 
-	for (TInt ind = 0; ind < allPossibleMessages; ind++)
-		{
-		receiverWsSession.EventReady(&testStatus);
-		timer.After(timerStatus, oneSecond);
-		User::WaitForRequest(testStatus, timerStatus);
-		if (testStatus == 0)
-			{
-			// Test incoming events
-			receiverWsSession.GetEvent(event);
-			if (event.Type() == sndrHanGrpWin)
-				{
-				++gotRealWasteMessages;
-				}
-			else if (event.Type() == EEventMessageReady)
-				{
-				if (gotRealWgMessages == 0)
-					{
-					for (TInt ind = 0; ind < numMaxMessages; ind++)
-						{
-						wasteEvent.SetType(sndrHanGrpWin);
-						err = senderWsSession.SendEventToWindowGroup(receiverGroupWin.Identifier(), wasteEvent);
-						if (err == KErrNone)
-							{
-							++numWasteMessages;
-							}
-						else
-							{
-							break;
-							}
-						}
-					}
-				++gotRealWgMessages;
-				TUid uid;
-				TPtr8 msgPtr(NULL,0);
-				err = receiverWsSession.FetchMessage(uid, msgPtr, event);
-				User::Free((TAny *) msgPtr.Ptr());
-				}
-			// testStatus has been completed. Hence, Cancel the timer.
-			timer.Cancel();
-			User::WaitForRequest(timerStatus);
-			}
-		else
-			{
-			// Times out, cancel the event notification
-			receiverWsSession.EventReadyCancel();
-			User::WaitForRequest(testStatus);
-			// All events were recieved
-			break;
-			}
-		}
-
-	LOG_MESSAGE3(_L("Got Waste message = %d expected =%d"),gotRealWasteMessages,numWasteMessages);
-	LOG_MESSAGE3(_L("Got Group message = %d expected =%d"),gotRealWgMessages,numWgMessages);
-	TEST(gotRealWasteMessages == numWasteMessages);
-	TEST(gotRealWgMessages == numWgMessages);
-
-	CleanupStack::PopAndDestroy(&receiverGroupWin);
-	CleanupStack::PopAndDestroy(&receiverWsSession);
-	CleanupStack::PopAndDestroy(&senderGroupWin);
-	CleanupStack::PopAndDestroy(&senderWsSession);
-	CleanupStack::PopAndDestroy(&timer);
-
-	TheClient->iWs.Flush();
-
-	}
-
-void CTMessage::RunTestCaseL(TInt /*aCurTestCase*/)
-	{
-	_LIT(KMsgTest0,"Message test 1");
-	_LIT(KMsgTest1,"Message test 2");
-	_LIT(KMsgTest2,"Message test 3");
-	_LIT(KMsgTest3,"Message test 4");
-	_LIT(KMsgTest4,"Message test 5");
-	_LIT(KMsgTest5,"Message test 6");
-	_LIT(KMsgTest6,"Message test 7");
-	_LIT(KMsgTest7,"Message test 8 - when event queue is overflow");
-
-	iState=iTest->iState; // used by iMessageReceiver array 
-	((CTMessageStep*)iStep)->SetTestStepID(KUnknownSYMTestCaseIDName);
-	switch(++iTest->iState)
-		{
-/**
-@SYMTestCaseID		GRAPHICS-WSERV-0084
-
-@SYMDEF             DEF081259
-
-@SYMTestCaseDesc    Test message sending and receiving
-
-@SYMTestPriority    High
-
-@SYMTestStatus      Implemented
-
-@SYMTestActions     Generates 5 short messages and sends them to window group, window group receives them
-
-@SYMTestExpectedResults Expects that received messages have the same length and the same content as those sent
-*/		
-		case 1:
-			((CTMessageStep*)iStep)->SetTestStepID(_L("GRAPHICS-WSERV-0084"));
-			iTest->LogSubTest(KMsgTest0);
-			MessageTests(KTotalNumberOfTestMessages,KTotalNumberOfTestMessages,EFalse,EFalse);
-			break;
-/**
-@SYMTestCaseID		GRAPHICS-WSERV-0406
-
-@SYMDEF             DEF102201,DEF141447
-
-@SYMTestCaseDesc    Test message sending and receiving
-
-@SYMTestPriority    High
-
-@SYMTestStatus      Implemented
-
-@SYMTestActions     Generates some diffrent size of messages and sends them to window group, window group receives them
-
-@SYMTestExpectedResults Expects that received messages have the same length and the same content as those sent
-*/		
-		case 2:
-			((CTMessageStep*)iStep)->SetTestStepID(_L("GRAPHICS-WSERV-0406"));
-			iTest->LogSubTest(KMsgTest1);
-			MessageTests(KMaxNumOfMessagesInActiveQueue-1,KMaxNumOfMessagesInActiveQueue-1,EFalse,EFalse);
-			break;
-		case 3:
-			((CTMessageStep*)iStep)->SetTestStepID(_L("GRAPHICS-WSERV-0406"));
-			iTest->LogSubTest(KMsgTest2);
-			MessageTests(KMaxNumOfMessagesInActiveQueue,2,EFalse,ETrue);
-			break;
-		case 4:
-			((CTMessageStep*)iStep)->SetTestStepID(_L("GRAPHICS-WSERV-0406"));
-			iTest->LogSubTest(KMsgTest3);
-			MessageTests(KMaxNumOfMessagesInActiveQueue+1,2,EFalse,ETrue);
-			break;
-		case 5:
-			((CTMessageStep*)iStep)->SetTestStepID(_L("GRAPHICS-WSERV-0406"));
-			iTest->LogSubTest(KMsgTest4);
-			MessageTests(KMaxNumOfMessagesInActiveQueue+2,2,EFalse,ETrue);
-			break;
-		case 6:
-			((CTMessageStep*)iStep)->SetTestStepID(_L("GRAPHICS-WSERV-0406"));
-			iTest->LogSubTest(KMsgTest5);
-			SyncSendReceiveCount=KMaxNumOfSyncMessages;
-			MessageTests(KMaxNumOfSyncMessages,KMaxNumOfSyncMessages,ETrue,EFalse);
-			break;
-		case 7:
-			((CTMessageStep*)iStep)->SetTestStepID(_L("GRAPHICS-WSERV-0406"));
-			iTest->LogSubTest(KMsgTest6);
-			MessageTests(KMaxNumOfMessagesInActiveQueue+1,2,EFalse,ETrue);
-			((*iMessageReceiver)[iState])->ResetMessageCount();
-			SyncSendReceiveCount=KTotalNumberOfTestMessages;
-			MessageTests(KTotalNumberOfTestMessages,KTotalNumberOfTestMessages,ETrue,EFalse);
-			break;
-		case 8:
-			((CTMessageStep*)iStep)->SetTestStepID(_L("GRAPHICS-WSERV-0406"));
-			iTest->LogSubTest(KMsgTest7);
-			TestMessageQueueOverflowL();
-			((CTMessageStep*)iStep)->SetTestStepID(KNotATestSYMTestCaseIDName);
-			((CTMessageStep*)iStep)->CloseTMSGraphicsStep();
-			TestComplete();
-			return;
-		}
-	((*iMessageReceiver)[iState])->ResetMessageCount();
-	((CTMessageStep*)iStep)->RecordTestResultL();
-	}
-	
-
-__WS_CONSTRUCT_STEP__(Message)