// Copyright (c) 2007-2009 Nokia Corporation and/or its subsidiary(-ies).

/*

* 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: Header for class specific to rtp functional tests

*

*/

#ifndef __RTPTESTAPP_H

#define __RTPTESTAPP_H

#include "rtpapi.h"

// Class Declaration

class CRtpTestApp : public CBase, public MRtpErrNotify, public MRtcpObserver, public MRtpObserver, public MRtpPostProcessingObserver

	{

public:

    static CRtpTestApp*  NewL();

    void ConstructL();

    void SendRtpPacketL();

    void SendRtpPacketLoopbackL();

    void SendZeroLengthRtpPacketL();

	~CRtpTestApp();

	//From observer interface

    void ErrorNotify( TInt aErrCode ) ;

    // from MRtcpObserver

    void SdesReceived( TRtpSSRC aSSRC,

                       const TRtpSdesParams& aParams );

    void ByeReceived( TRtpId aStreamId, TRtpSSRC aSSRC,

                      const TDesC8& aReason );

    void AppReceived( TRtpId aStreamId, TRtpSSRC aSSRC,

                      const TRtcpApp& aApp );

    void SrReceived( TRtpId aStreamId, TRtpSSRC aSSRC,

                     const TTimeStamps& aTimeStamps );

    void RrReceived( TRtpId aStreamId, TRtpSSRC aSSRC );

    // From MRtpObserver

    void RtpPacketReceived( TRtpId aStreamId, const TRtpRecvHeader& aHeaderInfo, const TDesC8& aPayloadData );

    // From MRtpPostProcessingObserver

    void ReadyToSendRtpPacket( TRtpId aTranStreamId, TPtr8 &aPacket );

	TInt iError;

	TBool iIgnoreIncrease;

	private:

    CRtpTestApp();

	CRtpAPI* iRtpApi ;

    TRtpSdesParams iParams;

    TCreateSessionParams iSessionParams;

    TBool       iEnableRtcp;

    TRtcpParams iRtcpParams;

    TRtpId iSessionId1;

    TRtpId iSessionId2;  

    TUint iPort1;

    TUint iPort2;

    CArrayFixFlat<TUint32>* iCsrclist;

    TInt iNoOfRtpPackets;

    TRtpId iS1T1;

    TRtpId iS2R1;

	};

class CrtpDataSender: public CActive

    {

public:

    static CrtpDataSender* NewL(CRtpAPI* aRtpApi, TRtpId sessId)

        {

        CrtpDataSender *pSelf = new(ELeave) CrtpDataSender();

        pSelf->iRtpApi = aRtpApi;

        pSelf->iSessId = sessId;

        return pSelf;

        }

    virtual void DoCancel()

        {

        iRtpApi->CancelSend(iSessId);

        }

    void RunL();

    void SendRtpData( TRtpSendPktParams& aHeaderInfo , TArray<TRtpCSRC> aCSRCList)

        {

        aHeaderInfo.iStatus = &iStatus;

        iRtpApi->SendRtpPacket(aHeaderInfo, aCSRCList);

        SetActive();

        }

private:

    CrtpDataSender():CActive(EPriorityStandard)

        {

        CActiveScheduler::Add(this);

        }

    CRtpAPI *iRtpApi;

    TRtpId  iSessId;

    };

#endif