interface_statistics.h

Go to the documentation of this file.

 
#ifndef INTERFACE_STATISTICS_H
#define INTERFACE_STATISTICS_H
 
#include <config.h>
 
#include <ui/qt/manager/interface_stats_worker.h>
 
#include <QHash>
#include <QList>
#include <QObject>
#include <QSet>
#include <QString>
#include <QStringList>
#include <QThread>

class InterfaceStatistics : public QObject
{
    Q_OBJECT
 
public:
    explicit InterfaceStatistics(QObject *parent = nullptr);

    ~InterfaceStatistics() override;

    QList<int> pointsFor(const QString &interfaceName) const;

    QList<int> droppedPointsFor(const QString &interfaceName) const;

    bool isActive(const QString &interfaceName) const;

    unsigned rate(const QString &interfaceName) const;

    int updateInterval() const;

    int historyCapacity() const;

    bool isRunning() const;
 
public slots:
    void start();

    void stop();

    void pauseSampling();

    void resumeSampling();

    void setUpdateInterval(int intervalMsec);

    void setInterfaceFilter(const QStringList &interfaceNames);

    void removeInterfaces(const QStringList &removedInterfaceNames);

    void resetActivity();

    void setHistoryCapacity(int maxEntries);
 
signals:
    void statisticsUpdated();

    void activityChanged();

    /* Bridge signals to the worker (queued across the thread boundary). */
    void startWorker();
    void stopWorker();
    void pauseWorker();
    void resumeWorker();
    void setWorkerInterval(int intervalMsec);
    void setWorkerFilter(const QStringList &interfaceNames);
 
private slots:
    void onSampled(const InterfaceStatsSnapshot &snapshot);

    void onWorkerFailed(int exitCode, const QString &message);
 
private:
    void appendCapped(QList<int> &buffer, int value) const;

    void trimToCapacity(QList<int> &buffer) const;

    void resetBaselines();
 
    InterfaceStatsWorker *worker_;            
    QThread workerThread_;                    
 
    QHash<QString, quint64> lastReceived_;    
    QHash<QString, quint64> lastDropped_;     
    QHash<QString, QList<int> > receivedHistory_; 
    QHash<QString, QList<int> > droppedHistory_;  
    QSet<QString> active_;                    
 
    QStringList interfaceFilter_;             
    int historyCapacity_;                     
    int updateIntervalMsec_;                  
    bool running_;                            
    bool paused_;                             
    bool warned_no_interfaces_;               
};
 
#endif // INTERFACE_STATISTICS_H