EthernetPriorityQueue

Package: inet.linklayer.ethernet.modular

compound module EthernetPriorityQueue

(no description)

EthernetPriorityQueuein --> classifier.in inherited from PriorityQueueclassifier.out++ --> queue[i].in inherited from PriorityQueue for i=0..sizeof(queue)-1⦀queue[i].out --> scheduler.in++ inherited from PriorityQueue for i=0..sizeof(queue)-1⦀scheduler.out --> out inherited from PriorityQueuebuffer: inet.queueing.contract.IPacketBuffer (like IPacketBuffer) inherited from PriorityQueue IPacketBuffer: Interface for packet buffer modules. Source: buffer: <default("")> like IPacketBuffer if typename != "" { parameters: @display("p=100,225"); }bufferclassifier: inet.queueing.classifier.PacketClassifier (like IPacketClassifier) inherited from PriorityQueue PacketClassifier: Connects one packet producer to multiple packet consumers. IPacketClassifier: Interface for packet classifier modules. Source: classifier: <default("PacketClassifier")> like IPacketClassifier { parameters: @display("p=100,100"); }classifierqueue[numQueues]: inet.queueing.queue.PacketQueue (like IPacketQueue) inherited from PriorityQueue PacketQueue: Implements a configurable packet queue, which is suitable for use in MAC protocols, traffic condi... IPacketQueue: Interface for packet queue modules. Source: queue[numQueues]: <default("PacketQueue")> like IPacketQueue { parameters: bufferModule = default(exists(parent.buffer) ? "^.buffer" : ""); @display("p=300,100,column,125"); }queue[numQueues]scheduler: inet.queueing.scheduler.PriorityScheduler (like IPacketScheduler) inherited from PriorityQueue PriorityScheduler: This scheduler pulls packets from the first non-empty among its connected packet providers. IPacketScheduler: Interface for packet scheduler modules. Source: scheduler: <default("PriorityScheduler")> like IPacketScheduler { parameters: @display("p=500,100"); }scheduler

Inheritance diagram

Extends

Name

Type

Description

PriorityQueue

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

inet::Packet

packetPulled

inet::Packet

packetPushEnded

inet::Packet?

packetPushStarted

inet::Packet

packetRemoved

inet::Packet

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