/*

* 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 "dummytraceserver.h"

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

//

//

// CDummyTraceServer implementation

//

//

CDummyTraceServer*	CDummyTraceServer::NewLC(CConsoleIO* aConsoleIO)

{

	CDummyTraceServer* self = new(ELeave) CDummyTraceServer(aConsoleIO);

	CleanupStack::PushL(self);

	self->ConstructL();

	return self;

}

CDummyTraceServer::CDummyTraceServer(CConsoleIO* aConsoleIO)

	: CActive(EPriorityLow),

	  iConsoleIO(aConsoleIO),

	  iMessageId(0)

{

	CActiveScheduler::Add(this);

}

void CDummyTraceServer::ConstructL()

{

	User::LeaveIfError(iTimer.CreateLocal());

}

CDummyTraceServer::~CDummyTraceServer()

{

}

void CDummyTraceServer::Start()

{

	TInt err = iAcmPort.Connect();

	if (err != KErrNone)

	{

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

		return;

	}

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

	err = iAcmPort.Open();

	if (err != KErrNone)

	{

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

		return;

	}

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

	TAcmConfig config;	

	err = iAcmPort.GetAcmConfig(config);

	if (err != KErrNone)

	{

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

		return;

	}

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

	err = iAcmPort.RegisterProtocolID(EOstProtTraceCore, EFalse);

	if (err != KErrNone)

	{

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

		return;

	}

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

	Activate();

	iConsoleIO->PrintToScreen(_L("Started sending dummy traces\n"));

}

void CDummyTraceServer::SendMessage()

{

	TBuf8<100> msg;

	TRequestStatus status;

	msg.Format(KTRACEMSG, iMessageId++);

	iAcmPort.WriteMessage(status, msg, EFalse);

	User::WaitForRequest(status);

}

void CDummyTraceServer::Activate()

{

	iTimer.After(iStatus, KPeriod);

	SetActive();		

}

void CDummyTraceServer::RunL()

{

	// now send the message

	SendMessage();

	// reactivate the timer

	Activate();

}

void CDummyTraceServer::DoCancel()

{

	iTimer.Cancel();

    Cancel();

    iTimer.Close();

    Deque();

    TInt err = iAcmPort.UnRegisterProtocolID(EOstProtTraceCore);

    if (err != KErrNone)

    {

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

        return;

    }

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

    err = iAcmPort.Close();

    if (err != KErrNone)

    {

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

        return;

    }

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

}