/*

* Copyright (c) 2004-2005 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 RtpRecvStream_H

#define RtpRecvStream_H

#include "rtpstream.h" // parent class

#include "rtpsdes.h" 

#include "rtpstreamdef.h"

/**

*  Derived class for RTP receive stream. 

*

*  @lib RtpService.dll

*/

class CRtpRecvStream : public CRtpStream

    {

    #if defined( _DEBUG ) && defined( RTP_UNIT_TEST )

	    //Friend class used for testing

	    friend class CRtpUtRtpStream; 

	    friend class CRtpUtRtpSession; 	    

    #endif 

    public:

        static CRtpRecvStream* NewL( const TRtpPayloadType aPayloadType,

                                     const TRtpId aSessionID,

                                     const TRtpId aRcvStreamID,

                                     MRtpObserver** aRtpObserver,

                                     MRtcpObserver* aRtcpObserver,

                                     const TUint32* aProfileRTPTimeRates,

                                     MSsrcCheckCallback* aCallback );

        ~CRtpRecvStream();

        TInt RtpStreamUpdateParamL( TRtpPacketType pType,

                                   TRtpPacketStreamParam* aStreamParam );

        void SetReceivedRTPPackets( TBool aFlag );

        void RegisterRtpObserver(MRtpObserver* aRtpObserver);        

        void UnRegisterRtpObserver();

        TInt RtpStreamProcessRtpPacketL( CRtpPacket* aPktRcv,

                                        TBool aAssignStream );

        TBool ReceivedRTPPackets() const;

        TInt GetRemoteStreamInfo( TRtpSdesParams& aSdes );

        TRtpSSRC GetRemoteSSRC();

    public: // from CRtpStream

        TInt ResetStreamStat();

        TInt GetStreamStat( TRtpPeerStat& aStat );

        TRtpRtcpEnum RtpStreamProcessRtcpReportSectionL( CRtpPacket* aPkt );

        void RtpStreamCreateRtcpReportSection( CRtpPacket* aPkt );

    public:

        CRtpSDES* iRemoteSDES;

    private:

        CRtpRecvStream( MSsrcCheckCallback* aCallback,

                        const TRtpPayloadType aPayloadType,

                        const TRtpId aSessionID,

                        const TRtpId aRcvStreamID,

                        MRtpObserver** aRtpObserver,

                        MRtcpObserver* aRtcpObserver,

                        const TUint32* aProfileRTPTimeRates );

        void ConstructL();

        void RtpStreamUpdateJitter( TRtpTimeStamp aCurrentTimeStamp );

        void RtpStreamSyncInfoInit();

        void RtpStreamJitterInit();

    private:

        // flag to indicate if a packet was received since last RTCP packet

        TBool iFlagReceivedRTPPackets;  

        TRtpTimeJitter iSyncJitter;

        // QoS statistics

        TUint32 iNumReceivedPackets;

        TUint32 iNumWrapAround;         // number of wrap around for 

        // backup of reported values for lost fraction calculation

        TUint32 iLastRR_numExpectedPackets;

        TUint32 iLastRR_numReceivedPackets;

        MRtpObserver** iRtpObserver; // RTP receive callback

        TRtpRecvHeader iHdr; // Header of received RTP packet

        TRtpHeaderExtension iHeaderExtension; // Header extension of RTP packet

        MSsrcCheckCallback* iCallback; // callback to CRtpSession

        TRtpSSRC iRemoteSSRC;

     private:    

	    #ifdef EUNIT_TESTING

		  friend class UT_CRtpStream;

		  friend class UT_CRtpSession;

		#endif     	    

    };

#endif	// RtpRecvStream_H