DropTailQueue

Package: inet.queueing.queue

DropTailQueue

simple module

This module is a limited packet queue which drops packets at the tail of the queue.

Inheritance diagram

The following diagram shows inheritance relationships for this type. Unresolved types are missing from the diagram.

Used in compound modules

Name Type Description
DiffservQueue compound module

This is an example queue, that can be used in interfaces of DS core and edge nodes to support the AFxy (RFC 2597) and EF (RFC 3246) PHBs.

Known subclasses

Name Type Description
EthernetQueue compound module

Queue module that gives the PAUSE frames a higher priority.

PendingQueue simple module (no description)

Extends

Name Type Description
PacketQueue simple module

This module implements a widely configurable packet queue, which is suitable among others, to be used in MAC protocols, traffic conditioning, and quality of services. This module can be used on its own, but it's also often supplemented by additional queueing components such as servers, classifiers, schedulers, multiplexers, etc. This kind of composition allows to form a larger module which can act as a packet queue with more complex behavior.

Parameters

Name Type Default value Description
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

packetCapacity int 100

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 "inet::queueing::PacketAtCollectionEndDropper"

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

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

bufferModule string ""

relative module path to the IPacketBuffer module used by this queue, implicit buffer by default

Properties

Name Value Description
display i=block/queue
class PacketQueue
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(packetPushEnded) + sum(packetLength(packetPushStarted)) - sum(packetLength(packetPulled)) - sum(packetLength(packetRemoved)) - sum(packetLength(packetDropped)))) last, max, timeavg, vector b sample-hold
queueLength queue length warmup(atomic(constant0(packetPushEnded) + count(packetPushStarted) - count(packetPulled) - count(packetRemoved) - count(packetDropped))) last, max, timeavg, vector pk sample-hold
droppedPacketsQueueOverflow dropped packets: queue overflow packetDropReasonIsQueueOverflow(packetDropped) count pk none
queueingTime queueing times queueingTime(packetPulled) histogram, vector s none
incomingDataRate incoming datarate throughput(packetPushStarted) vector bps linear
flowQueueingTime flow queueing times queueingTime(demuxFlow(packetPulled)) histogram, vector s none
incomingPacketLengths incoming packet lengths packetLength(packetPushStarted) sum, histogram, vector b none
flowIncomingDataRate flow specific incoming data rate throughput(flowPacketLength(demuxFlow(packetPushStarted))) vector bps linear
outgoingDataRate outgoing datarate throughput(packetPulled) vector bps linear
outgoingPacketLengths outgoing packet lengths packetLength(packetPulled) sum, histogram, vector b none
droppedPacketLengthsQueueOverflow dropped packet lengths: queue overflow packetLength(packetDropReasonIsQueueOverflow(packetDropped)) sum, vector b none
flowOutgoingDataRate flow specific outgoing data rate throughput(flowPacketLength(demuxFlow(packetPulled))) vector bps linear
incomingPackets incoming packets packetPushStarted count pk
outgoingPackets outgoing packets packetPulled count pk

Direct method calls (observed)

call tofunctioninfo
inet.examples.diffserv.onedomain.DSQueue1inet::queueing::CompoundPacketQueueBase::receiveSignalpacketDropped
AckingMacinet::AckingMac::handleCanPullPacketChangedhandleCanPullPacketChanged
BMacinet::BMac::handleCanPullPacketChangedhandleCanPullPacketChanged
CsmaCaMacinet::CsmaCaMac::handleCanPullPacketChangedhandleCanPullPacketChanged
EthernetCsmaMacinet::EthernetCsmaMac::handleCanPullPacketChangedhandleCanPullPacketChanged
EthernetMacinet::EthernetMac::handleCanPullPacketChangedhandleCanPullPacketChanged
EthernetFrameClassifierinet::EthernetFrameClassifier::handleCanPushPacketChangedhandleCanPushPacketChanged
EthernetQosQueueinet::queueing::CompoundPacketQueueBase::receiveSignalpacketDropped
EthernetFcsCheckerinet::EthernetFcsChecker::handleCanPullPacketChangedhandleCanPullPacketChanged
Ieee802154Macinet::Ieee802154Mac::handleCanPullPacketChangedhandleCanPullPacketChanged
Ieee802154NarrowbandMacinet::Ieee802154Mac::handleCanPullPacketChangedhandleCanPullPacketChanged
LMacinet::LMac::handleCanPullPacketChangedhandleCanPullPacketChanged
Pppinet::Ppp::handleCanPullPacketChangedhandleCanPullPacketChanged
XMacinet::XMac::handleCanPullPacketChangedhandleCanPullPacketChanged
BehaviorAggregateClassifierinet::BehaviorAggregateClassifier::handleCanPushPacketChangedhandleCanPushPacketChanged
PacketStreamerinet::PacketStreamer::handleCanPullPacketChangedhandleCanPullPacketChanged
ContentBasedClassifierinet::queueing::ContentBasedClassifier::handleCanPushPacketChangedhandleCanPushPacketChanged
PacketClassifierinet::queueing::PacketClassifier::handleCanPushPacketChangedhandleCanPushPacketChanged
PacketMultiplexerinet::queueing::PacketMultiplexer::handleCanPushPacketChangedhandleCanPushPacketChanged
PeriodicGateinet::queueing::PeriodicGate::handleCanPullPacketChangedhandleCanPullPacketChanged
DropTailQueueinet::queueing::PacketQueue::pushPacketpushPacket
PriorityQueueinet::queueing::CompoundPacketQueueBase::receiveSignalpacketDropped
PrioritySchedulerinet::queueing::PriorityScheduler::handleCanPullPacketChangedhandleCanPullPacketChanged
WrrSchedulerinet::queueing::WrrScheduler::handleCanPullPacketChangedhandleCanPullPacketChanged
InstantServerinet::queueing::InstantServer::handleCanPullPacketChangedhandleCanPullPacketChanged
PacketServerinet::queueing::PacketServer::handleCanPullPacketChangedhandleCanPullPacketChanged
TokenBasedServerinet::queueing::TokenBasedServer::handleCanPullPacketChangedhandleCanPullPacketChanged
ActivePacketSinkinet::queueing::ActivePacketSink::handleCanPullPacketChangedhandleCanPullPacketChanged
ActivePacketSourceinet::queueing::ActivePacketSource::handleCanPushPacketChangedhandleCanPushPacketChanged

Called methods (observed)

functioninfocall from
inet::queueing::PacketQueue::pullPacketpullPacketAckingMac, BMac, CsmaCaMac, EthernetCsmaMac, EthernetMac, EthernetFcsChecker, Ieee802154Mac, Ieee802154NarrowbandMac, LMac, Ppp, XMac, PacketStreamer, PeriodicGate, PriorityScheduler, WrrScheduler, InstantServer, PacketServer, TokenBasedServer, ActivePacketSink
inet::queueing::PacketQueue::pushPacketpushPacketLayeredEthernetInterface, EthernetFrameClassifier, BehaviorAggregateClassifier, DiffservQueue, ContentBasedClassifier, PacketClassifier, PacketMultiplexer, DropTailQueue, ActivePacketSource

Incoming messages (observed)

gatemsgkindctrlsrcModuletags
inPacket0EthernetEncapsulationInterfaceReq, MacAddressReq, PacketProtocolTag, DirectionTag?, Ieee802SapReq?
inPacket0ArpInterfaceReq, MacAddressReq, PacketProtocolTag
inPacket0Ipv4DispatchProtocolInd, InterfaceReq, NetworkProtocolInd, PacketProtocolTag, DirectionTag?, EcnInd?, ErrorRateInd?, InterfaceInd?, MacAddressInd?, MacAddressReq?, MulticastReq?, SignalPowerInd?, SignalTimeInd?, SnirInd?, SocketReq?, TransportProtocolInd?, UserPriorityInd?
inPacket0Ipv6DispatchProtocolInd, InterfaceReq, MacAddressReq, NetworkProtocolInd, PacketProtocolTag, InterfaceInd?, MacAddressInd?, MulticastReq?, SocketReq?, TransportProtocolInd?
inPacket0MplsInterfaceReq, PacketProtocolTag, DispatchProtocolInd?, DscpInd?, EcnInd?, HopLimitInd?, InterfaceInd?, L3AddressInd?, MulticastReq?, NetworkProtocolInd?, TosInd?, TransportProtocolInd?

Pulled out messages (observed)

gatemsgkindctrldestModuletags
outPacket0AckingMacInterfaceReq, MacAddressReq, PacketProtocolTag, DispatchProtocolInd?, ErrorRateInd?, InterfaceInd?, MacAddressInd?, MulticastReq?, NetworkProtocolInd?, SignalPowerInd?, SignalTimeInd?, SnirInd?, SocketReq?, TransportProtocolInd?
outPacket0BMacInterfaceReq, MacAddressReq, PacketProtocolTag, DispatchProtocolInd?, MulticastReq?, NetworkProtocolInd?, SocketReq?, TransportProtocolInd?
outPacket0CsmaCaMacInterfaceReq, MacAddressReq, PacketProtocolTag, DispatchProtocolInd?, ErrorRateInd?, InterfaceInd?, MacAddressInd?, MulticastReq?, NetworkProtocolInd?, SignalPowerInd?, SignalTimeInd?, SnirInd?, SocketReq?, TransportProtocolInd?, UserPriorityInd?
outPacket0EthernetCsmaMacInterfaceReq, MacAddressReq, PacketProtocolTag, DirectionTag?, Ieee802SapReq?
outPacket0EthernetMacInterfaceReq, MacAddressReq, PacketProtocolTag, DirectionTag?, Ieee802SapReq?
outPacket0EthernetFcsCheckerDirectionTag, DispatchProtocolInd, EncapsulationProtocolReq, InterfaceReq, MacAddressReq, MulticastReq, NetworkProtocolInd, PacketProtocolTag, TransportProtocolInd, VlanReq
outPacket0Ieee802154MacInterfaceReq, MacAddressReq, PacketProtocolTag, DispatchProtocolInd?, NetworkProtocolInd?, SocketReq?
outPacket0Ieee802154NarrowbandMacDispatchProtocolInd, InterfaceReq, MacAddressReq, MulticastReq, NetworkProtocolInd, PacketProtocolTag, TransportProtocolInd
outPacket0LMacInterfaceReq, MacAddressReq, PacketProtocolTag, DispatchProtocolInd?, MulticastReq?, NetworkProtocolInd?, SocketReq?, TransportProtocolInd?
outPacket0PppInterfaceReq, PacketProtocolTag, DirectionTag?, DispatchProtocolInd?, DscpInd?, EcnInd?, HopLimitInd?, InterfaceInd?, L3AddressInd?, MacAddressInd?, MacAddressReq?, MulticastReq?, NetworkProtocolInd?, SocketReq?, TosInd?, TransportProtocolInd?
outPacket0XMacInterfaceReq, MacAddressReq, PacketProtocolTag, DispatchProtocolInd?, MulticastReq?, NetworkProtocolInd?, SocketReq?, TransportProtocolInd?
outPacket0PacketStreamerDirectionTag, DispatchProtocolInd, EncapsulationProtocolReq, InterfaceReq, MacAddressReq, MulticastReq, NetworkProtocolInd, PacketProtocolTag, TransportProtocolInd, VlanReq
outPacket0PeriodicGateDirectionTag, InterfaceReq, MacAddressReq, PacketProtocolTag, DispatchProtocolInd?, DropEligibleInd?, EncapsulationProtocolReq?, InterfaceInd?, MulticastReq?, NetworkProtocolInd?, PcpInd?, SequenceNumberInd?, StreamReq?, TransportProtocolInd?, UserPriorityInd?, VlanInd?
outPacket0PrioritySchedulerInterfaceReq, PacketProtocolTag, DirectionTag?, DispatchProtocolInd?, EcnInd?, EncapsulationProtocolReq?, Ieee802SapReq?, InterfaceInd?, MacAddressInd?, MacAddressReq?, MulticastReq?, NetworkProtocolInd?, TransportProtocolInd?, VlanReq?
outPacket0WrrSchedulerDispatchProtocolInd, InterfaceInd, InterfaceReq, NetworkProtocolInd, PacketProtocolTag, MacAddressInd?
outPacket0InstantServerDirectionTag, DispatchProtocolInd, EncapsulationProtocolReq, InterfaceReq, MacAddressReq, MulticastReq, NetworkProtocolInd, PacketProtocolTag, TransportProtocolInd, VlanReq
outPacket0PacketServerDirectionTag, PacketProtocolTag
outPacket0TokenBasedServerDirectionTag, PacketProtocolTag
outPacket0ActivePacketSinkDirectionTag, PacketProtocolTag

Pushed in messages (observed)

gatemsgkindctrlsrcModuletags
inPacket0MessageDispatcherDirectionTag, DispatchProtocolInd, EncapsulationProtocolReq, InterfaceReq, MacAddressReq, MulticastReq, NetworkProtocolInd, PacketProtocolTag, TransportProtocolInd, VlanReq
inPacket0LayeredEthernetInterfaceDirectionTag, DispatchProtocolInd, EncapsulationProtocolReq, InterfaceReq, MacAddressReq, MulticastReq, NetworkProtocolInd, PacketProtocolTag, TransportProtocolInd, VlanReq
inPacket0EthernetFrameClassifierInterfaceReq, MacAddressReq, PacketProtocolTag, DirectionTag?, DispatchProtocolInd?, EcnInd?, EncapsulationProtocolReq?, Ieee802SapReq?, InterfaceInd?, MacAddressInd?, MulticastReq?, NetworkProtocolInd?, TransportProtocolInd?
inPacket0BehaviorAggregateClassifierDispatchProtocolInd, InterfaceInd, InterfaceReq, NetworkProtocolInd, PacketProtocolTag, MacAddressInd?
inPacket0TokenBucketMeterDispatchProtocolInd, InterfaceInd, InterfaceReq, MacAddressInd, NetworkProtocolInd, PacketProtocolTag
inPacket0ContentBasedClassifierDirectionTag, InterfaceReq, MacAddressReq, PacketProtocolTag, DispatchProtocolInd?, DropEligibleInd?, EncapsulationProtocolReq?, InterfaceInd?, MulticastReq?, NetworkProtocolInd?, PcpInd?, SequenceNumberInd?, StreamReq?, TransportProtocolInd?, UserPriorityInd?, VlanInd?
inPacket0PacketClassifierDirectionTag, DispatchProtocolInd, EncapsulationProtocolReq, InterfaceReq, MacAddressReq, MulticastReq, NetworkProtocolInd, PacketProtocolTag, TransportProtocolInd, VlanReq
inPacket0PacketMultiplexerDispatchProtocolInd, InterfaceInd, InterfaceReq, MacAddressInd, NetworkProtocolInd, PacketProtocolTag
inPacket0ActivePacketSourceDirectionTag, PacketProtocolTag

Region Tagging operations (observed)

tagTypetagAction
FlowTagmapAllTags
PacketEventTagmapAllTagsForUpdate
QueueingTimeTagmapAllTagsForUpdate

Source code

//
// This module is a limited packet queue which drops packets at the tail of the queue.
//
simple DropTailQueue extends PacketQueue
{
    parameters:
        packetCapacity = default(100);
        dropperClass = default("inet::queueing::PacketAtCollectionEndDropper");
}
File: src/inet/queueing/queue/DropTailQueue.ned