/*
* Copyright (c) 2002-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:    RTP Keepalive mechanism
*
*/




// INCLUDE FILES
#include <e32math.h>
#include "mccrtpkeepalivecontainer.h"
#include "mccrtpkeepalive.h"
#include "mccdef.h"
#include "mccinternaldef.h"
#include "mccsubcontrollerlogs.h"
#include "mccinternalevents.h"
#include "mccrtpinterface.h"


// EXTERNAL DATA STRUCTURES

// EXTERNAL FUNCTION PROTOTYPES  

// CONSTANTS

// MACROS

// LOCAL CONSTANTS AND MACROS

// MODULE DATA STRUCTURES

// LOCAL FUNCTION PROTOTYPES

// FORWARD DECLARATIONS


// ============================= LOCAL FUNCTIONS =============================


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

// ---------------------------------------------------------------------------
// CMccRtpKeepaliveContainer::NewL
// ---------------------------------------------------------------------------
//
CMccRtpKeepaliveContainer* CMccRtpKeepaliveContainer::NewL( 
    MAsyncEventHandler& aEventHandler,
    CRtpAPI& aRtpAPI,
    TRtpId aRtpSessionId )
    {
    CMccRtpKeepaliveContainer* self = 
        new ( ELeave ) CMccRtpKeepaliveContainer( aEventHandler,
                                                  aRtpAPI,
                                                  aRtpSessionId );
                                                  
    return self;  
    }

// ---------------------------------------------------------------------------
// CMccRtpKeepaliveContainer::~CMccRtpKeepaliveContainer
// ---------------------------------------------------------------------------
//        
CMccRtpKeepaliveContainer::~CMccRtpKeepaliveContainer()
    {
    iKeepaliveHandlers.ResetAndDestroy();
    }

// ---------------------------------------------------------------------------
// CMccRtpKeepaliveContainer::StartKeepaliveL
// ---------------------------------------------------------------------------
//
void CMccRtpKeepaliveContainer::StartKeepaliveL( 
    MMccRtpInterface& /*aUser*/, 
    TMccCodecInfo& /*aCodecInfo*/,
    CMccRtpMediaClock& /*aRtpMediaClock*/ )
    {
    __SUBCONTROLLER( "CMccRtpKeepalive::StartKeepaliveL()" )
    
    iStopped = EFalse;
    
    /*
    if ( aCodecInfo.iKeepaliveInterval > 0 && !iStopped )
        {
        __SUBCONTROLLER( "CMccRtpKeepalive::StartKeepaliveL(), interval defined" )
        
        CMccRtpKeepalive* handler = FindKeepaliveHandler( aCodecInfo.iKeepalivePT );
        if ( !handler )
            {
            handler = CMccRtpKeepalive::NewL( iEventHandler, 
                                              iRtpAPI, 
                                              iRtpSessionId, 
                                              aCodecInfo.iKeepalivePT,
                                              aCodecInfo.iKeepaliveInterval,
                                              aCodecInfo.iKeepaliveData,
                                              iRemoteAddressSet );
            CleanupStack::PushL( handler );
            iKeepaliveHandlers.AppendL( handler ); 
            CleanupStack::Pop( handler );                                                                  
            }
        handler->StartKeepaliveL( aUser );
        }
        */
    }

// ---------------------------------------------------------------------------
// CMccRtpKeepaliveContainer::StopKeepalive
// ---------------------------------------------------------------------------
//        
TInt CMccRtpKeepaliveContainer::StopKeepalive( 
    MMccRtpInterface& /*aUser*/, 
    const TMccCodecInfo& /*aCodecInfo*/ )
    {
    
    iStopped = ETrue;
    
    /*
    TInt err( KErrNotFound );
    CMccRtpKeepalive* handler = FindKeepaliveHandler( aCodecInfo.iKeepalivePT );
    if ( handler )
        {
        TInt refCount( 0 );
        err = handler->StopKeepalive( aUser, refCount );
        if ( !refCount )
            {
            // No more users, can be removed
            TInt index = iKeepaliveHandlers.Find( handler );
            if ( index != KErrNotFound )
                {
                delete iKeepaliveHandlers[ index ];
                iKeepaliveHandlers.Remove( index );
                }
            }
        }
    return err;
    */
    return KErrNone;
    }
    
// ---------------------------------------------------------------------------
// CMccRtpKeepaliveContainer::ResetKeepAliveTimer
// ---------------------------------------------------------------------------
//    
void CMccRtpKeepaliveContainer::ResetKeepaliveTimer()
    {
/*    TInt count = iKeepaliveHandlers.Count();        
    for ( TInt i = 0; i < count; i++ )
        {
        iKeepaliveHandlers[ i ]->ResetKeepaliveTimer();
        }*/        
    }    

// ---------------------------------------------------------------------------
// CMccRtpKeepaliveContainer::UpdateParamsL
// ---------------------------------------------------------------------------
//  
void CMccRtpKeepaliveContainer::UpdateParamsL( MMccRtpInterface& aUser,
    const TMccCodecInfo& aCodecInfo )
    {
    }

// ---------------------------------------------------------------------------
// CMccRtpKeepaliveContainer::StopAll
// ---------------------------------------------------------------------------
//    
void CMccRtpKeepaliveContainer::StopAll()
    {
    iKeepaliveHandlers.ResetAndDestroy();
    iStopped = ETrue;
    }

// ---------------------------------------------------------------------------
// CMccRtpKeepaliveContainer::RemoteAddressSet
// ---------------------------------------------------------------------------
//   
TInt CMccRtpKeepaliveContainer::RemoteAddressSet()
    {
    /*TInt err( KErrNotReady );
    iRemoteAddressSet = ETrue;
    if ( !iStopped )
        {
        err = KErrNone;
        for ( TInt i = 0; i < iKeepaliveHandlers.Count(); i++ )
            {
            err |= iKeepaliveHandlers[ i ]->RemoteAddressSet();
            }
        }
    return err;*/
    }

// ---------------------------------------------------------------------------
// CMccRtpKeepaliveContainer::FindKeepaliveHandler
// ---------------------------------------------------------------------------
//   
CMccRtpKeepalive* CMccRtpKeepaliveContainer::FindKeepaliveHandler( 
    TUint8 aKeepAlivePT, MMccRtpInterface& aUser )
    {
    /*CMccRtpKeepalive* handler = NULL;
    for ( TInt i = 0; i < iKeepaliveHandlers.Count() && !handler; i++ )
        {
        if ( aUser.IsSink() )
            {
            if ( iKeepaliveHandlers[ i ]->StreamId() == aUser.RtpStreamId() )
                {
                handler = iKeepaliveHandlers[ i ];
                }
            }
        else
            {
            if ( iKeepaliveHandlers[ i ]->PayloadType() == aKeepAlivePayloadType )
                {
                handler = iKeepaliveHandlers[ i ];
                }
            }
        }
    return handler;*/
    }
    
// ---------------------------------------------------------------------------
// CMccRtpKeepaliveContainer::CMccRtpKeepaliveContainer
// ---------------------------------------------------------------------------
//        
CMccRtpKeepaliveContainer::CMccRtpKeepaliveContainer( 
    MAsyncEventHandler& aEventHandler,
    CRtpAPI& aRtpAPI,
    TRtpId aRtpSessionId ) :
    iEventHandler( aEventHandler ), 
    iRtpAPI( aRtpAPI ),
    iRtpSessionId( aRtpSessionId )
    {
    }      

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

//  End of File