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

// Implements the active object that controls the Read() requests.

// 

//

/**

 @file

*/

#include "Receiver.h"

#include "Constants.h"

CReceiver::CReceiver(CBcaIoController& aObserver, CBttLogger* aTheLogger)

/**

 * Constructor. Performs standard active object initialisation.

 *

 * @param aObserver Reference to the observer of this state machine

 * @param aTheLogger The logging object

 */

	: CActive(EPriorityNormal), 

	  iObserver(aObserver), 

	  iTheLogger(aTheLogger)

	{

	CActiveScheduler::Add(this);

	}

CReceiver::~CReceiver()

/**

 * Destructor.

 */

	{

	Cancel();

	}

void CReceiver::RunL()

/**

 *  Method called when read request completes. This will only be once the BCA has a full IP 

 *  packet in its buffer.

 */

	{

	_LOG_L1C2(_L8("CReceiver::RunL [iStatus=%d]"), iStatus.Int());

	if (iStatus!=KErrNone)

		{

		if(iStatus == KErrNoMemory)

			{

			_LOG_L2C1(

				_L8("WARNING! CReceiver: Read failed with KErrNoMemory"));

			// Read operation failed!! Nif will re-issue the read request.

			StartListening();

			}

		else 

			{

			_LOG_L2C1(_L8("WARNING! CReceiver: Read failed"));

			iObserver.Stop(iStatus.Int());

			}

		return;

		}

	_LOG_L1C1(_L8("CReceiver: Data Packet Received"));

	// Process Ip packet

	iObserver.Process(iData);

	// The packet received was processed. NIF can start listening

	// for another one.

	StartListening();

	}

void CReceiver::DoCancel()

/**

 *	Cancel active request

 */

	{

	_LOG_L1C1(_L8("CReceiver::DoCancel"));

	(iObserver.Bca())->CancelRead(); 

	}

void CReceiver::StartListening()

/**

 *  This method issues a Read request. This is the API used to receive 

 *  packets from BCA.  

 */

	{

	_LOG_L1C1(_L8("CReceiver::StartListening"));

	// The BCA will complete this read once it has a full IP packet in its buffer.

	(iObserver.Bca())->Read(iStatus, iData);

	SetActive();

	}