#include <InterpacketGapInserter.h>

Inheritance diagram for inet::InterpacketGapInserter:

Public Member Functions
virtual	~InterpacketGapInserter ()

virtual IPassivePacketSink *	getConsumer (cGate *gate) override
	Returns the passive packet sink where packets are pushed or nullptr if the connected module doesn't implement the interface. More...

virtual bool	supportsPacketPushing (cGate *gate) const override
	Returns true if the processor supports pushing packets at the given gate. More...

virtual bool	supportsPacketPulling (cGate *gate) const override
	Returns true if the processor supports pulling packets at the given gate. More...

virtual bool	canPushSomePacket (cGate *gate) const override
	Returns false if the packet sink is full at the given gate and no more packets can be pushed into it without raising an error. More...

virtual bool	canPushPacket (Packet packet, cGate gate) const override
	Returns true if the given packet can be pushed at the given gate into the packet sink without raising an error. More...

virtual void	pushPacket (Packet packet, cGate gate) override
	Pushes the packet into the packet sink at the given gate. More...

virtual void	pushPacketStart (Packet packet, cGate gate, bps datarate) override
	Starts pushing the packet into the packet sink at the given gate. More...

virtual void	pushPacketEnd (Packet packet, cGate gate) override
	Ends pushing the packet into the packet sink at the given gate. More...

virtual void	pushPacketProgress (Packet packet, cGate gate, bps datarate, b position, b extraProcessableLength=b(0)) override
	Progresses pushing the packet into the packet sink at the given gate. More...

virtual void	handleCanPushPacketChanged (cGate *gate) override
	Notifies about a change in the possibility of pushing some packet into the passive packet sink at the given gate. More...

virtual void	handlePushPacketProcessed (Packet packet, cGate gate, bool successful) override
	Notifies about the completion of the packet processing for a packet that was pushed earlier independently whether the packet is passed or streamed. More...

Public Member Functions inherited from inet::ClockUserModuleMixin< PacketPusherBase >
virtual void	scheduleClockEventAt (clocktime_t time, ClockEvent *msg)

virtual void	scheduleClockEventAfter (clocktime_t delay, ClockEvent *msg)

virtual cMessage *	cancelClockEvent (ClockEvent *msg)

virtual void	cancelAndDeleteClockEvent (ClockEvent *msg)

virtual void	rescheduleClockEventAt (clocktime_t time, ClockEvent *msg)

virtual void	rescheduleClockEventAfter (clocktime_t time, ClockEvent *msg)

virtual clocktime_t	computeClockTimeFromSimTime (simtime_t time) const

virtual simtime_t	computeSimTimeFromClockTime (clocktime_t time) const

virtual clocktime_t	getClockTime () const

virtual clocktime_t	getArrivalClockTime (ClockEvent *msg) const

Public Member Functions inherited from inet::queueing::PacketProcessorBase
virtual bool	supportsPacketSending (cGate *gate) const override
	Returns true if the processor supports sending packets at the given gate. More...

virtual bool	supportsPacketPassing (cGate *gate) const override
	Returns true if the processor supports passing packets as a whole at the given gate. More...

virtual bool	supportsPacketStreaming (cGate *gate) const override
	Returns true if the processor supports streaming packets at the given gate. More...

Public Member Functions inherited from inet::queueing::IPacketProcessor
virtual	~IPacketProcessor ()

Public Member Functions inherited from inet::queueing::IPassivePacketSink
virtual	~IPassivePacketSink ()

Public Member Functions inherited from inet::queueing::IActivePacketSource
virtual	~IActivePacketSource ()

Protected Member Functions
virtual void	initialize (int stage) override

virtual void	handleMessage (cMessage *message) override

virtual void	receivePacketStart (cPacket packet, cGate gate, double datarate)

virtual void	receivePacketProgress (cPacket packet, cGate gate, double datarate, int bitPosition, simtime_t timePosition, int extraProcessableBitLength, simtime_t extraProcessableDuration)

virtual void	receivePacketEnd (cPacket packet, cGate gate, double datarate)

virtual void	pushOrSendOrSchedulePacketProgress (Packet packet, cGate gate, bps datarate, b position, b extraProcessableLength=b(0))

virtual const char *	resolveDirective (char directive) const override

Protected Member Functions inherited from inet::queueing::PacketProcessorBase
virtual int	numInitStages () const override

virtual void	refreshDisplay () const override

virtual void	handlePacketProcessed (Packet *packet)

virtual void	checkPacketOperationSupport (cGate *gate) const

virtual void	checkPacketOperationSupport (cGate startGate, cGate endGate) const

virtual void	animate (Packet packet, cGate gate, const SendOptions &sendOptions, Action action) const

virtual void	animatePacket (Packet packet, cGate gate, Action action) const

virtual void	animatePacketStart (Packet packet, cGate gate, bps datarate, long transmissionId, Action action) const

virtual void	animatePacketStart (Packet packet, cGate gate, bps datarate, const SendOptions &sendOptions, Action action) const

virtual void	animatePacketEnd (Packet packet, cGate gate, long transmissionId, Action action) const

virtual void	animatePacketEnd (Packet packet, cGate gate, const SendOptions &sendOptions, Action action) const

virtual void	animatePacketProgress (Packet packet, cGate gate, bps datarate, b position, b extraProcessableLength, long transmissionId, Action action) const

virtual void	animatePacketProgress (Packet packet, cGate gate, bps datarate, b position, b extraProcessableLength, const SendOptions &sendOptions, Action action) const

virtual void	pushOrSendPacket (Packet packet, cGate gate, IPassivePacketSink *consumer)

virtual void	pushOrSendPacketStart (Packet packet, cGate gate, IPassivePacketSink *consumer, bps datarate, int transmissionId)

virtual void	pushOrSendPacketEnd (Packet packet, cGate gate, IPassivePacketSink *consumer, int transmissionId)

virtual void	pushOrSendPacketProgress (Packet packet, cGate gate, IPassivePacketSink *consumer, bps datarate, b position, b extraProcessableLength, int transmissionId)

virtual void	animatePush (Packet packet, cGate gate, const SendOptions &sendOptions) const

virtual void	animatePushPacket (Packet packet, cGate gate) const

virtual void	animatePushPacketStart (Packet packet, cGate gate, bps datarate, long transmissionId) const

virtual void	animatePushPacketStart (Packet packet, cGate gate, bps datarate, const SendOptions &sendOptions) const

virtual void	animatePushPacketEnd (Packet packet, cGate gate, long transmissionId) const

virtual void	animatePushPacketEnd (Packet packet, cGate gate, const SendOptions &sendOptions) const

virtual void	animatePushPacketProgress (Packet packet, cGate gate, bps datarate, b position, b extraProcessableLength, long transmissionId) const

virtual void	animatePushPacketProgress (Packet packet, cGate gate, bps datarate, b position, b extraProcessableLength, const SendOptions &sendOptions) const

virtual void	animatePull (Packet packet, cGate gate, const SendOptions &sendOptions) const

virtual void	animatePullPacket (Packet packet, cGate gate) const

virtual void	animatePullPacketStart (Packet packet, cGate gate, bps datarate, long transmissionId) const

virtual void	animatePullPacketStart (Packet packet, cGate gate, bps datarate, const SendOptions &sendOptions) const

virtual void	animatePullPacketEnd (Packet packet, cGate gate, long transmissionId) const

virtual void	animatePullPacketEnd (Packet packet, cGate gate, const SendOptions &sendOptions) const

virtual void	animatePullPacketProgress (Packet packet, cGate gate, bps datarate, b position, b extraProcessableLength, long transmissionId) const

virtual void	animatePullPacketProgress (Packet packet, cGate gate, bps datarate, b position, b extraProcessableLength, const SendOptions &sendOptions) const

virtual void	dropPacket (Packet *packet, PacketDropReason reason, int limit=-1)

virtual void	updateDisplayString () const

Protected Attributes
cPar *	durationPar = nullptr

ClockEvent *	timer = nullptr

ClockEvent *	progress = nullptr

clocktime_t	packetDelay

clocktime_t	packetStartTime

clocktime_t	packetEndTime

bps	streamDatarate = bps(NaN)

Protected Attributes inherited from inet::queueing::PacketPusherBase
cGate *	inputGate = nullptr

IActivePacketSource *	producer = nullptr

cGate *	outputGate = nullptr

IPassivePacketSink *	consumer = nullptr

Protected Attributes inherited from inet::queueing::PacketProcessorBase
const char *	displayStringTextFormat = nullptr

int	numProcessedPackets = -1

b	processedTotalLength = b(-1)

Additional Inherited Members
Protected Types inherited from inet::queueing::PacketProcessorBase
enum	Action { PUSH, PULL }

Constructor & Destructor Documentation

◆ ~InterpacketGapInserter()

inet::InterpacketGapInserter::~InterpacketGapInserter ( )

virtual

 {
     cancelAndDelete(timer);
     cancelAndDeleteClockEvent(progress);
 }

Member Function Documentation

◆ canPushPacket()

bool inet::InterpacketGapInserter::canPushPacket	(	Packet *	packet,
		cGate *	gate
	)		const

overridevirtual

Returns true if the given packet can be pushed at the given gate into the packet sink without raising an error.

The packet must not be nullptr. The gate must be a valid gate of this module and it must support pushing packets.

Reimplemented from inet::queueing::PacketPusherBase.

 {
     // TODO getting a value from the durationPar here is wrong, because it's volatile and this method can be called any number of times
     return (getClockTime() >= packetEndTime + durationPar->doubleValue()) &&
            (consumer == nullptr || consumer->canPushPacket(packet, outputGate->getPathEndGate()));
 }

◆ canPushSomePacket()

bool inet::InterpacketGapInserter::canPushSomePacket ( cGate * gate ) const

overridevirtual

Returns false if the packet sink is full at the given gate and no more packets can be pushed into it without raising an error.

The gate must be a valid gate of this module and it must support pushing packets.

Reimplemented from inet::queueing::PacketPusherBase.

 {
     // TODO getting a value from the durationPar here is wrong, because it's volatile and this method can be called any number of times
     return (getClockTime() >= packetEndTime + durationPar->doubleValue()) &&
            (consumer == nullptr || consumer->canPushSomePacket(outputGate->getPathEndGate()));
 }

Referenced by handleMessage().

◆ getConsumer()

virtual IPassivePacketSink* inet::InterpacketGapInserter::getConsumer ( cGate * gate )

inlineoverridevirtual

Returns the passive packet sink where packets are pushed or nullptr if the connected module doesn't implement the interface.

The gate parameter must be a valid gate of this module.

Reimplemented from inet::queueing::PacketPusherBase.

46 { return consumer; }

◆ handleCanPushPacketChanged()

void inet::InterpacketGapInserter::handleCanPushPacketChanged ( cGate * gate )

overridevirtual

Notifies about a change in the possibility of pushing some packet into the passive packet sink at the given gate.

This method is called, for example, when a new packet can be inserted into a queue. It allows the source to push a new packet into the queue.

The gate parameter must be a valid gate of this module.

Reimplemented from inet::queueing::PacketPusherBase.

 {
     Enter_Method("handleCanPushPacketChanged");
     if (packetEndTime + durationPar->doubleValue() <= getClockTime()) {
         if (producer != nullptr)
             producer->handleCanPushPacketChanged(inputGate->getPathStartGate());
     }
     else {
         double interpacketGapDuration = durationPar->doubleValue();
         rescheduleClockEventAt(packetEndTime + interpacketGapDuration, timer);
         emit(interpacketGapStartedSignal, interpacketGapDuration);
     }
 }

◆ handleMessage()

void inet::InterpacketGapInserter::handleMessage ( cMessage * message )

overrideprotectedvirtual

Reimplemented from inet::queueing::PacketPusherBase.

 {
     if (message->isSelfMessage()) {
         if (message == timer) {
             emit(interpacketGapEndedSignal, NaN);
             if (canPushSomePacket(inputGate))
                 if (producer != nullptr)
                     producer->handleCanPushPacketChanged(inputGate->getPathStartGate());
         }
         else if (message == progress) {
             auto packet = static_cast<Packet *>(message->getContextPointer());
             if (packet->isUpdate()) {
                 auto progressTag = packet->getTag<ProgressTag>();
                 pushOrSendPacketProgress(packet, outputGate, consumer, progressTag->getDatarate(), progressTag->getPosition(), progressTag->getExtraProcessableLength(), packet->getTransmissionId());
             }
             else
                 pushOrSendPacket(packet, outputGate, consumer);
             handlePacketProcessed(packet);
         }
         else
             throw cRuntimeError("Unknown message");
     }
     else {
         // if an asynchronous message is received from the input gate
         // then it's processed as if it were pushed as synchronous message
         if (message->isPacket()) {
             auto packet = check_and_cast<Packet *>(message);
             if (packet->isUpdate()) {
                 auto progressTag = packet->getTag<ProgressTag>();
                 pushOrSendPacketProgress(packet, outputGate, consumer, progressTag->getDatarate(), progressTag->getPosition(), progressTag->getExtraProcessableLength(), packet->getTransmissionId());
             }
             else
                 pushPacket(packet, packet->getArrivalGate());
             handlePacketProcessed(packet);
         }
         else
             throw cRuntimeError("Unknown message");
     }
     updateDisplayString();
 }

◆ handlePushPacketProcessed()

void inet::InterpacketGapInserter::handlePushPacketProcessed	(	Packet *	packet,
		cGate *	gate,
		bool	successful
	)

overridevirtual

Notifies about the completion of the packet processing for a packet that was pushed earlier independently whether the packet is passed or streamed.

This method is called, for example, when a previously pushed packet is failed to be processed successfully. It allows the source to retry the operation.

The gate parameter must be a valid gate of this module. The packet must not be nullptr.

Reimplemented from inet::queueing::PacketPusherBase.

 {
     packetEndTime = getClockTime();
     if (producer != nullptr)
         producer->handlePushPacketProcessed(packet, inputGate->getPathStartGate(), successful);
 }

◆ initialize()

void inet::InterpacketGapInserter::initialize ( int stage )

overrideprotectedvirtual

Reimplemented from inet::queueing::PacketPusherBase.

 {
     ClockUserModuleMixin::initialize(stage);
     if (stage == INITSTAGE_LOCAL) {
         durationPar = &par("duration");
         timer = new ClockEvent("IfgTimer");
         progress = new ClockEvent("ProgressTimer");
         WATCH(packetStartTime);
         WATCH(packetEndTime);
     }
     // KLUDGE: this runs after the clock stage, the clocks must be initialized
     else if (stage == INITSTAGE_CLOCK + 1) {
         packetEndTime = par("initialChannelBusy") ? getClockTime() : getClockTime().setRaw(INT64_MIN / 2); // INT64_MIN / 2 to prevent overflow
     }
     else if (stage == INITSTAGE_LAST) {
         if (packetEndTime + durationPar->doubleValue() > getClockTime()) {
             double interpacketGapDuration = durationPar->doubleValue();
             scheduleClockEventAt(packetEndTime + interpacketGapDuration, timer);
             emit(interpacketGapStartedSignal, interpacketGapDuration);
         }
     }
 }

◆ pushOrSendOrSchedulePacketProgress()

void inet::InterpacketGapInserter::pushOrSendOrSchedulePacketProgress	(	Packet *	packet,
		cGate *	gate,
		bps	datarate,
		b	position,
		b	extraProcessableLength = `b(0)`
	)

protectedvirtual

 {
     auto now = getClockTime();
     if (now >= packetEndTime) {
         packetDelay = packetEndTime + durationPar->doubleValue() - now;
         if (packetDelay < 0)
             packetDelay = 0;
         packetStartTime = now + packetDelay;
     }
     packetEndTime = packetStartTime + SIMTIME_AS_CLOCKTIME(packet->getDuration());
     if (progress == nullptr || !progress->isScheduled()) {
         if (packet->getTotalLength() == position + extraProcessableLength)
             handlePacketProcessed(packet);
         pushOrSendPacketProgress(packet, outputGate, consumer, datarate, position, extraProcessableLength, packet->getTransmissionId());
     }
     else {
         EV_INFO << "Inserting packet gap before" << EV_FIELD(packet) << EV_ENDL;
         cancelClockEvent(progress);
         auto progressTag = packet->addTagIfAbsent<ProgressTag>();
         progressTag->setDatarate(datarate);
         progressTag->setPosition(position);
         progressTag->setExtraProcessableLength(extraProcessableLength);
         progress->setContextPointer(packet);
         scheduleClockEventAt(packetStartTime, progress);
     }
 }

Referenced by pushPacketEnd(), pushPacketProgress(), and pushPacketStart().

◆ pushPacket()

void inet::InterpacketGapInserter::pushPacket	(	Packet *	packet,
		cGate *	gate
	)

overridevirtual

Pushes the packet into the packet sink at the given gate.

This operation pushes the packet as a whole. The onwership of the packet is transferred to the sink.

This method is called, for example, when a packet source module pushes a packet into a queue module.

The sink must not be full at the gate. The packet must not be nullptr. The gate must be a valid gate of this module and it must support pushing and passing packets.

Reimplemented from inet::queueing::PacketPusherBase.

 {
     Enter_Method("pushPacket");
     take(packet);
     auto now = getClockTime();
     packetDelay = packetEndTime + durationPar->doubleValue() - now;
     if (packetDelay < 0)
         packetDelay = 0;
     packetStartTime = now + packetDelay;
     packetEndTime = packetStartTime + SIMTIME_AS_CLOCKTIME(packet->getDuration());
     if (packetDelay == 0) {
         handlePacketProcessed(packet);
         pushOrSendPacket(packet, outputGate, consumer);
     }
     else {
         EV_INFO << "Inserting packet gap before" << EV_FIELD(packet) << EV_ENDL;
         progress->setContextPointer(packet);
         scheduleClockEventAt(now + packetDelay, progress);
     }
     updateDisplayString();
 }

Referenced by handleMessage().

◆ pushPacketEnd()

void inet::InterpacketGapInserter::pushPacketEnd	(	Packet *	packet,
		cGate *	gate
	)

overridevirtual

Ends pushing the packet into the packet sink at the given gate.

This is a packet streaming operation. The onwership of the packet is transferred to the sink.

Packet streaming can be started with any of the streaming operations, and ends when the streaming position plus the extra processable packet length equals to the total packet length.

This method is called, for example, when a preemption supporting server module ends streaming a packet to the sink.

The sink must not be full at the gate and no other packet streaming can be in progress. The packet must not be nullptr. The gate must be a valid gate of this module and it must support pushing and streaming packets.

Reimplemented from inet::queueing::PacketPusherBase.

 {
     Enter_Method("pushPacketEnd");
     take(packet);
     pushOrSendOrSchedulePacketProgress(packet, gate, streamDatarate, packet->getDataLength(), b(0));
     streamDatarate = bps(NaN);
     updateDisplayString();
 }

◆ pushPacketProgress()

void inet::InterpacketGapInserter::pushPacketProgress	(	Packet *	packet,
		cGate *	gate,
		bps	datarate,
		b	position,
		b	extraProcessableLength = `b(0)`
	)

overridevirtual

Progresses pushing the packet into the packet sink at the given gate.

This is a packet streaming operation. The position specifies where the packet streaming is at the moment. The extra length parameter partially fixes the future of the packet streaming operation. The onwership of the packet is transferred to the sink.

Packet streaming can be started with any of the streaming operations, and ends when the streaming position plus the extra processable packet length equals to the total packet length.

This method is called, for example, to notify the sink about a change in the packet data when a preemption occurs.

The sink must not be full at the gate and no other packet streaming can be in progress. The packet must not be nullptr. The gate must be a valid gate of this module and it must support pushing and streaming packets.

Reimplemented from inet::queueing::PacketPusherBase.

 {
     Enter_Method("pushPacketProgress");
     take(packet);
     streamDatarate = datarate;
     pushOrSendOrSchedulePacketProgress(packet, gate, datarate, position, extraProcessableLength);
     updateDisplayString();
 }

◆ pushPacketStart()

void inet::InterpacketGapInserter::pushPacketStart	(	Packet *	packet,
		cGate *	gate,
		bps	datarate
	)

overridevirtual

Starts pushing the packet into the packet sink at the given gate.

This is a packet streaming operation. The onwership of the packet is transferred to the sink.

Packet streaming can be started with any of the streaming operations, and ends when the streaming position plus the extra processable packet length equals to the total packet length.

This method is called, for example, when a preemption supporting server module starts streaming a packet to the sink.

The sink must not be full at the gate and no other packet streaming can be in progress. The packet must not be nullptr. The gate must be a valid gate of this module and it must support pushing and streaming packets.

Reimplemented from inet::queueing::PacketPusherBase.

 {
     Enter_Method("pushPacketStart");
     take(packet);
     streamDatarate = datarate;
     pushOrSendOrSchedulePacketProgress(packet, gate, datarate, b(0), b(0));
     updateDisplayString();
 }

◆ receivePacketEnd()

void inet::InterpacketGapInserter::receivePacketEnd	(	cPacket *	packet,
		cGate *	gate,
		double	datarate
	)

protectedvirtual

 {
     auto packet = check_and_cast<Packet *>(cpacket);
     pushOrSendPacketEnd(packet, outputGate, consumer, packet->getTransmissionId());
 }

◆ receivePacketProgress()

void inet::InterpacketGapInserter::receivePacketProgress	(	cPacket *	packet,
		cGate *	gate,
		double	datarate,
		int	bitPosition,
		simtime_t	timePosition,
		int	extraProcessableBitLength,
		simtime_t	extraProcessableDuration
	)

protectedvirtual

 {
     auto packet = check_and_cast<Packet *>(cpacket);
     pushOrSendPacketProgress(packet, outputGate, consumer, bps(datarate), b(bitPosition), b(extraProcessableBitLength), packet->getTransmissionId());
 }

◆ receivePacketStart()

void inet::InterpacketGapInserter::receivePacketStart	(	cPacket *	packet,
		cGate *	gate,
		double	datarate
	)

protectedvirtual

 {
     auto packet = check_and_cast<Packet *>(cpacket);
     pushOrSendPacketStart(packet, outputGate, consumer, bps(datarate), packet->getTransmissionId());
 }

◆ resolveDirective()

const char * inet::InterpacketGapInserter::resolveDirective ( char directive ) const

overrideprotectedvirtual

Reimplemented from inet::queueing::PacketProcessorBase.

 {
     static std::string result;
     switch (directive) {
         case 'g':
             result = simtime_t(durationPar->doubleValue()).ustr().c_str();
             break;
         case 'd':
             result = CLOCKTIME_AS_SIMTIME(packetDelay).ustr().c_str();
             break;
         default:
             return PacketPusherBase::resolveDirective(directive);
     }
     return result.c_str();
 }

◆ supportsPacketPulling()

virtual bool inet::InterpacketGapInserter::supportsPacketPulling ( cGate * gate ) const

inlineoverridevirtual

Returns true if the processor supports pulling packets at the given gate.

Pulling a packet is a synchronous operation that is initiated by the sink module. A pulled packet can be passed as a whole using pullPacket(), or it can be streamed from the source to the sink using pullPacketStart(), pullPacketEnd(), and pullPacketProgress().

For output gates, true means that the connected module can pull packets from this module. For input gates, true means that this module can pull packets from the connected module. For example, a packet server module can pull packets from a queue module.

Connecting incompatible gates raises an error during initialize. The gate parameter must be a valid gate of this module. The gate should be marked with @labels(pull) in the NED file.

Reimplemented from inet::queueing::PacketPusherBase.

49 { return false; }

◆ supportsPacketPushing()

virtual bool inet::InterpacketGapInserter::supportsPacketPushing ( cGate * gate ) const

inlineoverridevirtual

Returns true if the processor supports pushing packets at the given gate.

Pushing a packet is a synchronous operation that is initiated by the source module. A pushed packet can be passed as a whole using pushPacket(), or it can be streamed from the source to the sink using pushPacketStart(), pushPacketEnd(), and pushPacketProgress().

For output gates, true means that this module can push packets into the connected module. For input gates, true means that the connected module can push packets into this module. For example, a packet generator module can push packets into a queue module.

Connecting incompatible gates raises an error during initialize. The gate parameter must be a valid gate of this module. The gate should be marked with @labels(push) in the NED file.

Reimplemented from inet::queueing::PacketPusherBase.

48 { return true; }

Member Data Documentation

◆ durationPar

cPar* inet::InterpacketGapInserter::durationPar = nullptr

protected

Referenced by canPushPacket(), canPushSomePacket(), handleCanPushPacketChanged(), initialize(), pushOrSendOrSchedulePacketProgress(), pushPacket(), and resolveDirective().

◆ packetDelay

clocktime_t inet::InterpacketGapInserter::packetDelay

protected

Referenced by pushOrSendOrSchedulePacketProgress(), pushPacket(), and resolveDirective().

◆ packetEndTime

clocktime_t inet::InterpacketGapInserter::packetEndTime

protected

Referenced by canPushPacket(), canPushSomePacket(), handleCanPushPacketChanged(), handlePushPacketProcessed(), initialize(), pushOrSendOrSchedulePacketProgress(), and pushPacket().

◆ packetStartTime

clocktime_t inet::InterpacketGapInserter::packetStartTime

protected

Referenced by initialize(), pushOrSendOrSchedulePacketProgress(), and pushPacket().

◆ progress

ClockEvent* inet::InterpacketGapInserter::progress = nullptr

protected

Referenced by handleMessage(), initialize(), pushOrSendOrSchedulePacketProgress(), pushPacket(), and ~InterpacketGapInserter().

◆ streamDatarate

bps inet::InterpacketGapInserter::streamDatarate = bps(NaN)

protected

Referenced by pushPacketEnd(), pushPacketProgress(), and pushPacketStart().

◆ timer

ClockEvent* inet::InterpacketGapInserter::timer = nullptr

protected

Referenced by handleCanPushPacketChanged(), handleMessage(), initialize(), and ~InterpacketGapInserter().

The documentation for this class was generated from the following files:

Public Member Functions

Protected Member Functions

Protected Attributes

Additional Inherited Members

Constructor & Destructor Documentation

◆ ~InterpacketGapInserter()

Member Function Documentation

◆ canPushPacket()

◆ canPushSomePacket()

◆ getConsumer()

◆ handleCanPushPacketChanged()

◆ handleMessage()

◆ handlePushPacketProcessed()

◆ initialize()

◆ pushOrSendOrSchedulePacketProgress()

◆ pushPacket()

◆ pushPacketEnd()

◆ pushPacketProgress()

◆ pushPacketStart()

◆ receivePacketEnd()

◆ receivePacketProgress()

◆ receivePacketStart()

◆ resolveDirective()

◆ supportsPacketPulling()

◆ supportsPacketPushing()

Member Data Documentation

◆ durationPar

◆ packetDelay

◆ packetEndTime

◆ packetStartTime

◆ progress

◆ streamDatarate

◆ timer