/*

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

#include "TrkFramingLayer.h"

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

//

// Default comm values

//

//

// Static helper functions

//

//

//

// CTrkXtiCommPort implementation

//

//

//

// CTrkXtiCommPort constructor

//

CTrkXtiCommPort::CTrkXtiCommPort()

	: CTrkCommPort(CActive::EPriorityStandard),

	  iConnected(EFalse),

	  iListening(EFalse),

	  iLineNumber(0),

	  iLddLoaded(EFalse)

{

}

//

// CTrkXtiCommPort::ConstructL

//

void CTrkXtiCommPort::ConstructL(TTrkConnData aTrkConnData, TDes& aErrorMessage)

{

	iLDD = aTrkConnData.iLDD;

	// We don't really need this

	//iUnitNumber = aTrkConnData.iPortNumber;

	if (!iLDD.Size())

	{

		aErrorMessage.Format(_L("LDD not specified in init file\r\n"));		

		User::Leave(KErrCorrupt);

	}

}

//

// CTrkXtiCommPort destructor

//

CTrkXtiCommPort::~CTrkXtiCommPort()

{

	if (iLddLoaded)	

	{				

		//cancel the read request

		iXtiDriver.ReadCancel();		

		iXtiDriver.Close();

		TInt err = User::FreeLogicalDevice(iLDD);

		if (KErrNone != err)

			User::Panic(_L("FreeLogicalDevice failed"), err);

		iLddLoaded = EFalse;

	}

}

//

// CTrkXtiCommPort::NewL

//

CTrkXtiCommPort* CTrkXtiCommPort::NewL(TTrkConnData aTrkConnData, TDes& aErrorMessage)

{

	CTrkXtiCommPort* self = new(ELeave) CTrkXtiCommPort;

	CleanupStack::PushL(self);

	self->ConstructL(aTrkConnData, aErrorMessage);

	CleanupStack::Pop(self);

	return self;

}

//

// CTrkXtiCommPort::OpenPortL

//

// Open the serial type communications port

//

void CTrkXtiCommPort::OpenPortL()

{

	TInt error = KErrNone;

	// make sure the LDD is not already loaded

	User::FreeLogicalDevice(iLDD);

	error = User::LoadLogicalDevice(iLDD);

	if ((KErrAlreadyExists != error) && (KErrNone != error))

		ReportAndLeaveIfErrorL(error, _L("Failed to load xti logical device."));	

	error = iXtiDriver.Open();

	if (KErrNone != error)

		ReportAndLeaveIfErrorL(error, _L("Failed to open xti logical device."));

	iLddLoaded = ETrue;

	_LIT(KXTIMSG, "Connection: XTI\r\nLDD: TrkXtiDriver\r\n");

	iConnectionMessage = KXTIMSG;

}

//

// CTrkXtiCommPort::ClosePort

//

// Close the communications port

//

void CTrkXtiCommPort::ClosePort()

{

	Cancel();

	if (iLddLoaded)

	{

		//cancel the read request

		iXtiDriver.ReadCancel();		

		iXtiDriver.Close();

		TInt err = User::FreeLogicalDevice(iLDD);

		if (KErrNone != err)

			User::Panic(_L("FreeLogicalDevice failed"), err);

		iLddLoaded = EFalse;			

	}

}

//

// CTrkXtiCommPort::SendDataL

//

// Write data to the serial type port

//

void CTrkXtiCommPort::SendDataL(const TDesC8& aBuffer)

{

	TInt err = iXtiDriver.Write(aBuffer);

	ReportAndLeaveIfErrorL(err, KSendErrMsg);

}

//

// CTrkXtiCommPort::Listen

//

// Start listening for data coming into the serial type communications port

//

void CTrkXtiCommPort::Listen(CTrkFramingLayer *aFramingLayer)

{

	iFramingLayer = aFramingLayer;

	CActiveScheduler::Add(this);

	IssueReadRequest();

	iListening = ETrue;

}

//

// CTrkXtiCommPort::StopListening

//

// Stop listening for data coming into the serial type communications port

//

void CTrkXtiCommPort::StopListening()

{

	if (iListening)

	{

		Cancel();

		Deque();

	}

	iListening = EFalse;

}

//

// CTrkXtiCommPort::ReportAndLeaveIfErrorL

//

// If an error occurred, print the error information to the screen and bail out

//

void CTrkXtiCommPort::ReportAndLeaveIfErrorL(TInt aError, const TDesC& aDesc)

{

	if (KErrNone != aError)

	{

		iErrorMessage.Format(_L("%S\r\nError Code: %d\r\n"), &aDesc, aError);

		User::Leave(aError);

	}

}

//

// CTrkXtiCommPort::IssueReadRequest

//

// Wait for data to come into the communications port

//

void CTrkXtiCommPort::IssueReadRequest()

{

	iNextReadChar = 0;

	iXtiDriver.ReadOneOrMore(iStatus, iReceivedChars);

	SetActive();

}

//

// CTrkXtiCommPort::DoCancel

//

// Cancel the request for data from the communications port

//

void CTrkXtiCommPort::DoCancel()

{

	iXtiDriver.ReadCancel();

}

//

// CTrkXtiCommPort::RunL

//

// Called when data comes into the communications port

//

void CTrkXtiCommPort::RunL()

{

	// pass the data onto the framing layer

	if (iStatus.Int() == KErrNone)

	{

		while (iNextReadChar < iReceivedChars.Length())

			iFramingLayer->HandleByte(iReceivedChars[iNextReadChar++]);

		//iXtiDriver.Write(iReceivedChars);

	}

	// continue waiting for data

	IssueReadRequest();

}