rtpreceiver.h

Go to the documentation of this file.

// ##########################################################################
// ####                                                                  ####
// ####                      RTP Audio Server Project                    ####
// ####                    ============================                  ####
// ####                                                                  ####
// #### RTP Receiver                                                     ####
// ####                                                                  ####
// #### 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 RTPRECEIVER_H
#define RTPRECEIVER_H


#include "system.h"
#include "thread.h"
#include "socket.h"
#include "rtppacket.h"
#include "decoderinterface.h"
#include "sourcestateinfo.h"
#include "internetflow.h"
#ifdef USE_TRANSPORTINFO
#include "transportinfo.h"
#endif


namespace Coral {


class RTPReceiver : public Thread
{
   // ====== Constructor/Destructor =========================================
   public:
   RTPReceiver();

   RTPReceiver(DecoderInterface* decoder,
               Socket*           receiverSocket);

   ~RTPReceiver();


   // ====== Initialize =====================================================
   void init(DecoderInterface* decoder,
             Socket*           receiverSocket);


   // ====== Status functions ===============================================
#ifdef USE_TRANSPORTINFO

   inline void getTransportInfo(TransportInfo& transportInfo,
                                const bool     calculateLevels) const;
#endif

   inline card64 getPosition() const;

   inline card64 getMaxPosition() const;

   inline card64 getBytesReceived(const cardinal layer) const;
      
   inline card64 getPacketsReceived(const cardinal layer) const;

   inline void resetBytesReceived(const cardinal layer);
   
   inline void resetPacketsReceived(const cardinal layer);

   inline cardinal getLayers() const;
   
   inline InternetFlow getInternetFlow(const cardinal layer = 0) const;

   inline SourceStateInfo getSSI(const cardinal layer = 0) const;


   friend class RTCPSender;


   // ====== Protected data =================================================
   protected:
   cardinal        Layers;
   InternetFlow    Flow[RTPConstants::RTPMaxQualityLayers];
   SourceStateInfo SSI[RTPConstants::RTPMaxQualityLayers];
   card64          BytesReceived[RTPConstants::RTPMaxQualityLayers];
   card64          PacketsReceived[RTPConstants::RTPMaxQualityLayers];


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


   DecoderInterface* Decoder;
   Socket*           ReceiverSocket;
};


}


#include "rtpreceiver.icc"


#endif