21 #include "ns3/abort.h" 22 #include "ns3/queue-limits.h" 23 #include "ns3/net-device-queue-interface.h" 24 #include "ns3/simulator.h" 25 #include "ns3/uinteger.h" 26 #include "ns3/queue-item.h" 37 .SetGroupName(
"Network")
44 : m_stoppedByDevice (false),
45 m_stoppedByQueueLimits (false),
180 static TypeId tid =
TypeId (
"ns3::NetDeviceQueueInterface")
182 .SetGroupName(
"Network")
184 .AddAttribute (
"TxQueuesType",
185 "The type of transmission queues to be used",
190 .AddAttribute (
"NTxQueues",
"The number of device transmission queues",
195 MakeUintegerChecker<uint16_t> (1, 65535))
243 tx->NotifyAggregatedObject (
this);
268 for (std::size_t i = 0; i < numTxQueues; i++)
Smart pointer class similar to boost::intrusive_ptr.
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by "...
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register an Object subclass with the TypeId system.
bool m_stoppedByDevice
True if the queue has been stopped by the device.
virtual void NotifyQueuedBytes(uint32_t bytes)
Called by the netdevice to report the number of bytes queued to the device queue. ...
bool m_stoppedByQueueLimits
True if the queue has been stopped by a queue limits object.
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file...
WakeCallback m_wakeCallback
Wake callback.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
void SetTypeId(TypeId tid)
Set the TypeId of the Objects to be created by this factory.
void SetSelectQueueCallback(SelectQueueCallback cb)
Set the select queue callback.
virtual void DoDispose(void)
Destructor implementation.
The attribute can be written at construction-time.
void NotifyAggregatedObject(Ptr< NetDeviceQueueInterface > ndqi)
Notify this NetDeviceQueue that the NetDeviceQueueInterface was aggregated to an object.
virtual bool IsStopped(void) const
Get the status of the device transmission queue.
std::size_t GetNTxQueues(void) const
Get the number of device transmission queues.
ObjectFactory m_txQueues
Device transmission queues TypeId.
The attribute can be read.
virtual void Start(void)
Called by the device to start this device transmission queue.
static TypeId GetTypeId(void)
Get the type ID.
static EventId ScheduleNow(FUNC f, Ts &&... args)
Schedule an event to expire Now.
Ptr< Object > Create(void) const
Create an Object instance of the configured TypeId.
#define NS_LOG_TEMPLATE_DEFINE(name)
Initialize a reference to a Log component.
Hold an unsigned integer type.
AttributeValue implementation for TypeId.
static TypeId GetTypeId(void)
Get the type ID.
SelectQueueCallback m_selectQueueCallback
Select queue callback.
Network device transmission queue interface.
SelectQueueCallback GetSelectQueueCallback(void) const
Get the select queue callback.
void SetTxQueuesType(TypeId type)
Set the type of device transmission queues to create.
Ptr< T > GetObject(void) const
Get a pointer to the requested aggregated Object.
void ResetQueueLimits()
Reset queue limits state.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
virtual void Stop(void)
Called by the device to stop this device transmission queue.
std::vector< Ptr< NetDeviceQueue > > m_txQueuesVector
Device transmission queues.
virtual void DoDispose(void)
Dispose of the object.
Ptr< const AttributeChecker > MakeTypeIdChecker(void)
void SetQueueLimits(Ptr< QueueLimits > ql)
Set queue limits to this queue.
std::function< std::size_t(Ptr< QueueItem >)> SelectQueueCallback
Callback invoked to determine the tx queue selected for a given packet.
friend class ObjectFactory
Friends.
virtual void NotifyTransmittedBytes(uint32_t bytes)
Called by the netdevice to report the number of bytes it is going to transmit.
Ptr< QueueLimits > m_queueLimits
Queue limits object.
Ptr< const AttributeAccessor > MakeTypeIdAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method...
NetDeviceQueueInterface()
Constructor.
#define NS_ABORT_MSG_IF(cond, msg)
Abnormal program termination if a condition is true, with a message.
virtual void Wake(void)
Called by the device to wake the queue disc associated with this device transmission queue...
Network layer to device interface.
void Nullify(void)
Discard the implementation, set it to null.
Ptr< NetDevice > m_device
the netdevice aggregated to the NetDeviceQueueInterface
Ptr< QueueLimits > GetQueueLimits()
Get queue limits to this queue.
virtual void SetWakeCallback(WakeCallback cb)
Set the wake callback.
virtual ~NetDeviceQueueInterface()
Ptr< NetDeviceQueue > GetTxQueue(std::size_t i) const
Get the i-th transmission queue of the device.
A base class which provides memory management and object aggregation.
virtual void NotifyNewAggregate(void)
Notify all Objects aggregated to this one of a new Object being aggregated.
virtual void NotifyNewAggregate(void)
Notify that an object was aggregated.
virtual ~NetDeviceQueue()
void SetNTxQueues(std::size_t numTxQueues)
Set the number of device transmission queues to create.
bool IsNull(void) const
Check for null implementation.
Network device transmission queue.
Ptr< const AttributeAccessor > MakeUintegerAccessor(T1 a1)
Create an AttributeAccessor for a class data member, or a lone class get functor or set method...
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
Set the parent TypeId.