/*
* Copyright (c) 2006 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 <e32cons.h>
#include <f32file.h>

#include "TrkConnData.h"
#include "TrkDbgTrcCommPort.h"
#include "TrkFramingLayer.h"

_LIT(KSendErrMsg, "Failed to write to the DbgTrc channel");

//
// Default comm values
//


//
// Static helper functions
//

//
//
// CTrkDbgTrcCommPort implementation
//
//

//
// CTrkDbgTrcCommPort constructor
//
CTrkDbgTrcCommPort::CTrkDbgTrcCommPort()
	: CTrkCommPort(CActive::EPriorityStandard),
	  iConnected(EFalse),
	  iListening(EFalse),
	  iLineNumber(0)
{
}

//
// CTrkDbgTrcCommPort::ConstructL
//
void CTrkDbgTrcCommPort::ConstructL(TTrkConnData aTrkConnData, TDes& aErrorMessage)
{
	iUnitNumber = aTrkConnData.iPortNumber;
}

//
// CTrkDbgTrcCommPort destructor
//
CTrkDbgTrcCommPort::~CTrkDbgTrcCommPort()
{
	
}

//
// CTrkDbgTrcCommPort::NewL
//
CTrkDbgTrcCommPort* CTrkDbgTrcCommPort::NewL(TTrkConnData aTrkConnData, TDes& aErrorMessage)
{
	CTrkDbgTrcCommPort* self = new(ELeave) CTrkDbgTrcCommPort;
	CleanupStack::PushL(self);
	self->ConstructL(aTrkConnData, aErrorMessage);
	CleanupStack::Pop(self);
	return self;
}

//
// CTrkDbgTrcCommPort::OpenPortL
//
// Open the serial type communications port
//
void CTrkDbgTrcCommPort::OpenPortL()
{
	TInt error = KErrNone;

	error = iDbgTrcPort.Connect();
	if ((KErrAlreadyExists != error) && (KErrNone != error))
		ReportAndLeaveIfErrorL(error, _L("Failed to connect to the debug trace comms server."));

	TAcmConfig config;	
	error = iDbgTrcPort.GetAcmConfig(config);

	if (KErrNone != error)
		ReportAndLeaveIfErrorL(error, _L("Failed to get the port configuration."));
		
	TAcmConfigV01 config1(*(TAcmConfigV01*)config.Ptr());
	config1.iPortNumber = iUnitNumber;
	
	error = iDbgTrcPort.SetAcmConfig(config);
	if (KErrNone != error && KErrInUse != error)
		ReportAndLeaveIfErrorL(error, _L("Failed to set the port configuration."));

	error = iDbgTrcPort.Open();
	
	if (KErrNone != error)
		ReportAndLeaveIfErrorL(error, _L("Failed to open debug trace port."));
	
	iConnected = ETrue;
	
	// register the protocol id here
	error = iDbgTrcPort.RegisterProtocolID(EOstProtTrk, EFalse);
	if (KErrNone != error)
		ReportAndLeaveIfErrorL(error, _L("Failed to register the protocol id."));

		
	iConnectionMessage.Format(_L("Connection: USB \r\nPort: %d\r\n"), iUnitNumber);
}

//
// CTrkDbgTrcCommPort::ClosePort
//
// Close the communications port
//
void CTrkDbgTrcCommPort::ClosePort()
{
	Cancel();	
	
	if (iConnected)
	{
		iDbgTrcPort.UnRegisterProtocolID(EOstProtTrk);		
		//iDbgTrcPort.Disconnect();
		iDbgTrcPort.Close();
		iConnected = EFalse;			
	}	
}

//
// CTrkDbgTrcCommPort::SendDataL
//
// Write data to the serial type port
//
void CTrkDbgTrcCommPort::SendDataL(const TDesC8& aBuffer)
{
	TRequestStatus status;
	iDbgTrcPort.WriteMessage(status, aBuffer, EFalse);
	User::WaitForRequest(status);
	
	TInt err = status.Int();	
	ReportAndLeaveIfErrorL(err, KSendErrMsg);
}

//
// CTrkDbgTrcCommPort::Listen
//
// Start listening for data coming into the serial type communications port
//
void CTrkDbgTrcCommPort::Listen(CTrkFramingLayer *aFramingLayer)
{	
	iFramingLayer = aFramingLayer;
	CActiveScheduler::Add(this);
	IssueReadRequest();
	iListening = ETrue;
}

//
// CTrkDbgTrcCommPort::StopListening
//
// Stop listening for data coming into the serial type communications port
//
void CTrkDbgTrcCommPort::StopListening()
{
	if (iListening)
	{
		Cancel();
		Deque();
	}
	
	iListening = EFalse;
}

//
// CTrkDbgTrcCommPort::ReportAndLeaveIfErrorL
//
// If an error occurred, print the error information to the screen and bail out
//
void CTrkDbgTrcCommPort::ReportAndLeaveIfErrorL(TInt aError, const TDesC& aDesc)
{
	if (KErrNone != aError)
	{
		iErrorMessage.Format(_L("%S\r\nError Code: %d\r\n"), &aDesc, aError);
		User::Leave(aError);
	}
}


//
// CTrkDbgTrcCommPort::IssueReadRequest
//
// Wait for data to come into the communications port
//
void CTrkDbgTrcCommPort::IssueReadRequest()
{
	iNextReadChar = 0;
	iDbgTrcPort.ReadMessage(iStatus, iReceivedChars);
	SetActive();
}

//
// CTrkDbgTrcCommPort::DoCancel
//
// Cancel the request for data from the communications port
//
void CTrkDbgTrcCommPort::DoCancel()
{
	iDbgTrcPort.ReadCancel();
}

//
// CTrkDbgTrcCommPort::RunL
//
// Called when data comes into the communications port
//
void CTrkDbgTrcCommPort::RunL()
{
	// pass the data onto the framing layer
	if (iStatus.Int() == KErrNone)
	{
		while (iNextReadChar < iReceivedChars.Length())
			iFramingLayer->HandleByte(iReceivedChars[iNextReadChar++]);
	}
	// continue waiting for data
	IssueReadRequest();
}