/*
* Copyright (c) 2004 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 "CMccController_stub.h"


void CMccControllerStub::OpenL ()
    {
    if ( !Stub() )
        {
        CMccControllerStub* self = new (ELeave) CMccControllerStub();
        CleanupStack::PushL( self );
        User::LeaveIfError( Dll::SetTls( self ) );
        CleanupStack::Pop( self );
        }
    }

void CMccControllerStub::Close ()
    {
    CMccControllerStub* self = Stub();
    delete self;
    Dll::SetTls( NULL );
    }

    
CMccControllerStub* CMccControllerStub::Stub()
    {
    return static_cast<CMccControllerStub*>(Dll::Tls());
    }
    
CMccControllerStub::CMccControllerStub()
    {
    Reset( ETrue );
    }

CMccControllerStub::~CMccControllerStub()
    {
    }
    

void CMccControllerStub::Reset( TBool aAll )
    {
    iActionPtr = 0;
    
    for( TInt i = 0; i < KMce_MM_MaxArray;i++)
        {
        iActions[ i ] = TAction();
        }   
    
    if ( aAll )
        {
        iSessionID = 0;
        iLinkID = KMce_MM_LinkIdBase;
        iStreamID = KMce_MM_StreamIdBase;
        iEndpointID = KMce_MM_EndpointIdBase;
        iRequireSignalling = ETrue;
        iRefCount = 0;
        iStreamExists = -1;

        for( TInt i = 0; i < KMce_MM_MaxArray;i++)
            {
            iCodecs[ i ] = TCodecInfo();
            }   
        for( TInt j = 0; j < KMce_MM_MaxArray;j++)
            {
            iLinks[ j ] = TLink();
            }   
        }
    
    iSetFmtpFailure = EFalse;    
    }
    
void CMccControllerStub::SetCodec( TCodecInfo aCodecInfo )
    {
    TInt i = 0;
    
    while( iCodecs[ i ].iStreamID != KMceNotAssigned &&
           iCodecs[ i ].iStreamID != aCodecInfo.iStreamID )
        {
        if ( i == KMce_MM_MaxArray - 1 )
            {
            User::Panic( _L(""), KErrNotFound );
            }
        else
            {
            i++;
            }
        }
    
    iCodecs[ i ] = aCodecInfo;       
    }

void CMccControllerStub::GetCodec( TCodecInfo& aCodecInfo )
    {
    TInt i = 0;
    
    while( iCodecs[ i ].iStreamID != aCodecInfo.iStreamID )
        {
        if ( i == KMce_MM_MaxArray - 1 )
            {
            User::Panic( _L(""), KErrNotFound );
            }
        else
            {
            i++;
            }
        }
    
    aCodecInfo = iCodecs[ i ];
    
    }

void CMccControllerStub::CreateStream( TLink aLink )
    {
    TInt i = 0;

    
    while( iLinks[ i ].iSessionID != KMceNotAssigned &&
           iLinks[ i ].iSessionID != aLink.iSessionID && 
           iLinks[ i ].iLinkID != aLink.iLinkID )
        {
        if ( i == KMce_MM_MaxArray - 1 )
            {
            User::Panic( _L(""), KErrNotFound );
            }
        else
            {
            i++;
            }
        }
    
    iLinks[ i ].iSessionID = aLink.iSessionID;
    iLinks[ i ].iLinkID = aLink.iLinkID;
    iLinks[ i ].iStreams++;
    
    }

CMccControllerStub::TLink& CMccControllerStub::GetLink( const TLink& aLink )
    {
    TInt i = 0;
    
    while( iLinks[ i ].iSessionID != aLink.iSessionID &&
           iLinks[ i ].iLinkID != aLink.iLinkID )
        {
        if ( i == KMce_MM_MaxArray - 1 )
            {
            User::Panic( _L(""), KErrNotFound );
            }
        else
            {
            i++;
            }
        }
    
    return iLinks[ i ];
    
    }
    
    
TUint32 CMccControllerStub::NextSessionId()
    {
    return iSessionID++;
    }

TUint32 CMccControllerStub::NextLinkId()
    {
    return iLinkID++;
    }

TUint32 CMccControllerStub::NextStreamId()
    {
    return iStreamID++;
    }

TUint32 CMccControllerStub::NextEndpointId()
    {
    if ( !iEndpointID )
        {
        iEndpointID++;
        }
    return iEndpointID++;
    }
    
TBool CMccControllerStub::StreamsExists( TUint32 aSessionId, 
                                         TUint32 aLinkId )
    {
    TLink link;
    link.iSessionID = aSessionId;
    link.iLinkID = aLinkId;
        
    return iStreamExists == -1 ? GetLink( link ).iStreams > 0 : iStreamExists == 1;
    }
    

    
    
TInt CMccControllerStub::ControllerCalled( TMMCActionType aAction,
                                           TUint32 aSessionID,
                                           TUint32 aLinkID,
                                           TUint32 aStreamID,
                                           TUint32 aEndpointID,
                                           TUint32 aLinkType,
                                           TUint32 aStreamType )
                                           
    {
    TAction action;
    action.iAction = aAction;
    action.iSessionID = aSessionID;
    action.iLinkID = aLinkID;
    action.iStreamID = aStreamID;
    action.iEndpointID = aEndpointID;
    action.iLinkType = aLinkType;
    action.iStreamType = aStreamType;
    action.iPaused = KMceNotAssigned;
    action.iEnableRTCP = KMceNotAssigned;
    
    iActions[ iActionPtr++ ] = action;
    iActionPtr = iActionPtr < KMce_MM_MaxArray-1 ? iActionPtr : 0;
    
    if ( aAction == EMccCreateStream )
        {
        TLink link;
        link.iSessionID = aSessionID;
        link.iLinkID = aLinkID;
        CreateStream( link );
        
        }
    else if ( aAction == EMccDeleteStream )
        {
        TLink link;
        link.iSessionID = aSessionID;
        link.iLinkID = aLinkID;
        TLink& l = GetLink( link );
        l.iStreams--;
        }
        
    return iLeaveError;
    
    }

TInt CMccControllerStub::ControllerStreamCtrCalled( TMMCActionType aAction,
                                                    TUint32 aSessionID,
                                                    TUint32 aLinkID,
                                                    TUint32 aStreamID,
                                                    TUint32 aEndpointID,
                                                    TUint32 aPaused,
                                                    TUint32 aEnableRTCP )
                                           
    {
    TAction action;
    action.iAction = aAction;
    action.iSessionID = aSessionID;
    action.iLinkID = aLinkID;
    action.iStreamID = aStreamID;
    action.iEndpointID = aEndpointID;
    action.iLinkType = KMceNotAssigned;
    action.iStreamType = KMceNotAssigned;
    action.iPaused = aPaused;
    action.iEnableRTCP = aEnableRTCP;
    action.iKey = KMceNotAssigned;
    action.iParamSet = KMceNotAssigned;
    
    iActions[ iActionPtr++ ] = action;

    iActionPtr = iActionPtr < KMce_MM_MaxArray-1 ? iActionPtr : 0;

    if ( aAction == EMccCreateStream )
        {
        TLink link;
        link.iSessionID = aSessionID;
        link.iLinkID = aLinkID;
        CreateStream( link );
        
        }
    else if ( aAction == EMccDeleteStream )
        {
        TLink link;
        link.iSessionID = aSessionID;
        link.iLinkID = aLinkID;
        TLink& l = GetLink( link );
        l.iStreams--;
        }
        
    
    return iLeaveError;
    
    }


TInt CMccControllerStub::ControllerStreamSettings(  TUint32 aSessionID,
                                                    TUint32 aLinkID,
                                                    TUint32 aStreamID,
                                                    TUint32 aEndpointID,
                                                    TUint32 aKey,
                                                    TUint32 aSet )
    {
    TAction action;
    action.iAction = EMccStreamSettings;
    action.iSessionID = aSessionID;
    action.iLinkID = aLinkID;
    action.iStreamID = aStreamID;
    action.iEndpointID = aEndpointID;
    action.iLinkType = KMceNotAssigned;
    action.iStreamType = KMceNotAssigned;
    action.iPaused = KMceNotAssigned;
    action.iEnableRTCP = KMceNotAssigned;
    action.iKey = aKey;
    action.iParamSet = aSet;
    
    iActions[ iActionPtr++ ] = action;

    iActionPtr = iActionPtr < KMce_MM_MaxArray-1 ? iActionPtr : 0;

    return iLeaveError;
    
    
    }

TInt CMccControllerStub::ControllerSignal(  TUint32 aSessionID,
                                            TUint32 aLinkID,
                                            TUint32 aStreamID,
                                            TUint32 aEndpointID,
                                            TUint32 aEventType )
    {
    TAction action;
    action.iAction = EMccSendMediaSignal;
    action.iSessionID = aSessionID;
    action.iLinkID = aLinkID;
    action.iStreamID = aStreamID;
    action.iEndpointID = aEndpointID;
    action.iLinkType = KMceNotAssigned;
    action.iStreamType = KMceNotAssigned;
    action.iPaused = KMceNotAssigned;
    action.iEnableRTCP = KMceNotAssigned;
    action.iKey = KMceNotAssigned;
    action.iParamSet = KMceNotAssigned;
    action.iEventType = aEventType;
    
    iActions[ iActionPtr++ ] = action;

    iActionPtr = iActionPtr < KMce_MM_MaxArray-1 ? iActionPtr : 0;

    return iLeaveError;
    
    
    }




    
//end of file