rtpsender.h

Go to the documentation of this file.

// ##########################################################################
// ####                                                                  ####
// ####                      RTP Audio Server Project                    ####
// ####                    ============================                  ####
// ####                                                                  ####
// #### RTP Sender                                                       ####
// ####                                                                  ####
// #### Version 1.00  --  February 16, 2001                              ####
// ####                                                                  ####
// #### Copyright (C) 1999  Thomas Dreibholz                             ####
// ####               2000  Universität Bonn, Abt. IV                    ####
// ####               2001  EMail: dreibh@iem.uni-due.de                 ####
// ####                     WWW:   https://www.uni-due.de/~be0001        ####
// ####                                                                  ####
// ##########################################################################


#ifndef RTPSENDER_H
#define RTPSENDER_H


#include "system.h"
#include "timedthread.h"
#include "socket.h"
#include "rtppacket.h"
#include "encoderinterface.h"
#include "trafficshaper.h"
#ifdef USE_TRANSPORTINFO
#include "extendedtransportinfo.h"
#else
#include "abstractqosdescription.h"
#include "bandwidthmanager.h"
#endif


namespace Coral {


class RTPSender :
#ifndef USE_TRANSPORTINFO
   virtual public ManagedStreamInterface,
#endif
   public TimedThread
{
   // ====== Constructor/Destructor =========================================
   public:
   RTPSender();

   RTPSender(const card32      ssrc,
             EncoderInterface* encoder,
             Socket*           senderSocket,
             const cardinal    maxPacketSize = 1500
#ifndef USE_TRANSPORTINFO
                     ,BandwidthManager* bwManager = NULL
#endif
                     );

   ~RTPSender();


   // ====== Initialize =====================================================
   void init(const card32      ssrc,
             EncoderInterface* encoder,
             Socket*           senderSocket,
             const cardinal    maxPacketSize = 1500
#ifndef USE_TRANSPORTINFO
             ,BandwidthManager* bwManager = NULL
#endif
             );



   // ====== Quality control ================================================

#ifdef USE_TRANSPORTINFO

   void adaptQuality(const double fractionLost, const cardinal layer);

   // ====== Transport info =================================================
   void getTransportInfo(ExtendedTransportInfo& transportInfo,
                         const bool             calculateLevels = true);

   void setTransportInfo(ExtendedTransportInfo& transportInfo,
                         const bool             calculateLevels = true);

#else

   AbstractQoSDescription* getQoSDescription(const card64 offset);

   void updateQuality(const AbstractQoSDescription* aqd);

   void lock();

   void unlock();

#endif


   // ====== Packet size ====================================================
   inline cardinal getMaxPacketSize() const;

   inline cardinal setMaxPacketSize(const cardinal size);


   // ====== Transmission control ===========================================
   inline bool paused() const;


   inline bool transmissionErrorDetected();


   inline void setPause(const bool on);


   inline card64 getBytesSent() const;   
      
   inline card64 getPacketsSent() const;

   inline void resetBytesSent();
   
   inline void resetPacketsSent();
  

   // ====== Private data =================================================== 
   private:
   void timerEvent();

   
   private:
   EncoderInterface* Encoder;
   Socket*           SenderSocket;

   cardinal      FramesPerSecond;
   cardinal      RenewCounter;
   cardinal      MaxPacketSize;
   card32        SSRC;
   card64        BytesSent;
   card64        PacketsSent;
   card64        TimeStamp;

   card32        PayloadBytesSent;
   card32        PayloadPacketsSent;

   bool          Pause;
   bool          TransmissionError;


   InternetFlow  Flow[RTPConstants::RTPMaxQualityLayers];
   card16        SequenceNumber[RTPConstants::RTPMaxQualityLayers];


#ifdef USE_TRANSPORTINFO

   void update(const TransportInfo& transportInfo);

   cardinal     UnitBytesCheckCounter;
   card64       UnitBytesSent[RTPConstants::RTPMaxQualityLayers];
   cardinal     UnitPacketsSent[RTPConstants::RTPMaxQualityLayers];
   cardinal     PacketsPerSecond[RTPConstants::RTPMaxQualityLayers];
   card64       BytesPerSecond[RTPConstants::RTPMaxQualityLayers];

#else

   void update(const AbstractQoSDescription* aqd);

   BandwidthManager* BandwidthMgr;
   cardinal          Bandwidth[RTPConstants::RTPMaxQualityLayers];
   double            BufferDelay[RTPConstants::RTPMaxQualityLayers];

#endif

#ifdef USE_TRAFFICSHAPER
   TrafficShaper SenderReportBuffer;
   TrafficShaper Shaper[RTPConstants::RTPMaxQualityLayers];
#endif
};


}


#include "rtpsender.icc"


#endif