/*

* Copyright (c) 2006 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:    

*

*/

// INCLUDES

#include "test_async_features.h"

#include "mccteststubs.h"

#include "mmccinterface.h"

#include "mmcccodecinformation.h"

#include "testdefinitions.hrh"

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

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

// CTestAsyncFeat::CTestAsyncFeat

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

// might leave.

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

//

CTestAsyncFeat::CTestAsyncFeat( CConsoleBase& aConsole,

     const TMccNetSettings& aNetsettings, CMccInterface& aIF,

     CMccInterfaceStub& aIFStub )

    : iInterface( aIF ), iConsole( aConsole ), iNetsettings( aNetsettings ),

    iIfStub( aIFStub )

    {

    }

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

// CTestAsyncFeat::ConstructL

// Symbian 2nd phase constructor can leave.

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

//

void CTestAsyncFeat::ConstructL(  )

    {

    }

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

// CTestAsyncFeat::NewL

// Static constructor.

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

//   

CTestAsyncFeat* CTestAsyncFeat::NewL( CConsoleBase& aConsole,

        const TMccNetSettings& aNetsettings, CMccInterface& aIF,

        CMccInterfaceStub& aIFStub )

    {

    CTestAsyncFeat* self 

        = new ( ELeave ) CTestAsyncFeat( aConsole, aNetsettings, aIF, aIFStub );

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    return self;

    }

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

// CTestAsyncFeat::~CTestAsyncFeat

// Destructor.

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

//

CTestAsyncFeat::~CTestAsyncFeat()

    {  

    delete iCodec;

    }

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

// CTestAsyncFeat::DoRunAsyncFeatureTestsL

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

//

void CTestAsyncFeat::DoRunAsyncFeatureTestsL()

    {

    iConsole.Printf( _L("REQUEST MEDIA QUALITY\n") );

    RDebug::Print( _L("Mcc_COM_TEST_START: TestMediaQualityRequestL") );

    //__UHEAP_MARK;

    TestMediaQualityRequestL();

    //__UHEAP_MARKEND;

    RDebug::Print( _L("Mcc_COM_TEST_STOP: TestMediaQualityRequestL") );

    }

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

// CTestAsyncFeat::TestMediaQualityRequestL()

// private

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

//

void CTestAsyncFeat::TestMediaQualityRequestL()

    {

    RDebug::Print( _L("CTestAsyncFeat::TestMediaQualityRequestL") );

    User::LeaveIfError( iInterface.CreateSession( iSessionId ) );

    RDebug::Print( _L("CTestAsyncFeat::TestMediaQualityRequestL KMccLinkGeneral") );

    User::LeaveIfError(

        iInterface.CreateLink( iSessionId, KMccLinkGeneral, iLinkId,

            iNetsettings ) );

    iIfStub.WaitForEvent( iSessionId, iLinkId, 0, KMccLinkCreated );

//    User::LeaveIfError( iInterface.SetRemoteAddress( iSessionId, iLinkId, iNetsettings.iRemoteAddress ) );

    iCodec = FetchCodecByMimeSubtypeNameL( iInterface, KAMRSdpName );

    // AUDIO DOWNLINK STREAM CREATION

    RDebug::Print( _L("CTestAsyncFeat::TestMediaQualityRequestL ADD RSC AUDIO DL") );

    User::LeaveIfError(

        iInterface.AddDataSink( KUidMmfAudioOutput, KNullDesC8, iAudioSinkId ) );

    User::LeaveIfError(

        iInterface.AddDataSource( KMccRtpSourceUid, KNullDesC8, iRtpSourceId ) );

    User::LeaveIfError( iInterface.CreateStream( iSessionId, iLinkId, iStreamId1, 

        KMccAudioDownlinkStream, *iCodec ) );

    User::LeaveIfError( iInterface.PrepareStream( iSessionId, iLinkId, iStreamId1 ) );

    iIfStub.WaitForEvent( iSessionId, iLinkId, iStreamId1, KMccStreamPrepared );

    iIfStub.WaitForEvent( iSessionId, iLinkId, iStreamId1, KMccStreamPrepared );

    User::LeaveIfError( iInterface.StartStream( iSessionId, iLinkId, iStreamId1 ) );

    iIfStub.WaitForEvent( iSessionId, iLinkId, iStreamId1, KMccStreamStarted );

    iIfStub.WaitForEvent( iSessionId, iLinkId, iStreamId1, KMccStreamStarted );

    // AUDIO UPLINK STREAM CREATION

    RDebug::Print( _L("CTestAsyncFeat::TestMediaQualityRequestL CREATE AUDIO UL") );

    User::LeaveIfError(

        iInterface.AddDataSink( KMccRtpSinkUid, KNullDesC8, iRtpSinkId ) );

    User::LeaveIfError(

        iInterface.AddDataSource( KUidMmfAudioInput, KNullDesC8, iAudioSourceId ) );

    User::LeaveIfError( iInterface.CreateStream( iSessionId, iLinkId, iStreamId2, 

        KMccAudioUplinkStream, *iCodec ) );

    User::LeaveIfError( iInterface.PrepareStream( iSessionId, iLinkId, iStreamId2 ) );

    iIfStub.WaitForEvent( iSessionId, iLinkId, iStreamId2, KMccStreamPrepared );

    iIfStub.WaitForEvent( iSessionId, iLinkId, iStreamId2, KMccStreamPrepared );

    User::LeaveIfError( iInterface.StartStream( iSessionId, iLinkId, iStreamId2 ) );

    iIfStub.WaitForEvent( iSessionId, iLinkId, iStreamId2, KMccStreamStarted );

    iIfStub.WaitForEvent( iSessionId, iLinkId, iStreamId2, KMccStreamStarted );

    iConfig.iJitterLevel = 1;

    iConfig.iPacketLoss = 1;

    iConfig.iReportType = EMccJitterReport;

    iConfig.iReportIntervalType = EMccQualityTimeBased;

    iConfig.iReportInterval = 100;

    iConfig.iSessionId = iSessionId;

    iConfig.iEndpointId = iRtpSourceId;

    iConsole.Printf( _L( "Media quality observing: Start\n" ) );

    User::LeaveIfError( iInterface.MediaQualityRequest( iConfig ) );

    iConsole.Printf( _L( "Press a key to stop \n" ) );

    iConsole.Getch();

    User::LeaveIfError( iInterface.CancelMediaQualityRequest( iConfig ) );

    User::LeaveIfError( iInterface.StopStream( iSessionId, iLinkId, iStreamId1 ) );

    iIfStub.WaitForEvent( iSessionId, iLinkId, iStreamId1, KMccStreamStopped );

    iIfStub.WaitForEvent( iSessionId, iLinkId, iStreamId1, KMccStreamStopped );

    User::LeaveIfError( iInterface.StopStream( iSessionId, iLinkId, iStreamId2 ) );

    iIfStub.WaitForEvent( iSessionId, iLinkId, iStreamId2, KMccStreamStopped );

    iIfStub.WaitForEvent( iSessionId, iLinkId, iStreamId2, KMccStreamStopped );

    User::LeaveIfError( iInterface.DeleteStream( iSessionId, iLinkId, iStreamId1 ) );

    User::LeaveIfError( iInterface.DeleteStream( iSessionId, iLinkId, iStreamId2 ) );

    //iInterface.RemoveDataSink( iSessionId, iLinkId1, iStreamId1, iAudioSinkId );

    //iInterface.RemoveDataSource( iSessionId, iLinkId1, iStreamId1, iRtpSourceId );

    User::LeaveIfError( iInterface.CloseLink( iSessionId, iLinkId ) );

    User::LeaveIfError( iInterface.CloseSession( iSessionId ) );

    }

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

// CTestAsyncFeat::FetchCodecByMimeSubtypeNameL

// Private

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

//

CMccCodecInformation* CTestAsyncFeat::FetchCodecByMimeSubtypeNameL( 

        const CMccInterface& aInterface, const TDesC8& aName ) const

    {

    RPointerArray<CMccCodecInformation> codecArray;

    CleanupResetAndDestroy< RPointerArray<CMccCodecInformation> >::PushL( codecArray );

    User::LeaveIfError( aInterface.GetCapabilities( codecArray ) );

    CMccCodecInformation* tmp = NULL;

    TInt ind( codecArray.Count() );

    while ( ( ind-- ) && ( NULL == tmp ) )

        {

        if ( codecArray[ind]->SdpName().Compare( aName ) == 0 )

            {

            tmp = codecArray[ind]->CloneDetailedL();

            }

        }

    if ( NULL == tmp )

        {

        User::Leave( KErrNotFound );

        }

    CleanupStack::PopAndDestroy( &codecArray );

    return tmp;

    }

// End of File