/*

* 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:    

*

*/

#ifndef MCCQOSCONTROLLER_H

#define MCCQOSCONTROLLER_H

//  INCLUDES

#include <e32base.h>

#include "mccrateadaptationdef.h"

#include "mccinternalevents.h"

#include "mmccevents.h"

// CONSTANTS

// MACROS

// DATA TYPES

// FUNCTION PROTOTYPES

// FORWARD DECLARATIONS

class MMccRateAdaptationObserver;

class MMccResources;

class TMccEvent;

class CDeltaTimer;

class MDataSink;

class MDataSource;

// CLASS DECLARATION

class TMccQosControllerIcmpError

    {

    public:

        TMccQosControllerIcmpError() :

            iLinkId( 0 ),

            iErrorTimeWindowBeginning( 0 ),

            iErrorCount( 0 )

            {

            }

    public:

        TUint32 iLinkId;

        TTime iErrorTimeWindowBeginning;

        TInt iErrorCount;

    };

/**

*

*/

class CMccQosController : public CBase

    {

    public:  // Constructors and destructor

        /**

        * Two-phased constructor.

        */

        IMPORT_C static CMccQosController* NewL( MMccRateAdaptationObserver& aObserver, 

                                        MMccResources& aResources );

        /**

        * Destructor.

        */

        IMPORT_C ~CMccQosController();

    public: // New functions

        /**

        * Processes event if it is qos related.

        * @param aEvent

        * @return ETrue if event should be ignored, otherwise EFalse

        */

        IMPORT_C TBool EventReceived( const TMccEvent& aEvent );       

    public: // Functions from base classes       

    protected:  // New functions

    protected:  // Functions from base classes

    private:

        /**

        * C++ default constructor.

        */

        CMccQosController( MMccRateAdaptationObserver& aObserver,

                           MMccResources& aResources );

        /**

        * By default Symbian 2nd phase constructor is private.

        */

        void ConstructL();

        void DoAdaptationCalculations();

        void FillRateAdaptationEvent();

        void ClearRateEventData();

        /**

		*Starts timer of type CDeltaTimer, 

		*which callback is AsyncTimerExpired function

		*/

		void StartTimerForAsync();

		/**

		* A callback for CDeltaTimer

		*/

		static TInt AsyncTimerExpired(TAny* aPtr);

        void GetSinkSources();

        void CheckRateChangeResult(TInt aValue);

        TBool HandleIcmpError( const TMccEvent& aEvent );

        static TBool IcmpErrorMatch( const TMccQosControllerIcmpError& aError1, 

                                     const TMccQosControllerIcmpError& aError2 );

        static TBool IcmpErrorCleanup( const TMccQosControllerIcmpError& aError1, 

                                       const TMccQosControllerIcmpError& aError2 );

        void DoAdaptation();

        TInt GetShortTermComparisonDelay();

        TInt CalculateDelayOfShortTermPeriod();

    public:     // Data

    protected:  // Data

    private:    // Data

        MMccRateAdaptationObserver& iMainObserver;

        MMccResources& 				iResources;

        TInt 						iRoundTripTime;

        TRtpPeerStat 				iStreamStat;

        TMccRateAdaptationEventData iRateEventData;

        TMccEvent					iEvent;

        TMccEvent					iResultEvent;

        TThresholdValues 			iThresholdValues; //rate control threshold values

        CDeltaTimer* 				iDeltaTimer;

        TCallBack 					iDeltaTimerCallBack;

		TDeltaTimerEntry 			iDeltaTimerEntry;

       TBool						iBitRateChanged;

       TUint						iEventCounter;

       TBool                        iAdapted;

       TInt                         iRoundTripDelayOfPreviousShortPeriod;

       TInt                         iRoundTripDelays[ KMccShortTermCalculation ];

        RArray<TMccQosControllerIcmpError> iIcmpErrors;

    public:     // Friend classes

    protected:  // Friend classes

    private:    // Friend classes

    #ifdef TEST_EUNIT

    friend class UT_CMccQosController;

    #endif

    };

#endif      // MCCQOSCONTROLLER_H   

// End of File