bandwidthmanager.h

Go to the documentation of this file.

// ##########################################################################
// ####                                                                  ####
// ####                    Master Thesis Implementation                  ####
// ####  Management of Layered Variable Bitrate Multimedia Streams over  ####
// ####                  DiffServ with A Priori Knowledge                ####
// ####                                                                  ####
// #### ================================================================ ####
// ####                                                                  ####
// ####                                                                  ####
// #### Bandwidth Manager                                                ####
// ####                                                                  ####
// #### 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 BANDWIDTHMANAGER_H
#define BANDWIDTHMANAGER_H


#include "system.h"
#include "abstractqosdescription.h"
#include "timedthread.h"
#include "servicelevelagreement.h"
#include "streamdescription.h"
#include "sessiondescription.h"
#include "roundtriptimepinger.h"
#include "rtcppacket.h"


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


namespace Coral {


struct ResourceUtilizationSimplePoint
{
   // ====== Stream and point identification ================================
   StreamDescription* Stream;

   cardinal Point;

   double StreamPriorityFactor;


   // ====== Point data =====================================================
   card64 Bandwidth;

   double BandwidthCost;

   double Utilization;

   double SortingValue;
};

ostream& operator<<(ostream& os, const ResourceUtilizationSimplePoint& srup);



struct ResourceUtilizationMultiPoint
{
   // ====== Comparision operators ==========================================
   inline int operator<(const ResourceUtilizationMultiPoint& srup) const;

   inline int operator>(const ResourceUtilizationMultiPoint& srup) const;


   // ====== Session identification =========================================
   SessionDescription* Session;

   double SessionPriorityFactor;


   // ====== Streams and points identification ==============================
   static const cardinal MaxStreamsPerSession = 128;

   cardinal Streams;

   StreamDescription* Stream[MaxStreamsPerSession];

   cardinal Point[MaxStreamsPerSession];


   // ====== Point data =====================================================
   card64 Bandwidth;

   double BandwidthCost;

   double Utilization;

   double SortingValue;


   // ====== Miscellaneous ==================================================
   bool AlreadyAllocated;
};


ostream& operator<<(ostream& os, const ResourceUtilizationMultiPoint& srup);



class BandwidthManager : public TimedThread
{
   // ====== Constructor/Destructor =========================================
   public:
   BandwidthManager(ServiceLevelAgreement* sla,
                    RoundTripTimePinger*   rttp);

   ~BandwidthManager();


   // ====== Stream management ==============================================
   void addStream(ManagedStreamInterface* stream,
                  const cardinal          sessionID = 0,
                  const char*             name      = NULL);

   void removeStream(ManagedStreamInterface* stream);

   void updateStream(ManagedStreamInterface* stream);

   inline void forceCompleteRemapping();

   // ====== Events =========================================================
   void intervalChangeEvent(ManagedStreamInterface* stream,
                            const bool              isNew,
                            const card64            when,
                            const bool              newRUList);

   void reportEvent(ManagedStreamInterface*         stream,
                    const RTCPReceptionReportBlock* report,
                    const cardinal                  layer);

   void bufferFlushEvent(ManagedStreamInterface* stream,
                         const cardinal          layer);

   void timerEvent();


   // ====== Settings =======================================================
   void setLogStream(ostream* logStream);

   inline void getPartialRemapping(bool&   enabled,
                                   double& reservedPortion,
                                   double& utilizationTolerance,
                                   double& maxRemappingInterval) const;


   inline void setPartialRemapping(const bool   enabled,
                                   const double reservedPortion,
                                   const double utilizationTolerance,
                                   const double maxRemappingInterval);

   inline void getFairness(double& fairnessSession,
                           double& fairnessStream) const;

   inline void setFairness(const double fairnessSession,
                           const double fairnessStream);

   inline void getQoSOptimizationParameters(
                  cardinal& maxRUPoints,
                  double&   utilizationThreshold,
                  card64&   bandwidthThreshold,
                  double&   systemDelayTolerance,
                  bool&     unlayeredAllocation) const;

   inline void setQoSOptimizationParameters(
                  const cardinal maxRUPoints,
                  const double   utilizationThreshold,
                  const card64   bandwidthThreshold,
                  const double   systemDelayTolerance,
                  const bool     unlayeredAllocation);


   // ====== Bandwidth variables ============================================
   card64 TotalAvailableBandwidth;
   card64 ClassAvailableBandwidthArray[TrafficClassValues::MaxValues];
   card64 TotalBandwidth;
   card64 ClassBandwidthArray[TrafficClassValues::MaxValues];
   int64  SLAUpdateRecommendation[TrafficClassValues::MaxValues];


   // ====== Information about remappings ===================================
   card64   StreamIDGenerator;
   card64   LastCompleteRemapping;
   card64   LastCompleteRemappingDuration;
   cardinal CompleteRemappings;
   cardinal PartialRemappings;
   cardinal TotalBufferFlushes;


   // ====== Simulator variables ============================================
   static card64 SimulatorTime;


   // ====== Stream and session management ==================================
   multimap<ManagedStreamInterface*,StreamDescription*> StreamSet;
   multimap<cardinal,SessionDescription*>               SessionSet;
   ServiceLevelAgreement*                               SLA;
   cardinal                                             Streams;
   cardinal                                             Sessions;


   // ====== Constants ======================================================
   cardinal MaxRUPoints;
   double   UtilizationThreshold;
   card64   BandwidthThreshold;
   double   SystemDelayTolerance;
   double   FairnessSession;
   double   FairnessStream;
   double   AlphaLossRate;
   double   AlphaJitter;
   double   PartialRemappingPortion;
   double   PartialRemappingUtilizationTolerance;
   card64   MaxRemappingInterval;
   bool     EnablePartialRemappings;
   bool     UnlayeredAllocation;


   // ====== Private data ===================================================
   private:
   cardinal calculateSessionMultiPoints(
               SessionDescription*       session,
               const cardinal            offset,
               const cardinal            lastPoint,
               ResourceUtilizationMultiPoint* rumpList);
   void getRoundTripTimes(StreamDescription* sd);

   inline double getPriorityFactor(const int8 streamPriority) const;
   inline double getResourcePart(const ResourceUtilizationSimplePoint& rup) const;
   inline double getResourcePart(const ResourceUtilizationMultiPoint& rump) const;
   inline double getStreamSortingValue(const ResourceUtilizationSimplePoint& rup) const;
   inline double getSessionSortingValue(const ResourceUtilizationMultiPoint& rump) const;

   static inline void smoothedUpdate(double& value, const double measured, const double alpha);

   public:
   void updateReservation(StreamDescription* streamDescription);
   private:

   bool tryAllocation(
           ResourceUtilizationMultiPoint& rump,
           const card64                   bandwidthLimit = (card64)-1);

   void doAllocationTrials(
           ResourceUtilizationMultiPoint* rumpList,
           const cardinal                 points,
           const card64                   bandwidthLimit = (card64)-1);

   bool doPartialRemapping(StreamDescription* streamDescription);
   void doCompleteRemapping();


   RoundTripTimePinger* RTTP;
   ostream*             Log;
   card64               LogStartupTimeStamp;
   bool                 Changed;
};


}


#include "bandwidthmanager.icc"


#endif