diff -r 000000000000 -r bde4ae8d615e os/kernelhwsrv/kerneltest/e32test/notifier/t_textnotifier.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/os/kernelhwsrv/kerneltest/e32test/notifier/t_textnotifier.cpp	Fri Jun 15 03:10:57 2012 +0200
@@ -0,0 +1,289 @@
+// Copyright (c) 2003-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\notifier\t_textnotifier.cpp
+// Overview:
+// Test the RNotifier class.
+// API Information:
+// RNotifier
+// Details:	
+// - For IPC Ver. 1 and IPC Ver 2, connect to and start anotifier server.
+// Perform a variety of tests including CancelNotifier, StartNotifier,
+// UpdateNotifier, UpdateNotifierAndGetResponse, StartNotifierAndGetResponse.
+// Verify results are as expected. Check for memory leaks and cleanup.
+// - For IPC Ver. 1 and IPC Ver 2, using MNotifierManager, connect to and 
+// start anotifier server. Perform a variety of tests including CancelNotifier, 
+// StartNotifier, UpdateNotifier, UpdateNotifierAndGetResponse, 
+// StartNotifierAndGetResponse. Verify results are as expected. 
+// Check for memory leaks and cleanup.
+// - Do interactive tests as requested.
+// Platforms/Drives/Compatibility:
+// Hardware (Automatic).
+// Assumptions/Requirement/Pre-requisites:
+// Failures and causes:
+// Base Port information:
+// 
+//
+
+#include <e32std.h>
+#include <e32std_private.h>
+#include <e32test.h>
+#include "textnotifier.h"
+#include <e32debug.h>
+
+LOCAL_D RTest test(_L("T_TEXTNOTIFIER"));
+
+void DoMemoryLeakTests(TUid aUid,TBool aCheckMNotifierManager)
+	{
+	TInt r;
+	TRequestStatus stat;
+
+	test.Start(_L("Connect to notifier server"));
+	RNotifier n;
+	r = n.Connect();
+	test(r==KErrNone);
+
+	test.Next(_L("Get Notifier Server Heap Info"));
+	static TBuf8<128> heapInfo1;
+	heapInfo1.Zero();
+	n.StartNotifierAndGetResponse(stat,aUid,KHeapData,heapInfo1);
+	User::WaitForRequest(stat);
+	n.CancelNotifier(aUid);
+	TInt heapCellCount=stat.Int();
+	test(heapCellCount>0);
+
+	test.Next(_L("Repeated StartNotifierAndGetResponse"));
+	for(TInt i=0; i<1000; i++)
+		{
+		TBuf8<128> response;
+		response.SetMax();
+		response.FillZ();
+		response.Zero();
+		n.StartNotifierAndGetResponse(stat,aUid,aCheckMNotifierManager?*&KMNotifierManager:*&KStartData,response);
+		User::WaitForRequest(stat);
+		n.CancelNotifier(aUid);
+		test(stat==KErrNone);
+		test(response==KResponseData);
+		}
+
+	test.Next(_L("Check Notifier Server Heap Info"));
+	static TBuf8<128> heapInfo2;
+	heapInfo2.Zero();
+	n.StartNotifierAndGetResponse(stat,aUid,KHeapData,heapInfo2);
+	User::WaitForRequest(stat);
+	n.CancelNotifier(aUid);
+	test(stat==heapCellCount);
+	test(heapInfo1==heapInfo2);
+
+	test.Next(_L("Close connection to notifier server"));
+	n.Close();
+
+	test.End();
+	}
+
+void DoCleanumpTests(TUid aUid,TBool aCheckMNotifierManager)
+	{
+	TInt r;
+
+	test.Start(_L("Connect to notifier server"));
+	RNotifier n;
+	r = n.Connect();
+	test(r==KErrNone);
+
+	test.Next(_L("StartNotifierAndGetResponse"));
+	TBuf8<128> response;
+	response.SetMax();
+	response.FillZ();
+	response.Zero();
+	TRequestStatus stat;
+	n.StartNotifierAndGetResponse(stat,aUid,aCheckMNotifierManager?*&KMNotifierManager:*&KStartData,response);
+	User::WaitForRequest(stat);
+	test(stat==KErrNone);
+	test(response==KResponseData);
+
+	test.Next(_L("Close connection to notifier server"));
+	n.Close();
+
+	test.Next(_L("Connect to notifier server"));
+	r = n.Connect();
+	test(r==KErrNone);
+
+	test.Next(_L("StartNotifierAndGetResponse (to check previous notifier was cancelled)"));
+	response.SetMax();
+	response.FillZ();
+	response.Zero();
+	n.StartNotifierAndGetResponse(stat,aUid,aCheckMNotifierManager?*&KMNotifierManagerWithCancelCheck:*&KStartWithCancelCheckData,response);
+	User::WaitForRequest(stat);
+	test(stat==KTestNotifierWasPreviouselyCanceled);
+	test(response==KResponseData);
+
+	test.Next(_L("Close connection to notifier server"));
+	n.Close();
+
+	test.End();
+	}
+
+
+
+void DoTests(TUid aUid,TBool aCheckMNotifierManager)
+	{	
+	TInt r;
+	
+	test.Start(_L("Connect to notifier server"));
+	RNotifier n;
+	r = n.Connect();
+	test(r==KErrNone);
+
+	test.Next(_L("StartNotifier (without response)"));
+	r = n.StartNotifier(aUid,aCheckMNotifierManager?*&KMNotifierManager:*&KStartData);
+	RDebug::Printf("r=%d", r);
+	test(r==KErrNone);
+
+	test.Next(_L("CancelNotifier"));
+	r = n.CancelNotifier(aUid);
+	test(r==KErrNone);
+
+	test.Next(_L("StartNotifier"));
+	TBuf8<128> response;
+	response.SetMax();
+	response.FillZ();
+	response.Zero();
+	r = n.StartNotifier(aUid,aCheckMNotifierManager?*&KMNotifierManager:*&KStartData,response);
+	test(r==KErrNone);
+	test(response==KResponseData);
+
+	test.Next(_L("UpdateNotifier"));
+	response.SetMax();
+	response.FillZ();
+	response.Zero();   // EKA1 text notifier dies if current length < length of response
+	r = n.UpdateNotifier(aUid,aCheckMNotifierManager?*&KMNotifierManager:*&KUpdateData,response);
+	test(r==KErrNone);
+	test(response==KResponseData);
+
+	test.Next(_L("UpdateNotifierAndGetResponse"));
+	response.SetMax();
+	response.FillZ();
+	response.Zero();   // EKA1 text notifier dies if current length < length of response
+	TRequestStatus updateStat;
+	n.UpdateNotifierAndGetResponse(updateStat,aUid,aCheckMNotifierManager?*&KMNotifierManager:*&KUpdateData,response);
+	User::WaitForRequest(updateStat);
+	test(updateStat==KErrNone);
+	test(response==KResponseData);
+
+	test.Next(_L("CancelNotifier"));
+	r = n.CancelNotifier(aUid);
+	test(r==KErrNone);
+
+	test.Next(_L("StartNotifierAndGetResponse (to check previous notifier was cancelled)"));
+	response.SetMax();
+	response.FillZ();
+	response.Zero();
+	TRequestStatus stat;
+	n.StartNotifierAndGetResponse(stat,aUid,aCheckMNotifierManager?*&KMNotifierManagerWithCancelCheck:*&KStartWithCancelCheckData,response);
+	User::WaitForRequest(stat);
+	test(stat==KTestNotifierWasPreviouselyCanceled);
+	test(response==KResponseData);
+
+	test.Next(_L("CancelNotifier"));
+	r = n.CancelNotifier(aUid);
+	test(r==KErrNone);
+
+	test.Next(_L("Close connection to notifier server"));
+	n.Close();
+
+	test.Next(_L("Memory leak tests"));
+	DoMemoryLeakTests(aUid,aCheckMNotifierManager);
+
+	test.Next(_L("Session cleanup test"));
+	DoCleanumpTests(aUid,aCheckMNotifierManager);
+
+	test.End();
+	}
+
+void DoInteractiveTests()
+	{
+	TInt r;
+
+	test.Start(_L("Connect to notifier server"));
+	RNotifier n;
+	r = n.Connect();
+	test(r==KErrNone);
+
+	test.Next(_L("Launching simple notifier"));
+	_LIT(KLine1,"Line1 - Select Button2");
+	_LIT(KLine2,"Line2 - or press enter");
+	_LIT(KButton1,"Button1");
+	_LIT(KButton2,"Button2");
+	TInt button=-1;
+	TRequestStatus stat;
+	n.Notify(KLine1,KLine2,KButton1,KButton2,button,stat);
+	User::WaitForRequest(stat);
+	test(button==1);
+
+	test.Next(_L("Close connection to notifier server"));
+	n.Close();
+
+	test.End();
+	}
+
+#include <e32svr.h>
+
+GLDEF_C TInt E32Main()
+    {
+	test.Title();
+
+	test.Start(_L("Test V1 notifier"));
+	if(UserSvr::IpcV1Available())
+		DoTests(KUidTestTextNotifier1,EFalse);
+	else
+		test.Printf(_L("IPC V1 not supported"));
+
+	test.Next(_L("Test V2 notifier"));
+	DoTests(KUidTestTextNotifier2,EFalse);
+
+	test.Next(_L("Test V1 notifier using MNotifierManager"));
+	if(UserSvr::IpcV1Available())
+		DoTests(KUidTestTextNotifier1,ETrue);
+	else
+		test.Printf(_L("IPC V1 not supported"));
+
+	test.Next(_L("Test V2 notifier using MNotifierManager"));
+	if(UserSvr::IpcV1Available())
+		DoTests(KUidTestTextNotifier2,ETrue);
+	else
+		test.Printf(_L("FIX ME! - Can't run because IPC V1 not supported\n"));
+
+	test.Next(_L("Interactive Tests"));
+	test.Printf(_L("  Do you want to test notifiers interactively? y/n\n"));
+	test.Printf(_L("  Waiting 10 seconds for answer...\n"));
+	TRequestStatus keyStat;
+	test.Console()->Read(keyStat);
+	RTimer timer;
+	test(timer.CreateLocal()==KErrNone);
+	TRequestStatus timerStat;
+	timer.After(timerStat,10*1000000);
+	User::WaitForRequest(timerStat,keyStat);
+	TInt key = 0;
+	if(keyStat!=KRequestPending)
+		key = test.Console()->KeyCode();
+	timer.Cancel();
+	test.Console()->ReadCancel();
+	User::WaitForAnyRequest();
+	if(key=='y' || key=='Y')
+		DoInteractiveTests();
+	else
+		test.Printf(_L("  Interactive Tests Not Run\n"));
+
+	test.End();
+	return(0);
+	}