61 #include "ns3/uinteger.h"
62 #include "ns3/double.h"
63 #include "ns3/simulator.h"
64 #include "ns3/abort.h"
65 #include "ns3/random-variable-stream.h"
78 .AddConstructor<RedQueue> ()
79 .AddAttribute (
"Mode",
80 "Determines unit for QueueLimit",
85 .AddAttribute (
"MeanPktSize",
86 "Average of packet size",
89 MakeUintegerChecker<uint32_t> ())
90 .AddAttribute (
"IdlePktSize",
91 "Average packet size used during idle times. Used when m_cautions = 3",
94 MakeUintegerChecker<uint32_t> ())
95 .AddAttribute (
"Wait",
96 "True for waiting between dropped packets",
99 MakeBooleanChecker ())
100 .AddAttribute (
"Gentle",
101 "True to increases dropping probability slowly when average queue exceeds maxthresh",
104 MakeBooleanChecker ())
105 .AddAttribute (
"MinTh",
106 "Minimum average length threshold in packets/bytes",
109 MakeDoubleChecker<double> ())
110 .AddAttribute (
"MaxTh",
111 "Maximum average length threshold in packets/bytes",
114 MakeDoubleChecker<double> ())
115 .AddAttribute (
"QueueLimit",
116 "Queue limit in bytes/packets",
119 MakeUintegerChecker<uint32_t> ())
121 "Queue weight related to the exponential weighted moving average (EWMA)",
124 MakeDoubleChecker <double> ())
125 .AddAttribute (
"LInterm",
126 "The maximum probability of dropping a packet",
129 MakeDoubleChecker <double> ())
130 .AddAttribute (
"Ns1Compat",
131 "NS-1 compatibility",
134 MakeBooleanChecker ())
135 .AddAttribute (
"LinkBandwidth",
136 "The RED link bandwidth",
139 MakeDataRateChecker ())
140 .AddAttribute (
"LinkDelay",
141 "The RED link delay",
154 m_hasRedStarted (false)
157 m_uv = CreateObject<UniformRandomVariable> ();
222 uint32_t nQueued = 0;
246 m = uint32_t (ptc * (now -
m_idleTime).GetSeconds ());
300 NS_LOG_DEBUG (
"\t Dropping due to Queue Full " << nQueued);
364 m_vA = 1.0 / th_diff;
392 else if (
m_qW == -1.0)
400 m_qW = 1.0 - std::exp (-1.0 / (10 * rtt *
m_ptc));
402 else if (
m_qW == -2.0)
412 <<
"; m_isGentle " <<
m_isGentle <<
"; th_diff " << th_diff
413 <<
"; lInterm " <<
m_lInterm <<
"; va " <<
m_vA <<
"; cur_max_p "
431 newAve += qW * nQueued;
454 double pkts =
m_ptc * 0.05;
455 double fraction = std::pow ((1 -
m_qW), pkts);
457 if ((
double) qSize < fraction *
m_qAvg)
474 double pkts =
m_ptc * 0.05;
475 double fraction = std::pow ((1 -
m_qW), pkts);
476 double ratio = qSize / (fraction *
m_qAvg);
502 double vB,
double vC,
double vD,
double maxP)
504 NS_LOG_FUNCTION (
this << qAvg << maxTh << isGentle << vA << vB << vC << vD << maxP);
507 if (isGentle && qAvg >= maxTh)
513 else if (!isGentle && qAvg >= maxTh)
543 uint32_t meanPktSize,
bool isWait, uint32_t size)
545 NS_LOG_FUNCTION (
this << p << count << countBytes << meanPktSize << isWait << size);
546 double count1 = (double) count;
550 count1 = (double) (countBytes / meanPktSize);
555 if (count1 * p < 1.0)
559 else if (count1 * p < 2.0)
561 p /= (2.0 - count1 * p);
570 if (count1 * p < 1.0)
572 p /= (1.0 - count1 * p);
582 p = (p * size) / meanPktSize;
uint32_t m_bytesInQueue
bytes in the queue
uint32_t qLimDrop
Drops due to queue limits.
Ptr< UniformRandomVariable > m_uv
rng stream
QueueMode m_mode
Mode (Bytes or packets)
Simulation virtual time values and global simulation resolution.
uint32_t DropEarly(Ptr< Packet > p, uint32_t qSize)
Check if packet p needs to be dropped due to probability mark.
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by "...
void SetStream(int64_t stream)
Specifies the stream number for this RNG stream.
Ptr< const AttributeChecker > MakeEnumChecker(int v1, std::string n1, int v2, std::string n2, int v3, std::string n3, int v4, std::string n4, int v5, std::string n5, int v6, std::string n6, int v7, std::string n7, int v8, std::string n8, int v9, std::string n9, int v10, std::string n10, int v11, std::string n11, int v12, std::string n12, int v13, std::string n13, int v14, std::string n14, int v15, std::string n15, int v16, std::string n16, int v17, std::string n17, int v18, std::string n18, int v19, std::string n19, int v20, std::string n20, int v21, std::string n21, int v22, std::string n22)
#define NS_ABORT_MSG(msg)
Abnormal program termination.
virtual ~RedQueue()
Destructor.
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register the class in the ns-3 factory.
void SetMode(RedQueue::QueueMode mode)
Set the operating mode of this queue.
double m_ptc
packet time constant in packets/second
void SetQueueLimit(uint32_t lim)
Set the limit of the queue.
virtual Ptr< Packet > DoDequeue(void)
Pull a packet from the queue.
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file...
uint32_t m_cautious
0 for default RED 1 experimental (see red-queue.cc) 2 experimental (see red-queue.cc) 3 use Idle packet size in the ptc
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
uint32_t GetSize(void) const
Returns the the size in bytes of the packet (including the zero-filled initial payload).
#define NS_LOG_INFO(msg)
Use NS_LOG to output a message of level LOG_INFO.
virtual bool DoEnqueue(Ptr< Packet > p)
Push a packet in the queue.
DataRate m_linkBandwidth
Link bandwidth.
uint32_t m_queueLimit
Queue limit in bytes / packets.
Stats m_stats
RED statistics.
Abstract base class for packet Queues.
Class for representing data rates.
bool m_isGentle
True to increases dropping prob.
uint32_t GetQueueSize(void)
Get the current value of the queue in bytes or packets.
double GetSeconds(void) const
int64_t AssignStreams(int64_t stream)
Assign a fixed random variable stream number to the random variables used by this model...
Time m_linkDelay
Link delay.
std::list< Ptr< Packet > > m_packets
packets in the queue
double m_vA
1.0 / (m_maxTh - m_minTh)
RedQueue::QueueMode GetMode(void)
Get the encapsulation mode of this queue.
hold variables of type 'enum'
Stats GetStats()
Get the RED statistics after running.
uint32_t m_countBytes
Number of bytes since last drop.
hold objects of type ns3::Time
virtual Ptr< const Packet > DoPeek(void) const
Peek the front packet in the queue.
uint32_t m_meanPktSize
Avg pkt size.
An "unforced" (random) drop.
Hold an unsigned integer type.
RedQueue()
RedQueue Constructor.
bool m_isNs1Compat
Ns-1 compatibility.
#define NS_LOG_LOGIC(msg)
Use NS_LOG to output a message of level LOG_LOGIC.
double m_lInterm
The max probability of dropping a packet.
static TypeId GetTypeId(void)
Get the type ID.
double Estimator(uint32_t nQueued, uint32_t m, double qAvg, double qW)
Compute the average queue size.
void SetTh(double minTh, double maxTh)
Set the thresh limits of RED.
double CalculatePNew(double qAvg, double, bool gentle, double vA, double vB, double vC, double vD, double maxP)
Returns a probability using these function parameters for the DropEarly function. ...
uint32_t m_count
Number of packets since last random number generation.
uint32_t m_idle
0/1 idle status
Use number of bytes for maximum queue size.
double ModifyP(double p, uint32_t count, uint32_t countBytes, uint32_t meanPktSize, bool wait, uint32_t size)
Returns a probability using these function parameters for the DropEarly function. ...
void InitializeParams(void)
Initialize the queue parameters.
bool m_isWait
True for waiting between dropped packets.
uint32_t m_old
0 when average queue first exceeds threshold
uint64_t GetBitRate() const
Get the underlying bitrate.
bool m_hasRedStarted
True if RED has started.
static Time Now(void)
Return the "current simulation time".
QueueMode
Enumeration of the modes supported in the class.
Ptr< const AttributeAccessor > MakeEnumAccessor(T1 a1)
Use number of packets for maximum queue size.
uint32_t m_idlePktSize
Avg pkt size used during idle times.
Time m_idleTime
Start of current idle period.
uint32_t forcedDrop
Forced drops, qavg > max threshold.
hold objects of type ns3::DataRate
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
double m_qW
Queue weight given to cur queue size sample.
double m_qAvg
Average queue length.
double m_vB
-m_minTh / (m_maxTh - m_minTh)
Ptr< const AttributeChecker > MakeTimeChecker(const Time min, const Time max)
Helper to make a Time checker with bounded range.
uint32_t unforcedDrop
Early probability drops.
double m_vC
(1.0 - m_curMaxP) / m_maxTh - used in "gentle" mode
double m_maxTh
Max avg length threshold (bytes), should be >= 2*minTh.
Hold a floating point type.
double m_curMaxP
Current max_p.
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
double m_minTh
Min avg length threshold (bytes)
void Drop(Ptr< Packet > packet)
Drop a packet.
double m_vD
2.0 * m_curMaxP - 1.0 - used in "gentle" mode