15#include "ns3/net-device-queue-interface.h"
17#include "ns3/string.h"
31 .SetGroupName(
"TrafficControl")
103 TypeId(
"ns3::FqCoDelQueueDisc")
105 .SetGroupName(
"TrafficControl")
107 .AddAttribute(
"UseEcn",
108 "True to use ECN (packets are marked instead of being dropped)",
112 .AddAttribute(
"Interval",
113 "The CoDel algorithm interval for each FQCoDel queue",
117 .AddAttribute(
"Target",
118 "The CoDel algorithm target queue delay for each FQCoDel queue",
122 .AddAttribute(
"MaxSize",
123 "The maximum number of packets accepted by this queue disc",
127 .AddAttribute(
"Flows",
128 "The number of queues into which the incoming packets are classified",
132 .AddAttribute(
"DropBatchSize",
133 "The maximum number of packets dropped from the fat flow",
137 .AddAttribute(
"Perturbation",
138 "The salt used as an additional input to the hash function used to "
143 .AddAttribute(
"CeThreshold",
144 "The FqCoDel CE threshold for marking packets",
148 .AddAttribute(
"EnableSetAssociativeHash",
149 "Enable/Disable Set Associative Hash",
153 .AddAttribute(
"SetWays",
154 "The size of a set of queues (used by set associative hash)",
158 .AddAttribute(
"UseL4s",
159 "True to use L4S (only ECT1 packets are marked at CE threshold)",
217 m_tags[outerHash] = flowHash;
239 flowHash =
static_cast<uint32_t>(ret);
243 NS_LOG_ERROR(
"No filter has been able to classify this packet, drop it.");
261 NS_LOG_DEBUG(
"Creating a new flow queue with index " << h);
273 flow->SetQueueDisc(qd);
291 flow->GetQueueDisc()->Enqueue(item);
320 if (flow->GetDeficit() <= 0)
322 NS_LOG_DEBUG(
"Increase deficit for new flow index " << flow->GetIndex());
329 NS_LOG_DEBUG(
"Found a new flow " << flow->GetIndex() <<
" with positive deficit");
338 if (flow->GetDeficit() <= 0)
340 NS_LOG_DEBUG(
"Increase deficit for old flow index " << flow->GetIndex());
346 NS_LOG_DEBUG(
"Found an old flow " << flow->GetIndex() <<
" with positive deficit");
357 item = flow->GetQueueDisc()->Dequeue();
361 NS_LOG_DEBUG(
"Could not get a packet from the selected flow queue");
380 flow->IncreaseDeficit(item->GetSize() * -1);
397 NS_LOG_ERROR(
"FqCoDelQueueDisc cannot have internal queues");
409 if (ndqi && (dev = ndqi->GetObject<
NetDevice>()))
424 NS_LOG_ERROR(
"The number of queues must be an integer multiple of the size "
425 "of the set of queues used by set associative hash");
434 NS_LOG_WARN(
"Enabling ECN as L4S mode is enabled");
467 if (bytes > maxBacklog)
477 uint32_t threshold = maxBacklog >> 1;
483 NS_LOG_DEBUG(
"Drop packet (overflow); count: " << count <<
" len: " << len
484 <<
" threshold: " << threshold);
485 item = qd->GetInternalQueue(0)->Dequeue();
487 len += item->GetSize();
A CoDel packet queue disc.
A flow queue used by the FqCoDel queue disc.
FqCoDelFlow()
FqCoDelFlow constructor.
FlowStatus GetStatus() const
Get the status of this flow.
void SetIndex(uint32_t index)
Set the index for this flow.
uint32_t GetIndex() const
Get the index of this flow.
static TypeId GetTypeId()
Get the type ID.
void SetDeficit(uint32_t deficit)
Set the deficit for this flow.
int32_t m_deficit
the deficit for this flow
FlowStatus m_status
the status of this flow
int32_t GetDeficit() const
Get the deficit for this flow.
uint32_t m_index
the index for this flow
void IncreaseDeficit(int32_t deficit)
Increase the deficit for this flow.
void SetStatus(FlowStatus status)
Set the status for this flow.
FlowStatus
Used to determine the status of this flow queue.
A FqCoDel packet queue disc.
std::list< Ptr< FqCoDelFlow > > m_oldFlows
The list of old flows.
Time m_ceThreshold
Threshold above which to CE mark.
uint32_t m_setWays
size of a set of queues (used by set associative hash)
void InitializeParams() override
Initialize parameters (if any) before the first packet is enqueued.
ObjectFactory m_queueDiscFactory
Factory to create a new queue.
static constexpr const char * UNCLASSIFIED_DROP
No packet filter able to classify packet.
static constexpr const char * OVERLIMIT_DROP
Overlimit dropped packets.
ObjectFactory m_flowFactory
Factory to create a new flow.
uint32_t FqCoDelDrop()
Drop a packet from the head of the queue with the largest current byte count.
Ptr< QueueDiscItem > DoDequeue() override
This function actually extracts a packet from the queue disc.
void SetQuantum(uint32_t quantum)
Set the quantum value.
std::string m_interval
CoDel interval attribute.
~FqCoDelQueueDisc() override
uint32_t m_dropBatchSize
Max number of packets dropped from the fat flow.
bool DoEnqueue(Ptr< QueueDiscItem > item) override
This function actually enqueues a packet into the queue disc.
std::string m_target
CoDel target attribute.
bool m_useEcn
True if ECN is used (packets are marked instead of being dropped)
FqCoDelQueueDisc()
FqCoDelQueueDisc constructor.
uint32_t m_perturbation
hash perturbation value
std::map< uint32_t, uint32_t > m_flowsIndices
Map with the index of class for each flow.
std::map< uint32_t, uint32_t > m_tags
Tags used by set associative hash.
bool CheckConfig() override
Check whether the current configuration is correct.
uint32_t SetAssociativeHash(uint32_t flowHash)
Compute the index of the queue for the flow having the given flowHash, according to the set associati...
bool m_useL4s
True if L4S is used (ECT1 packets are marked at CE threshold)
bool m_enableSetAssociativeHash
whether to enable set associative hash
uint32_t m_quantum
Deficit assigned to flows at each round.
std::list< Ptr< FqCoDelFlow > > m_newFlows
The list of new flows.
static TypeId GetTypeId()
Get the type ID.
uint32_t m_flows
Number of flow queues.
uint32_t GetQuantum() const
Get the quantum value.
Network layer to device interface.
void SetAttribute(std::string name, const AttributeValue &value)
Set a single attribute, raising fatal errors if unsuccessful.
Ptr< Object > Create() const
Create an Object instance of the configured TypeId.
void Set(const std::string &name, const AttributeValue &value, Args &&... args)
Set an attribute to be set during construction.
void SetTypeId(TypeId tid)
Set the TypeId of the Objects to be created by this factory.
static const int PF_NO_MATCH
Standard value used by packet filters to indicate that no match was possible.
Smart pointer class similar to boost::intrusive_ptr.
QueueDiscClass is the base class for classes that are included in a queue disc.
QueueDisc is an abstract base class providing the interface and implementing the operations common to...
void AddQueueDiscClass(Ptr< QueueDiscClass > qdClass)
Add a queue disc class to the tail of the list of classes.
QueueSize GetCurrentSize() const
Get the current size of the queue disc in bytes, if operating in bytes mode, or packets,...
int32_t Classify(Ptr< QueueDiscItem > item)
Classify a packet by calling the packet filters, one at a time, until either a filter able to classif...
Ptr< NetDeviceQueueInterface > GetNetDeviceQueueInterface() const
void DropAfterDequeue(Ptr< const QueueDiscItem > item, const char *reason)
Perform the actions required when the queue disc is notified of a packet dropped after dequeue.
std::size_t GetNQueueDiscClasses() const
Get the number of queue disc classes.
QueueSize GetMaxSize() const
Get the maximum size of the queue disc.
Ptr< QueueDiscClass > GetQueueDiscClass(std::size_t i) const
Get the i-th queue disc class.
std::size_t GetNPacketFilters() const
Get the number of packet filters.
bool SetMaxSize(QueueSize size)
Set the maximum size of the queue disc.
std::size_t GetNInternalQueues() const
Get the number of internal queues.
void DropBeforeEnqueue(Ptr< const QueueDiscItem > item, const char *reason)
Perform the actions required when the queue disc is notified of a packet dropped before enqueue.
Class for representing queue sizes.
Hold variables of type string.
static Time Max()
Maximum representable Time Not to be confused with Max(Time,Time).
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
Set the parent TypeId.
Hold an unsigned integer type.
#define NS_ABORT_MSG_IF(cond, msg)
Abnormal program termination if a condition is true, with a message.
#define NS_LOG_ERROR(msg)
Use NS_LOG to output a message of level LOG_ERROR.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by ",...
#define NS_LOG_WARN(msg)
Use NS_LOG to output a message of level LOG_WARN.
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register an Object subclass with the TypeId system.
QueueSizeUnit
Enumeration of the operating modes of queues.
@ PACKETS
Use number of packets for queue size.
QueueDiscSizePolicy
Enumeration of the available policies to handle the queue disc size.
@ MULTIPLE_QUEUES
Used by queue discs with multiple internal queues/child queue discs.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
Ptr< const AttributeAccessor > MakeQueueSizeAccessor(T1 a1)
Ptr< const AttributeChecker > MakeBooleanChecker()
Ptr< const AttributeChecker > MakeUintegerChecker()
Ptr< const AttributeAccessor > MakeTimeAccessor(T1 a1)
Ptr< const AttributeAccessor > MakeUintegerAccessor(T1 a1)
Ptr< const AttributeChecker > MakeQueueSizeChecker()
Ptr< T1 > StaticCast(const Ptr< T2 > &p)
Cast a Ptr.
Ptr< const AttributeChecker > MakeStringChecker()
Ptr< const AttributeAccessor > MakeStringAccessor(T1 a1)
Ptr< const AttributeAccessor > MakeBooleanAccessor(T1 a1)
Ptr< const AttributeChecker > MakeTimeChecker()
Helper to make an unbounded Time checker.