/*

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

#define __RTPCOMM_H

// INCLUDES

#include "rtpcommdef.h"

#include "rtpcommrecv.h"

#include "rtpcommsend.h"

/**

*  Class for socket communication. 

*

*  @lib RtpService.dll

*/

class CRtpComm : public CBase

    {

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

    // Friend class used for testing

        friend class CRtpUtRtpComm;

        friend class CRtpUtRtpSession;

    #endif 

    public:

        static CRtpComm* NewL( TUint& aLocalPort, 

                               RSocketServ& aSocketServ,

                               RConnection& aRConn, 

                               const TCreateSessionParams& aParams,

                               MRtpErrNotify& aErrNotify,

                               TBool aEnableRtcp );

        ~CRtpComm();

        /**

        * Create the resources necessary for sending RTP, and RTCP if necessary

        */

        void ConstructSenderL(TInetAddr& aRtpAddr, TInetAddr& aRtcpAddr);

        /**

        * Create the resources necessary for receiving RTP, and RTCP if

        * necessary.

        */

        void ConstructReceiverL(TBool aNonRtpObserverSet);

        TInt SetToAddress( TPortType aPortType, TInetAddr& aAddr );

        void SetAcceptedFromAddress(TInetAddr& aAddr);

        void SetRecvCallback( TPortType aPortType, TCallBack& aCallback );

        TInt Send( TPortType aPortType, const TDesC8& aSendBuf );

        void Send( TPortType aPortType, const TDesC8& aSendBuf,

                   TRequestStatus& aStatus ); 

        void CancelSend( TPortType aPortType );

        TInt Receive( TPortType aPortType, TDes8& aRecvBuf );

        void RegisterReceivedNotify( MReceivedNotify* aNotify );

        RSocket* GetSocket( TPortType aPortType );

        void SetNonRtpObserverFlag(TBool aValue);

        TInt MaxSocketSize();

    private:

        CRtpComm();

        void ConstructL( TUint& aLocalPort, 

                         RSocketServ& aSocketServ,             

                         RConnection& aRConn, 

                         const TCreateSessionParams& aParams,

                         MRtpErrNotify& aErrNotify,

                         TBool aEnableRtcp );

        void Close();

   	protected:

   		CRtpCommRecv* iReceiver[KMaxPorts];

    private:

        RSocket iSocket[KMaxPorts];

        CRtpCommSend* iSender[KMaxPorts];

        TUint iPriority;

        MRtpErrNotify* iErrNotify;

        TBool iRtcpEnabled;

        MReceivedNotify* iReceivedNotify;

        TInt iSocketSize;

    private: 

    	friend class CRtpSession;	

    #ifdef EUNIT_TESTING

	  friend class UT_CRtpAPI;

	  friend class UT_CRtpComm;

	  friend class UT_CRtpSession;

	  friend class UT_CRtpSessionSrtp;

	#endif     	    

    };

#endif  // __RTPCOMM_H

// End of File