txtimepacketscheduler.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 TxTimePacketScheduler : public PacketScheduler {
        public:
                TxTimePacketScheduler() = default;
                ~TxTimePacketScheduler() override = default;
 
                Error configure(const Spec &spec) override;
                int   enqueue(const PacketTransport::DatagramList &datagrams) override;
                int   predictedTxDelayUs() const override;
 
        private:
                uint64_t taiNanosNow() const;
 
                Cadence  _streamCadence{Duration()};
                bool     _streamAnchored = false;
                bool     _txTimeEnabled = false;
                int64_t  _taiOffsetNs = 0; 
                int      _stallMultiplier = 10;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NETWORK