DataRateTracker.h

Go to the documentation of this file.

#pragma once
 
#include <functional>
 
#include <QtCore/QtGlobal>
 
#include "MonotonicClock.h"
 
class DataRateTracker
{
public:
    using Clock = std::function<quint64()>;
    explicit DataRateTracker(Clock clock = MonotonicClock::nowUs);
 
    void recordBytes(qsizetype bytes);
 
    void refresh();
 
    quint64 totalBytes() const { return _totalBytes; }
 
    double bytesPerSec() const { return _currentRate; }
 
    double kBps() const { return _currentRate / 1024.0; }
 
    bool rateUpdated() const { return _rateUpdated; }
 
    void reset();
    void resetRate();
 
private:
    Clock _clock;
    quint64 _windowStartedUs = 0;
    quint64 _totalBytes = 0;
    qsizetype _windowBytes = 0;
    double _currentRate = 0.0;
    bool _rateUpdated = false;
 
    static constexpr quint64 kWindowUs = 1000000;
};