--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/kerneltest/e32test/secure/t_rendezvous.cpp	Mon Oct 19 15:55:17 2009 +0100
@@ -0,0 +1,320 @@
+// Copyright (c) 2001-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\secure\t_rendezvous.cpp
+// Overview:
+// Test RThread and RProcess rendezvous
+// API Information:
+// RThread, RProcess
+// Details:
+// - Create a thread, request rendezvous, cancel rendezvous, request rendezvous
+// again, resume thread and wait for rendezvous, verify results as expected.
+// - Create a thread, request rendezvous, allow thread to die, verify results.
+// - Create a thread, request rendezvous, allow thread to finish, verify results.
+// - Create a process, request rendezvous, cancel rendezvous, request rendezvous
+// again, resume process and wait for rendezvous, verify results as expected.
+// - Create a process, request rendezvous, allow process to die, verify results.
+// - Create a process, request rendezvous, allow process to finish, verify results.
+// Platforms/Drives/Compatibility:
+// All.
+// Assumptions/Requirement/Pre-requisites:
+// Failures and causes:
+// Base Port information:
+// 
+//
+
+#include <e32test.h>
+
+LOCAL_D RTest test(_L("T_RENDEZVOUS"));
+
+_LIT(KSyncMutext,"T_RENDEZVOUS-sync-mutex");
+RMutex SyncMutex;
+
+void Wait()
+	{
+	RMutex syncMutex;
+	if(syncMutex.OpenGlobal(KSyncMutext)!=KErrNone)
+		User::Invariant();
+	syncMutex.Wait();
+	syncMutex.Signal();
+	syncMutex.Close();
+	}
+
+const TInt KRendezvousOk = 1;
+
+TInt ThreadRendezvous(TAny *)
+	{
+	RThread::Rendezvous(KRendezvousOk);
+	Wait();
+	return KErrNone;
+	}
+
+TInt ThreadDie(TAny *)
+	{
+	User::Panic(_L("ThreadDie"),KErrDied);
+	return KErrNone;
+	}
+
+TInt ThreadFinish(TAny *)
+	{
+	return KErrNone;
+	}
+
+void TestThreadRendezvous()
+	{
+	TRequestStatus rendezvousStatus;
+	TRequestStatus rendezvousStatusCancel;
+	TRequestStatus logonStatus;
+	TInt r;
+	RThread thread;
+
+	//
+
+	test.Start(_L("Create thread 'ThreadRendezvous'"));
+	r=thread.Create(_L("ThreadRendezvous"),ThreadRendezvous,KDefaultStackSize,KDefaultStackSize,KDefaultStackSize,NULL);
+	test(r==KErrNone);
+
+	test.Next(_L("Request rendezvous"));
+	thread.Rendezvous(rendezvousStatusCancel);
+	test(rendezvousStatusCancel==KRequestPending);
+
+	test.Next(_L("Cancel rendezvous request"));
+	r = thread.RendezvousCancel(rendezvousStatusCancel);
+	test(r==KErrNone);
+	test(rendezvousStatusCancel==KErrNone);
+
+	test.Next(_L("Request rendezvous again"));
+	thread.Rendezvous(rendezvousStatus);
+	test(rendezvousStatus==KRequestPending);
+
+	test.Next(_L("Also logon to thread"));
+	thread.Logon(logonStatus);
+	test(logonStatus==KRequestPending);
+
+	test.Next(_L("Resume thread and wait for rendezvous..."));
+	SyncMutex.Wait();
+	thread.Resume();
+	User::WaitForRequest(rendezvousStatus,logonStatus);
+	test(rendezvousStatus==KRendezvousOk);
+	test(logonStatus==KRequestPending);
+	test(rendezvousStatusCancel==KErrNone);
+
+	test.Next(_L("Rendezvous OK, now wait for thread to end..."));
+	SyncMutex.Signal();
+	User::WaitForRequest(logonStatus);
+	test(logonStatus==KErrNone);
+	test(rendezvousStatusCancel==KErrNone);
+
+	CLOSE_AND_WAIT(thread);
+
+	//
+
+	test.Next(_L("Create thread 'ThreadDie'"));
+	r=thread.Create(_L("ThreadDie"),ThreadDie,KDefaultStackSize,KDefaultStackSize,KDefaultStackSize,NULL);
+	test(r==KErrNone);
+
+	test.Next(_L("Request rendezvous"));
+	thread.Rendezvous(rendezvousStatus);
+	test(rendezvousStatus==KRequestPending);
+
+	test.Next(_L("Resume thread and wait for thread to die..."));
+	TBool jit = User::JustInTime();
+	User::SetJustInTime(EFalse);
+	thread.Resume();
+	User::WaitForRequest(rendezvousStatus);
+	User::SetJustInTime(jit);
+	test(rendezvousStatus==KErrDied);
+	test(thread.ExitReason()==KErrDied);
+	test(thread.ExitType()==EExitPanic);
+
+	CLOSE_AND_WAIT(thread);
+
+	//
+
+	test.Next(_L("Create thread 'ThreadFinish'"));
+	r=thread.Create(_L("ThreadFinish"),ThreadFinish,KDefaultStackSize,KDefaultStackSize,KDefaultStackSize,NULL);
+	test(r==KErrNone);
+
+	test.Next(_L("Request rendezvous"));
+	thread.Rendezvous(rendezvousStatus);
+	test(rendezvousStatus==KRequestPending);
+
+	test.Next(_L("Resume thread and wait for thread to finish..."));
+	thread.Resume();
+	User::WaitForRequest(rendezvousStatus);
+	test(rendezvousStatus==KErrNone);
+	test(thread.ExitReason()==KErrNone);
+	test(thread.ExitType()==EExitKill);
+
+	CLOSE_AND_WAIT(thread);
+
+	//
+
+	test.End();
+	}
+
+
+enum TTestProcessFunctions
+	{
+	ETestProcessRendezvous,
+	ETestProcessDie,
+	ETestProcessFinish,
+	};
+
+#include "testprocess.h"
+
+TInt DoTestProcess(TInt aTestNum,TInt aArg1,TInt aArg2)
+	{
+	(void)aArg1; // Keep compiler quiet about unused parameters
+	(void)aArg2;
+
+	switch(aTestNum)
+		{
+	case ETestProcessRendezvous:
+		RProcess::Rendezvous(KRendezvousOk);
+		Wait();
+		return KErrNone;
+
+	case ETestProcessDie:
+		User::Panic(_L("ProcessDie"),KErrDied);
+		return KErrNone;
+
+	case ETestProcessFinish:
+		return KErrNone;
+
+	default:
+		User::Panic(_L("T_RENDEZVOUS"),1);
+		}
+	return KErrNone;
+	}
+
+void TestProcessRendezvous()
+	{
+	TRequestStatus rendezvousStatus;
+	TRequestStatus rendezvousStatusCancel;
+	TRequestStatus logonStatus;
+	TInt r;
+	RTestProcess process;
+
+	test.Start(_L("Create new process"));
+	process.Create(ETestProcessRendezvous);
+
+	test.Next(_L("Request rendezvous"));
+	process.Rendezvous(rendezvousStatusCancel);
+	test(rendezvousStatusCancel==KRequestPending);
+
+	test.Next(_L("Cancel rendezvous request"));
+	r = process.RendezvousCancel(rendezvousStatusCancel);
+	test(r==KErrNone);
+	test(rendezvousStatusCancel==KErrNone);
+
+	test.Next(_L("Request rendezvous again"));
+	process.Rendezvous(rendezvousStatus);
+	test(rendezvousStatus==KRequestPending);
+
+	test.Next(_L("Also logon to process"));
+	process.Logon(logonStatus);
+	test(logonStatus==KRequestPending);
+
+	test.Next(_L("Resume process and wait for rendezvous..."));
+	SyncMutex.Wait();
+	process.Resume();
+	User::WaitForRequest(rendezvousStatus,logonStatus);
+	test(rendezvousStatus==KRendezvousOk);
+	test(logonStatus==KRequestPending);
+	test(rendezvousStatusCancel==KErrNone);
+
+	test.Next(_L("Rendezvous OK, now wait for process to end..."));
+	SyncMutex.Signal();
+	User::WaitForRequest(logonStatus);
+	test(logonStatus==KErrNone);
+	test(rendezvousStatusCancel==KErrNone);
+
+	CLOSE_AND_WAIT(process);
+
+	//
+
+	test.Next(_L("Create new process"));
+	process.Create(ETestProcessDie);
+
+	test.Next(_L("Request rendezvous"));
+	process.Rendezvous(rendezvousStatus);
+	test(rendezvousStatus==KRequestPending);
+
+	test.Next(_L("Resume process and wait for process to die..."));
+	process.Resume();
+	User::WaitForRequest(rendezvousStatus);
+	test(rendezvousStatus==KErrDied);
+	test(process.ExitReason()==KErrDied);
+	test(process.ExitType()==EExitPanic);
+
+	CLOSE_AND_WAIT(process);
+
+	//
+
+	test.Next(_L("Create new process"));
+	process.Create(ETestProcessFinish);
+
+	test.Next(_L("Request rendezvous"));
+	process.Rendezvous(rendezvousStatus);
+	test(rendezvousStatus==KRequestPending);
+
+	test.Next(_L("Resume process and wait for process to finish..."));
+	process.Resume();
+	User::WaitForRequest(rendezvousStatus);
+	test(rendezvousStatus==KErrNone);
+	test(process.ExitReason()==KErrNone);
+	test(process.ExitType()==EExitKill);
+
+	CLOSE_AND_WAIT(process);
+
+	// 
+
+	test.End();
+	}
+
+
+
+GLDEF_C TInt E32Main()
+    {
+	TBuf16<512> cmd;
+	User::CommandLine(cmd);
+	if(cmd.Length() && TChar(cmd[0]).IsDigit())
+		{
+		TInt function = -1;
+		TInt arg1 = -1;
+		TInt arg2 = -1;
+		TLex lex(cmd);
+		lex.Val(function);
+		lex.SkipSpace();
+		lex.Val(arg1);
+		lex.SkipSpace();
+		lex.Val(arg2);
+		return DoTestProcess(function,arg1,arg2);
+		}
+
+	test.Title();
+	test(SyncMutex.CreateGlobal(KSyncMutext)==KErrNone);
+
+	test.Start(_L("Test Thread rendezvous"));
+	TestThreadRendezvous();
+
+	test.Next(_L("Test Process rendezvous"));
+	TestProcessRendezvous();
+
+	SyncMutex.Close();
+	test.End();
+
+	return(0);
+    }
+