rtcpabstractserver.h

Go to the documentation of this file.

// ##########################################################################
// ####                                                                  ####
// ####                      RTP Audio Server Project                    ####
// ####                    ============================                  ####
// ####                                                                  ####
// #### RTCP Abstract Server Implementation                              ####
// ####                                                                  ####
// #### 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 RTCPABSTRACTSERVER_H
#define RTCPABSTRACTSERVER_H


#include "system.h"
#include "timedthread.h"
#include "rtcppacket.h"
#include "internetflow.h"
#include "sourcestateinfo.h"


#include <multimap.h>
#include <algo.h>


namespace Coral {


class RTCPAbstractServer : public TimedThread
{
   // ====== Definitions ====================================================
   public:
   struct Client {
      card32       SSRC;
      InternetFlow ClientAddress;
      card64       TimeStamp;
      card64       Timeout;
      void*        UserData;
   };


   // ====== Constructor/Destructor =========================================
   RTCPAbstractServer();

   ~RTCPAbstractServer();


   // ====== Virtual functions ==============================================
   virtual void* newClient(Client* client, const char* cname) = 0;


   enum DeleteReason {
      DeleteReason_UserBye  = 0,
      DeleteReason_Timeout  = 1,
      DeleteReason_Shutdown = 2,
      DeleteReason_Error    = 3,
   };

   virtual void deleteClient(Client*            client,
                             const DeleteReason reason) = 0;

   virtual bool checkClient(const Client* client) = 0;

   virtual void appMessage(const Client*  client,
                           const char*    name,
                           const void*    data,
                           const cardinal dataLength) = 0;

   virtual void sdesMessage(const Client*  client,
                            const card8    type,
                            const char*    data,
                            const cardinal length) = 0;

   virtual void receiverReport(const Client*                   client,
                               const RTCPReceptionReportBlock* report,
                               const cardinal                  layer) = 0;


   virtual void outOfMemoryWarning();


   inline cardinal getMembers();

   
   // ====== Settings =======================================================
   inline card64 getDefaultTimeout() const;

   inline void setDefaultTimeout(const card64 timeout);


   // ====== stop() reimplementation ========================================
   void stop();


   // ====== RTCP packet handlers ===========================================
   private:
   friend class RTCPReceiver;

   void receivedSenderReport(const InternetFlow              flow,
                             const card32                    source,
                             const RTCPReceptionReportBlock* report,
                             const cardinal                  layer);
   void receivedReceiverReport(const InternetFlow              flow,
                               const card32                    source,
                               const RTCPReceptionReportBlock* report,
                               const cardinal                  layer);
   void receivedSourceDescription(const InternetFlow flow,
                                  const card32       source,
                                  const card8        type,
                                  const char*        data,
                                  const card8        length);
   void receivedApp(const InternetFlow flow,
                    const card32       source,
                    const char*        name,
                    const void*        data,
                    const card32       dataLength);
   void receivedBye(const InternetFlow flow,
                    const card32       source,
                    const DeleteReason reason);

   Client* findClient(const card32 source, const InternetFlow flow);
   

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


   card64                           DefaultTimeout;
   multimap<const cardinal,Client*> ClientSet;
};


}


#include "rtcpabstractserver.icc"


#endif