/*

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

*

*/

#include "mccmediastream.h"

#include <mmcccodecinformation.h>

#include <mmccinterface.h>

#include "mccsession.h"

#include "mcclink.h"

const TInt KAudioPrefVoipAudioUplink = 0x05220001;

const TInt KAudioPrefVoipAudioDownlink = 0x05210001;

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

// CMccMediaStream::ConstructL

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

// 

void CMccMediaStream::ConstructL()

    {

    }

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

// CMccMediaStream::NewL

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

// 

CMccMediaStream* CMccMediaStream::NewL( CMccLink* aLink, CMccSession* aSession,

    TStreamDirection aStreamDirection )

    {

    CMccMediaStream* self = new( ELeave ) CMccMediaStream(

        aLink, aSession, aStreamDirection );

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    return self;

    }

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

// CMccMediaStream::CMccMediaStream

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

// 

CMccMediaStream::CMccMediaStream( CMccLink* aLink, CMccSession* aSession,

    TStreamDirection aStreamDirection ) :

    iLink( aLink ), iSession( aSession ), iStreamDirection( aStreamDirection ),

    iState( EStreamReady )

    {

    }

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

// CMccMediaStream::~CMccMediaStream

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

//     

CMccMediaStream::~CMccMediaStream()

    {

    if ( ERtcpStreamStarted == iState )

        {

        iSession->MccInterface()->StopStream( iSession->MccSessionId(),

            iLink->LinkId(), iStreamId );

        }

    if ( iStreamId )

        {

        iSession->MccInterface()->DeleteStream( iSession->MccSessionId(),

            iLink->LinkId(), iStreamId );

        }

    }

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

// CMccMediaStream::CreateStreamL

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

//     

void CMccMediaStream::CreateStreamL( TInt32& aStreamId, TRequestStatus& aStatus )

    {

    TUint32 dataSinkId;

    TUint32 dataSourceId;

    RPointerArray<CMccCodecInformation> codecArray;

    CleanupResetAndDestroy< RPointerArray<CMccCodecInformation> >::PushL(

        codecArray );

    User::LeaveIfError( iSession->MccInterface()->GetCapabilities( codecArray ) );

    CleanupStack::Pop( &codecArray );

    if (  EUpStream == iStreamDirection )

        {

        User::LeaveIfError( iSession->MccInterface()->AddDataSink( KMccRtpSinkUid,

            KNullDesC8, dataSinkId ) );

        User::LeaveIfError( iSession->MccInterface()->AddDataSource( KUidMmfAudioInput,

            KNullDesC8, dataSourceId ) );

        codecArray[0]->SetPriorityPreference( KAudioPrefVoipAudioUplink );

        User::LeaveIfError( iSession->MccInterface()->CreateStream(

            iSession->MccSessionId(), iLink->LinkId(), iStreamId,

            KMccAudioUplinkStream, *codecArray[0] ) );

        }

    else

        {

        User::LeaveIfError( iSession->MccInterface()->AddDataSink( KUidMmfAudioOutput,

            KNullDesC8, dataSinkId ) );

        User::LeaveIfError( iSession->MccInterface()->AddDataSource( KMccRtpSourceUid,

            KNullDesC8, dataSourceId ) );

        codecArray[0]->SetPriorityPreference( KAudioPrefVoipAudioDownlink );

        User::LeaveIfError( iSession->MccInterface()->CreateStream(

            iSession->MccSessionId(), iLink->LinkId(), iStreamId, KMccAudioDownlinkStream,

            *codecArray[0] ) );

        }

    iState = EStreamCreated;

    User::LeaveIfError( iSession->MccInterface()->PrepareStream(

        iSession->MccSessionId(), iLink->LinkId(), iStreamId ) );

    aStreamId = iStreamId;

    aStatus = KRequestPending;

    }

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

// CMccMediaStream::PrepareStreamL

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

//     

void CMccMediaStream::PrepareStreamL( TRequestStatus& aStatus )

    {

    User::LeaveIfError( iSession->MccInterface()->PrepareStream(

        iSession->MccSessionId(), iLink->LinkId(), iStreamId ) );

    aStatus = KRequestPending;

    }

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

// CMccMediaStream::StartStreamL

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

//     

void CMccMediaStream::StartStreamL( TRequestStatus& aStatus )

    {

    User::LeaveIfError( iSession->MccInterface()->StartStream(

        iSession->MccSessionId(), iLink->LinkId(), iStreamId ) );

    aStatus = KRequestPending;

    }

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

// CMccMediaStream::StreamId

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

// 

TUint32 CMccMediaStream::StreamId()

    {

    return iStreamId;

    }

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

// CMccMediaStream::State

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

// 

TMccStreamState CMccMediaStream::State()

    {

    return iState;

    }

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

// CMccMediaStream::SetState

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

// 

void CMccMediaStream::SetState( TMccStreamState aState )

    {

    iState = aState;

    }

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

// CMccMediaStream::Delete

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

//     

TInt CMccMediaStream::Delete()

    {

    iState = EStreamReady;

    return iSession->MccInterface()->DeleteStream( iSession->MccSessionId(),

        iLink->LinkId(), iStreamId );

    }