/*

* Copyright (c) 2007 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 <e32def.h>

#include <e32cmn.h>

#include <arm.h>

#include <kernel.h>

#include <kern_priv.h>

#include <nk_trace.h>

#include "TrkXtiComm.h"

#include "TrkXtiDriver.h"

#include "TrkXtiSubscriber.h"

/**

 * Constructor

 */

DTrkXtiSubscriber::DTrkXtiSubscriber() : 

					iTraceMessageInitialized(FALSE),

					iHeaderBuf(NULL)

{

	LOG_MSG("DTrkXtiSubscriber::DTrkXtiSubscriber()");

}

DTrkXtiSubscriber::~DTrkXtiSubscriber() 

{

	LOG_MSG("DTrkXtiSubscriber::~DTrkXtiSubscriber()");

	// Unsubscribe here

	Unsubscribe(kIntTrkMessageId);

	if (iHeaderBuf)

	{

		delete iHeaderBuf;

		iHeaderBuf = NULL;

	}

}

TInt DTrkXtiSubscriber::Create(DTrkXtiChannel* aChannel, DThread* aClient)

{

	LOG_MSG("DTrkXtiSubscriber::Create()");

	iChannel = aChannel; //Don't add ref the channel, since channel closes the event handler before it ever gets destroyed.

	TInt err = aClient->Open();

	if (err != KErrNone)

	{

		LOG_MSG("DTrkXtiSubscriber::Create() - Thread Opened, error");

		return err;

	}

	iClientThread = aClient;

	// subscribe to receive trk messages from TraceCore

	err = Subscribe( kIntTrkMessageId ); //  To do: replace with SOS_MON_TRK_SEND_MESSAGE_REQ 

	if (err != KErrNone)

		return err;

	return KErrNone;	

}

void DTrkXtiSubscriber::MessageReceived(TTraceMessage& aMessage)

{ 

	LOG_MSG("DTrkXtiSubscriber::MessageReceived()");

	if (!iTraceMessageInitialized)

	{ 

		iTraceMessage.iHeader = NULL;

		iTraceMessageInitialized = TRUE; 

	}

	StoreMessage (aMessage);

	// iTraceMessage.iMessageId = 0x45;  

	LOG_MSG2("iTraceMessage.iHeader->Length() = %d", iTraceMessage.iHeader->Length());

  	LOG_MSG2("aMessage.iHeader->Length() = %d", aMessage.iHeader->Length());

  	LOG_MSG2("aMessage.iData->Length() = %d", aMessage.iData->Length());

	iChannel->DoCompleteRx(*aMessage.iData);

}

TInt DTrkXtiSubscriber::Send(TDesC8& aMessage)

{

	LOG_MSG("DTrkXtiSubscriber::Send()");

	if (!iTraceMessageInitialized)

	{

		LOG_MSG("Trace message header not initialized");

		return KErrNotReady;

	}

	iTraceMessage.iData = &aMessage;

	// Replace this with SOS_MON_TRK_SEND_MESSAGE_RESP when get the new tracecore header

	iTraceMessage.iMessageId = 0x45;

	TInt err = KErrNone;

	err = iMessageSender->SendMessage(iTraceMessage);

	LOG_MSG2("iMessageSender->SendMessage, error = %d", err);

	LOG_MSG2("iTraceMessage.iHeader->Length() = %d", iTraceMessage.iHeader->Length());

	LOG_MSG2("iTraceMessage.iData->Length() = %d", iTraceMessage.iData->Length());

	return err;

}

/**

 * Stores the header from the incoming message

 */

void DTrkXtiSubscriber::StoreMessage( const TTraceMessage& aMessage )

{

    LOG_MSG("DTrkXtiSubscriber::StoreMessage()");

    if (iHeaderBuf == NULL)

    {

        iHeaderBuf = HBuf8::New(aMessage.iHeader->Length( ));

    }

    iHeaderBuf->Copy( *aMessage.iHeader );

    iTraceMessage = aMessage; // Copy message

    iTraceMessage.iHeader = iHeaderBuf; // Assign copy of header

}