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