Package: inet.queueing.queue
RedDropperQueue
compound moduleCombines a packet queue with random early detection (RED) dropper.
Usage diagram
The following diagram shows usage relationships between types. Unresolved types are missing from the diagram.
Inheritance diagram
The following diagram shows inheritance relationships for this type. Unresolved types are missing from the diagram.
Extends
Name | Type | Description |
---|---|---|
CompoundPacketQueueBase | compound module |
This compound module serves as a base module for complex packet queues formed by combining several queueing components. |
Parameters
Name | Type | Default value | Description |
---|---|---|---|
displayStringTextFormat | string | "contains %p pk (%l) pushed %u created %c\n pulled %o removed %r dropped %d" |
determines the text that is written on top of the submodule |
packetCapacity | int | -1 |
maximum number of packets in the queue, no limit by default |
dataCapacity | int | -1b |
maximum total length of packets in the queue, no limit by default |
dropperClass | string | "" |
determines which packets are dropped when the queue is overloaded, packets are not dropped by default; the parameter must be the name of a C++ class which implements the IPacketDropperFunction C++ interface and is registered via Register_Class |
Properties
Name | Value | Description |
---|---|---|
display | i=block/queue | |
class | CompoundPacketQueueBase | |
defaultStatistic | queueLength:vector |
Gates
Name | Direction | Size | Description |
---|---|---|---|
in | input | ||
out | output |
Signals
Name | Type | Unit |
---|---|---|
packetRemoved | inet::Packet | |
packetPushStarted | inet::Packet | |
packetDropped | inet::Packet | |
packetPushEnded | inet::Packet? | |
packetPulled | inet::Packet |
Statistics
Name | Title | Source | Record | Unit | Interpolation Mode |
---|---|---|---|---|---|
queueBitLength | queue bit length | warmup(atomic(constant0(localSignal(packetPushEnded)) + sum(packetLength(localSignal(packetPushStarted))) - sum(packetLength(localSignal(packetPulled))) - sum(packetLength(localSignal(packetRemoved))) - sum(packetLength(localSignal(packetDropped))))) | last, max, timeavg, vector | b | sample-hold |
queueLength | queue length | warmup(atomic(constant0(localSignal(packetPushEnded)) + count(localSignal(packetPushStarted)) - count(localSignal(packetPulled)) - count(localSignal(packetRemoved)) - count(localSignal(packetDropped)))) | last, max, timeavg, vector | pk | sample-hold |
droppedPacketsQueueOverflow | dropped packets: queue overflow | packetDropReasonIsQueueOverflow(localSignal(packetDropped)) | count | pk | none |
queueingTime | queueing times | queueingTime(localSignal(packetPulled)) | histogram, vector | s | none |
incomingDataRate | incoming datarate | throughput(localSignal(packetPushStarted)) | vector | bps | linear |
flowQueueingTime | flow queueing times | queueingTime(demuxFlow(localSignal(packetPulled))) | histogram, vector | s | none |
incomingPacketLengths | incoming packet lengths | packetLength(localSignal(packetPushStarted)) | sum, histogram, vector | b | none |
flowIncomingDataRate | flow specific incoming data rate | throughput(flowPacketLength(demuxFlow(localSignal(packetPushStarted)))) | vector | bps | linear |
outgoingDataRate | outgoing datarate | throughput(localSignal(packetPulled)) | vector | bps | linear |
outgoingPacketLengths | outgoing packet lengths | packetLength(localSignal(packetPulled)) | sum, histogram, vector | b | none |
droppedPacketLengthsQueueOverflow | dropped packet lengths: queue overflow | packetLength(packetDropReasonIsQueueOverflow(localSignal(packetDropped))) | sum, vector | b | none |
flowOutgoingDataRate | flow specific outgoing data rate | throughput(flowPacketLength(demuxFlow(localSignal(packetPulled)))) | vector | bps | linear |
incomingPackets | incoming packets | localSignal(packetPushStarted) | count | pk | |
outgoingPackets | outgoing packets | localSignal(packetPulled) | count | pk |
Direct method calls (observed)
call to | function | info |
---|---|---|
PacketQueue | inet::queueing::PacketQueue::pullPacket | pullPacket |
Called methods (observed)
function | info | call from |
---|---|---|
inet::queueing::CompoundPacketQueueBase::pullPacket | pullPacket | EthernetMac |
inet::queueing::CompoundPacketQueueBase::receiveSignal | packetDropped | RedDropper |
Region Tagging operations (observed)
tagType | tagAction |
---|---|
FlowTag | mapAllTags |
Unassigned submodule parameters
Name | Type | Default value | Description |
---|---|---|---|
red.displayStringTextFormat | string | "dropped %d/%p pk (%k/%l)" |
determines the text that is written on top of the submodule |
red.backpressure | bool | false | |
red.collectionModule | string | "" | |
red.wq | double | 0.002 |
weight of the current queue length in the averaged queue length, in range [0.0, 1.0] |
red.minth | double | 5 |
minimum threshold for avg queue length |
red.maxth | double | 50 |
maximum threshold for avg queue length (=buffer capacity), in range (minth,packetCapacity] |
red.maxp | double | 0.02 |
maximum value for pbs, in range [0.0, 1.0] |
red.pkrate | double | 150 |
average packet rate for calculations when queue is empty |
red.useEcn | bool | false |
if enabled, packets are marked with ECN if applicable |
red.packetCapacity | int | int(maxth) |
packets are dropped if queue length is greater |
Source code
// // Combines a packet queue with random early detection (RED) dropper. // module RedDropperQueue extends CompoundPacketQueueBase { submodules: red: RedDropper { @display("p=100,100"); } fifo: <default("PacketQueue")> like IPacketQueue { @display("p=100,200"); } connections: in --> { @display("m=n"); } --> red.in; red.out --> fifo.in; fifo.out --> { @display("m=s"); } --> out; }File: src/inet/queueing/queue/RedMarkerQueue.ned