/*
* 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 "TrkDccCommPort.h"
#include "TrkFramingLayer.h"

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

//
// Default comm values
//


//
// Static helper functions
//

//
//
// CTrkDccCommPort implementation
//
//

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

//
// CTrkDccCommPort::ConstructL
//
void CTrkDccCommPort::ConstructL(TTrkConnData& aTrkConnData, TDes& aErrorMessage)
{

	iLDD = aTrkConnData.iLDD;
	iUnitNumber = aTrkConnData.iPortNumber;

	if (!iLDD.Size())
	{
		aErrorMessage.Format(_L("LDD not specified in init file\r\n"));		
		User::Leave(KErrCorrupt);
	}

	
}

//
// CTrkDccCommPort destructor
//
CTrkDccCommPort::~CTrkDccCommPort()
{
	if (iLddLoaded)	
	{
		//cancel the read request
		iDccDriver.ReadCancel();
		iDccDriver.Close();
		
		TInt err = User::FreeLogicalDevice(iLDD);
		if (KErrNone != err)
			User::Panic(_L("FreeLogicalDevice failed"), err);
			
		iLddLoaded = EFalse;
	}

}

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

//
// CTrkDccCommPort::OpenPortL
//
// Open the serial type communications port
//
void CTrkDccCommPort::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 dcc logical device."));

	error = iDccDriver.Open();
	if (KErrNone != error)
		ReportAndLeaveIfErrorL(error, _L("Failed to open dcc logical device."));
	
	iLddLoaded = ETrue;
	
	
	_LIT(KDCCMSG, "LDD: TrkDccDriver\r\nPort number: 42\r\n");
	
	iConnectionMessage = KDCCMSG;
}

//
// CTrkDccCommPort::ClosePort
//
// Close the communications port
//
void CTrkDccCommPort::ClosePort()
{
	Cancel();
	
	if (iLddLoaded)
	{
		//cancel the read request
		iDccDriver.ReadCancel();		
		iDccDriver.Close();
		
		TInt err = User::FreeLogicalDevice(iLDD);
		if (KErrNone != err)
			User::Panic(_L("FreeLogicalDevice failed"), err);

		iLddLoaded = EFalse;			
	}

}

//
// CTrkDccCommPort::SendDataL
//
// Write data to the serial type port
//
void CTrkDccCommPort::SendDataL(const TDesC8& aBuffer)
{
	TInt err = iDccDriver.Write(aBuffer);
	
	ReportAndLeaveIfErrorL(err, KSendErrMsg);
}

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

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

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


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

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

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