// Copyright (c) 2002-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_sobject.cpp

// Overview:

// Test the security aspects of the TFind??? (TFindChunk etc.) classes.

// API Information:

// TFind??? (TFindChunk, TFindThread etc.)

// Details:

// - Test TFindPhysicalDevices and attempt to open the found device. 

// Verify results are as expected.

// - Test TFindLogicalDevices and attempt to open the found device. 

// Duplicate the object in another thread. Verify results are as expected.

// - Test TFindLibrary and attempt to open the found device. Verify results 

// are as expected.

// - Test TFindServer and attempt to open the found server. Test duplication 

// of a named or unnamed server. Verify results are as expected.

// - Test TFindProcess and attempt to open the found process. Test duplication 

// of the object. Attempt to open the process by name and by id. Verify 

// results are as expected.

// - Test TFindThread and attempt to open the found thread. Test duplication 

// of the object. Attempt to open the thread in various ways. Verify 

// results are as expected.

// - Test TFindChunk and attempt to open the found object. Test duplication 

// of the object. Attempt to open the object in various ways. Verify 

// results are as expected.

// - Test TFindSemaphore and attempt to open the found object. Attempt to 

// open the object in various ways. Test duplication of the object. Verify 

// results are as expected.

// - Test TFindMutex and attempt to open the found object. Attempt to 

// open the object in various ways. Test duplication of the object. Verify 

// results are as expected.

// - Create some RMsgQueue objects. Attempt to open the objects in various ways. 

// Test duplication of the objects. Verify results are as expected.

// - Create some RCondVar objects. Attempt to open the objects in various ways. 

// Test duplication of the objects. Verify results are as expected.

// - Test passing a handle via IPC: test sending LogicalChannel, Chunk, 

// Semaphore, Mutex, MsgQueue, CondVar and Session handles. Verify results

// are as expected.

// Platforms/Drives/Compatibility:

// All.

// Assumptions/Requirement/Pre-requisites:

// Failures and causes:

// Base Port information:

// 

//

#define __E32TEST_EXTENSION__

#include <e32test.h>

#include <e32msgqueue.h>

#include <f32file.h>

#include "d_sldd.h"

LOCAL_D RTest test(_L("T_SOBJECT"));

TInt PlatSecProcessIsolationError = 1;

TInt PlatSecFindError = 1;

_LIT(KTestMutexName,"T_SOBJECT-test-mutex");

_LIT(KTestSemaphoreName,"T_SOBJECT-test-semaphore");

_LIT(KTestChunkName,"T_SOBJECT-test-chunk");

_LIT(KTestMsgQueueName,"T_SOBJECT-test-msgqueue");

_LIT(KTestCondVarName,"T_SOBJECT-test-condvar");

TFullName Name;

TFullName Name2;

void SetName(RHandleBase a)

	{

	Name = a.FullName();

	}

TBool CheckName(RHandleBase a)

	{

	Name2 = a.FullName();

	return Name==Name2;

	}

class RTestHandle : public RHandleBase

	{

public:

	inline TInt Open(const TFindHandleBase& aHandle,TOwnerType aType=EOwnerThread)

		{ return RHandleBase::Open(aHandle,aType); }

	};

enum TTestProcessFunctions

	{

	ETestProcessServer,

	ETestProcessDuplicate,

	ETestProcessOpenThreadById,

	};

#include "testprocess.h"

TThreadId MainThreadId;

TInt TestThreadDuplicate(TAny* aArg)

	{

	RHandleBase handle;

	handle.SetHandle((TInt)aArg);

	RThread thread;

	TInt r = thread.Open(MainThreadId);

	if(r!=KErrNone)

		r = 999;

	else

		r = handle.Duplicate(thread);

	thread.Close();

	return r;

	}

TInt DuplicateInOtherThread(RHandleBase aHandle)

	{

	RThread thread;

	TRequestStatus logonStatus;

	thread.Create(_L(""),TestThreadDuplicate,KDefaultStackSize,KDefaultStackSize,KDefaultStackSize,(TAny*)aHandle.Handle());

	MainThreadId = RThread().Id();

	thread.Logon(logonStatus);

	thread.Resume();

	User::WaitForRequest(logonStatus);

	test(thread.ExitType()==EExitKill);

	CLOSE_AND_WAIT(thread);

	return logonStatus.Int();

	}

TInt DuplicateInOtherProcess(RHandleBase aHandle)

	{

	RTestProcess process;

	TRequestStatus logonStatus;

	process.Create(ETestProcessDuplicate,RThread().Id(),aHandle.Handle());

	process.Logon(logonStatus);

	process.Resume();

	User::WaitForRequest(logonStatus);

	test(process.ExitType()==EExitKill);

	CLOSE_AND_WAIT(process);

	return logonStatus.Int();

	}

TInt OpenThreadByIdInOtherProcess(TThreadId aId)

	{

	RTestProcess process;

	TRequestStatus logonStatus;

	process.Create(ETestProcessOpenThreadById,aId);

	process.Logon(logonStatus);

	process.Resume();

	User::WaitForRequest(logonStatus);

	test(process.ExitType()==EExitKill);

	CLOSE_AND_WAIT(process);

	return logonStatus.Int();

	}

//

// RTestSession

//

enum TServerName

	{

	EMainServer,EGlobalSharableServer,EAnonymousServer,ENumServerTypes

	};

_LIT(KServerName,"T_SOBJECT-MainServer");

_LIT(KServerName2,"T_SOBJECT-GlobalSharableServer");

inline const TDesC& ServerName(TServerName aName)

	{

	switch(aName)

		{

	case EMainServer:

		return KServerName;

	case EGlobalSharableServer:

		return KServerName2;

	default:

		return KNullDesC;

		}

	}

class RTestSession : public RSessionBase

	{

public:

	inline TInt Connect(TServerName aName=EMainServer)

		{

		TInt r=CreateSession(ServerName(aName),TVersion());

		if(r) return r;

		return ShareAuto();

		}

	inline TInt ConnectProtected(TServerName aName=EMainServer)

		{

		TInt r=CreateSession(ServerName(aName),TVersion());

		if(r) return r;

		return ShareProtected();

		}

	inline TInt Open(RMessagePtr2 aMessage,TInt aParam,TOwnerType aType=EOwnerProcess)

		{ return RSessionBase::Open(aMessage,aParam,aType); }

	inline TInt Open(RMessagePtr2 aMessage,TInt aParam,const TSecurityPolicy& aServerPolicy,TOwnerType aType=EOwnerProcess)

		{ return RSessionBase::Open(aMessage,aParam,aServerPolicy,aType); }

	inline TInt Send(TInt aFunction)

		{ return RSessionBase::SendReceive(aFunction); }

	inline TInt Send(TInt aFunction,const TIpcArgs& aArgs)

		{ return RSessionBase::SendReceive(aFunction,aArgs); }

	inline void Send(TInt aFunction,TRequestStatus& aStatus)

		{ RSessionBase::SendReceive(aFunction,aStatus); }

	inline void Send(TInt aFunction,const TIpcArgs& aArgs,TRequestStatus& aStatus)

		{ RSessionBase::SendReceive(aFunction,aArgs,aStatus); }

	};

//

// CTestSession

//

class CTestSession : public CSession2

	{

public:

	enum {EShutdown,EPing,ETestMutex,ETestSemaphore,ETestMsgQueue,ETestCondVar,ETestChunk,ETestChunkAdjust,ETestLdd,

		ETestSession,ETestSession2,ETestSession3,ETestServerDuplicateInThread,ETestServerDuplicateInProcess};

public:

	CTestSession();

	virtual void ServiceL(const RMessage2& aMessage);

public:

	};

CTestSession::CTestSession()

	: CSession2()

	{

	}

void CTestSession::ServiceL(const RMessage2& aMessage)

	{

	RMessagePtr2 m(aMessage);

	TFullName name;

	TInt r = KErrGeneral;

	switch (aMessage.Function())

		{

		case CTestSession::EShutdown:

			CActiveScheduler::Stop();

			break;

		case CTestSession::EPing:

			r=aMessage.Int0();

			break;

		case CTestSession::ETestMutex:

			{

			RMutex object;

			r = object.Open(m,0,EOwnerThread);

			if(r!=KErrBadHandle || object.Handle())

				goto fail;

			r = object.Open(m,1,EOwnerProcess);

			if(r!=KErrNone)

				break;

			name = object.FullName();

			object.Close();

			if(name!=KTestMutexName)

				goto fail;

			r = object.Open(m,2,EOwnerThread);

			if(r!=KErrNone)

				break;

			SetName(object);

			m.Read(3,Name2);

			if(Name!=Name2)

				goto fail;

			m.Complete(object);

			object.Close();

			return;

			}

		case CTestSession::ETestSemaphore:

			{

			RSemaphore object;

			r = object.Open(m,0,EOwnerThread);

			if(r!=KErrBadHandle || object.Handle())

				goto fail;

			r = object.Open(m,1,EOwnerProcess);

			if(r!=KErrNone)

				break;

			name = object.FullName();

			object.Close();

			if(name!=KTestSemaphoreName)

				goto fail;

			r = object.Open(m,2,EOwnerThread);

			if(r!=KErrNone)

				break;

			SetName(object);

			m.Read(3,Name2);

			if(Name!=Name2)

				goto fail;

			m.Complete(object);

			object.Close();

			return;

			}

		case CTestSession::ETestMsgQueue:

			{

			RMsgQueue<TInt> object;

			r = object.Open(m,0,EOwnerThread);

			if(r!=KErrBadHandle || object.Handle())

				goto fail;

			r = object.Open(m,1,EOwnerProcess);

			if(r!=KErrNone)

				break;

			name = object.FullName();

			object.Close();

			if(name!=KTestMsgQueueName)

				goto fail;

			r = object.Open(m,2,EOwnerThread);

			if(r!=KErrNone)

				break;

			SetName(object);

			m.Read(3,Name2);

			if(Name!=Name2)

				goto fail;

			m.Complete(object);

			object.Close();

			return;

			}

		case CTestSession::ETestCondVar:

			{

			RCondVar object;

			r = object.Open(m,0,EOwnerThread);

			if(r!=KErrBadHandle || object.Handle())

				goto fail;

			r = object.Open(m,1,EOwnerProcess);

			if(r!=KErrNone)

				break;

			name = object.FullName();

			object.Close();

			if(name!=KTestCondVarName)

				goto fail;

			r = object.Open(m,2,EOwnerThread);

			if(r!=KErrNone)

				break;

			SetName(object);

			m.Read(3,Name2);

			if(Name!=Name2)

				goto fail;

			m.Complete(object);

			object.Close();

			return;

			}

		case CTestSession::ETestChunk:

			{

			RChunk object;

			r = object.Open(m,0,EOwnerThread);

			if(r!=KErrBadHandle || object.Handle())

				goto fail;

			r = object.Open(m,1,EOwnerProcess);

			if(r!=KErrNone)

				break;

			name = object.FullName();

			object.Close();

			if(name!=KTestChunkName)

				goto fail;

			r = object.Open(m,2,EOwnerThread);

			if(r!=KErrNone)

				break;

			SetName(object);

			m.Read(3,Name2);

			if(Name!=Name2)

				goto fail;

			m.Complete(object);

			object.Close();

			return;

			}

		case CTestSession::ETestChunkAdjust:

			{

			RChunk object;

			r = object.Open(m,0,EOwnerThread);

			if(r==KErrNone)

				r = object.Adjust(0x1000);

			object.Close();

			}

			break;

		case CTestSession::ETestLdd:

			{

			RLddTest object;

			r = object.Open(m,0);

			if(r!=KErrBadHandle || object.Handle())

				goto fail;

			r = object.Open(m,1);

			if(r!=KErrNone)

				break;

			SetName(object);

			m.Read(3,Name2);

			if(Name!=Name2)

				goto fail;

			r = object.Test1();

			if(r!=aMessage.Int2())

				goto fail;

			m.Complete(object);

			object.Close();

			return;

			}

		case CTestSession::ETestSession:

			{

			RTestSession object;

			r = object.Open(m,0);

			if(r!=KErrBadHandle || object.Handle())

				goto fail;

			r = object.Open(m,1,TSecurityPolicy(ECapabilityTCB));

			if(r!=KErrPermissionDenied || object.Handle())

				goto fail;

			r = object.Open(m,1);

			if(r!=KErrNone)

				break;

			SetName(object);

			m.Read(3,Name2);

			if(Name!=Name2)

				goto fail;

			RFs fs;

			r = fs.Open(m,2,TSecurityPolicy(ECapabilityTCB));

			if(r!=KErrNone)

				goto fail;

			fs.Close();

			r=object.Send(CTestSession::EPing,TIpcArgs(234));

			if(r!=234)

				goto fail;

			m.Complete(object);

			object.Close();

			return;

			}

		case CTestSession::ETestSession2:

			{

			RTestSession object;

			object.Connect(EGlobalSharableServer);

			m.Complete(object);

			object.Close();

			return;

			}

		case CTestSession::ETestSession3:

			{

			RFs object;

			object.Connect();

			object.ShareProtected();

			m.Complete(object);

			object.Close();

			return;

			}

		case CTestSession::ETestServerDuplicateInThread:

			r = DuplicateInOtherThread(Server()->Server());

			break;

		case CTestSession::ETestServerDuplicateInProcess:

			r = DuplicateInOtherProcess(Server()->Server());

			break;

		default:

			m.Complete(KErrNotSupported);

			break;

		}

	m.Complete(r);

	return;

fail:

	m.Complete(KErrGeneral);

	return;

	}

RTestSession Session;

//

// CTestServer

//

class CTestServer : public CServer2

	{

public:

	CTestServer(TInt aPriority,TInt aType=ESharableSessions);

	virtual CSession2* NewSessionL(const TVersion& aVersion,const RMessage2& aMessage) const;

	};

CTestServer::CTestServer(TInt aPriority,TInt aType)

	: CServer2(aPriority,(TServerType)aType)

	{

	}