RTCPEndsystemModule.h

Go to the documentation of this file.

/***************************************************************************
                          RTCPEndsystemModule.h  -  description
                             -------------------
    begin                : Sun Oct 21 2001
    copyright            : (C) 2001 by Matthias Oppitz
    email                : Matthias.Oppitz@gmx.de
 ***************************************************************************/

/***************************************************************************
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; either version 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *                                                                         *
 ***************************************************************************/

#ifndef __RTCPENDSYSTEMMODULE_H__
#define __RTCPENDSYSTEMMODULE_H__

#include "omnetpp.h"

#include "sockets.h"

#include "types.h"
#include "RTPInnerPacket.h"
#include "RTPParticipantInfo.h"
#include "RTPSenderInfo.h"
#include "RTPReceiverInfo.h"

class RTCPEndsystemModule : public cSimpleModule {

        Module_Class_Members(RTCPEndsystemModule, cSimpleModule, 0);
        
        virtual void initialize();
        
        virtual void handleMessage(cMessage *msg);
        
        protected:
        
                virtual void handleMessageFromRTP(cMessage *msg);
                
                virtual void handleMessageFromSocketLayer(cMessage *msg);
                
                virtual void handleSelfMessage(cMessage *msg);
                
                virtual void initializeRTCP(RTPInnerPacket *rinp);
                
                virtual void senderModuleInitialized(RTPInnerPacket *rinp);
                
                virtual void dataOut(RTPInnerPacket *packet);
                
                virtual void dataIn(RTPInnerPacket *rinp);
                
                virtual void leaveSession(RTPInnerPacket *rinp);
                
                virtual void socketRet(SocketInterfacePacket *sifpIn);
                
                virtual void connectRet(SocketInterfacePacket *sifpIn);
                
                virtual void readRet(SocketInterfacePacket *sifpIn);
                
        private:
        
                int _mtu;
                
                int _bandwidth;
                
                int _rtcpPercentage;
                
                IN_Addr _destinationAddress;
                
                IN_Port _port;
                
                bool _ssrcChosen;
                
                bool _leaveSession;
                
                RTPSenderInfo *_senderInfo;
                
                cArray *_participantInfos;
                
                Socket::Filedesc _socketFdIn;
                
                Socket::Filedesc _socketFdOut;
                
                int _packetsCalculated;
                
                double _averagePacketSize;

                cOutVector *_rtcpIntervalOutVector;
                
                virtual void createServerSocket();
                
                virtual void createClientSocket();
                
                virtual void chooseSSRC();
                
                virtual void scheduleInterval();
                
                virtual void createPacket();
                
                virtual void processOutgoingRTPPacket(RTPPacket *packet);
                
                virtual void processIncomingRTPPacket(RTPPacket *packet, IN_Addr address, IN_Port port);
                
                virtual void processIncomingRTCPPacket(RTCPCompoundPacket *packet, IN_Addr address, IN_Port port);
                
                virtual RTPParticipantInfo* findParticipantInfo(u_int32 ssrc);
                
                virtual void calculateAveragePacketSize(int size);
};

#endif

---