Abstract base class for packet Queues. More...
#include "queue.h"
Public Types | |
typedef Callback< void, Ptr< QueueItem > > | DropCallback |
Callback set by the object (e.g., a queue disc) that wants to be notified of a packet drop. More... | |
enum | QueueMode { QUEUE_MODE_PACKETS, QUEUE_MODE_BYTES } |
Enumeration of the modes supported in the class. More... | |
Public Member Functions | |
Queue () | |
virtual | ~Queue () |
Ptr< QueueItem > | Dequeue (void) |
Remove an item from the front of the Queue, counting it as dequeued. More... | |
void | DequeueAll (void) |
Flush the queue. More... | |
bool | Enqueue (Ptr< QueueItem > item) |
Place a queue item into the rear of the Queue. More... | |
uint32_t | GetMaxBytes (void) const |
uint32_t | GetMaxPackets (void) const |
Queue::QueueMode | GetMode (void) const |
Get the encapsulation mode of this device. More... | |
uint32_t | GetNBytes (void) const |
uint32_t | GetNPackets (void) const |
uint32_t | GetTotalDroppedBytes (void) const |
uint32_t | GetTotalDroppedPackets (void) const |
uint32_t | GetTotalReceivedBytes (void) const |
uint32_t | GetTotalReceivedPackets (void) const |
bool | IsEmpty (void) const |
Ptr< const QueueItem > | Peek (void) const |
Get a copy of the item at the front of the queue without removing it. More... | |
Ptr< QueueItem > | Remove (void) |
Remove an item from the front of the Queue, counting it as dropped. More... | |
void | ResetStatistics (void) |
Resets the counts for dropped packets, dropped bytes, received packets, and received bytes. More... | |
virtual void | SetDropCallback (DropCallback cb) |
Set the drop callback. More... | |
void | SetMaxBytes (uint32_t maxBytes) |
Set the maximum amount of bytes that can be stored in this queue. More... | |
void | SetMaxPackets (uint32_t maxPackets) |
Set the maximum amount of packets that can be stored in this queue. More... | |
void | SetMode (Queue::QueueMode mode) |
Set the operating mode of this device. More... | |
![]() | |
Object () | |
Constructor. More... | |
virtual | ~Object () |
Destructor. More... | |
void | AggregateObject (Ptr< Object > other) |
Aggregate two Objects together. More... | |
void | Dispose (void) |
Dispose of this Object. More... | |
AggregateIterator | GetAggregateIterator (void) const |
Get an iterator to the Objects aggregated to this one. More... | |
virtual TypeId | GetInstanceTypeId (void) const |
Implement the GetInstanceTypeId method defined in ObjectBase. More... | |
template<typename T > | |
Ptr< T > | GetObject (void) const |
Get a pointer to the requested aggregated Object. More... | |
template<typename T > | |
Ptr< T > | GetObject (TypeId tid) const |
Get a pointer to the requested aggregated Object by TypeId. More... | |
void | Initialize (void) |
Invoke DoInitialize on all Objects aggregated to this one. More... | |
bool | IsInitialized (void) const |
Check if the object has been initialized. More... | |
![]() | |
SimpleRefCount () | |
Constructor. More... | |
SimpleRefCount (const SimpleRefCount &o) | |
Copy constructor. More... | |
uint32_t | GetReferenceCount (void) const |
Get the reference count of the object. More... | |
SimpleRefCount & | operator= (const SimpleRefCount &o) |
Assignment. More... | |
void | Ref (void) const |
Increment the reference count. More... | |
void | Unref (void) const |
Decrement the reference count. More... | |
![]() | |
virtual | ~ObjectBase () |
Virtual destructor. More... | |
void | GetAttribute (std::string name, AttributeValue &value) const |
Get the value of an attribute, raising fatal errors if unsuccessful. More... | |
bool | GetAttributeFailSafe (std::string name, AttributeValue &value) const |
Get the value of an attribute without raising erros. More... | |
void | SetAttribute (std::string name, const AttributeValue &value) |
Set a single attribute, raising fatal errors if unsuccessful. More... | |
bool | SetAttributeFailSafe (std::string name, const AttributeValue &value) |
Set a single attribute without raising errors. More... | |
bool | TraceConnect (std::string name, std::string context, const CallbackBase &cb) |
Connect a TraceSource to a Callback with a context. More... | |
bool | TraceConnectWithoutContext (std::string name, const CallbackBase &cb) |
Connect a TraceSource to a Callback without a context. More... | |
bool | TraceDisconnect (std::string name, std::string context, const CallbackBase &cb) |
Disconnect from a TraceSource a Callback previously connected with a context. More... | |
bool | TraceDisconnectWithoutContext (std::string name, const CallbackBase &cb) |
Disconnect from a TraceSource a Callback previously connected without a context. More... | |
Static Public Member Functions | |
static TypeId | GetTypeId (void) |
Get the type ID. More... | |
![]() | |
static TypeId | GetTypeId (void) |
Register this type. More... | |
![]() | |
static void | Cleanup (void) |
Noop. More... | |
![]() | |
static TypeId | GetTypeId (void) |
Get the type ID. More... | |
Protected Member Functions | |
void | Drop (Ptr< QueueItem > item) |
Drop a packet. More... | |
![]() | |
Object (const Object &o) | |
Copy an Object. More... | |
virtual void | DoDispose (void) |
Destructor implementation. More... | |
virtual void | DoInitialize (void) |
Initialize() implementation. More... | |
virtual void | NotifyNewAggregate (void) |
Notify all Objects aggregated to this one of a new Object being aggregated. More... | |
![]() | |
void | ConstructSelf (const AttributeConstructionList &attributes) |
Complete construction of ObjectBase; invoked by derived classes. More... | |
virtual void | NotifyConstructionCompleted (void) |
Notifier called once the ObjectBase is fully constructed. More... | |
Private Member Functions | |
virtual Ptr< QueueItem > | DoDequeue (void)=0 |
Pull the item to dequeue from the queue. More... | |
virtual bool | DoEnqueue (Ptr< QueueItem > item)=0 |
Push an item in the queue. More... | |
virtual Ptr< const QueueItem > | DoPeek (void) const =0 |
Peek the front item in the queue. More... | |
virtual Ptr< QueueItem > | DoRemove (void)=0 |
Pull the item to drop from the queue. More... | |
void | NotifyDrop (Ptr< QueueItem > item) |
Notification of a packet drop. More... | |
Private Attributes | |
DropCallback | m_dropCallback |
drop callback More... | |
uint32_t | m_maxBytes |
max bytes in the queue More... | |
uint32_t | m_maxPackets |
max packets in the queue More... | |
QueueMode | m_mode |
queue mode (packets or bytes limited) More... | |
TracedValue< uint32_t > | m_nBytes |
Number of bytes in the queue. More... | |
TracedValue< uint32_t > | m_nPackets |
Number of packets in the queue. More... | |
uint32_t | m_nTotalDroppedBytes |
Total dropped bytes. More... | |
uint32_t | m_nTotalDroppedPackets |
Total dropped packets. More... | |
uint32_t | m_nTotalReceivedBytes |
Total received bytes. More... | |
uint32_t | m_nTotalReceivedPackets |
Total received packets. More... | |
TracedCallback< Ptr< const Packet > > | m_traceDequeue |
Traced callback: fired when a packet is dequeued. More... | |
TracedCallback< Ptr< const Packet > > | m_traceDrop |
Traced callback: fired when a packet is dropped. More... | |
TracedCallback< Ptr< const Packet > > | m_traceEnqueue |
Traced callback: fired when a packet is enqueued. More... | |
Additional Inherited Members | |
![]() | |
static TypeId | GetObjectIid (void) |
Ensure the TypeId for ObjectBase gets fully configured to anchor the inheritance tree properly. More... | |
Abstract base class for packet Queues.
This class defines the base APIs for packet queues in the ns-3 system
ns3::Queue is accessible through the following paths with Config::Set and Config::Connect:
Size of this type is 168 bytes (on a 64-bit architecture).
typedef Callback<void, Ptr<QueueItem> > ns3::Queue::DropCallback |
ns3::Queue::Queue | ( | ) |
Definition at line 78 of file queue.cc.
References NS_LOG_FUNCTION.
|
virtual |
Definition at line 90 of file queue.cc.
References NS_LOG_FUNCTION.
Remove an item from the front of the Queue, counting it as dequeued.
Definition at line 135 of file queue.cc.
References DoDequeue(), ns3::TracedValue< T >::Get(), m_nBytes, m_nPackets, m_traceDequeue, NS_ASSERT, NS_LOG_FUNCTION, and NS_LOG_LOGIC.
Referenced by DequeueAll(), and DropTailQueueTestCase::DoRun().
void ns3::Queue::DequeueAll | ( | void | ) |
Flush the queue.
Definition at line 188 of file queue.cc.
References Dequeue(), IsEmpty(), and NS_LOG_FUNCTION.
Pull the item to dequeue from the queue.
Implemented in ns3::DropTailQueue.
Referenced by Dequeue().
Push an item in the queue.
item | the item to enqueue |
Implemented in ns3::DropTailQueue.
Referenced by Enqueue().
Peek the front item in the queue.
Implemented in ns3::DropTailQueue.
Referenced by Peek().
Pull the item to drop from the queue.
Implemented in ns3::DropTailQueue.
Referenced by Remove().
Drop a packet.
item | item that was dropped |
This method is called by the base class when a packet is dropped because the queue is full and by the subclasses to notify parent (this class) that a packet has been dropped for other reasons.
Definition at line 364 of file queue.cc.
References m_nTotalDroppedBytes, m_nTotalDroppedPackets, m_traceDrop, NotifyDrop(), NS_LOG_FUNCTION, and NS_LOG_LOGIC.
Referenced by Enqueue(), and Remove().
Place a queue item into the rear of the Queue.
item | item to enqueue |
Definition at line 97 of file queue.cc.
References DoEnqueue(), Drop(), ns3::TracedValue< T >::Get(), m_maxBytes, m_maxPackets, m_mode, m_nBytes, m_nPackets, m_nTotalReceivedBytes, m_nTotalReceivedPackets, m_traceEnqueue, NS_LOG_FUNCTION, NS_LOG_LOGIC, QUEUE_MODE_BYTES, and QUEUE_MODE_PACKETS.
Referenced by DropTailQueueTestCase::DoRun().
uint32_t ns3::Queue::GetMaxBytes | ( | void | ) | const |
Definition at line 340 of file queue.cc.
References m_maxBytes, and NS_LOG_FUNCTION.
Referenced by GetTypeId().
uint32_t ns3::Queue::GetMaxPackets | ( | void | ) | const |
Definition at line 319 of file queue.cc.
References m_maxPackets, and NS_LOG_FUNCTION.
Referenced by GetTypeId().
Queue::QueueMode ns3::Queue::GetMode | ( | void | ) | const |
Get the encapsulation mode of this device.
Definition at line 298 of file queue.cc.
References m_mode, and NS_LOG_FUNCTION.
Referenced by GetTypeId().
uint32_t ns3::Queue::GetNBytes | ( | void | ) | const |
Definition at line 221 of file queue.cc.
References m_nBytes, NS_LOG_FUNCTION, and NS_LOG_LOGIC.
uint32_t ns3::Queue::GetNPackets | ( | void | ) | const |
Definition at line 213 of file queue.cc.
References m_nPackets, NS_LOG_FUNCTION, and NS_LOG_LOGIC.
Referenced by ns3::DropTailQueue::DoDequeue(), ns3::DropTailQueue::DoEnqueue(), ns3::DropTailQueue::DoPeek(), ns3::DropTailQueue::DoRemove(), and DropTailQueueTestCase::DoRun().
uint32_t ns3::Queue::GetTotalDroppedBytes | ( | void | ) | const |
Definition at line 253 of file queue.cc.
References m_nTotalDroppedBytes, NS_LOG_FUNCTION, and NS_LOG_LOGIC.
uint32_t ns3::Queue::GetTotalDroppedPackets | ( | void | ) | const |
Definition at line 261 of file queue.cc.
References m_nTotalDroppedPackets, NS_LOG_FUNCTION, and NS_LOG_LOGIC.
uint32_t ns3::Queue::GetTotalReceivedBytes | ( | void | ) | const |
Definition at line 237 of file queue.cc.
References m_nTotalReceivedBytes, NS_LOG_FUNCTION, and NS_LOG_LOGIC.
uint32_t ns3::Queue::GetTotalReceivedPackets | ( | void | ) | const |
Definition at line 245 of file queue.cc.
References m_nTotalReceivedPackets, NS_LOG_FUNCTION, and NS_LOG_LOGIC.
|
static |
Get the type ID.
Definition at line 33 of file queue.cc.
References GetMaxBytes(), GetMaxPackets(), GetMode(), m_nBytes, m_nPackets, m_traceDequeue, m_traceDrop, m_traceEnqueue, ns3::MakeEnumAccessor(), ns3::MakeEnumChecker(), ns3::MakeTraceSourceAccessor(), ns3::MakeUintegerAccessor(), QUEUE_MODE_BYTES, QUEUE_MODE_PACKETS, SetMaxBytes(), SetMaxPackets(), SetMode(), and ns3::TypeId::SetParent().
bool ns3::Queue::IsEmpty | ( | void | ) | const |
Definition at line 229 of file queue.cc.
References ns3::TracedValue< T >::Get(), m_nPackets, NS_LOG_FUNCTION, and NS_LOG_LOGIC.
Referenced by DequeueAll().
Notification of a packet drop.
item | item that was dropped |
Definition at line 353 of file queue.cc.
References ns3::Callback< R, T1, T2, T3, T4, T5, T6, T7, T8, T9 >::IsNull(), m_dropCallback, and NS_LOG_FUNCTION.
Referenced by Drop().
Get a copy of the item at the front of the queue without removing it.
Definition at line 198 of file queue.cc.
References DoPeek(), ns3::TracedValue< T >::Get(), m_nPackets, NS_LOG_FUNCTION, and NS_LOG_LOGIC.
Remove an item from the front of the Queue, counting it as dropped.
Definition at line 162 of file queue.cc.
References DoRemove(), Drop(), ns3::TracedValue< T >::Get(), m_nBytes, m_nPackets, NS_ASSERT, NS_LOG_FUNCTION, and NS_LOG_LOGIC.
void ns3::Queue::ResetStatistics | ( | void | ) |
Resets the counts for dropped packets, dropped bytes, received packets, and received bytes.
Definition at line 269 of file queue.cc.
References m_nTotalDroppedBytes, m_nTotalDroppedPackets, m_nTotalReceivedBytes, m_nTotalReceivedPackets, and NS_LOG_FUNCTION.
|
virtual |
Set the drop callback.
cb | the callback to set |
Called when a queue is added to a queue disc in order to set a callback to the Drop method of the queue disc.
Definition at line 347 of file queue.cc.
References m_dropCallback.
void ns3::Queue::SetMaxBytes | ( | uint32_t | maxBytes | ) |
Set the maximum amount of bytes that can be stored in this queue.
maxBytes | amount of bytes |
Definition at line 326 of file queue.cc.
References ns3::TracedValue< T >::Get(), m_maxBytes, m_mode, m_nBytes, NS_ABORT_MSG_IF, NS_LOG_FUNCTION, and QUEUE_MODE_BYTES.
Referenced by GetTypeId().
void ns3::Queue::SetMaxPackets | ( | uint32_t | maxPackets | ) |
Set the maximum amount of packets that can be stored in this queue.
maxPackets | amount of packets |
Definition at line 305 of file queue.cc.
References ns3::TracedValue< T >::Get(), m_maxPackets, m_mode, m_nPackets, NS_ABORT_MSG_IF, NS_LOG_FUNCTION, and QUEUE_MODE_PACKETS.
Referenced by GetTypeId().
void ns3::Queue::SetMode | ( | Queue::QueueMode | mode | ) |
Set the operating mode of this device.
mode | The operating mode of this device. |
Definition at line 279 of file queue.cc.
References ns3::TracedValue< T >::Get(), m_mode, m_nBytes, m_nPackets, NS_ABORT_MSG_IF, NS_LOG_FUNCTION, QUEUE_MODE_BYTES, and QUEUE_MODE_PACKETS.
Referenced by GetTypeId().
|
private |
drop callback
Definition at line 267 of file queue.h.
Referenced by NotifyDrop(), and SetDropCallback().
|
private |
max bytes in the queue
Definition at line 265 of file queue.h.
Referenced by Enqueue(), GetMaxBytes(), and SetMaxBytes().
|
private |
max packets in the queue
Definition at line 264 of file queue.h.
Referenced by Enqueue(), GetMaxPackets(), and SetMaxPackets().
|
private |
queue mode (packets or bytes limited)
Definition at line 266 of file queue.h.
Referenced by Enqueue(), GetMode(), SetMaxBytes(), SetMaxPackets(), and SetMode().
|
private |
Number of bytes in the queue.
Definition at line 257 of file queue.h.
Referenced by Dequeue(), Enqueue(), GetNBytes(), GetTypeId(), Remove(), SetMaxBytes(), and SetMode().
|
private |
Number of packets in the queue.
Definition at line 259 of file queue.h.
Referenced by Dequeue(), Enqueue(), GetNPackets(), GetTypeId(), IsEmpty(), Peek(), Remove(), SetMaxPackets(), and SetMode().
|
private |
Total dropped bytes.
Definition at line 261 of file queue.h.
Referenced by Drop(), GetTotalDroppedBytes(), and ResetStatistics().
|
private |
Total dropped packets.
Definition at line 262 of file queue.h.
Referenced by Drop(), GetTotalDroppedPackets(), and ResetStatistics().
|
private |
Total received bytes.
Definition at line 258 of file queue.h.
Referenced by Enqueue(), GetTotalReceivedBytes(), and ResetStatistics().
|
private |
Total received packets.
Definition at line 260 of file queue.h.
Referenced by Enqueue(), GetTotalReceivedPackets(), and ResetStatistics().
|
private |
Traced callback: fired when a packet is dequeued.
Definition at line 253 of file queue.h.
Referenced by Dequeue(), and GetTypeId().
|
private |
Traced callback: fired when a packet is dropped.
Definition at line 255 of file queue.h.
Referenced by Drop(), and GetTypeId().
|
private |
Traced callback: fired when a packet is enqueued.
Definition at line 251 of file queue.h.
Referenced by Enqueue(), and GetTypeId().