X-Git-Url: https://git.stg.codes/stg.git/blobdiff_plain/cf951863b80fb594f99b29e87558e03d453f75ef..1147628fd6aa3e78322a596880c1d46f8e6468df:/projects/stargazer/plugins/other/smux/smux.h diff --git a/projects/stargazer/plugins/other/smux/smux.h b/projects/stargazer/plugins/other/smux/smux.h index 03d3d3b6..1b1ee96e 100644 --- a/projects/stargazer/plugins/other/smux/smux.h +++ b/projects/stargazer/plugins/other/smux/smux.h @@ -5,6 +5,7 @@ #include #include +#include #include "stg/SMUX-PDUs.h" #include "stg/ObjectSyntax.h" @@ -52,6 +53,27 @@ private: std::string password; }; //----------------------------------------------------------------------------- +class CHG_AFTER_NOTIFIER : public PROPERTY_NOTIFIER_BASE { +public: + CHG_AFTER_NOTIFIER(SMUX & s, const USER_PTR & u) : smux(s), userPtr(u) {} + void Notify(const std::string &, const std::string &); + + USER_PTR GetUserPtr() { return userPtr; } + +private: + SMUX & smux; + USER_PTR userPtr; +}; +//----------------------------------------------------------------------------- +class ADD_DEL_USER_NOTIFIER : public NOTIFIER_BASE { +public: + ADD_DEL_USER_NOTIFIER(SMUX & s) : smux(s) {} + void Notify(const USER_PTR &); + +private: + SMUX & smux; +}; +//----------------------------------------------------------------------------- class SMUX : public PLUGIN { public: SMUX(); @@ -76,6 +98,8 @@ public: uint16_t GetStartPosition() const { return 100; } uint16_t GetStopPosition() const { return 100; } + bool UpdateTables(); + private: static void * Runner(void * d); void Run(); @@ -92,7 +116,8 @@ private: bool GetNextRequestHandler(const PDUs_t * pdus); bool SetRequestHandler(const PDUs_t * pdus); - bool UpdateTables(); + void SetNotifiers(); + void ResetNotifiers(); USERS * users; TARIFFS * tariffs; @@ -117,6 +142,8 @@ private: Sensors sensors; Tables tables; + std::list notifiers; + ADD_DEL_USER_NOTIFIER addDelNotifier; }; //-----------------------------------------------------------------------------