/*

* Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of "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: 

*

*/

#include <e32base.h>

#include <e32cons.h>

#include "dbgtrccomm.h"

#include "dummytraceserver.h"

#include "dbgtrctest.h"

LOCAL_C CConsoleIO* consoleIO = NULL;

#define SafeDelete(x) { if (x) delete x; x = NULL; }

CKeyboardInput::CKeyboardInput(CConsoleBase* aConsole)

	: CActive(EPriorityUserInput),

	  iConsole(aConsole)

{

	CActiveScheduler::Add(this);

}

CKeyboardInput::~CKeyboardInput()

{

	Cancel();

	Deque();

}

void CKeyboardInput::ListenToKeyboard()

{

	iConsole->Read(iStatus);

	SetActive();

}

void CKeyboardInput::RunL()

{

	TKeyCode key = iConsole->KeyCode();

	if (key == 'q' || key == 'Q')

		CActiveScheduler::Stop();

	else

		ListenToKeyboard();

}

void CKeyboardInput::DoCancel()

{

	iConsole->ReadCancel();

}

CConsoleIO::CConsoleIO()

	: iConsole(0),

	  iKeyboardInput(0)

{

	TRAPD(error, iConsole = Console::NewL(_L("DBGTRCTEST"), TSize(KConsFullScreen, KConsFullScreen)));

	if (error != KErrNone)

		User::Panic(_L("DBGTRCTEST failed to allocate CConsoleBase"), __LINE__);

	iKeyboardInput = new CKeyboardInput(iConsole);

	if (iKeyboardInput == 0)

		User::Panic(_L("DBGTRCTEST failed to allocate CKeyboardInput"), __LINE__);

	iKeyboardInput->ListenToKeyboard();

}

CConsoleIO::~CConsoleIO()

{

	SafeDelete(iKeyboardInput);

	SafeDelete(iConsole);

}

//

// CConsoleIO::PrintToScreen

//

//	Print a message to the screen

//

void CConsoleIO::PrintToScreen(TRefByValue<const TDesC> aFmt, ...)

{

	VA_LIST(l);

	VA_START(l, aFmt);

	iBuffer.FormatList(aFmt, l);

	iConsole->Printf(iBuffer);

}

//

// CConsoleIO::Terminating

//

//	Notify user of termination

//

void CConsoleIO::Terminating()

{

	iConsole->Printf(_L("\r\nPress any key to exit."));

	iKeyboardInput->Cancel();

	iConsole->Getch();

}

LOCAL_C void runBasicTests()

{	

	RDbgTrcComm acmPort;

	TInt err = acmPort.Connect();

	if (err != KErrNone)

	{

		consoleIO->PrintToScreen(_L("Connect failed: %d"), err);

		return;

	}

	consoleIO->PrintToScreen(_L("Successfully the DbgTrc Comms server\n"));

	err = acmPort.Open();

	if (err != KErrNone)

	{

		consoleIO->PrintToScreen(_L("Opening port failed: %d\n"), err);

		return;

	}

	consoleIO->PrintToScreen(_L("Successfully opened the DbgTrc Comm Port\n"));

	TAcmConfig config;	

	err = acmPort.GetAcmConfig(config);

	if (err != KErrNone)

	{

		consoleIO->PrintToScreen(_L("Unable to get port configuration: %d\n"), err);

		return;

	}

	consoleIO->PrintToScreen(_L("Current ACM port number: %d\n"), config().iPortNumber);

	err = acmPort.RegisterProtocolID(EOstProtTrk, EFalse);

	if (err != KErrNone)

	{

		consoleIO->PrintToScreen(_L("Unable to register protocol: %d\n"), err);

		return;

	}

	consoleIO->PrintToScreen(_L("Registered the protocol id: %d\n"), EOstProtTraceCore);

	TAcmConfigV01 config1(*(TAcmConfigV01*)config.Ptr());

	TBuf8<100> msg;

	_LIT8(KTRACEMSG, "Test trace server message: %d\n");

	TRequestStatus status;

	for (TInt i=0; i<1000; i++)

	{

		msg.Format(KTRACEMSG, i);

		acmPort.WriteMessage(status, msg, ETrue);

		User::WaitForRequest(status);

		User::After(100);

	}

	if (status.Int() != KErrNone)

	{

		consoleIO->PrintToScreen(_L("Unable to write the message: %d\n"), status.Int());

		return;	

	}

	consoleIO->PrintToScreen(_L("Successfuly sent the message\n"));

	err = acmPort.UnRegisterProtocolID(EOstProtTraceCore);

	if (err != KErrNone)

	{

		consoleIO->PrintToScreen(_L("Unable to unregister protocol: %d\n"), err);

		return;

	}

	consoleIO->PrintToScreen(_L("Successfuly unregistered the protocol id: %d\n"), EOstProtTraceCore);

	err = acmPort.Close();

	if (err != KErrNone)

	{

		consoleIO->PrintToScreen(_L("Unable to close the port: %d\n"), err);

		return;

	}

	consoleIO->PrintToScreen(_L("Successfuly closed the port\n"));

}

void MainL()

{

	//RProcess().SetPriority(EPriorityHigh);

	//RThread().SetPriority(EPriorityAbsoluteHigh);

	consoleIO->PrintToScreen(_L("DBGTRCTEST App\r\n"));

	//runBasicTests();	

	CDummyTraceServer* traceServer = CDummyTraceServer::NewLC(consoleIO);

	traceServer->Start();

	consoleIO->PrintToScreen(_L("Press q or Q to quit\n"));

	CActiveScheduler::Start();

	CleanupStack::PopAndDestroy(traceServer);

}

//

// EXE entrypoint

//

TInt E32Main()

{	

	__UHEAP_MARK;

	CTrapCleanup* cleanupStack = CTrapCleanup::New();

	if (cleanupStack == 0)

		User::Panic(_L("DBGTRCTEST failed to allocate CTrapCleanup"), __LINE__);

	CActiveScheduler* scheduler = new CActiveScheduler;

	if (scheduler == 0)

		User::Panic(_L("DBGTRCTEST failed to allocate CActiveScheduler"), __LINE__);

	CActiveScheduler::Install(scheduler);

	consoleIO = new CConsoleIO;

	if (!consoleIO)

		User::Panic(_L("DBGTRCTEST failed to allocate CTrkConsoleIO"), __LINE__);

	TRAPD(error, MainL());

	if (error != KErrNone)

	{

		consoleIO->PrintToScreen(_L("\r\nUnexpected error %d"), error);

		consoleIO->Terminating();

	}

	SafeDelete(consoleIO);	

	SafeDelete(scheduler);

	SafeDelete(cleanupStack);

	__UHEAP_MARKEND;

	User::Exit(0);

	return 0;

}