/*

* Copyright (c) 2004-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:    Symmetric subthread client

*

*/

// INCLUDE FILES

#include <mmf/server/mmfdatasource.h>

#include <mmf/server/mmfdatasink.h>

#include "mccsymsubthreadclient.h"

#include "mccsymulstream.h"

#include "mccsymdlstream.h"

#include "mccsymsimpledlstream.h"

#include "mccdtmfdlstream.h"

#include "mccdtmfulstream.h"

#include "mccrtpmanager.h"

#include "amrpayloadformatutil.h"

#include "mccinternalevents.h"

#include "mccsubcontrollerlogs.h"

#include "mmccsecureinterface.h"

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

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

// CMccSymSubthreadClient::CMccSymSubthreadClient

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

// might leave.

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

CMccSymSubthreadClient::CMccSymSubthreadClient(

    MMccEventHandler* aObserver,

    MMccResources* aMccResources,

    TInt aLinkType,

    TUint32 aMccSessionId ):

    CMccSubThreadClientBase( aObserver, aMccResources, aLinkType, aMccSessionId )        

    {

    }

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

// CMccSymSubthreadClient::ConstructL

// Symbian 2nd phase constructor can leave.

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

void CMccSymSubthreadClient::ConstructL()

    {

	__SUBCONTROLLER( "CMccSymSubthreadClient::ConstructL" )

	User::LeaveIfNull( iObserver );

	User::LeaveIfNull( iMccResources );

	__SUBCONTROLLER( "CMccSymSubthreadClient::ConstructL, exit" )

    }

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

// CMccSymSubthreadClient::NewL

// Static constructor.

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

CMccSymSubthreadClient* CMccSymSubthreadClient::NewL( 

    MMccEventHandler* aObserver, 

    MMccResources* aMccResources,

    TInt aLinkType,

    TUint32 aMccSessionId )

    {        

    CMccSymSubthreadClient* self = 

            new ( ELeave ) CMccSymSubthreadClient( aObserver, aMccResources, aLinkType, aMccSessionId );

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    return self;

    }

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

// CMccSymSubthreadClient::~CMccSymSubthreadClient

// Destructor

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

CMccSymSubthreadClient::~CMccSymSubthreadClient()

    {

	__SUBCONTROLLER( "CMccSymSubthreadClient::~CMccSymSubthreadClient" )

    iStreams.ResetAndDestroy();

    iStreams.Close();

    iUnusedStreams.Reset();

    iUnusedStreams.Close();

    if( iRtpmanager )

        {

        iRtpmanager->CloseSession();

        delete iRtpmanager;

	__SUBCONTROLLER( "CMccSymSubthreadClient::~CMccSymSubthreadClient, exit" )

    }

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

// CMccSymSubthreadClient::SetVolumeL

// Creates a new RTP session in a subthread

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

void CMccSymSubthreadClient::SetVolumeL( TInt aVolume )

    {

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::SetVolumeL", aVolume )

    TInt strmCount = iStreams.Count();

    if( strmCount )

        {

        for( TInt k = 0; k < strmCount; k++ )

            {

            iStreams[k]->SetVolumeL( aVolume );

            }

        }

    else

        {        

	    __SUBCONTROLLER( "CMccSymSubthreadClient::SetVolumeL, no streams" )

        }

	__SUBCONTROLLER( "CMccSymSubthreadClient::SetVolumeL, exit" )

    }

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

// CMccSymSubthreadClient::SetGainL

// Creates a new RTP session in a subthread

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

void CMccSymSubthreadClient::SetGainL( TInt aGain )

    {

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::SetGainL", aGain )

    TInt strmCount = iStreams.Count();

    if( strmCount )

        {

        for( TInt k = 0; k < strmCount; k++ )

            {

            iStreams[k]->SetGainL( aGain );

            }

        }

    else

        {

	    __SUBCONTROLLER( "CMccSymSubthreadClient::SetGainL, no streams" )

        }

	__SUBCONTROLLER( "CMccSymSubthreadClient::SetGainL, exit" )

    }

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

// CMccSymSubthreadClient::VolumeL

// Creates a new RTP session in a subthread

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

TInt CMccSymSubthreadClient::GetVolumeL( const TUint32 aStreamId )

    {

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::GetVolumeL for streamId", aStreamId )

	__ASSERT_ALWAYS( iStreams.Count(), User::Leave( KErrNotFound ) );

    TInt volume = 0;

    TInt index = FindStreamL( aStreamId );

    volume = iStreams[index]->VolumeL();

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::GetVolumeL exit with", volume )

    return volume;

    }

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

// CMccSymSubthreadClient::GainL

// Creates a new RTP session in a subthread

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

TInt CMccSymSubthreadClient::GetGainL( const TUint32 aStreamId )

    {

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::GetGainL for streamId", aStreamId )

	__ASSERT_ALWAYS( iStreams.Count(), User::Leave( KErrNotFound ) );

    TInt gain = 0;

    TInt index = FindStreamL( aStreamId );

    gain = iStreams[index]->GainL();

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::GetGainL exit with", gain )

    return gain;

    }

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

// CMccSymSubthreadClient::MaxVolumeL

// Creates a new RTP session in a subthread

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

TInt CMccSymSubthreadClient::MaxVolumeL( const TUint32 aStreamId )

    {

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::MaxVolumeL for streamId", aStreamId )

	__ASSERT_ALWAYS( iStreams.Count(), User::Leave( KErrNotFound ) );

    TInt maxvolume = 0;

    TInt index = FindStreamL( aStreamId );

    maxvolume = iStreams[index]->MaxVolumeL();

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::MaxVolumeL exit with", maxvolume )

    return maxvolume;

    }

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

// CMccSymSubthreadClient::MaxGainL

// Creates a new RTP session in a subthread

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

TInt CMccSymSubthreadClient::MaxGainL( const TUint32 aStreamId )

    {

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::MaxGainL for streamId", aStreamId )

	__ASSERT_ALWAYS( iStreams.Count(), User::Leave( KErrNotFound ) );

    TInt maxgain = 0;

    TInt index = FindStreamL( aStreamId );

    maxgain = iStreams[index]->MaxGainL();

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::MaxGainL exit with", maxgain )

    return maxgain;

    }

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

// CMccSymSubthreadClient::SetBalanceL

// From CMccSubThreadClientBase

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

void CMccSymSubthreadClient::SetBalanceL( const TUint32 aStreamId, TInt aLeftBalance, 

        TInt aRightBalance )

    {

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::SetBalanceL for streamId", aStreamId )

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::SetBalanceL for LeftBalance", aLeftBalance )

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::SetBalanceL for RightBalance", aRightBalance )

	__ASSERT_ALWAYS( iStreams.Count(), User::Leave( KErrNotFound ) );

    TInt index = FindStreamL( aStreamId );

    iStreams[index]->SetBalanceL( aLeftBalance, aRightBalance );

	__SUBCONTROLLER( "CMccSymSubthreadClient::SetBalanceL exit" )

    }

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

// CMccSymSubthreadClient::GetBalanceL

// From CMccSubThreadClientBase

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

void CMccSymSubthreadClient::GetBalanceL( const TUint32 aStreamId, TInt& aLeftBalance, 

        TInt& aRightBalance )

    {

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::GetBalanceL for streamId", aStreamId )

	__ASSERT_ALWAYS( iStreams.Count(), User::Leave( KErrNotFound ) );

    TInt index = FindStreamL( aStreamId );

    iStreams[index]->GetBalanceL( aLeftBalance, aRightBalance );

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::GetBalanceL for LeftBalance", aLeftBalance )

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::GetBalanceL for RightBalance", aRightBalance )

	__SUBCONTROLLER( "CMccSymSubthreadClient::GetBalanceL exit" )

    }

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

// CMccSymSubthreadClient::OpenL

// From CMccSubThreadClientBase

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

void CMccSymSubthreadClient::OpenL( TInt aStreamType,

                                    TFourCC aFourCC,

                                    MDataSource* aDatasource, 

                                    MDataSink* aDatasink,

                                    const TUint32 aStreamId,

                                    TMMFPrioritySettings aSettings )

    {

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::OpenL for streamId", aStreamId )

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient stream type", aStreamType )

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

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

    TUid sourceType = aDatasource->DataSourceType();

    TUid sinkType = aDatasink->DataSinkType();

	iPrioritySettingsData = aSettings;

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient audio priority", iPrioritySettingsData.iPriority )

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient audio preference", iPrioritySettingsData.iPref )

    CMccSymStreamBase* stream( NULL );

    TBool localAVToDisplayStream = ( aStreamType == KMccVideoLocalStream ||

                                     aStreamType == KMccAudioLocalStream ) &&

                                     sourceType == KMccFileSourceUid &&

                                     sinkType == KMccVideoSinkUid;

        {

        __SUBCONTROLLER( "CMccSymSubthreadClient::OpenL, new CMccDtmfDlStream" )

        stream = CMccDtmfDlStream::NewLC( aStreamId, this, iMccResources,

            iRtpmanager, aFourCC, aStreamType, *iRtpMediaClock );

        }

    else if ( KMccDtmfStream == aStreamType && KMccRtpSinkUid == sinkType )

        {

        __SUBCONTROLLER( "CMccSymSubthreadClient::OpenL, new CMccDtmfUlStream" )

        stream = CMccDtmfUlStream::NewLC( aStreamId, this, iMccResources,

            iRtpmanager, aFourCC, aStreamType, *iRtpMediaClock );

        }

    // Special handling for local video if it should be displayed (treat as uplink)

    else if( sinkType == KMccRtpSinkUid ||

        localAVToDisplayStream )

        {

	    __SUBCONTROLLER( "CMccSymSubthreadClient::OpenL, new CMccSymUlStream" )

        stream = CMccSymUlStream::NewLC( aStreamId, 

                                         this, 

                                         iMccResources, 

                                         iRtpmanager, 

                                         aFourCC, 

                                         aStreamType,

                                         *iRtpMediaClock );

        }

    else if( sourceType == KMccRtpSourceUid && sinkType != KMccVideoSinkUid )

        {

	    __SUBCONTROLLER( "CMccSymSubthreadClient::OpenL, new CMccSymDlStream" )

        stream = CMccSymDlStream::NewLC( aStreamId, 

                                         this, 

                                         iMccResources,

                                         iRtpmanager, 

                                         aStreamType,

                                         *iRtpMediaClock );

        }

    else if( ( sourceType == KMccRtpSourceUid && sinkType == KMccVideoSinkUid ) ||

             ( aStreamType == KMccAudioLocalStream || aStreamType == KMccVideoLocalStream ) )

        {  

        __SUBCONTROLLER( "CMccSymSubthreadClient::OpenL, new CMccSymSimpleDlStream" )      

        stream = CMccSymSimpleDlStream::NewLC( aStreamId, 

                                               this, 

                                               iMccResources,

                                               iRtpmanager, 

                                               aFourCC, 

                                               aStreamType,

                                               *iRtpMediaClock );

        }

    else

        {

	    __SUBCONTROLLER( "CMccSymSubthreadClient::OpenL, KErrArgument" )

        User::Leave( KErrArgument );

        }

    stream->AddSinkAndSourceL( aDatasink, aDatasource );

    iStreams.AppendL( stream );

    CleanupStack::Pop( stream );

    TInt index = FindStreamL( aStreamId );     

    iStreams[ index ]->SetMMFPriority( aSettings );

	__SUBCONTROLLER( "CMccSymSubthreadClient::OpenL, exit" )

    }

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

// CMccSymSubthreadClient::PrepareL

// From CMccSubThreadClientBase

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

void CMccSymSubthreadClient::PrepareL( const TUint32 aStreamId, 

									   const TUint32 aEndpointId )

    {

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::PrepareL, streamId", aStreamId )

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::PrepareL, aEndpointId", aEndpointId )

	__ASSERT_ALWAYS( iStreams.Count(), User::Leave( KErrNotFound ) );

    TInt index = FindStreamL( aStreamId );

    iStreams[index]->PrimeL( aEndpointId );	

	__SUBCONTROLLER( "CMccSymSubthreadClient::PrepareL, exit" )

    }

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

// CMccSymSubthreadClient::PlayL

// From CMccSubThreadClientBase

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

void CMccSymSubthreadClient::PlayL( const TUint32 aStreamId,

                                    const TUint32 aEndpointId,

                                    TBool aStreamPaused,

                                    TBool aEnableRTCP )

    {

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::PlayL, streamId", aStreamId )

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::PlayL, aEndpointId", aEndpointId )

	__ASSERT_ALWAYS( iStreams.Count(), User::Leave( KErrNotFound ) );

    TInt index = FindStreamL( aStreamId );

    iStreams[index]->PlayL( aEndpointId, aStreamPaused, aEnableRTCP ); 

	__SUBCONTROLLER( "CMccSymSubthreadClient::PlayL, exit" )

    }

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

// CMccSymSubthreadClient::StopL

// From CMccSubThreadClientBase

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

void CMccSymSubthreadClient::StopL( const TUint32 aStreamId,

									const TUint32 aEndpointId )

    {

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::StopL, streamId", aStreamId )

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::StopL, aEndpointId", aEndpointId )

    TInt index = FindStream( aStreamId );

    if ( index != KErrNotFound )

        {

        iStreams[index]->StopL( aEndpointId );

        }

    else

        {

        // No need to stop if unused

        index = iUnusedStreams.Find( aStreamId );

        __ASSERT_ALWAYS( index != KErrNotFound, User::Leave( KErrNotFound ) );

        }

	__SUBCONTROLLER( "CMccSymSubthreadClient::StopL, exit" )

    }

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

// CMccSymSubthreadClient::PauseL

// From CMccSubThreadClientBase

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

void CMccSymSubthreadClient::PauseL( const TUint32 aStreamId,

									 const TUint32 aEndpointId,

                                     TBool aEnableRTCP )

    {

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::PauseL, streamId", aStreamId )

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::PauseL, aEndpointId", aEndpointId )

	__ASSERT_ALWAYS( iStreams.Count(), User::Leave( KErrNotFound ) );

    TInt index = FindStreamL( aStreamId );

    iStreams[index]->PauseL( aEndpointId, aEnableRTCP );

	__SUBCONTROLLER( "CMccSymSubthreadClient::PauseL, exit" )

    }

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

// CMccSymSubthreadClient::ResumeL

// From CMccSubThreadClientBase

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

void CMccSymSubthreadClient::ResumeL( const TUint32 aStreamId,

									  const TUint32 aEndpointId,

                                      TBool aEnableRTCP )

    {

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::ResumeL, streamId", aStreamId )

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::ResumeL, aEndpointId", aEndpointId )

	__ASSERT_ALWAYS( iStreams.Count(), User::Leave( KErrNotFound ) );

    TInt index = FindStreamL( aStreamId );

    iStreams[index]->ResumeL( aEndpointId, aEnableRTCP );

    __SUBCONTROLLER( "CMccSymSubthreadClient::ResumeL, exit" )

    }

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

// CMccSymSubthreadClient::CloseL

// From CMccSubThreadClientBase

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

void CMccSymSubthreadClient::CloseL( const TUint32 aStreamId )

    {

	__SUBCONTROLLER_INT1( "CMccSymSubthreadClient::CloseL, streamId", aStreamId )

    TInt index = FindStream( aStreamId );

    if ( index != KErrNotFound )

        {

        CMccSymStreamBase* tmp = iStreams[index];

        iStreams.Remove( index );

        delete tmp;

        }

    else 

        {

        index = iUnusedStreams.Find( aStreamId );

        __ASSERT_ALWAYS( index != KErrNotFound, User::Leave( KErrNotFound ) );

        // Stream was already deleted

        iUnusedStreams.Remove( index );

        }

	__SUBCONTROLLER( "CMccSymSubthreadClient::CloseL, exit" )

    }

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

// CMccSymSubthreadClient::CloseL 

// Closes all links

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

void CMccSymSubthreadClient::CloseL()

    {

	__SUBCONTROLLER( "CMccSymSubthreadClient::CloseL" )

    for ( TInt i = iStreams.Count() - 1; i >= 0; i-- )

    	{

        CMccSymStreamBase* tmp = iStreams[i];

        tmp->RemoveContext( 0 );

        iStreams.Remove( i );

        delete tmp;        	    	

    	}