// 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);

    }