st2110vrxmonitor.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_NETWORK
#include <cstdint>
#include <promeki/duration.h>
#include <promeki/namespace.h>
#include <promeki/timestamp.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class St2110VrxMonitor {
        public:
                St2110VrxMonitor() = default;
 
                void configure(uint64_t drainRateBytesPerSec, int64_t vrxFullBytes,
                               int cmaxPackets,
                               const Duration &burstWindow = Duration::fromMicroseconds(5));
 
                void reset();
 
                void observePacket(int64_t timestamp, int sizeBytes);
 
                bool isConfigured() const { return _drainRateBytesPerSec > 0; }
 
                uint64_t drainRateBytesPerSec() const { return _drainRateBytesPerSec; }
 
                int64_t vrxFullBytes() const { return _vrxFullBytes; }
 
                int cmaxPackets() const { return _cmaxPackets; }
 
                int64_t occupancyBytes() const { return _occupancyBytes; }
 
                int64_t peakOccupancyBytes() const { return _peakOccupancyBytes; }
 
                int peakBurstPackets() const { return _peakBurstPackets; }
 
                int64_t vrxViolations() const { return _vrxViolations; }
 
                int64_t cmaxViolations() const { return _cmaxViolations; }
 
                int64_t observedPackets() const { return _observedPackets; }
 
                int64_t observedBytes() const { return _observedBytes; }
 
                bool isConformant() const { return _vrxViolations == 0 && _cmaxViolations == 0; }
 
        private:
                uint64_t _drainRateBytesPerSec = 0;
                int64_t  _vrxFullBytes = 0;
                int      _cmaxPackets = 0;
                int64_t  _burstWindowNs = 5'000;
 
                int64_t _occupancyBytes = 0;
                int64_t _peakOccupancyBytes = 0;
                int     _currentBurstPackets = 0;
                int     _peakBurstPackets = 0;
                int64_t _vrxViolations = 0;
                int64_t _cmaxViolations = 0;
                int64_t _observedPackets = 0;
                int64_t _observedBytes = 0;
                int64_t _lastTimestampNs = -1;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NETWORK