// Copyright (c) 2006-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:

//

/**

 @file

 @internalComponent

*/

#include "hctlbcspreceiver.h"

#include "hctlbcsp.h"

#include "hctlbcspconsts.h"

#include "debug.h"

/**

Implementation of Class CHCTLBcspReceiver

*/

CHCTLBcspReceiver::CHCTLBcspReceiver(CHCTLBcsp& aHCTLBcsp, RBusDevComm& aPort) :

	CActive(EPriorityStandard), 

	iHctlBcsp(aHCTLBcsp),

	iReceiveBufPtr(NULL,0),

	iPort(aPort)

    {

	LOG_FUNC

	CActiveScheduler::Add(this);

    }

CHCTLBcspReceiver::~CHCTLBcspReceiver()

    {

	LOG_FUNC

	Cancel();

    iReceiveBuffer.Close();

    }

CHCTLBcspReceiver* CHCTLBcspReceiver::NewL(CHCTLBcsp& aHCTLBcsp, RBusDevComm& aPort) 

    {

	LOG_STATIC_FUNC

    CHCTLBcspReceiver* self=new(ELeave)CHCTLBcspReceiver(aHCTLBcsp, aPort);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

    }

void CHCTLBcspReceiver::ProcessData()	

/**

	This method parses the byte stream for a pair of 0xC0 bytes denoting beginning and end of packets

	Then calls the HandleRx

	Then zeros the pointer to the receive buffer and queues another read for the next frame

*/

    {

	LOG_FUNC

#ifdef __DEBUG_FLOG_RAW_UART_	

	LOG(_L8("HCTLBCSP: UART RX..."));

	TPtrC8 ptr = iReceiveBufPtr.Ptr();

	TInt len = iReceiveBufPtr.Length();

	LOGHEXDESC(iReceiveBufPtr);

#endif

	if(iReceiveBufPtr.Length() > 1) // Processing the remainder of the SLIP encoded Frame

		{

		if(iHctlBcsp.HandleRx(iReceiveBufPtr) != KErrNone)	// SLIP Decode Frame

			{

			LOG(_L8("HCTLBCSP: SLIP Decoding failed discard packet requeue read..."))

			}

		}

	// Reset Buffers

	iReceiveBufPtr.Zero();

	QueueReadForNextFrame(); // Get more stuff until next slip byte

	}

void CHCTLBcspReceiver::QueueReadForNextFrame()

/**

	Method moved due to HCI refactoring to reduce code duplication

	This method should suffice for all RBusDevComm reads

	@param aBytesRequired

*/

	{

	LOG_FUNC

	if (IsActive())

        {

		LOG(_L8("Receiver already active - TRYING TO CANCEL AND REQUEUE"));

 		Cancel(); // consume signal then do re-queue

        }

    SetActive();

	iPort.Read(iStatus, iReceiveBufPtr);

	}

void CHCTLBcspReceiver::RunL()

/**

	If no error occurred, call ProcessData(). Otherwise, throw any data away 

	and requeue the Read. 	

*/

	{

	LOG_LINE

	LOG_FUNC

	LOG1(_L8("\tiStatus = %d"), iStatus.Int());

	switch(iStatus.Int())

		{

		case KErrNone:

			// Receiver has a framer state machine

			ProcessData();

			break;

		case KErrAbort:

		case KErrBadPower:

			iReceiveBufPtr.Zero();

			// Pretend nothing happened and requeue the read.

			// Indeed the driver gives us this notification, not on power-down

			// but on the next power-up, so we can requeue.

			QueueReadForNextFrame();

			break;

#ifdef __DEBUG_INIT_PROGRESS

		case KErrCommsOverrun:

		case KErrCommsFrame:

		case KErrCommsParity:

			break;

		default:

			PANIC(KHCTLBcspPanicCat, EHCIHCTLReceiverFramerBadState);

			break;

#else

		default:

			// Ignore error condition.

			iReceiveBufPtr.Zero();

			QueueReadForNextFrame();

			break;

#endif

		};

	}

void CHCTLBcspReceiver::ConstructL()

    {

	LOG_FUNC

	//Create a HBufC based RBuf Object. 

    HBufC8* buf = HBufC8::NewMaxL(KHCTLRecvBufSize);

    iReceiveBuffer.Assign(buf);

    iReceiveBufPtr.Set(buf->Des());

    }

void CHCTLBcspReceiver::DoCancel()

	{

	LOG_FUNC

	iPort.ReadCancel();

	}

TInt CHCTLBcspReceiver::RunError(TInt aError)

	{

	LOG_LINE

	LOG_FUNC

	LOG1(_L8("\taError = %d"), aError);

	static_cast<void>(aError); // prevent unused variable warning

	return KErrNone;

	}