/*
* 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:    Mcc Subthread client baseclass
*
*/




// INCLUDE FILES
#include "mccsubthreadclientbase.h"
#include "mccrtpmanager.h"
#include "mccmsrpmanager.h"
#include "mccsubcontrollerlogs.h"
#include "mccsymstreambase.h"
#include "mmccinterfacedef.h"


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

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::~CMccSubThreadClientBase
// Destructor
// -----------------------------------------------------------------------------
CMccSubThreadClientBase::~CMccSubThreadClientBase()
    {
    iDatasink = NULL;
    iDatasource = NULL;
    iObserver = NULL;
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::GetCodecL
// Returns the used codec
// -----------------------------------------------------------------------------
void CMccSubThreadClientBase::GetCodecL( const TUint32 /*aStreamId*/,
                                         TMccCodecInfo& aCodec )
    {   
    TFourCC nullFourCC;
    if( nullFourCC == iCodecInfo.iFourCC )
        {
        //User::Leave( KErrNotReady );
        }
    else
        {
        aCodec = iCodecInfo;
        }
    }


// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::CodecInformationL
// Returns the used codec
// -----------------------------------------------------------------------------
void CMccSubThreadClientBase::CodecInformationL( TUint32 aStreamId,
                                                 TMccCodecInfo& aCodec )
    {
    __SUBCONTROLLER_INT1( "CMccSubThreadClientBase::GetCodecL streamId", aStreamId )
    
	__ASSERT_ALWAYS( iStreams.Count(), User::Leave( KErrNotFound ) );
    
    const TInt index = FindStreamL( aStreamId );
    iStreams[index]->GetCodecL( aCodec );
    
	__SUBCONTROLLER( "CMccSubThreadClientBase::GetCodecL exit" )
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::SendMediaSignalL
// Default implementation of the signal sending
// -----------------------------------------------------------------------------
void CMccSubThreadClientBase::SendMediaSignalL( const TMccEvent& /*aEvent*/ )
    {
    User::Leave( KErrNotSupported );
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::SetCodecInformationL
// Sets the codec information for this stream
// -----------------------------------------------------------------------------
void CMccSubThreadClientBase::SetCodecInformationL( TUint32  aStreamId,
    const TMccCodecInfo& aCodecInfo,
    const TDesC8& aFmtp )
    {
    __SUBCONTROLLER_INT1( "CMccSubThreadClientBase::SetCodecInformationL streamId",
        aStreamId )
    __SUBCONTROLLER_INT1( "CMccSubThreadClientBase::SetCodecInformationL streamCount",
        iStreams.Count() )
    
	__ASSERT_ALWAYS( iStreams.Count(), User::Leave( KErrNotFound ) );
	
    const TInt index = FindStreamL( aStreamId );
    iStreams[ index ]->LoadCodecL( aCodecInfo, aFmtp );
    iStreams[ index ]->SetMMFPriority( aCodecInfo.iPriority );
   
	__SUBCONTROLLER( "CMccSubThreadClientBase::SetCodecInformationL, exit" )
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::SetRemoteAddressL
// Sets the remote address of uplink stream
// -----------------------------------------------------------------------------
void CMccSubThreadClientBase::SetRemoteAddressL( TInetAddr /*aRemAddr*/ )
    {
    User::Leave( KErrNotSupported );    
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::SetRemoteRtcpAddrL
// Sets the remote address of uplink stream
// -----------------------------------------------------------------------------
void CMccSubThreadClientBase::SetRemoteRtcpAddrL( TInetAddr /*aRemAddr*/ )
    {
    User::Leave( KErrNotSupported );    
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::SetRemoteMsrpPathL
// Sets the remote msrp path of uplink stream
// -----------------------------------------------------------------------------
void CMccSubThreadClientBase::SetRemoteMsrpPathL( TDes8& /*aRemAddr*/, TDes8& /*aConnStatus*/ )
    {
    User::Leave( KErrNotSupported );    
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::InitializeLinkL
// Creates the RTP session in the subthread, STEP #1
// -----------------------------------------------------------------------------
//
void CMccSubThreadClientBase::InitializeLinkL( TRequestStatus& /*aStatus*/, 
                                               TInt /*aIapId*/ )
    {
    User::Leave( KErrNotSupported );    
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::InitializeLinkL
// Creates the MSRP session in the subthread, STEP #1
// -----------------------------------------------------------------------------
//
void CMccSubThreadClientBase::InitializeLinkL( TRequestStatus& /*aStatus*/, 
                                               TInt /*aIapId*/,
                                               HBufC8*& /*aLocalMsrpPath*/ )
    {
    User::Leave( KErrNotSupported );    
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::CreateSessionL
// Creates the RTP session in the subthread, STEP #2
// -----------------------------------------------------------------------------
//
void CMccSubThreadClientBase::CreateRtpSessionL( TUint /*aPort*/, 
                                                 TBool /*aEnableRTCP*/,
                                                 TInt /*aIpTos*/,
                                                 CMccRtpMediaClock& /*aClock*/ )
    {
    User::Leave( KErrNotSupported );    
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::SetLinkId
// Creates the RTP session in the subthread
// -----------------------------------------------------------------------------
//
void CMccSubThreadClientBase::SetLinkId( TUint32 aLinkId )
    {
    iLinkId = aLinkId;
    if(this->iLinkType == KMccLinkMessage)
        {
        iMsrpmanager->SetLinkId( aLinkId );
        }
    else
        {
        if ( iRtpmanager )
            {
            iRtpmanager->SetLinkId( aLinkId );
            }
        }
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::GetLinkIndex
// Creates the RTP session in the subthread
// -----------------------------------------------------------------------------
//
TUint32 CMccSubThreadClientBase::GetLinkId() const
    {
    return iLinkId;
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::MccSessionId
// -----------------------------------------------------------------------------
//
TUint32 CMccSubThreadClientBase::MccSessionId() const
    {
    return iSessionId;
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::CloseL 
// Closes all links
// -----------------------------------------------------------------------------
void CMccSubThreadClientBase::CloseL()
    {
    User::Leave( KErrNotSupported );
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::StreamsExistsL 
// -----------------------------------------------------------------------------
TBool CMccSubThreadClientBase::StreamsExistsL()
    {
    return  EFalse;
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::StartInactivityTimer
// Starts inactivity timer for a stream 
// -----------------------------------------------------------------------------    
void CMccSubThreadClientBase::StartInactivityTimerL( const TUint32 /*aStreamId*/,
                                            		 TUint32 /*aTimeoutTime*/ )
	{
	User::Leave( KErrNotSupported );
	}
       
// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::StopInactivityTimer
// Stops inactivity timer for a stream 
// -----------------------------------------------------------------------------    
void CMccSubThreadClientBase::StopInactivityTimerL( const TUint32 /*aStreamId*/ )
	{
	User::Leave( KErrNotSupported );
	}

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::GetSupportedBitratesL
// Gets the supported bitrates from the codec of the specified stream
// -----------------------------------------------------------------------------    
void CMccSubThreadClientBase::GetSupportedBitratesL( const TUint32 /*aStreamId*/,
                                  RArray<TUint>& /*aBitrates*/ )
    {
    User::Leave( KErrNotSupported );
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::SendRTCPReceiverReportL
// Sends a RTCP receiver report
// -----------------------------------------------------------------------------
//  
void CMccSubThreadClientBase::SendRTCPReceiverReportL( const TUint32 /*aStreamId*/ )
    {
    User::Leave( KErrNotSupported );
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::SendRTCPSenderReportL
// Sends a RTCP sender report
// -----------------------------------------------------------------------------
// 
void CMccSubThreadClientBase::SendRTCPSenderReportL( const TUint32 /*aStreamId*/ )
    {
    User::Leave( KErrNotSupported );
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::SendRTCPDataL
// Sends Non-RTCP data
// -----------------------------------------------------------------------------
// 
void CMccSubThreadClientBase::SendRTCPDataL( const TUint32 /*aStreamId*/,
                                             const TDesC8& /*aData*/ )
    {
    User::Leave( KErrNotSupported );
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::GetFmtpAttrL
// Fetches the FMTP attribute of the current codec
// -----------------------------------------------------------------------------
// 
void CMccSubThreadClientBase::GetFmtpAttrL( const TUint32 /*aStreamId*/, TDes8& /*aFmtp*/ )
    {
    User::Leave( KErrNotSupported );
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::SetPrioritySettingsL 
// Sets priority
// -----------------------------------------------------------------------------
void CMccSubThreadClientBase::SetPrioritySettingsL( TUint32 aStreamId,
    const TMMFPrioritySettings& aPrioritySet )
    {
    __SUBCONTROLLER_INT1( "CMccSubThreadClientBase::SetPrioritySettingsL, streamId", 
	                      aStreamId )
    
	__ASSERT_ALWAYS( iStreams.Count(), User::Leave( KErrNotFound ) );
    
    const TInt index = FindStreamL( aStreamId );
    iStreams[ index ]->SetMMFPriority( aPrioritySet );
    
	__SUBCONTROLLER( "CMccSubThreadClientBase::SetPrioritySettingsL, exit" )	
    }
    
// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::GetSSRCL 
// -----------------------------------------------------------------------------
void CMccSubThreadClientBase::GetSSRCL( const TUint32  /*aStreamId*/, TUint32& /*aSSRCValue*/ )
	{
 	User::Leave( KErrNotSupported );	
	}

        
// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::FindStreamL
// Finds a streams index from the stream array
// -----------------------------------------------------------------------------
//
TInt CMccSubThreadClientBase::FindStreamL( TUint32 aStreamId )
    {
    const TInt index = FindStream( aStreamId );
    User::LeaveIfError( index );	
    return index;
    }

// -----------------------------------------------------------------------------
// CMccSubThreadClientBase::FindStream
// Finds a streams index from the stream array
// -----------------------------------------------------------------------------
//
TInt CMccSubThreadClientBase::FindStream( TUint32 aStreamId )
    {
	__SUBCONTROLLER_INT1( "CMccSubThreadClientBase::FindStream, streamId", aStreamId )
    
    const TInt strmCount = iStreams.Count();
    for( TInt k = 0; k < strmCount; k++ )
        {
        if( aStreamId == iStreams[k]->MccStreamId() )
            {
            return k;
            }
        }
    
    return KErrNotFound;
    }

TInt CMccSubThreadClientBase::GetLinkType()
    {
    return iLinkType;
    }

// -----------------------------------------------------------------------------
// CMccUlDlClient::SetMsrpObject()
// Sets CMSRP object
// -----------------------------------------------------------------------------
//
void CMccSubThreadClientBase::SetMsrpObject(CMSRP* aMsrpObject)
    {
    iMsrpmanager->SetMsrpObject(aMsrpObject);
    }

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

//  End of File