/*

* 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 sender class for target

*

*/

/*

* %version: 15 %

*/

#include "am_debug.h"

#include "sender_hw.h"

#include "WlanProto.h"

#include "carddrv.h"

// Protocol blocks sending if it receives a return <= 0

// This value should be propogated up through the stack

const TInt KStopSending		= 0;

const TInt KContinueSending	= 1;

// ============================ MEMBER FUNCTIONS ===============================

// ---------------------------------------------------------

// CSender::Send()

// ---------------------------------------------------------

//

TInt CSender::Send( RMBufChain& aPacket )

    {

	TInt ret( KContinueSending );

    TDataBuffer* txDataBuffer = iParent->iCard.AllocTxBuffer( 

        aPacket.Length()

        // size of the packet's UP value

        - 1  );

    if ( txDataBuffer )

        {

        //First buffer contains UP value

        RMBuf* rmbuf = aPacket.First();

        TInt num = aPacket.NumBufs();

        TUint8 UPValue = rmbuf->Get();

        txDataBuffer->SetUserPriority( UPValue );

        //Frame starts from second buffer

        rmbuf = rmbuf->Next();

        num--;

        for( TInt i(0); i < num; i++ )

            {

            txDataBuffer->AppendBuffer( rmbuf->Ptr(), rmbuf->Length() );

            rmbuf = rmbuf->Next();

            }

        if ( !iParent->iCard.AddTxFrame( txDataBuffer ) )

            {

            DEBUG("CSender::Send: AddTxPacket returned false => stop flow");

            ret = KStopSending;

            iStopSending = ETrue;

            RequestResumeTx();

            }

        }

    else

        {

        DEBUG("CSender::Send: Tx buf could't be allocated => stop flow");

        // in this case the Tx packet could possibly be kept - if seen

        // feasible - until ResumeTx completes and then re-submitted 

        ret = KStopSending;

        iStopSending = ETrue;

        RequestResumeTx();

        }

    aPacket.Free();

	return ret;

    }

// ---------------------------------------------------------

// CSender::RequestResumeTx()

// ---------------------------------------------------------

//

void CSender::RequestResumeTx()

    {

    if ( !iReqPending )

        {

        DEBUG("CSender::RequestResumeTx()");

        iReqPending = ETrue;

    	SetActive();	

        iParent->iCard.ResumeTx( iStatus );

        }

    }

// ---------------------------------------------------------

// CSender::RunL()

// ---------------------------------------------------------

//

void CSender::RunL()

    {

    // Write completion from the LDD

	DEBUG("CSender::RunL()");

	iReqPending = EFalse;

	if (iStopSending)

	    {

		DEBUG("CSender::RunL(): resume flow");

		iStopSending = EFalse;

		iParent->iParent->ResumeSending();

		}

	else

	    {

	    DEBUG("CSender::RunL(): flow hasn't been stopped");

	    }

    }