// Copyright (c) 2002-2010 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"
#include <es_ini.h>


CSender::CSender(CBcaIoController& aObserver, CBttLogger* aTheLogger, TInt aMaxPacketSise)
/**
 * Constructor. Performs standard active object initialisation.
 *
 * @param aObserver Reference to the observer of this state machine
 */
	: CActive(EPriorityUserInput), 
	  iObserver(aObserver),
	  iTheLogger(aTheLogger),
	  iMaxPacketSize(aMaxPacketSise)
	{
    // EPriorityUserInput is higher than the default priority but lower than
    // EPriorityHigh which is used on Receiving (DL having priority), however,
    // we want this to be handled in an expedited manner compared to other
    // active objects in the thread.
	CActiveScheduler::Add(this);
	}

CSender* CSender::NewL(CBcaIoController& aObserver, CBttLogger* aTheLogger, TInt aMaxPacketSise)
/**
 * Two-phase constructor. Creates a new CBcaIoController object, performs 
 * second-phase construction, then returns it.
 *
 * @param aObserver The observer, to which events will be reported
 * @param aTheLogger The logging object
 * @return A newly constructed CBcaIoController object
 */
	{
	CSender* self = new (ELeave) CSender(aObserver, aTheLogger, aMaxPacketSise);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

void CSender::ConstructL()
/**
 * Second-phase constructor. Creates all the state objects it owns.
 */
	{
	_LOG_L1C1(_L8("CSender::ConstructL"));
	iSendBuffer.CreateL(iMaxPacketSize);
	}

CSender::~CSender()
/**
 * Destructor.
 */
	{
	iSendBuffer.Close();
	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();

	(iObserver.Bca())->Write(iStatus, iSendBuffer);
	
	SetActive();
	}