/*
* Copyright (c) 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:  Provides RTP observation class
*
*/


#include "svprtpobserver.h"
#include "svprtpobserverrequest.h"
#include "svpsessionbase.h"
#include "svplogger.h"

// ---------------------------------------------------------------------------
// CSVPRtpObserver::CSVPRtpObserver
// ---------------------------------------------------------------------------
//
CSVPRtpObserver::CSVPRtpObserver()
    {
    // No implementation required
    }

// ---------------------------------------------------------------------------
// CSVPRtpObserver::~CSVPRtpObserver
// ---------------------------------------------------------------------------
//
CSVPRtpObserver::~CSVPRtpObserver()
    {
    iRequestArray.ResetAndDestroy();
    iRequestArray.Close();
    }

// ---------------------------------------------------------------------------
// CSVPRtpObserver::NewLC
// ---------------------------------------------------------------------------
//
CSVPRtpObserver* CSVPRtpObserver::NewLC()
    {
    CSVPRtpObserver* self = new ( ELeave ) CSVPRtpObserver();
    CleanupStack::PushL( self );
    return self;
    }

// ---------------------------------------------------------------------------
// CSVPRtpObserver::NewL
// ---------------------------------------------------------------------------
//
CSVPRtpObserver* CSVPRtpObserver::NewL()
    {
    CSVPRtpObserver* self = CSVPRtpObserver::NewLC();
    CleanupStack::Pop( self );
    return self;
    }

// ---------------------------------------------------------------------------
// CSVPRtpObserver::SRReceived
// ---------------------------------------------------------------------------
//
void CSVPRtpObserver::SRReceived( CMceSession& aSession,
    CMceMediaStream& aStream )
    {
    SVPDEBUG1( "CSVPRtpObserver::SRReceived" )
    
    CSVPRtpObserverRequest* assocReq = FindByMceSession( &aSession );
    if ( assocReq )
        {
        assocReq->RtcpPacketReceived( 
            CSVPRtpObserverRequest::ERtcpSrPacket, aSession, aStream );
        }
    }

// ---------------------------------------------------------------------------
// CSVPRtpObserver::RRReceived
// ---------------------------------------------------------------------------
//
void CSVPRtpObserver::RRReceived( CMceSession& aSession,
    CMceMediaStream& aStream )
    {
    SVPDEBUG1( "CSVPRtpObserver::RRReceived" )
    
    CSVPRtpObserverRequest* assocReq = FindByMceSession( &aSession );
    if ( assocReq )
        {
        assocReq->RtcpPacketReceived(
            CSVPRtpObserverRequest::ERtcpRrPacket, aSession, aStream );
        }
    }

// ---------------------------------------------------------------------------
// CSVPRtpObserver::InactivityTimeout
// ---------------------------------------------------------------------------
//
void CSVPRtpObserver::InactivityTimeout( CMceMediaStream& /*aStream*/,
    CMceRtpSource& /*aSource*/ )
    {
    SVPDEBUG1( "CSVPRtpObserver::InactivityTimeout" )
    }

// ---------------------------------------------------------------------------
// CSVPRtpObserver::SsrcAdded
// ---------------------------------------------------------------------------
//
void CSVPRtpObserver::SsrcAdded( CMceMediaStream& /*aStream*/,
    CMceRtpSource& /*aSource*/, TUint /*aSsrc*/ )
    {
    SVPDEBUG1( "CSVPRtpObserver::SsrcAdded" )
    }

// ---------------------------------------------------------------------------
// CSVPRtpObserver::SsrcRemoved
// ---------------------------------------------------------------------------
//
void CSVPRtpObserver::SsrcRemoved( CMceMediaStream& /*aStream*/,
    CMceRtpSource& /*aSource*/, TUint /*aSsrc*/ )
    {
    SVPDEBUG1( "CSVPRtpObserver::SsrcRemoved" )
    }

// ---------------------------------------------------------------------------
// CSVPRtpObserver::AddSessionForObservingL
// ---------------------------------------------------------------------------
//
void CSVPRtpObserver::AddSessionForObservingL( CSVPSessionBase* aSession )
    {
    SVPDEBUG2( "CSVPRtpObserver::AddSessionForObservingL aSession: 0x%x",
        aSession )
        
    __ASSERT_ALWAYS( aSession, User::Leave( KErrArgument ) );
    __ASSERT_ALWAYS( !FindBySvpSession( aSession ),
        User::Leave( KErrAlreadyExists ) );
    
    CSVPRtpObserverRequest* req = CSVPRtpObserverRequest::NewLC( *aSession );
    iRequestArray.AppendL( req );
    CleanupStack::Pop( req );
    }

// ---------------------------------------------------------------------------
// CSVPRtpObserver::RemoveSessionFromObserving
// ---------------------------------------------------------------------------
//
TInt CSVPRtpObserver::RemoveSessionFromObserving( CSVPSessionBase* aSession )
    {
    SVPDEBUG2( "CSVPRtpObserver::RemoveSessionFromObserving aSession: 0x%x",
        aSession )
    
    TInt ret = KErrNone;
    if ( !aSession )
        {
        ret = KErrArgument;
        }
    else
        {
        CSVPRtpObserverRequest* todel = FindBySvpSession( aSession );
        if ( todel )
            {
            TInt index = iRequestArray.Find( todel );
            iRequestArray.Remove( index );
            delete todel;
            }
        else
            {
            ret = KErrNotFound;
            }
        }
        
    SVPDEBUG2( "CSVPRtpObserver::RemoveSessionFromObserving ret: %d", ret )
    
    return ret;
    }

// ---------------------------------------------------------------------------
// CSVPRtpObserver::ResetSessionInObserving
// ---------------------------------------------------------------------------
//
TInt CSVPRtpObserver::ResetSessionInObserving( CSVPSessionBase* aSession )
    {
    SVPDEBUG2( "CSVPRtpObserver::ResetSessionInObserving aSession: 0x%x",
        aSession )
    
    TInt ret = KErrNone;
    if ( !aSession )
        {
        ret = KErrArgument;
        }
    else
        {
        CSVPRtpObserverRequest* toreset = FindBySvpSession( aSession );
        if ( toreset )
            {
            toreset->Reset();
            }
        else
            {
            ret = KErrNotFound;
            }
        }
    
    SVPDEBUG2( "CSVPRtpObserver::ResetSessionInObserving ret: %d", ret )
    
    return ret;
    }

// ---------------------------------------------------------------------------
// CSVPRtpObserver::FindBySvpSession
// ---------------------------------------------------------------------------
//
CSVPRtpObserverRequest* CSVPRtpObserver::FindBySvpSession(
    const CSVPSessionBase* aSession )
    {
    TInt count = iRequestArray.Count();
    CSVPRtpObserverRequest* ret( NULL );
    while( count-- && !ret && aSession )
        {
        if ( aSession == iRequestArray[count]->SvpSession() )
            {
            ret = iRequestArray[count];
            }
        }
        
    SVPDEBUG2( "CSVPRtpObserver::FindBySvpSession ret: 0x%x", ret )
    
    return ret;
    }
    
// ---------------------------------------------------------------------------
// CSVPRtpObserver::FindByMceSession
// ---------------------------------------------------------------------------
//
CSVPRtpObserverRequest* CSVPRtpObserver::FindByMceSession(
    const CMceSession* aSession )
    {
    TInt count = iRequestArray.Count();
    CSVPRtpObserverRequest* ret( NULL );
    while( count-- && !ret && aSession )
        {
        if ( aSession == iRequestArray[count]->MceSession() )
            {
            ret = iRequestArray[count];
            }
        }
    
    SVPDEBUG2( "CSVPRtpObserver::FindByMceSession ret: 0x%x", ret )
    
    return ret;
    }