/*

* Copyright (c) 2006 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:    Implementation of MCC session creator active object

*

*/

#include <mmf/common/mmfcontrollerframework.h>

#include <e32math.h>

#include <es_sock.h>

#include "mccasynclinkcreator.h"

#include "mcculdlclient.h"

#include "masynclinkcreationobserver.h"

#ifdef _DEBUG

#include <e32svr.h>

#define TRACE_LINK_CREATOR

#endif

#ifdef VOIP_TRACE_ENABLED

#include <voip_trace.h>

#endif

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

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

// C++ Default constructor

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

//

CMccAsyncLinkCreator::CMccAsyncLinkCreator( 

    MAsyncLinkCreationObserver& aObserver, CMccUlDlClient* aSession ) : 

    CActive( EPriorityStandard ), iObserver( aObserver ),

    iClientData( TMccCreateLinkPckg() ), iSession( aSession )

    {

    CActiveScheduler::Add( this );

    }

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

// Static constructor, does not leave instance in cleanupstack

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

//

CMccAsyncLinkCreator* CMccAsyncLinkCreator::NewL( 

    MAsyncLinkCreationObserver& aObserver, 

    CMccUlDlClient* aSession )

    {

    CMccAsyncLinkCreator* self = 

        CMccAsyncLinkCreator::NewLC( aObserver, aSession );

    CleanupStack::Pop( self );

    return self;

    }

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

// Static constructor, leaves instance in cleanupstack

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

//

CMccAsyncLinkCreator* CMccAsyncLinkCreator::NewLC( 

    MAsyncLinkCreationObserver& aObserver, 

    CMccUlDlClient* aSession )

    {

    CMccAsyncLinkCreator* self =

        new ( ELeave ) CMccAsyncLinkCreator( aObserver, aSession );

    CleanupStack::PushL( self );

    return self;

    }

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

// Destructor

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

//

CMccAsyncLinkCreator::~CMccAsyncLinkCreator()

    {

    this->Cancel();

    }

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

// From class CActive

// Active object eventhandler

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

//

void CMccAsyncLinkCreator::RunL()

    {

    #ifdef TRACE_LINK_CREATOR

        RDebug::Print( _L("CMccAsyncLinkCreator::RunL status: %d"),

           iStatus.Int() );

    #endif

    if( KErrNone == iStatus.Int() )

        {

        if ( iLinkCreated == EFalse )

            {                                                           

            iSession->CreateRtpSessionL( iClientData().iLinkID,

                                         iClientData().iLocalAddress.Port(),

                                         iClientData().iIpTOS,

                                         iClientData().iMediaSignaling );

            iLinkCreated = ETrue;

            }

        TRAPD( error, iSession->GetLocalIpAddressesL( iClientData() ) );

        #ifdef TRACE_LINK_CREATOR

            RDebug::Print( _L("CMccAsyncLinkCreator::RunL complete request: %d"),

                error );

        #endif

        this->CompleteRequest( error );

        }

    else

        {

        #ifdef TRACE_LINK_CREATOR

            RDebug::Print( _L("CMccAsyncLinkCreator::RunL ERR: %d"), 

                iStatus.Int() );

        #endif

        // Connection process failed for some reason, so complete the client

        this->CompleteRequest( iStatus.Int() );

        }

    }

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

// From class CActive

// Active object request cancellation

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

//

void CMccAsyncLinkCreator::DoCancel()

    {

    if( iSession )

        {

        #ifdef TRACE_LINK_CREATOR

            RDebug::Print( _L("CMccAsyncLinkCreator::DoCancel iSession") );

        #endif

        TRAP_IGNORE( iSession->CloseLinkL( iClientData().iLinkID ) );

        // Null the session in order to avoid looping if this object

        // is deleted inside callback (docancel is re-entried)

        iSession = NULL; 

        iObserver.CreationProcessEnd( iClientData, NULL, KErrCancel );

        }

    }

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

// From class CActive

// RunL error handling

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

//

TInt CMccAsyncLinkCreator::RunError( TInt aError )

    {

    #ifdef TRACE_LINK_CREATOR

        RDebug::Print( _L("CMccAsyncLinkCreator::RunError ERR: %d"), aError );

    #endif

    // We have a leave when RunL is executing

    CompleteRequest( aError );

    if ( aError != KErrNoMemory )

        {

        aError = KErrNone;

        }

    return aError;

    }

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

// Completes the client request with given error code

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

//

void CMccAsyncLinkCreator::CompleteRequest( TInt aError )

    {

    #ifdef TRACE_LINK_CREATOR

        RDebug::Print( _L("CMccAsyncLinkCreator::CompleteRequest") );

    #endif

    // Notify controller that we are through with the link creation

    // process so it can delete this link creator. Resolved addresses

    // and ports are also passed to the controller. 

    iObserver.CreationProcessEnd( iClientData, this, aError );

    }

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

// CMccAsyncLinkCreator::StartLinkCreationL

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

//

void CMccAsyncLinkCreator::StartLinkCreationL( TMMFMessage& aMessage )

    {

    #ifdef TRACE_LINK_CREATOR

        RDebug::Print( _L("CMccAsyncLinkCreator::StartLinkCreationL") );

    #endif

    __ASSERT_ALWAYS( !IsActive(), User::Leave( KErrInUse ) );

    __ASSERT_ALWAYS( iSession, User::Leave( KErrNotReady ) );

    aMessage.ReadData1FromClientL( iClientData );

    iSession->CreateLinkL( iClientData().iLinkID, iClientData().iLinkType );

    iSession->InitializeLinkL( iStatus,

                               iClientData().iLinkID,

                               iClientData().iIapId );

    this->SetActive();

    aMessage.WriteDataToClientL( iClientData );

    }

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

// CMccAsyncLinkCreator::GetSessionId

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

//

TUint32 CMccAsyncLinkCreator::GetSessionId()

 	{

	return iSession->GetSessionId();

 	}

// ======== GLOBAL FUNCTIONS ========