// 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 Write() requests. 

// 

//

/**

 @file

*/

#include "Sender.h"

#include "Constants.h"

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

/**

 * Constructor. Performs standard active object initialisation.

 *

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

 */

	: CActive(EPriorityNormal), 

	  iObserver(aObserver),

	  iTheLogger(aTheLogger)

	{

	CActiveScheduler::Add(this);

	}

CSender::~CSender()

/**

 * Destructor.

 */

	{

	Cancel();

	}

void CSender::RunL()

/**

 * This method checks if any error occured in the write operation.  

 */

	{

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

	if (iStatus!=KErrNone)

		{

		if(iStatus == KErrNoMemory)

			{

			_LOG_L2C1(_L8("WARNING! CSender: Write failed with KErrNoMemory"));

			_LOG_L2C1(_L8("WARNING! CSender: Ignoring packet!!!!"));

			// Write operation failed!! Nif will ignore this packet.

			iObserver.SendComplete();

			}

		else if (iStatus == KErrNotReady)

			{

			_LOG_L2C1(_L8("WARNING! CSender: Write failed with KErrNotReady"));

			_LOG_L2C1(_L8("WARNING! CSender: Ignoring packet!!!!"));

			// Write operation failed!! Nif will ignore this packet.

			iObserver.SendComplete();

			}

		else

			{

			_LOG_L2C1(_L8("ERROR! CSender: Write failed!!!!"));

			// Nif will shut down

			iObserver.Stop(iStatus.Int());

			}

		return;

		}

	else

		{

		// The Ip packet was sent successfuly

		_LOG_L1C1(_L8("***** CSender: Packet Sent."));

		iObserver.SendComplete();

		}

	}

void CSender::DoCancel()

/**

 *	Cancel active request

 */

	{

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

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

	}

void CSender::Send(RMBufChain& aPdu)

/**

 * Copies the specified RMBufChain into a descriptor and sends it.

 *

 * @param aPdu The IP packet to be sent.

 * @return KStopSending, or KErrArgument if the packet is too large.

 */

	{

	_LOG_L1C1(_L8("CSender::Send"));

	// Copy the IP portion of the RMBufChain to the buffer.

	iSendBuffer.SetMax();

	aPdu.CopyOut(iSendBuffer, aPdu.First()->Length());

#ifdef RAWIP_HEADER_APPENDED_TO_PACKETS

	iObserver.AddHeader(iSendBuffer);

#endif // RAWIP_HEADER_APPENDED_TO_PACKETS

	aPdu.Free();

	SendBuffer(iSendBuffer);

	}

void CSender::SendBuffer(const TDesC8& aBuffer)

/**

 * Sends an IP packet, contained in the specified descriptor

 *

 * @param aBuffer The IP packet to send.

 * @return Always KStopSending.

 */

	{

	_LOG_L1C1(_L8("CSender::SendBuffer"));

	// Finally, send the packet to BCA

	(iObserver.Bca())->Write(iStatus, aBuffer);

	SetActive();

	}