rtpsender.h

Go to the documentation of this file.

// ##########################################################################
// ####                                                                  ####
// ####                      RTP Audio Server Project                    ####
// ####                    ============================                  ####
// ####                                                                  ####
// #### RTP Sender                                                       ####
// ####                                                                  ####
// ####           Copyright (C) 1999-2012 by Thomas Dreibholz            ####
// ####                                                                  ####
// #### Contact:                                                         ####
// ####    EMail: dreibh@iem.uni-due.de                                  ####
// ####    WWW:   https://www.nntb.no/~dreibh/rtpaudio                ####
// ####                                                                  ####
// #### ---------------------------------------------------------------- ####
// ####                                                                  ####
// #### 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 3 of   ####
// #### the License, or (at your option) any later version.              ####
// ####                                                                  ####
// #### This program is distributed in the hope that it will be useful,  ####
// #### but WITHOUT ANY WARRANTY; without even the implied warranty of   ####
// #### MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the    ####
// #### GNU General Public License for more details.                     ####
// ####                                                                  ####
// #### You should have received a copy of the GNU General Public        ####
// #### License along with this program.  If not, see                    ####
// #### <http://www.gnu.org/licenses/>.                                  ####
// ####                                                                  ####
// ##########################################################################
// $Id: rtpsender.h 1286 2011-12-18 13:43:16Z dreibh $


#ifndef RTPSENDER_H
#define RTPSENDER_H


#include "tdsystem.h"
#include "timedthread.h"
#include "tdsocket.h"
#include "rtppacket.h"
#include "encoderinterface.h"
#include "trafficshaper.h"
#include "abstractqosdescription.h"
#include "qosmanagerinterface.h"


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

   RTPSender(const InternetFlow&  flow,
             const card32         ssrc,
             EncoderInterface*    encoder,
             Socket*              senderSocket,
             const card32         controlPPID,
             const card32         dataPPID,
             const cardinal       maxPacketSize = 1500,
             QoSManagerInterface* qosManager     = NULL);

   ~RTPSender();


   // ====== Initialize =====================================================
   void init(const InternetFlow&  flow,
             const card32         ssrc,
             EncoderInterface*    encoder,
             Socket*              senderSocket,
             const card32         controlPPID,
             const card32         dataPPID,
             const cardinal       maxPacketSize = 1500,
             QoSManagerInterface* qosManager    = NULL);



   // ====== Quality control ================================================
   AbstractQoSDescription* getQoSDescription(const card64 offset);

   void updateQuality(const AbstractQoSDescription* aqd);

   void lock();

   void unlock();


   // ====== 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();

   inline card64 getPacketsSent();

   inline void resetBytesSent();

   inline void resetPacketsSent();


   // ====== Private data ===================================================
   private:
   void timerEvent();
   void updateFrameRate(const AbstractQoSDescription* aqd);


   private:
   EncoderInterface*    Encoder;
   Socket*              SenderSocket;

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

   card32               PayloadBytesSent;
   card32               PayloadPacketsSent;

   bool                 Pause;
   bool                 TransmissionError;

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

   QoSManagerInterface* QoSMgr;
   cardinal             Bandwidth[RTPConstants::RTPMaxQualityLayers];
   double               BufferDelay[RTPConstants::RTPMaxQualityLayers];

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


#include "rtpsender.icc"


#endif