// Copyright (c) 2006-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:

// Tests the functionality of the run mode debug device driver.

// 

//

#include <e32base.h>

#include <e32base_private.h>

#include <e32cons.h>

#include <e32test.h>

#include <e32ldr.h>

#include <f32dbg.h>

#include "d_rmdebugclient.h"

#include "d_rmdebugthread.h"

#include "t_rmdebug.h"

IMPORT_C TInt StartDebugThread(RThread& aServerThread);

IMPORT_D extern TInt TestData;

IMPORT_D extern TBuf8<SYMBIAN_RMDBG_MEMORYSIZE> gMemoryAccessBytes;

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

CRunModeAgent::CRunModeAgent()

//

// CRunModeAgent constructor

//

	{

	}

CRunModeAgent* CRunModeAgent::NewL()

//

// CRunModeAgent::NewL

//

	{

	CRunModeAgent* self = new(ELeave) CRunModeAgent();

  	self->ConstructL();

   if (self->iState != ERunModeAgentRunning)

       {

       delete self;

       self = NULL;

       }       

	return self;

	}

CRunModeAgent::~CRunModeAgent()

//

// CRunModeAgent destructor

//

	{

	iServSession.Close();

	iDebugThread.Close();

   iState = ERunModeAgentUnInit;

	}

void CRunModeAgent::ConstructL()

//

// CRunModeAgent::ConstructL

//

	{

	TInt err;

	err = StartDebugThread(iDebugThread);

	if (err == KErrNone)

		{

		if (iServSession.Open() == KErrNone)

           {

           iState = ERunModeAgentRunning;

           }

       else

           {

           iState = ERunModeAgentUnInit;

           }

		}

	else

		{

		User::Panic(_L("Can't start debug thread"), err);

		}

}

CRunModeAgent *RunModeAgent;

// Test process names

_LIT(ProcessName1,"T_RMDEBUG");

_LIT(ProcessName1a,"t_rmdebug");

//_LIT(ProcessName2,"ekern");

//_LIT(ProcessName3,"efile");

_LIT(KWildCard,"*");

//---------------------------------------------

//! @SYMTestCaseID KBase-0185

//! @SYMTestType 

//! @SYMPREQ PREQ1426

//! @SYMTestCaseDesc Test reading process list

//! @SYMTestActions Several calls to read the process list

//! @SYMTestExpectedResults KErrNone and the owning process ID set

//! @SYMTestPriority High

//! @SYMTestStatus Implemented

//---------------------------------------------

void CRunModeAgent::TestProcessList()

	{

	TInt    err=KErrNone;

	TBool	found = FALSE;

	test.Next(_L("TestProcessList - Read Process List\n"));

	TFindProcess find(KWildCard);

	TFullName name;

	while(find.Next(name)==KErrNone)

		{

		RProcess process;

		err = process.Open(find);

		if (err == KErrNone)

			{

			if ((name.Find(ProcessName1) != KErrNotFound) ||

				(name.Find(ProcessName1a) != KErrNotFound))

				{				

					iProcessID = process.Id();

					found = TRUE;				

				}

			process.Close();				

			}

	   }   

	test(found== TRUE);   

	}

// Test thread name

_LIT(ThreadName1,"DebugThread");

//---------------------------------------------

//! @SYMTestCaseID KBase-0186

//! @SYMTestType 

//! @SYMPREQ PREQ1426

//! @SYMTestCaseDesc Test reading thread list

//! @SYMTestActions Several calls to read the thread list

//! @SYMTestExpectedResults KErrNone and the debug thread ID set

//! @SYMTestPriority High

//! @SYMTestStatus Implemented

//---------------------------------------------

void CRunModeAgent::TestThreadList()

	{

	TInt        err=KErrNone;

	TBool       found = FALSE;

	test.Next(_L("TestThreadList - Read Thread List\n"));

   	TFindThread find(KWildCard);

	TFullName name;

	while(find.Next(name)==KErrNone)

		{

		RThread thread;

		err = thread.Open(find);

       	if (err == KErrNone)

			{

			RProcess process;

			thread.Process(process);

			if (((TUint32)process.Id() == iProcessID) &&

				(name.Find(ThreadName1) != KErrNotFound))

				{

				found = TRUE;           

				iThreadID = thread.Id();

				}

			}

			thread.Close();

   		}   

	test(found==TRUE);   

	}

//---------------------------------------------

//! @SYMTestCaseID KBase-0187

//! @SYMTestType 

//! @SYMPREQ PREQ1426

//! @SYMTestCaseDesc Test reading and writing thread memory

//! @SYMTestActions Several call to read and write blocks of thread memory

//! @SYMTestExpectedResults KErrNone

//! @SYMTestPriority High

//! @SYMTestStatus Implemented

//---------------------------------------------

void CRunModeAgent::TestMemoryAccess()

{

	TInt err=KErrNone;

	TMemoryInfo MemoryInfo;

	TInt i;

	test.Next(_L("TestMemoryAccess - Read Memory\n"));     

	for (i = 0; i < SYMBIAN_RMDBG_MEMORYSIZE; i++)

		{

		gMemoryAccessBytes.Append(i);

		}

	MemoryInfo.iAddress = (TUint32)(&gMemoryAccessBytes[0]);

	MemoryInfo.iSize = SYMBIAN_RMDBG_MEMORYSIZE;

	HBufC8 *data = HBufC8::NewLC(SYMBIAN_RMDBG_MEMORYSIZE);

	TPtr8 ptr_memread(data->Des());   

	MemoryInfo.iDataPtr = &ptr_memread;

//	test.Printf(_L("Read address = 0x%x Read size = 0x%x\n"),MemoryInfo.iAddress,MemoryInfo.iSize);

	err = iServSession.ReadMemory(iThreadID, &MemoryInfo);

	for (i = 0; i < MemoryInfo.iSize; i++)

		{

		if (ptr_memread.Ptr()[i] != gMemoryAccessBytes[i])

			{

			err = KErrCorrupt;       		

			}

		}

	// Test out writing memory.   

	test.Next(_L("TestMemoryAccess - Write Memory\n"));

//	test.Printf(_L("Write address = 0x%x Write size = 0x%x\n"),MemoryInfo.iAddress,MemoryInfo.iSize);

	if (err== KErrNone)

		{

		// Now reset the buffer

		for (i = 0; i < SYMBIAN_RMDBG_MEMORYSIZE; i++)

			{

			gMemoryAccessBytes[i] = 0;

			}      

		// Write our data into the buffer

		err = iServSession.WriteMemory(iThreadID, &MemoryInfo);

		for (i = 0; i < MemoryInfo.iSize; i++)

			{

			if (ptr_memread.Ptr()[i] != gMemoryAccessBytes[i])

				{

				err = KErrCorrupt;       		

				}

			}

		}

	if (gMemoryAccessBytes[5] == 0)

		{

		err = KErrCorrupt;

		}

	CleanupStack::PopAndDestroy(data);       

	test(err==KErrNone);   

	}

//---------------------------------------------

//! @SYMTestCaseID KBase-0188

//! @SYMTestType 

//! @SYMPREQ PREQ1426

//! @SYMTestCaseDesc Test suspending and resuming a task

//! @SYMTestActions Suspends a thread checks the contents of a variable then waits and tests it hasnt changed

//! @SYMTestExpectedResults KErrNone

//! @SYMTestPriority High

//! @SYMTestStatus Implemented

//---------------------------------------------

void CRunModeAgent::TestSuspendResume()

	{

	TInt err;

	test.Next(_L("TestSuspendResume - Suspend\n"));

	// Suspend the thread

	err = iServSession.SuspendThread(iThreadID);

	test(err==KErrNone);

	TInt localtestdata;

	localtestdata = TestData;

	// Wait 3 seconds (suspends this thread) and hopefully resumes the

	// thread we are controlling via the iServSession.SuspendThread request

	User::After(3000000);

	// Now check data hasnt changed

	test(localtestdata==TestData);

	// Resume the thread

	test.Next(_L("TestSuspendResume - Resume\n"));

	err = iServSession.ResumeThread(iThreadID);

	test(err==KErrNone);

	// Wait 3 seconds (suspends this thread) and hopefully resumes the

	// thread we are controlling via the iServSession.SuspendThread request

	User::After(3000000);

	// Now check that the thread being controlled has resumed and is

	// updating the variable

	test(localtestdata!=TestData);

	}

void CRunModeAgent::ClientAppL()

//

// Performs each test in turn

//

	{

	test.Start(_L("ClientAppL"));

	TestProcessList();

	TestThreadList();

	TestMemoryAccess();

	TestSuspendResume();

	test.End();   

	}

GLDEF_C TInt E32Main()

//

// Entry point for run mode debug driver test

//

	{

   TInt ret = KErrNone;

	// client

	CTrapCleanup* trap = CTrapCleanup::New();

	if (!trap)

		return KErrNoMemory;

   RunModeAgent = CRunModeAgent::NewL();

   if (RunModeAgent != NULL)

       {

   	test.Title();

        __UHEAP_MARK;

	    TRAPD(r,RunModeAgent->ClientAppL());

       ret = r;

	    __UHEAP_MARKEND;

	    delete RunModeAgent;

       }

	delete trap;

	return ret;

	}