// Copyright (c) 1998-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\system\t_prot2.cpp

// 

//

#include <e32test.h>

#include "u32std.h"

const TInt KHeapSize=0x1000;

_LIT(KSecondProcessName,"T_PROT2A");

_LIT(KSecondProcessDataChunkName,"T_PROT2A*$DAT");

RTest test(_L("T_PROT2"));

LOCAL_C TInt WatcherThread(TAny* aSemaphoreHandle)

	{

	RTest wtest(_L("Watcher Thread"));

	wtest.Title();

	RThread().SetPriority(EPriorityMuchMore);

	wtest.Start(_L("Create undertaker"));

	RUndertaker u;

	TInt r=u.Create();

	if (r!=KErrNone)

		{

		RProcess me;

		me.Panic(_L("UNDERTAKER"),r);

		}

	RSemaphore sem;

	sem.SetHandle((TInt)aSemaphoreHandle);

	sem.Signal();

	FOREVER

		{

		TRequestStatus s;

		TInt h;

		u.Logon(s,h);

		User::WaitForRequest(s);

		RThread t;

		t.SetHandle(h);

		const TDesC& fn=t.FullName();

		wtest.Printf(_L("Thread %S exited\n"),&fn);

		const TDesC& cat=t.ExitCategory();

		wtest.Printf(_L("Exit type %d,%d,%S\n"),t.ExitType(),t.ExitReason(),&cat);

		t.Close();

		}

	}

LOCAL_C void StartWatcherThread()

	{

	test.Next(_L("Start watcher thread"));

	RSemaphore s;

	TInt r=s.CreateLocal(0);

	test(r==KErrNone);

	RThread t;

	r=t.Create(_L("WatcherThread"),WatcherThread,KDefaultStackSize,KHeapSize,KHeapSize,(TAny*)s.Handle());

	test(r==KErrNone);

	t.Resume();

	s.Wait();

	s.Close();

	}

void ExceptionHandler(TExcType)

	{

	User::Leave(KErrAbort);

	}

LOCAL_C TInt RogueThread1(TAny*)

	{

	TInt n;

	TInt m=0;

	TUint* p=NULL;

	RChunk c;

	User::SetExceptionHandler(ExceptionHandler,KExceptionFault);

	for (n=0; n<100; n++)

		{

		User::AfterHighRes(1000);	// wait 1ms

		if (m==0 && !p)

			{

			TFindChunk fc(KSecondProcessDataChunkName);

			TFullName fn;

			TInt r=fc.Next(fn);

			if (r!=KErrNone)

				continue;

			r=c.Open(fc);

			if (r!=KErrNone)

				continue;

			p=(TUint*)c.Base();	// second process is fixed

			continue;

			}

		if (m==0 && p)

			{

			if (c.Size()==0)

				continue;

			m++;

			c.Close();

			}

		TRAPD(r,Mem::Fill(p,0x1000,0xc9));

		if (r==KErrNone)

			return KErrNone;

		}

	User::Panic(_L("NOTFOUND"),m);

	return KErrNone;

	}

LOCAL_C void TestLoaderProtection()

	{

	test.Next(_L("Create rogue thread"));

	RThread t;

	TInt r=t.Create(_L("RogueThread1"),RogueThread1,KDefaultStackSize,KHeapSize,KHeapSize,NULL);

	test(r==KErrNone);

	t.SetPriority(EPriorityRealTime);	// this should be above the loader

	TRequestStatus s;

	t.Logon(s);

	test(s==KRequestPending);

	test.Next(_L("Resume rogue thread"));

	t.Resume();

	test.Next(_L("Create second process"));

	RProcess p;

	r=p.Create(KSecondProcessName,KNullDesC);

	test(r==KErrNone);

	TRequestStatus s2;

	p.Logon(s2);

	test(s2==KRequestPending);

	test.Next(_L("Resume second process"));

	p.Resume();

	test.Next(_L("Wait for second process to exit"));

	User::WaitForRequest(s2);

	const TDesC& pcat=p.ExitCategory();

	test.Printf(_L("Exit type %d,%d,%S\n"),p.ExitType(),p.ExitReason(),&pcat);

	test.Getch();

	test.Next(_L("Wait for rogue thread to exit"));

	User::WaitForRequest(s);

	const TDesC& tcat=t.ExitCategory();

	test.Printf(_L("Exit type %d,%d,%S\n"),t.ExitType(),t.ExitReason(),&tcat);

	test.Getch();

	}

GLDEF_C TInt E32Main()

	{

	test.Title();

	test.Start(_L("Testing protection against errant user threads"));

	RProcess().SetPriority(EPriorityHigh);

	StartWatcherThread();

	TestLoaderProtection();

	test.End();

	return KErrNone;

	}