/*
* Copyright (c) 2002-2004 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:    Waits for sink buffer flushing in datapaths
*
*/




// INCLUDE FILES
#include <mmf/common/mmfcontroller.h>
#include "mcccompletecallback.h"
#include "mcculdatapath.h"
#include "mccdldatapath.h"

// EXTERNAL DATA STRUCTURES

// EXTERNAL FUNCTION PROTOTYPES  

// CONSTANTS

// MACROS

// LOCAL CONSTANTS AND MACROS

// MODULE DATA STRUCTURES

// LOCAL FUNCTION PROTOTYPES

// FORWARD DECLARATIONS

// ============================= LOCAL FUNCTIONS ===============================

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

// -----------------------------------------------------------------------------
// CCompleteCallback::CCompleteCallback
// Constructor
// -----------------------------------------------------------------------------
CCompleteCallback::CCompleteCallback( MAsyncEventHandler& aEventhandler, 
        TBool aWaitForSink ) : CActive( EPriorityNormal ), 
        iEventhandler( aEventhandler ),
        iWaitForSink( aWaitForSink )
    {
    CActiveScheduler::Add( this );
    }

// -----------------------------------------------------------------------------
// CCompleteCallback::~CCompleteCallback
// Destructor
// -----------------------------------------------------------------------------
CCompleteCallback::~CCompleteCallback()
    {
    Cancel();
    }

// -----------------------------------------------------------------------------
// CCompleteCallback::SignalDataPathComplete
// Signals that datapath is completed
// -----------------------------------------------------------------------------
void CCompleteCallback::SignalDataPathComplete( TInt aDataPathError )
    {
    iDataPathComplete = ETrue;
    iDataPathError = aDataPathError;
    if ( !IsActive() )
        {
        // Signal ourselves to run with the given completion code
        TRequestStatus* status = &ActiveStatus();
        User::RequestComplete( status, KErrNone );
        }
    }

// -----------------------------------------------------------------------------
// CCompleteCallback::ActiveStatus
// Sets the object active and returns it's status
// -----------------------------------------------------------------------------
TRequestStatus& CCompleteCallback::ActiveStatus()
    {
    SetActive();
    return iStatus;
    }

// -----------------------------------------------------------------------------
// CCompleteCallback::DoCancel
// Cancel worker functions
// -----------------------------------------------------------------------------
void CCompleteCallback::DoCancel()
    {
    }

// -----------------------------------------------------------------------------
// CCompleteCallback::RunL
// Active object event handling
// -----------------------------------------------------------------------------
void CCompleteCallback::RunL()
    {
    if ( iWaitForSink )
        {
        if ( iDataPathComplete && iSinkComplete )
            {
            iDataPathComplete = EFalse;
            iSinkComplete = EFalse;
            // If we have to wait for the sink to complete, always use the sink error
            TMMFEvent event( KMMFEventCategoryPlaybackComplete, iSinkError );
            iEventhandler.SendEventToClient( event );
            }
        }
    else if ( iDataPathComplete )
        {
        iDataPathComplete = EFalse;
        iSinkComplete = EFalse;        
        TMMFEvent event( KMMFEventCategoryPlaybackComplete, iSinkError );
        iEventhandler.SendEventToClient( event );
        }
    else
        {
        // RunL activated for someunknown reason, so leave
        User::Leave( KErrUnknown );
        }
    };

// -----------------------------------------------------------------------------
// CCompleteCallback::RunError
// Active object event handling
// -----------------------------------------------------------------------------
TInt CCompleteCallback::RunError( TInt /*aError*/ )
	{
	return KErrNone;
	}

// ========================== OTHER EXPORTED FUNCTIONS =========================

//  End of File