audioserver.h

Go to the documentation of this file.

// ##########################################################################
// ####                                                                  ####
// ####                      RTP Audio Server Project                    ####
// ####                    ============================                  ####
// ####                                                                  ####
// #### Audio Server                                                     ####
// ####                                                                  ####
// ####           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: audioserver.h 1286 2011-12-18 13:43:16Z dreibh $


#ifndef AUDIOSERVER_H
#define AUDIOSERVER_H


#include "tdsystem.h"
#include "multiaudioreader.h"
#include "tdsocket.h"
#include "audioencoderrepository.h"
#include "rtpsender.h"
#include "rtcppacket.h"
#include "rtcpreceiver.h"
#include "rtcpabstractserver.h"
#include "multiaudioreader.h"
#include "qosmanagerinterface.h"

#include "audioclientapppacket.h"

#include <map>


class AudioServer : public RTCPAbstractServer
{
   // ====== Definitions ====================================================
   private:
   struct User {
      RTCPAbstractServer::Client* Client;
      RTPSender                   Sender;
      Socket                      SenderSocket;
      InternetFlow                Flow;
      AudioEncoderRepository      Repository;
      MultiAudioReader            Reader;
      String                      MediaName;
      integer                     StreamIdentifier;
      card64                      BandwidthLimit;
      card16                      LastSequenceNumber;
      card16                      PosChgSeqNumber;
      bool                        UserLimitPause;
      bool                        ManagerLimitPause;
      bool                        ClientPause;
   };


   // ====== Constructor/Destructor =========================================
   public:
   AudioServer(QoSManagerInterface* qosManager    = NULL,
               const cardinal       maxPacketSize = 1500,
               const bool           useSCTP       = false);

   ~AudioServer();


   // ====== Status functions ===============================================
   card32 getOurSSRC() const;

   inline bool getLossScalability() const;

   inline void setLossScalability(const bool on);


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

   inline cardinal setMaxPacketSize(const cardinal size);


   // ====== RTCPAbstractServer implementation ==============================
   void outOfMemoryWarning();

   void* newClient(RTCPAbstractServer::Client* client, const char* cname);

   void deleteClient(RTCPAbstractServer::Client* client, const DeleteReason reason);

   bool checkClient(RTCPAbstractServer::Client* client);

   void appMessage(RTCPAbstractServer::Client* client,
                   const char*                 name,
                   void*                       data,
                   const cardinal              dataLength);

   void sdesMessage(RTCPAbstractServer::Client* client,
                    const card8                 type,
                    char*                       data,
                    const cardinal              length);

   void receiverReport(RTCPAbstractServer::Client* client,
                       RTCPReceptionReportBlock*   report,
                       const cardinal              layer);


   // ====== Execute user command ===========================================
   void userCommand(RTCPAbstractServer::Client* client,
                    User*                       user,
                    AudioClientAppPacket*       app);

   void managementUpdate(RTCPAbstractServer::Client* client, User* user);


   // ====== Private data ===================================================
   private:
   QoSManagerInterface*                QoSMgr;
   std::multimap<const cardinal,User*> UserSet;
   Synchronizable                      UserSetSync;
   cardinal                            MaxPacketSize;
   card32                              OurSSRC;
   bool                                LossScalability;
   bool                                UseSCTP;
};


#include "audioserver.icc"


#endif