examples/MultimediaProtocols/RTPExample/inc/RTPFileStreamer.h

// Copyright (c) 2005-2009 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 __RTPFILESTREAMER_H__
#define __RTPFILESTREAMER_H__

#include "commdbconnpref.h"
#include <in_sock.h>
#include <f32file.h>
#include <rtp.h>


class MFileStreamerObserver
{
public:
        virtual void NotifyPacketSent() {}
        virtual void NotifyPacketReceived() {}
        virtual void NotifyComplete() {}
        virtual void NotifyError() {}
};



class CRtpFileSender : public CActive
{
public:
        //Callbacks for the sender
        static void PacketSent(CRtpFileSender* aPtr, const TRtpEvent& aEvent);
        void DoPacketSent(const TRtpEvent& aEvent);
        static void SendError(CRtpFileSender* aPtr, const TRtpEvent& aEvent);
        void DoSendError(const TRtpEvent& aEvent);
        static CRtpFileSender* NewL(RRtpSession& aSession,RFs& aFs,const TDesC& aSrcFilename, TInt aPacketSize, TInt aDelayMicroSeconds);
        void StartL();
        void SetObserver(MFileStreamerObserver& aObserver)
                {
                iObserver = &aObserver;
                }
        ~CRtpFileSender();
private:
        CRtpFileSender(RRtpSession& aSession,RFs& aFs,TInt aPacketSize, TInt aDelayMicroSeconds);
        void ConstructL(const TDesC& aSrcFilename);
        void RunL();
        void DoCancel();
        

private:
        RTimer  iSendIntervalTimer;
        TInt    iDelayMicroSecs;
        TInt    iPacketSize;
        RRtpSession&    iSession;
        RRtpSendSource  iSendSrc;
        RRtpSendPacket  iSendPacket;
        TPtr8                   iPayloadDesC;
        MFileStreamerObserver*  iObserver;
        RFile   iFile;
        RFs&    iFs;
};




class CRtpFileStreamer : public CBase
{
public:

    static CRtpFileStreamer* NewL(      RSocketServ& aRSocketServ,
                                                                const TDesC& aSrcFilename,
                                                                const TDesC& aDestFilename, 
                                                                TInt aBlockLen,
                                                                const TInetAddr& aDestAddr,
                                                                TUint aLocalPort,TInt aConnId);
    
    ~CRtpFileStreamer();
        //Callbacks for the receiver
        static void NewSource(CRtpFileStreamer* aPtr, const TRtpEvent& aEvent);
        static void PacketArrived(CRtpFileStreamer* aPtr, const TRtpEvent& aEvent);
        inline RRtpReceiveSource& ReceiveSrc() 
                {
                return iRtpRecvSrc;
                }
        void SendNextPacketL();
        void HandleReceivedPacketL();
        void SetObserver(MFileStreamerObserver& aObserver) 
                {
                iObserver = &aObserver;
                if (iSender) iSender->SetObserver(aObserver);
                }
        void StartL();
        
private:
   CRtpFileStreamer( RSocketServ& aSocketServ, const TInetAddr& aDestAddr, TUint aLocalPort);
   void ConstructL(const TDesC& aSrcFilename, const TDesC& aDestFilename, TInt aPacketSize, TInt aDelayMicroSecs, TInt aConnId);
public:
        RRtpReceivePacket iRecvPacket;
private:
    RSocketServ& iSocketServ;
    RSocket iSocket;
        RSocket iRtcpSocket;
        RConnection     iConnection;
        TInetAddr                       iDestAddr;
        TUint                           iLocalPort;
    RRtpSession                 iRtpSession;
    RRtpReceiveSource   iRtpRecvSrc;
        MFileStreamerObserver*  iObserver;
        CRtpFileSender* iSender;
        RFs             iRFs;
        RFile   iDestFile;
};


#endif //__RTPFILESTREAMER_H__

---