/*

* Copyright (c) 2005-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:    Mcc Symmetric subthread downlink stream

*

*/

// INCLUDE FILES

#include <mmf/server/mmfformat.h>

#include <mmf/server/mmfaudiooutput.h>

#include "mccsymdlstream.h"

#include "mccdldatapath.h"

#include "mccjitterbuffer.h"

#include "mccrtpmanager.h"

#include "mcccodecconfigurator.h"

#include "mccinternaldef.h"

#include "mccaudiorouter.h"

#include "mccsubcontrollerlogs.h"

#include "mccmultiplexer.h"

#include "mccresources.h"

#include "mccredpayloadread.h"

// CONSTANTS

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

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

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

// CMccSymDlStream::CMccSymDlStream

// C++ default constructor can NOT contain any code, that

// might leave.

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

//

CMccSymDlStream::CMccSymDlStream( 

    TUint32 aMccStreamId, 

    MAsyncEventHandler* aEventhandler, 

    MMccResources* aMccResources, 

    CMccRtpManager* aManager, 

    TInt aStreamType ) : 

    CMccSymStreamBase( aMccStreamId, 

                       aEventhandler, 

                       aMccResources, 

                       aManager, 

                       aStreamType ), 

    iJitterBuffer( NULL ), 

    iFormatDecode( NULL )

    {

    }

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

// CMccSymDlStream::NewL

// Two-phased constructor.

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

//

CMccSymDlStream* CMccSymDlStream::NewLC( 

    TUint32 aMccStreamId, 

    MAsyncEventHandler* aEventhandler, 

    MMccResources* aMccResources,

    CMccRtpManager* aManager, 

    TInt aStreamType ) 

    {

    CMccSymDlStream* s = 

            new ( ELeave ) CMccSymDlStream( aMccStreamId, 

                                            aEventhandler, 

                                            aMccResources,

                                            aManager, 

                                            aStreamType );

    CleanupStack::PushL( s );

    s->ConstructL();

    return s;

    }

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

// CMccSymDlStream::ConstructL

// Symbian 2nd phase constructor can leave.

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

//

void CMccSymDlStream::ConstructL()

    {

    iDatapath = 

        CMccDlDataPath::NewL( this, iMccResources, KUidMediaTypeAudio );

    iJitterBuffer = CMccJitterBuffer::NewL( this );

    }

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

// CMccSymDlStream::~CMccSymDlStream

// Destructor

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

//

CMccSymDlStream::~CMccSymDlStream()

    {

    delete iAudioRouter;

    if ( iSoundDevice )

        {

        iSoundDevice = NULL;

        }

    if ( iJitterBuffer )

        {

        iJitterBuffer->SinkThreadLogoff();

        delete iJitterBuffer;

        iJitterBuffer = NULL;

        }

    // Must do mux cleanup before decoder (mux sink) deletion

    MultiplexerCleanup();

    if ( iFormatDecode )

        {

        iFormatDecode->SourceThreadLogoff();

        delete iFormatDecode;

        iFormatDecode = NULL;

        }

    delete iRedFormatDecode;

    }

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

// CMccSymDlStream::SetPrioritySettingsL

// Sets the MMF priority settings for this stream

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

//

void CMccSymDlStream::SetPrioritySettingsL( 

        const TMMFPrioritySettings& aPriority )

    {

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

    iDatasink->SetSinkPrioritySettings( aPriority );

    }

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

// CMccSymDlStream::AddSinkAndSourceL

// From CMccSymStreamBase

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

//

void CMccSymDlStream::AddSinkAndSourceL( MDataSink* aDatasink, 

        MDataSource* aDatasource )

    {

    __SUBCONTROLLER( "CMccSymDlStream::AddSinkAndSourceL" )

    __ASSERT_ALWAYS( aDatasink && aDatasource, User::Leave( KErrArgument ) );

    iDatasink = aDatasink;

    iDatasource = aDatasource;

    iMultiplexer = iMccResources->MultiplexerL( iDatasource );

 	if ( iDatasink->DataSinkType() == KUidMmfAudioOutput )

    	{

	    iJitterBuffer->AddDataSinkL( iDatasink );

	    // Cause the devsound to be loaded, as this call will pass through

	    // jitterbuffer

	    User::LeaveIfError( iJitterBuffer->SinkThreadLogon( *this ) );

	    __SUBCONTROLLER( "CMccSymDlStream::AddSinkAndSourceL, devsound loaded" )

	    iSoundDevice = &( static_cast<MMMFAudioOutput*>( iDatasink )->SoundDevice() );

	    // Create new audio router

	    delete iAudioRouter;

        iAudioRouter = 0;

        iAudioRouter = CMccAudioRouter::NewL( *iSoundDevice );

        iDatapath->AddDataSinkL( iJitterBuffer );

    	}

    else if ( iDatasink->DataSinkType() == KMccVideoSinkUid )

    	{

        iDatapath->AddDataSinkL( iDatasink );

        User::LeaveIfError( iDatasink->SinkThreadLogon(*this ) );

    	}

    else

        {

        }

    // Inform datapath about ids of associated sink and source

    iDatapath->SetAssociatedSink( iDatasink );

    iDatapath->SetAssociatedSource( iDatasource );

    __SUBCONTROLLER( "CMccSymDlStream::AddSinkAndSourceL, exit" )

    }

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

// CMccSymDlStream::LoadCodecL

// From CMccSymStreamBase

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

//

void CMccSymDlStream::LoadCodecL( const TMccCodecInfo& aCodecInfo,

                                  const TDesC8& aFmtp )

    {

    __SUBCONTROLLER_INT1( "CMccSymDlStream::LoadCodecL codec state:", 

        CurrentCodecState() )

    __ASSERT_ALWAYS( CurrentCodecState() == EStateCodecNone || 

                     iCodecInfo.iFourCC == aCodecInfo.iFourCC,

                     User::Leave( KErrArgument ) );

    TMccCodecInfo orig = iCodecInfo;

    iCodecInfo = aCodecInfo;

    if ( CurrentCodecState() == EStateCodecNone )

        {

        delete iFmtpAttr;

        iFmtpAttr = NULL;

    	iFmtpAttr = HBufC8::NewL( aFmtp.Length() );

        iFmtpAttr->Des().Copy( aFmtp );

        iCodecInfo.iFmtpLength = iFmtpAttr->Length();

        CreatePayloadFormatDecoderL();

        // Just negotiate the codec, load it later

        static_cast<CMccDlDataPath*>( iDatapath )->NegotiateL( *iFormatDecode );

        SetCodecState( EStateCodecNegotiated );        	

        }

    else if ( CurrentCodecState() == EStateCodecNegotiated )

        {

        // Codec is not fully usable yet, do just formatter initialization

        MccCodecConfigurator::ConfigureCodecL( *iFormatDecode,

                                                *iDatasink,

                                                aCodecInfo,

                                                *iRtpMediaClock,

                                                CurrentCodecState() );

        SetCodecState( EStateCodecPrepared );

        }

    else if ( CurrentCodecState() == EStateCodecPrepared )

        {

        if ( CodecLoadingAllowed() )

            {

            // Load the codec

            static_cast<CMccDlDataPath*>( iDatapath )->LoadL( *iFormatDecode );

            TInt jbufLen = iCodecInfo.iMaxPtime;

            iJitterBuffer->SetupL( jbufLen, 

                                   iCodecInfo.iJitterBufThreshold, 

                                   iCodecInfo );

            // Set state before updating as the state affects to update functionality

            SetCodecState( EStateCodecLoaded );

            UpdateCodecInformationL( orig, iCodecInfo );

            }

        }

    else if ( CurrentCodecState() == EStateCodecLoaded ||

              CurrentCodecState() == EStateCodecLoadedAndUpdating )

        {

        // Update codec info

        if ( iDatasource->DataSourceType() == KMccRtpSourceUid )

       	    {

            CMccRtpDataSource* dataSource = 

                static_cast<CMccRtpDataSource*>( iDatasource );

            // For updating keep alive parameters

            TMccCodecInfoBuffer infoBuffer( iCodecInfo );     

            dataSource->ConfigureL( infoBuffer );

       	    }

        SetCodecState( EStateCodecLoadedAndUpdating );

    	UpdateCodecInformationL( orig, iCodecInfo );

        }

    else

        {

        User::Leave( KErrNotReady );

        }

    __SUBCONTROLLER_INT1( "CMccSymDlStream::LoadCodecL exit, new state:", 

        CurrentCodecState() )

    }

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

// CMccSymDlStream::UpdateCodecInformationL

// From CMccSymStreamBase

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

//

void CMccSymDlStream::UpdateCodecInformationL( const TMccCodecInfo& aOriginal,

    const TMccCodecInfo& aNew )

    {

    __SUBCONTROLLER( "CMccSymDlStream::UpdateCodecInformationL Entry" )

    // UpdateCodecInformationL is called from LoadCodecL which checks that

    // codec itself is not changed. Here we re-configure the codec

    // parameters.

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

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

    HandleSpecialSinksAndSources();

    // NB; updated in LoadCodecL, update information added here

    iCodecInfo.iIsUpdate = ETrue;

    TBool specNeed = MccCodecConfigurator::IlbcNeedsStopResume(

            aOriginal.iBitrate,

            iCodecInfo.iBitrate,

            iCodecInfo.iFourCC );

    // Need to check also the codec state because CurrentCodecState may

    // return such codec state that does not allow iLBC reconfiguration.

    TCodecState codecState = CurrentCodecState();

    if ( specNeed && EStateStreaming == CurrentState() )

        {

        iJitterBuffer->SinkStopL();

        codecState = CMccSymStreamBase::EStateCodecLoaded;

        }

    MccCodecConfigurator::ConfigureCodecL( *iFormatDecode,

                                           *iDatasink,

                                           aNew,

                                           *iRtpMediaClock,

                                           codecState );

    if ( specNeed && EStateStreaming == CurrentState() )

        {

        iJitterBuffer->SinkPlayL();

        }

    __SUBCONTROLLER( "CMccSymDlStream::UpdateCodecInformationL Exit" )

    }

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

// CMccSymDlStream::CreatePayloadFormatDecoderL

// Creates the payload format decoder

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

//

void CMccSymDlStream::CreatePayloadFormatDecoderL()

    {

    __SUBCONTROLLER( "CMccSymDlStream::CreatePayloadFormatEncoderL" )

    __ASSERT_ALWAYS( NULL == iFormatDecode, User::Leave( KErrAlreadyExists ) );

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

    TUid formatuid;

    formatuid.iUid = iCodecInfo.iPayloadFormatDecoder;

    RArray<TUint> payloads;

    CleanupClosePushL( payloads );

    ParsePayloadTypesL( payloads, iCodecInfo );

    if ( EGenRedUsed == iCodecInfo.iAlgoUsed )

        {

        __ASSERT_ALWAYS( KMccPayloadTypeMax != iCodecInfo.iRedundantPayload,

            User::Leave( KErrArgument ) );

        iRedFormatDecode = CMMFFormatDecode::NewL(

            TUid::Uid( KImplUidRedPayloadFormatDecode ), iMultiplexer );

        iFormatDecode = CMMFFormatDecode::NewL( formatuid, iRedFormatDecode );

        User::LeaveIfError( iMultiplexer->MultiplexerSourceThreadLogon( *this, 

            *iRedFormatDecode, ETrue, Type(), EFalse ) );

        iMultiplexer->RegClientForPayloadsL( *iRedFormatDecode, payloads );

        }

    else

        {

        iFormatDecode = CMMFFormatDecode::NewL( formatuid, iMultiplexer );

        User::LeaveIfError( iMultiplexer->MultiplexerSourceThreadLogon( *this, 

            *iFormatDecode, ETrue, Type(), EFalse ) );

        iMultiplexer->RegClientForPayloadsL( *iFormatDecode, payloads );

        }

    iFormatDecode->SetSourceDataTypeCode( iCodecInfo.iFourCC, Type() );

    User::LeaveIfError( iFormatDecode->SourceThreadLogon( *this ) );

    CleanupStack::PopAndDestroy( &payloads );

    }

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

// CMccSymDlStream::PrimeL

// Primes the audio stream ready

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

//

void CMccSymDlStream::PrimeL( const TUint32 aEndpointId )

    {

    __SUBCONTROLLER( "CMccSymDlStream::PrimeL" )

    TBool controlNetworkResources = SetStateL( EStatePrepared, aEndpointId );    

    if ( controlNetworkResources )

        {

        iRtpmanager->CreateReceiveStreamL( *iDatasource, iCodecInfo );

        }

    LoadCodecL( iCodecInfo, KNullDesC8 ); 

    DoPrimeL();

    InformStreamStateChange( KMccStreamPrepared, aEndpointId );

    }

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

// CMccSymDlStream::PlayL

// Starts audio streaming

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

//

void CMccSymDlStream::PlayL( const TUint32 aEndpointId,

							 TBool /*aStreamPaused*/, 

                             TBool aEnableRtcp )

    {

    __SUBCONTROLLER( "CMccSymDlStream::PlayL" )

    TBool controlNetworkResources = SetStateL( EStateStreaming, aEndpointId );

    if ( controlNetworkResources )

        {

        iRtpmanager->StartSessionL();

        }

    User::LeaveIfError( iRtpmanager->SetRTCPSendReceive( aEnableRtcp ) ); 

    UpdateCodecLoadingPermission( IsCodecOperationAllowed() );

    LoadCodecL( iCodecInfo, KNullDesC8 );

    DoPlayL();

    HandleStandby( aEndpointId, EFalse );

    InformStreamStateChange( KMccStreamStarted, aEndpointId );

    __SUBCONTROLLER( "CMccSymDlStream::PlayL, exit" )

    }

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

// CMccSymDlStream::PauseL

// Pauses audio streaming

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

//

void CMccSymDlStream::PauseL( const TUint32 aEndpointId, TBool aEnableRtcp )

    {

    __SUBCONTROLLER( "CMccSymDlStream::PauseL" )

    /*TBool standbyEndpointControl( StandbyStream() && 

                                  aEndpointId == MCC_ENDPOINT_ID( iDatasink ) );*/

    SetStateL( EStatePaused, aEndpointId );

    User::LeaveIfError( iRtpmanager->SetRTCPSendReceive( aEnableRtcp ) );

    DoPauseL();

    HandleStandby( aEndpointId, ETrue );

    InformStreamStateChange( KMccStreamPaused, aEndpointId ); 

    }

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

// CMccSymDlStream::ResumeL

// Resumes paused audio streaming

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

//

void CMccSymDlStream::ResumeL( const TUint32 aEndpointId, TBool aEnableRtcp )

    { 

    __SUBCONTROLLER( "CMccSymDlStream::ResumeL" )

    // In first resume of the standby stream sink is treated as in normal

    // startup phase

    TBool standbyEndpointControl( StandbyStream() && 

                                  aEndpointId == MCC_ENDPOINT_ID( iDatasink ) );

    if ( standbyEndpointControl && !iFirstResumeDone )

        {

        __SUBCONTROLLER( "CMccSymDlStream::ResumeL, standby, first resume" )

        SetStateL( EStateStreaming, aEndpointId );

        UpdateCodecLoadingPermission( IsCodecOperationAllowed() );

        LoadCodecL( iCodecInfo, KNullDesC8 );

        DoPlayL();

        iFirstResumeDone = IsControllingMmfEndpoint();

        }

    else

        {

        /*TBool controlNetworkResources = */

        SetStateL( EStateStreaming, aEndpointId );

        User::LeaveIfError( iRtpmanager->SetRTCPSendReceive( aEnableRtcp ) );

        DoResumeL();

        }

    HandleStandby( aEndpointId, EFalse );

    InformStreamStateChange( KMccStreamResumed, aEndpointId );

    __SUBCONTROLLER( "CMccSymDlStream::ResumeL, exit" )

    }

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

// CMccSymDlStream::StopL

// Stops the audio streaming

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

//

void CMccSymDlStream::StopL( const TUint32 aEndpointId )

    {

    __SUBCONTROLLER( "CMccSymDlStream::StopL" )

    SetStateL( EStateStopped, aEndpointId );    

    DoStopL();

    InformStreamStateChange( KMccStreamStopped, aEndpointId );

    }

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

// CMccSymDlStream::SetBalanceL

// Sets the current play balance

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

//

void CMccSymDlStream::SetBalanceL( TInt aLeftBal, TInt aRightBal )