EthernetPriorityQueue¶
Package: inet.linklayer.ethernet.modular
compound module EthernetPriorityQueue
(no description)
Inheritance diagram¶
Extends¶
Name |
Type |
Description |
|---|---|---|
compound module |
Implements a priority queue with multiple inner queues and an optional shared memory buffer. |
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, supports displaying pars, watches, and module-specific information |
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 |
numQueues |
int |
Properties¶
Name |
Value |
Description |
|---|---|---|
class |
CompoundPacketQueueBase |
|
defaultStatistic |
queueLength:vector |
|
display |
i=block/queue |
Gates¶
Name |
Direction |
Size |
Description |
|---|---|---|---|
in |
input |
||
out |
output |
Signals¶
Name |
Type |
Unit |
Description |
|---|---|---|---|
packetDropped |
|||
packetPulled |
|||
packetPushEnded |
inet::Packet? |
||
packetPushStarted |
|||
packetRemoved |
Statistics¶
Name |
Title |
Source |
Record |
Unit |
Interpolation Mode |
Description |
|---|---|---|---|---|---|---|
droppedPacketLengthsQueueOverflow |
dropped packet lengths: queue overflow |
packetLength(packetDropReasonIsQueueOverflow(warmup(localSignal(packetDropped)))) |
sum,vector |
b |
none |
the statistical value is the length of the packet that is dropped due to queue overflow |
droppedPacketsQueueOverflow |
dropped packets: queue overflow |
packetDropReasonIsQueueOverflow(warmup(localSignal(packetDropped))) |
count |
pk |
none |
the statistical value is the packet that is dropped due to queue overflow |
flowIncomingDataRate |
flow specific incoming data rate |
throughput(flowPacketLength(demuxFlow(warmup(localSignal(packetPushStarted))))) |
vector |
bps |
linear |
the statistical value is the flow specific data rate of the incoming packets |
flowOutgoingDataRate |
flow specific outgoing data rate |
throughput(flowPacketLength(demuxFlow(warmup(localSignal(packetPulled))))) |
vector |
bps |
linear |
the statistical value is the flow specific data rate of the outgoing packets |
flowQueueingTime |
flow queueing times |
queueingTime(demuxFlow(warmup(localSignal(packetPulled)))) |
histogram,vector |
s |
none |
the statistical value is the flow specific queueing time of packets |
incomingDataRate |
incoming datarate |
throughput(warmup(localSignal(packetPushStarted))) |
vector |
bps |
linear |
the statistical value is the data rate of the incoming packets |
incomingPacketLengths |
incoming packet lengths |
packetLength(warmup(localSignal(packetPushStarted))) |
sum,histogram,vector |
b |
none |
the statistical value is the length of the incoming packet |
incomingPackets |
incoming packets |
warmup(localSignal(packetPushStarted)) |
count |
pk |
the statistical value is the incoming packet |
|
outgoingDataRate |
outgoing datarate |
throughput(warmup(localSignal(packetPulled))) |
vector |
bps |
linear |
the statistical value is the data rate of the outgoing packets |
outgoingPacketLengths |
outgoing packet lengths |
packetLength(warmup(localSignal(packetPulled))) |
sum,histogram,vector |
b |
none |
the statistical value is the length of the outgoing packet |
outgoingPackets |
outgoing packets |
warmup(localSignal(packetPulled)) |
count |
pk |
the statistical value is the outgoing packet |
|
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 |
the statistical value is the total bit length of all packets in the queue |
queueingTime |
queueing times |
queueingTime(warmup(localSignal(packetPulled))) |
histogram,vector |
s |
none |
the statistical value is the queueing time of packets |
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 |
the statistical value is the number of packets in the queue |
Unassigned submodule parameters¶
Name |
Type |
Default value |
Description |
|---|---|---|---|
classifier.displayStringTextFormat |
string |
“classified %p pk (%l)” |
Determines the text that is written on top of the submodule, supports displaying pars, watches, and module-specific information |
classifier.reverseOrder |
bool |
false |
|
classifier.classifierClass |
string |
Determines the output queue of packets, the parameter must be the name of a C++ class which implements the IPacketClassifierFunction interface and is registered via Register_Class |
|
queue.displayStringTextFormat |
string |
“contains %p pk (%l) pushed %u\npulled %o removed %r dropped %d” |
Determines the text that is written on top of the submodule, supports displaying pars, watches, and module-specific information |
queue.packetCapacity |
int |
-1 |
Maximum number of packets in the queue, no limit by default |
queue.dataCapacity |
int |
-1b |
Maximum total length of packets in the queue, no limit by default |
queue.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 |
queue.comparatorClass |
string |
“” |
Determines the order of packets in the queue, insertion order by default; the parameter must be the name of a C++ class which implements the IPacketComparatorFunction C++ interface and is registered via Register_Class |
queue.bufferModule |
string |
exists(parent.buffer) ? “^.buffer” : “” |
Relative module path to the IPacketBuffer module used by this queue, implicit buffer by default |
scheduler.displayStringTextFormat |
string |
“scheduled %p pk (%l)” |
Determines the text that is written on top of the submodule, supports displaying pars, watches, and module-specific information |
scheduler.reverseOrder |
bool |
false |
Source code¶
module EthernetPriorityQueue extends PriorityQueue
{
parameters:
classifier.reverseOrder = default(true);
classifier.classifierClass = default("inet::queueing::PacketUserPriorityIndClassifier");
}
File: src/inet/linklayer/ethernet/modular/EthernetPriorityQueue.ned