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

// Name          : CSenderUdp.cpp

// Part of       : ConnectionMgr

// Version       : SIP/5.1

//

#include "CSenderUdp.h"

#include "CommonConsts.h"

#include "SipLogs.h"

#include "SipAssert.h"

#include "siperr.h"

#include "TSIPTransportParams.h"

#include "sipmessage.h"

#include "CSocketContainer.h"

#include "COwnerSettingsList.h"

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

// CSenderUdp::NewL

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

//

CSenderUdp* CSenderUdp::NewL( 

    MContext& aContext, 

    COwnerSettingsList& aSettingsList )

	{

	CSenderUdp* self = NewLC( aContext, aSettingsList );

	CleanupStack::Pop( self );

	return self;

	}

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

// CSenderUdp::NewLC

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

//

CSenderUdp* CSenderUdp::NewLC( 

    MContext& aContext, 

    COwnerSettingsList& aSettingsList )

	{

	CSenderUdp* self = new ( ELeave ) CSenderUdp( aContext, aSettingsList );

	CleanupStack::PushL( self );

	return self;

	}

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

// CSenderUdp::CSenderUdp

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

//

CSenderUdp::CSenderUdp( MContext& aContext, COwnerSettingsList& aSettingsList ) : 

    CSender( aContext, aSettingsList ),

    iPermissionToSend( ETrue )

	{

	}

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

// CSenderUdp::~CSenderUdp

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

//

CSenderUdp::~CSenderUdp()

	{

	Cancel();

	}

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

// CSenderUdp::SendL

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

//

TBool CSenderUdp::SendL( const TSIPTransportParams& aTransportParams,

                         CSIPMessage& aMessage,

					     const TInetAddr& aAddr,

					     TUint aOrigTransport,

					     TRequestStatus& aStat,

					     TBool /*aStore*/,

					     TBool aForceUDP )

	{

    COutgoingData* data = 

        COutgoingData::NewL( aTransportParams, aMessage, aAddr, 

	                         aOrigTransport, aStat, *iContext.SigCompHandler(),

						     aForceUDP );	

	if ( !IsActive() && iPermissionToSend )

		{

	    iList.AddFirst( *data );		

        TCleanupItem cleanupItem( CleanCurrentDataOnLeave, this );

        CleanupStack::PushL( cleanupItem );		

        EncodeAndSendL( EFalse );

        CleanupStack::Pop( 1 ); // cleanupItem

		}

	else

	    {

	    iList.AddLast( *data );

	    }

    return EFalse;

	}

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

// CSenderUdp::SendL

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

//

void CSenderUdp::SendL( COutgoingData* aData )

	{

	iList.AddLast( *aData );

	SendNextL();

	}

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

// CSenderUdp::SendNextL

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

//

void CSenderUdp::SendNextL()

	{

	if ( !IsActive() )

	    {

    	if ( iPermissionToSend && !iList.IsEmpty() )

    		{

    		EncodeAndSendL( ETrue );

    		}

        else

            {

            iContext.Sending( EFalse );

            }

	    }

	}

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

// CSenderUdp::SetSendPermission

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

//	

void CSenderUdp::SetSendPermission( TBool aPermissionToSend )

    {

    iPermissionToSend = aPermissionToSend;

    }

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

// CSenderUdp::EncodeAndSendL

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

//

void CSenderUdp::EncodeAndSendL( TBool aRemoveFromList )

	{

	COutgoingData* data = CurrentData();

	__SIP_ASSERT_LEAVE( data, KErrNotFound );

	TBool sendData = ETrue;

	TPtr8 pointer = data->EncodeL( EFalse );	

	TInt encodedLen = pointer.Length();

	if ( encodedLen > KMaxMessageLength && data->ForceUDP() )

		{

		// Message is too large to be sent with UDP

		User::Leave( KErrTooBig );

		}

	if ( (encodedLen < KMaxUdpMessageSize ||

		 !data->Message().IsRequest() ||

		 data->ForceUDP() ||

		 data->OrigTransport() == KProtocolInetUdp) &&

		 !data->Compressed() )

		{

		iOutgoingMessage.Set( pointer );

		}

	else if ( data->Compressed() && encodedLen < KMaxUdpMessageSize )

		{

		iOutgoingMessage.Set( pointer );

		}

	else

		{

		data->Sent();

		if ( aRemoveFromList )

			{

			iList.Remove( *data );

			}

		CleanupStack::PushL( data );

		iContext.ReRouteL( KProtocolInetTcp, data );

		CleanupStack::Pop( data );

		sendData = EFalse;

		}

	if ( sendData )

	    {

        CSocketContainer* socketContainer( 

            iContext.SocketContainer( IpAddrType( data->Address() ) ) );

        __ASSERT_ALWAYS( socketContainer, User::Leave( KErrNotFound ) );

    	__SIP_MESSAGE_LOG( "Connection Manager::SendToNetwork via UDP", 

    	                   iOutgoingMessage )

    	WriteToLog( iOutgoingMessage );

    	// Set socket options before sending, options will be cleared after

    	// send has completed.

    	iSettingsList.SetOpts( 

    	    data->TransportParams(), socketContainer->Socket() );

    	iContext.Sending( ETrue );

    	socketContainer->Socket().SendTo( 

            iOutgoingMessage,

            data->Address(),

            0,

            iStatus );

    	SetActive();

	    }

	}