interface_stats_worker.h

Go to the documentation of this file.

 
#ifndef INTERFACE_STATS_WORKER_H
#define INTERFACE_STATS_WORKER_H
 
#include <config.h>
 
#include <wsutil/processes.h> /* for ws_process_id */
 
#include <QHash>
#include <QMetaType>
#include <QObject>
#include <QString>
#include <QStringList>
 
class QTimer;

struct InterfaceStatsSample
{
    quint64 receivedPackets = 0; 
    quint64 droppedPackets = 0;  
};

typedef QHash<QString, InterfaceStatsSample> InterfaceStatsSnapshot;
 
Q_DECLARE_METATYPE(InterfaceStatsSample)
Q_DECLARE_METATYPE(InterfaceStatsSnapshot)
 

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

    ~InterfaceStatsWorker() override;

    int updateInterval() const;
 
public slots:
    void start();

    void stop();

    void setInterfaceFilter(const QStringList &interfaceNames);

    void setUpdateInterval(int intervalMsec);

    void pause();

    void resume();
 
signals:
    void started();

    void stopped();

    void failed(int exitCode, const QString &errorMessage);

    void sampled(const InterfaceStatsSnapshot &snapshot);
 
private slots:
    void poll();
 
private:
    bool openStream();

    void closeStream();

    void armTimer();

    void disarmTimer();

    void assertWorkerThread() const;
 
    QStringList interfaceFilter_; 
    int updateIntervalMsec_;      
    QTimer *timer_;               
    int statFd_;                  
    ws_process_id forkChild_;     
    bool paused_;                 
};
 
#endif // INTERFACE_STATS_WORKER_H