/*
* Copyright (c) 2007 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:    Executes client specified callbacks.
*
*/




#include "cncmcallbackexecuter.h"
#include "ncmconnectionmultiplexerlogs.h"

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


// ---------------------------------------------------------------------------
// CNcmCallBackExecuter::CNcmCallBackExecuter
// ---------------------------------------------------------------------------
//
CNcmCallBackExecuter::CNcmCallBackExecuter() : CActive( EPriorityStandard )
    {
    CActiveScheduler::Add( this );
    }


// ---------------------------------------------------------------------------
// CNcmCallBackExecuter::NewL
// ---------------------------------------------------------------------------
//
CNcmCallBackExecuter* CNcmCallBackExecuter::NewL()
    {
    CNcmCallBackExecuter* self = CNcmCallBackExecuter::NewLC();
    CleanupStack::Pop( self );
    return self;
    }


// ---------------------------------------------------------------------------
// CNcmCallBackExecuter::NewLC
// ---------------------------------------------------------------------------
//
CNcmCallBackExecuter* CNcmCallBackExecuter::NewLC()
    {
    CNcmCallBackExecuter* self 
        = new( ELeave ) CNcmCallBackExecuter();
    CleanupStack::PushL( self );
    self->WaitForRequestsL();
    return self;
    }


// ---------------------------------------------------------------------------
// CNcmCallBackExecuter::~CNcmCallBackExecuter
// ---------------------------------------------------------------------------
//
CNcmCallBackExecuter::~CNcmCallBackExecuter()
    {
    Cancel();
    iCallBacks.Close();
    }


// ---------------------------------------------------------------------------
// CNcmCallBackExecuter::AddCallBackL
// ---------------------------------------------------------------------------
//
void CNcmCallBackExecuter::AddCallBackL( const TNcmCallBack& aCallBack )
    {
    __CONNECTIONMULTIPLEXER( "CNcmCallBackExecuter::AddCallBackL" )
    
    if ( iStatus == KRequestPending )
        {
        Wakeup();
        }
        
    iCallBacks.AppendL( aCallBack );
    }


// ---------------------------------------------------------------------------
// CNcmCallBackExecuter::ExecuteFirstCallback
// Handle one callback request and wait for the next one. If there are more
// callbacks, complete the asynchronous request so that RunL will soon be 
// called again.
// ---------------------------------------------------------------------------
//    
void CNcmCallBackExecuter::ExecuteFirstCallback()
    {
    TNcmCallBack* callback = &iCallBacks[0];
    callback->CallBack();

    iCallBacks.Remove( 0 );
      
    if ( iCallBacks.Count() )
        {
        Wakeup();
        }
    }


// ---------------------------------------------------------------------------
// CNcmCallBackExecuter::WaitForRequestsL
// ---------------------------------------------------------------------------
//
void CNcmCallBackExecuter::WaitForRequestsL()
    {
    __ASSERT_ALWAYS( !IsActive(), User::Leave( KErrNotReady ) );

    iStatus = KRequestPending;
    SetActive();
    }


// ---------------------------------------------------------------------------
// CNcmCallBackExecuter::Wakeup
// ---------------------------------------------------------------------------
//
void CNcmCallBackExecuter::Wakeup()
    {
    TRequestStatus* status = &iStatus;
    User::RequestComplete( status, KErrNone );
    }
    

// ---------------------------------------------------------------------------
// From class CActive.
// ---------------------------------------------------------------------------
//
void CNcmCallBackExecuter::RunL()
    {
    __CONNECTIONMULTIPLEXER( "CNcmCallBackExecuter::RunL" )
    __ASSERT_ALWAYS( iCallBacks.Count(), User::Leave( KErrNotFound ) );
    
    WaitForRequestsL();
    ExecuteFirstCallback();
    }


// ---------------------------------------------------------------------------
// From class CActive.
// ---------------------------------------------------------------------------
//
void CNcmCallBackExecuter::DoCancel()
    {
    __CONNECTIONMULTIPLEXER( "CNcmCallBackExecuter::DoCancel" )
    
    iCallBacks.Reset();
    
    if ( iStatus == KRequestPending )
        {
        TRequestStatus* status = &iStatus;    
        User::RequestComplete( status, KErrCancel );
        }
    }