cadencepacketscheduler.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_NETWORK
#include <promeki/cadence.h>
#include <promeki/duration.h>
#include <promeki/namespace.h>
#include <promeki/packetscheduler.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class CadencePacketScheduler : public PacketScheduler {
        public:
                static constexpr int DefaultStallReanchorMultiplier = 10;
 
                CadencePacketScheduler();
                ~CadencePacketScheduler() override = default;
 
                Error configure(const Spec &spec) override;
                int   enqueue(const PacketTransport::DatagramList &datagrams) override;
                int   predictedTxDelayUs() const override;
 
                void setStallReanchorMultiplier(int n) { _stallMultiplier = n; }
 
        private:
                int sendOne(const PacketTransport::Datagram &d);
 
                Cadence _streamCadence{Duration()};
                bool    _streamAnchored = false;
                int     _stallMultiplier = DefaultStallReanchorMultiplier;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NETWORK