libgfaipc/Test/qmlApp/qappctrl.h

// qappctrl.h :
//

#if !defined(AGD_QAPPCTRL_H__ADD46467_F628_4A07_8844_613598E359DE__INCLUDED_)
#define AGD_QAPPCTRL_H__ADD46467_F628_4A07_8844_613598E359DE__INCLUDED_

#include <QObject>
#include <QQmlEngine>
#include <QQmlContext>
#include <gfa/gfaipc.h>

#ifdef __cplusplus

/////////////////////////////////////////////////////////////////////////////
// qappctrl.h - Declarations:

class QGfaAppInfo : public QObject
{
    Q_OBJECT
	Q_PROPERTY(int state READ state NOTIFY stateChanged)
	Q_PROPERTY(QString stateText READ stateText NOTIFY stateTextChanged)
	Q_PROPERTY(QString name READ name NOTIFY nameChanged)
	Q_PROPERTY(quint64 cycInt READ cycInt NOTIFY cycIntChanged)
	Q_PROPERTY(quint64 cycCur READ cycCur NOTIFY cycCurChanged)
	Q_PROPERTY(quint64 cycMin READ cycMin NOTIFY cycMinChanged)
	Q_PROPERTY(quint64 cycMax READ cycMax NOTIFY cycMaxChanged)
	Q_PROPERTY(quint64 wktCur READ wktCur NOTIFY wktCurChanged)
	Q_PROPERTY(quint64 wktMin READ wktMin NOTIFY wktMinChanged)
	Q_PROPERTY(quint64 wktMax READ wktMax NOTIFY wktMaxChanged)
	Q_PROPERTY(quint64 upTime READ upTime NOTIFY upTimeChanged)
	Q_PROPERTY(double cpuTime READ cpuTime NOTIFY cpuTimeChanged)
	Q_PROPERTY(double cpuCur READ cpuCur NOTIFY cpuCurChanged)
	Q_PROPERTY(double cpuAvg READ cpuAvg NOTIFY cpuAvgChanged)
	Q_PROPERTY(quint32 vmPeak READ vmPeak NOTIFY vmPeakChanged)
	Q_PROPERTY(quint32 vmSize READ vmSize NOTIFY vmSizeChanged)
	Q_PROPERTY(quint32 vmHWM READ vmHWM NOTIFY vmHWMChanged)
	Q_PROPERTY(quint32 vmRSS READ vmRSS NOTIFY vmRSSChanged)

public:
	Q_INVOKABLE bool pause(void);
	Q_INVOKABLE bool resume(void);
	Q_INVOKABLE bool stop(void);

signals:
	void stateChanged(int val);
	void stateTextChanged(const QString &val);
	void nameChanged(const QString &val);
	void sendControlMessage(appid_t nAppID, ctrlmsg_t msg);
	void cycIntChanged(quint64 val);
	void cycCurChanged(quint64 val);
	void cycMinChanged(quint64 val);
	void cycMaxChanged(quint64 val);
	void wktCurChanged(quint64 val);
	void wktMinChanged(quint64 val);
	void wktMaxChanged(quint64 val);
	void upTimeChanged(quint64 val);
	void cpuTimeChanged(double val);
	void cpuCurChanged(double val);
	void cpuAvgChanged(double val);
	void vmPeakChanged(quint32 val);
	void vmSizeChanged(quint32 val);
	void vmHWMChanged(quint32 val);
	void vmRSSChanged(quint32 val);

public:
	explicit QGfaAppInfo(int nIndex, QObject *pParent = NULL);
	virtual ~QGfaAppInfo(void);

	int state(void) const;
	bool setState(int val);

	QString stateText(void) const;
	void setStateText(int val);

	QString name(void) const;
	void setName(const QString &val);
	
	quint64 cycInt(void) const;
	quint64 cycCur(void) const;
	quint64 cycMin(void) const;
	quint64 cycMax(void) const;
	quint64 wktCur(void) const;
	quint64 wktMin(void) const;
	quint64 wktMax(void) const;
	quint64 upTime(void) const;
	double cpuTime(void) const;
	double cpuCur(void) const;
	double cpuAvg(void) const;
	quint32 vmPeak(void) const;
	quint32 vmSize(void) const;
	quint32 vmHWM(void) const;
	quint32 vmRSS(void) const;

	void setAppTimes(LPCGFA_APPCTRL_APPTIMES pat, GfaIpcAppStates state, bool bDoHeavyLoadUpdate = false);
	void setAppMemInfo(LPCGFA_APPCTRL_APPMEM pam, GfaIpcAppStates state, bool bDoHeavyLoadUpdate = false);

private:

private:
	int m_state;
	QString m_stateText;
	QString m_name;
	int m_nIndex;
	appid_t m_nAppID;
	quint64 m_cycInt;
	quint64 m_cycCur;
	quint64 m_cycMin;
	quint64 m_cycMax;
	quint64 m_wktCur;
	quint64 m_wktMin;
	quint64 m_wktMax;
	quint64 m_upTime;
	double m_cpuTime;
	double m_cpuPercCur;
	double m_cpuPercAvg;
	quint32 m_vmPeak;
	quint32 m_vmSize;
	quint32 m_vmHWM;
	quint32 m_vmRSS;
};

/////////////////////////////////////////////////////////////////////////////

class QGfaAppCtrl : public QObject
{
    Q_OBJECT
    Q_PROPERTY(QQmlListProperty<QGfaAppInfo> appInfo READ appInfo CONSTANT)
	Q_PROPERTY(quint64 minPass READ minPass NOTIFY minPassChanged)
	Q_PROPERTY(quint64 maxPass READ maxPass NOTIFY maxPassChanged)
	Q_PROPERTY(quint64 avgPass READ avgPass NOTIFY avgPassChanged)

public:
	enum AppStates
	{
		STATE_NOT_RUNNING	= GIAS_StateNotRunning,
		STATE_INITIALIZING,
		STATE_RUNNING,
		STATE_PAUSED,
		STATE_HANGING,
		STATE_TERMINATING,
		STATE_INVALID
	};
	Q_ENUM(AppStates)
	
	enum AppIndex
	{
		APP_INDEX_REMANENT		= GAI_Remanent,
		APP_INDEX_DATALOGGER	= GAI_Datalogger,
		APP_INDEX_SUMMARIST		= GAI_Summarist,
		APP_INDEX_REST			= GAI_Rest,
		APP_INDEX_MQTTCL		= GAI_Mqttcl
	};
	Q_ENUM(AppIndex)

signals:
	void minPassChanged(quint64 val);
	void maxPassChanged(quint64 val);
	void avgPassChanged(quint64 val);

public:
	explicit QGfaAppCtrl(QObject *pParent = NULL);
	virtual ~QGfaAppCtrl(void);

	bool Create(appid_t nAppID, const char *pszDisplayName, int nTimerIntMs, clock64_t nHeavyLoadUpdateIntervalMs);
	void Release(void);
	void RegisterQmlTypes(QQmlEngine &rEng, int nVerMajor = 1, int nVerMinor = 0);
	bool PresetDisplayName(appid_t nAppID, const char *pszName);
	bool SubscribeStateEvents(appid_t nAppMask);
	int SetState(int nState);

public:
	Q_INVOKABLE int appIndexFromAppID(quint64 nAppID);

public:
	QQmlListProperty<QGfaAppInfo> appInfo(void);
	quint64 minPass(void) const;
	quint64 maxPass(void) const;
	quint64 avgPass(void) const;

private slots:
	void onSendControlMessage(appid_t nAppID, ctrlmsg_t msg);
	void timerEvent(QTimerEvent *event) override;

private:
	HAPPCTRL m_hAC;
	appid_t m_nAppID;
	int m_nTimerID;
	QList<QGfaAppInfo*> m_appInfo;
	clock64_t m_curPass;
	clock64_t m_minPass;
	clock64_t m_maxPass;
	clock64_t m_avgPass;
	appid_t m_nEvtSrcs;
	clock64_t m_nHeavyLoadUpdateIntervalUs;
	struct timespec m_tsLastHeavyLoadUpdate;
};

/////////////////////////////////////////////////////////////////////////////
#endif	//	__cplusplus
#endif	//	!defined(AGD_QAPPCTRL_H__ADD46467_F628_4A07_8844_613598E359DE__INCLUDED_)