traceserver.h

Go to the documentation of this file.

// ##########################################################################
// ####                                                                  ####
// ####                    Master Thesis Implementation                  ####
// ####  Management of Layered Variable Bitrate Multimedia Streams over  ####
// ####                  DiffServ with A Priori Knowledge                ####
// ####                                                                  ####
// #### ================================================================ ####
// ####                                                                  ####
// ####                                                                  ####
// #### Trace Server                                                     ####
// ####                                                                  ####
// #### Version 1.00  --  February 19, 2001                              ####
// ####                                                                  ####
// #### Copyright (C) 2000/2001 Thomas Dreibholz                         ####
// #### University of Bonn, Department of Computer Science IV            ####
// #### EMail: dreibh@iem.uni-due.de                                     ####
// #### WWW:   https://www.uni-due.de/~be0001/diplom/index.html          ####
// ####                                                                  ####
// ##########################################################################


#ifndef TRACESERVER_H
#define TRACESERVER_H


#include "system.h"
#include "tdtfmediareader.h"
#include "socket.h"
#include "traceencoderrepository.h"
#include "rtpsender.h"
#include "rtcppacket.h"
#include "rtcpreceiver.h"
#include "rtcpabstractserver.h"
#include "traceclientapppacket.h"
#include "bandwidthmanager.h"
#ifdef USE_TRANSPORTINFO
#include "extendedtransportinfo.h"
#endif


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


namespace Coral {


class TraceServer : public RTCPAbstractServer
{
   // ====== Definitions ====================================================
   private:
   struct User {
      RTCPAbstractServer::Client* Client;
      RTPSender                   Sender;
      Socket                      SenderSocket;
      InternetFlow                Flow;
      TraceEncoderRepository      Repository;
      TDTFMediaReader             Reader;
      String                      MediaName;
      integer                     StreamIdentifier;
      card16                      LastSequenceNumber;
      card16                      PosChgSeqNumber;
      bool                        ClientPause;
   };


   // ====== Constructor/Destructor =========================================
   public:
   TraceServer(BandwidthManager* bwManager,
               const cardinal    maxPacketSize = 1500);

   ~TraceServer();


   // ====== 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(Client* client, const char* cname);

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

   bool checkClient(const Client* client);

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

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

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


   // ====== Execute user command ===========================================
   void userCommand(const Client*               client,
                    User*                       user,
                    const TraceClientAppPacket* app);

   void managementUpdate(const Client* client, User* user);


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


}


#include "traceserver.icc"


#endif