/*

* Copyright (c) 2006-2008 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:    Send data to User of NAT Connectivity Framework.

*

*/

#include "natfwsocketsender.h"

#include "natfwsocketmediaconnwrapperlogs.h"

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

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

// CNATFWSocketSender::CNATFWSocketSender( )

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

//

CNATFWSocketSender::CNATFWSocketSender( MNATFWSocketSenderObserver& aObserver,

    TUint aProtocol ) : CActive(EPriorityUserInput), iProtocol( aProtocol ),

    iObserver( aObserver ), iSendQueue( CNsmcwSendItem::iOffset ),

    iQueueIter( iSendQueue )

    {

    __SOCKETMEDIACONNWRAPPER( "CNATFWSocketSender::CNATFWSocketSender" )

    CActiveScheduler::Add(this);

    }

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

// CNATFWSocketSender::NewL(  )

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

//

CNATFWSocketSender* CNATFWSocketSender::NewL( 

    MNATFWSocketSenderObserver& aObserver, TUint aProtocol )

    {

    __SOCKETMEDIACONNWRAPPER( "CNATFWSocketSender::NewL" )

    CNATFWSocketSender* self = 

            new (ELeave) CNATFWSocketSender ( aObserver, aProtocol );

    return self;

    }

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

// CNATFWSocketSender::~CNATFWSocketSender()

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

//

CNATFWSocketSender::~CNATFWSocketSender()

    {

    __SOCKETMEDIACONNWRAPPER( "CNATFWSocketSender::~CNATFWSocketSender")

    Cancel();

    iQueueIter.SetToFirst();

    CNsmcwSendItem* item = iQueueIter++;

    while ( item )

        {

        iSendQueue.Remove( *item );

        delete item;

        item = iQueueIter++;

        }

    }

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

// CNATFWSocketSender::SetRemoteAddress( )

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

//

void CNATFWSocketSender::SetRemoteAddress( const TSockAddr& aRemoteAddress,

                                           const RSocket& aSocket )

    {

    iRemoteAddress = aRemoteAddress;

    iSocket = aSocket;

    }

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

// CNATFWSocketSender::SendL(  )

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

//

void CNATFWSocketSender::SendL( const TDesC8& aStreamPortion )

    {    

    CNsmcwSendItem* item = NULL;    

    TRAPD( err, item = CNsmcwSendItem::NewL( aStreamPortion ) );

    if ( KErrNone == err && item )

        {

        iSendQueue.AddLast( *item );

        }

    else

        {

        User::Leave( err );

        }

    if ( !IsActive() )

        {

        SendNextPacket();

        }

    }

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

// CNATFWSocketSender::SendNextPacket()

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

//

void CNATFWSocketSender::SendNextPacket()

    {

    __SOCKETMEDIACONNWRAPPER( "CNATFWSocketSender::SendNextPacket" )

    iQueueIter.SetToFirst();

    CNsmcwSendItem* item = iQueueIter++;

    if ( item )

        {

        if( KProtocolInetUdp == iProtocol )

            {

            iSocket.SendTo( item->GetData(), iRemoteAddress, 0, iStatus );

            }

        if( KProtocolInetTcp == iProtocol )

            {

            iSocket.Send( item->GetData(), 0, iStatus );

            } 

        SetActive();

        }

    __SOCKETMEDIACONNWRAPPER( "CNATFWSocketSender::SendNextPacket - End" )    

    }

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

// CNATFWSocketSender::RemoveFromQueue()

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

//

void CNATFWSocketSender::RemoveFromQueue()

    {    

    if ( !( iSendQueue.IsEmpty( ) ) )

        {

        CNsmcwSendItem* item = iSendQueue.First();

        iSendQueue.Remove( *item );

        delete item;

        }

    }

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

// CNATFWSocketSender::RunL( )

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

//

void CNATFWSocketSender::RunL( )

    {

    __SOCKETMEDIACONNWRAPPER_INT1( 

        "CNATFWSocketSender::RunL iStatus:", iStatus.Int() )  

    iObserver.SendingCompleted( iStatus.Int() );

    if ( KErrNone == iStatus.Int() )

        {

        RemoveFromQueue();

        SendNextPacket();

        }

    else 

        {

        __SOCKETMEDIACONNWRAPPER( "CNATFWSocketSender::RunL - Sending failed" )

        iQueueIter.SetToFirst();

        CNsmcwSendItem* item = iQueueIter++;

        while ( item )

            {

            iSendQueue.Remove( *item );

            delete item;

            item = iQueueIter++;

            }

        }

    }

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

// CNATFWSocketSender::DoCancel( )

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

//

void CNATFWSocketSender::DoCancel( )

    {

    __SOCKETMEDIACONNWRAPPER( "CNATFWSocketSender::DoCancel start" )

    iSocket.CancelAll();

    }