/*

* Copyright (c) 2004-2008 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 RtpCommSend_H

#define RtpCommSend_H

#include <es_sock.h>

#include <rtpdef.h>

#include "rtpsenditem.h"

#include "rtpcommdef.h"

#include "rtputil.h"

/**

*  Class definition for sending

*

*  @lib RtpService.dll

*/

class CRtpCommSend : public CActive

    {

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

    // Friend class used for testing

        friend class CRtpUtRtpCommSend;

    #endif 

    public:

        static CRtpCommSend* NewL( RSocket& aSocket, MRtpErrNotify& aErrNotify, 

                                   /*TInt aBufSize,*/ TInetAddr& aAddr ); 

        ~CRtpCommSend();

        TInt Send( const TDesC8& aPacket );

        void Send( const TDesC8& aPacket, TRequestStatus& aStatus );

        void CancelAsyncSend();

        void SetToAddress(TInetAddr& aAddr);

    protected: // from CActive

        /**

        * Cancel any outstanding operation

        */

        void DoCancel();

        /**

        * Called when operation complete

        */

        void RunL();

    private:

        CRtpCommSend( RSocket& aSocket, MRtpErrNotify& aErrNotify, TInetAddr& aAddr );

        void ConstructL( /*TInt aBufSize*/ );

        /**

        * Handle a 'write buffer empty' situation.

        */

        void SendNextPacket();

        /**

        * Remove Item From Queue

        */

        void RemoveFromQueue();

        /**

         * Complete and remove queue items.

         * @since S60 3.2.3

         * @param aError completion code

         */

        void CompleteAndRemoveRequests( TInt aError );

        /**

         * Complete client's request.

         * @since S60 3.2.3

         * @param aItem send item

         * @param aReason completion code

         */

        void CompleteClientRequest( CRtpSendItem& aItem, TInt aReason ) const;

    private: // Member data

        enum TWriteState 

            {

            ESending, EWaiting, ECommsFailed

            };

        RSocket&        iSocket;

        TInetAddr       iToAddr;

        TWriteState     iWriteStatus;

        TPtrC8          iBufPtr;  // As a data memeber to hold the packet point for

                                  // Asyn sending in case the sending packet is out of scope.

        MRtpErrNotify&  iRtpErrNotify; 

	    TSglQue <CRtpSendItem> iSendQue;

        /** List iterator - needed to delete all the items */

		TSglQueIter<CRtpSendItem> iQueueIter;

		#ifdef EUNIT_TESTING

	  	friend class UT_CRtpAPI;

	  	friend class UT_CRtpSession;

	  	friend class UT_CRtpSessionSrtp;

	  	friend class UT_CRtpComm;

		#endif     	    

           };

#endif	// RtpCommSend_H