X-Git-Url: https://git.stg.codes/stg.git/blobdiff_plain/b4e18f8f29d35f891cfd872638e27c8cf70b52c3..51998949e60e2a7e86e4393b315cfb76a58ca80d:/projects/stargazer/plugins/other/ping/ping.h?ds=sidebyside diff --git a/projects/stargazer/plugins/other/ping/ping.h b/projects/stargazer/plugins/other/ping/ping.h index 2f4791a1..9986be39 100644 --- a/projects/stargazer/plugins/other/ping/ping.h +++ b/projects/stargazer/plugins/other/ping/ping.h @@ -1,150 +1,142 @@ - /* - $Revision: 1.16 $ - $Date: 2009/06/23 11:32:28 $ - $Author: faust $ - */ +#pragma once -#ifndef PING_H -#define PING_H - -#include +#include "stg/plugin.h" +#include "stg/module_settings.h" +#include "stg/notifer.h" +#include "stg/user_ips.h" +#include "stg/pinger.h" +#include "stg/users.h" +#include "stg/logger.h" #include +#include +#include -#include "os_int.h" -#include "base_plugin.h" -#include "notifer.h" -#include "user_ips.h" -#include "pinger.h" -#include "../../../users.h" +#include -using namespace std; +class PING; -extern "C" BASE_PLUGIN * GetPlugin(); +namespace STG +{ +struct USER; +struct SETTINGS; +} -class PING; +using UserPtr = STG::User*; //-----------------------------------------------------------------------------*/ -class CHG_CURRIP_NOTIFIER_PING: public PROPERTY_NOTIFIER_BASE -{ +class CHG_CURRIP_NOTIFIER_PING: public STG::PropertyNotifierBase { public: - CHG_CURRIP_NOTIFIER_PING(const PING & p, user_iter u) : user(u), ping(p) {} + CHG_CURRIP_NOTIFIER_PING(const PING & p, UserPtr u) + : user(u), ping(p) {} void Notify(const uint32_t & oldIP, const uint32_t & newIP); - user_iter GetUser() { return user; } + UserPtr GetUser() const { return user; } private: - user_iter user; + CHG_CURRIP_NOTIFIER_PING & operator=(const CHG_CURRIP_NOTIFIER_PING &); + + UserPtr user; const PING & ping; }; //----------------------------------------------------------------------------- -class CHG_IPS_NOTIFIER_PING: public PROPERTY_NOTIFIER_BASE -{ +class CHG_IPS_NOTIFIER_PING: public STG::PropertyNotifierBase { public: - CHG_IPS_NOTIFIER_PING(const PING & p, user_iter u) : user(u), ping(p) {} - void Notify(const USER_IPS & oldIPS, const USER_IPS & newIPS); - user_iter GetUser() { return user; } + CHG_IPS_NOTIFIER_PING(const PING & p, UserPtr u) + : user(u), ping(p) {} + void Notify(const STG::UserIPs & oldIPS, const STG::UserIPs & newIPS); + UserPtr GetUser() const { return user; } private: - user_iter user; + CHG_IPS_NOTIFIER_PING & operator=(const CHG_IPS_NOTIFIER_PING &); + + UserPtr user; const PING & ping; }; //----------------------------------------------------------------------------- -class ADD_USER_NONIFIER_PING: public NOTIFIER_BASE -{ +class ADD_USER_NONIFIER_PING: public STG::NotifierBase { public: - ADD_USER_NONIFIER_PING(PING & p) : ping(p) {} - virtual ~ADD_USER_NONIFIER_PING() {} - void Notify(const user_iter & user); + explicit ADD_USER_NONIFIER_PING(PING & p) : ping(p) {} + void Notify(const UserPtr & user); private: + ADD_USER_NONIFIER_PING(const ADD_USER_NONIFIER_PING &); + ADD_USER_NONIFIER_PING & operator=(const ADD_USER_NONIFIER_PING &); + PING & ping; }; //----------------------------------------------------------------------------- -class DEL_USER_NONIFIER_PING: public NOTIFIER_BASE -{ +class DEL_USER_NONIFIER_PING: public STG::NotifierBase { public: - DEL_USER_NONIFIER_PING(PING & p) : ping(p) {} - virtual ~DEL_USER_NONIFIER_PING() {} - void Notify(const user_iter & user); + explicit DEL_USER_NONIFIER_PING(PING & p) : ping(p) {} + void Notify(const UserPtr & user); private: + DEL_USER_NONIFIER_PING(const DEL_USER_NONIFIER_PING &); + DEL_USER_NONIFIER_PING & operator=(const DEL_USER_NONIFIER_PING &); + PING & ping; }; //----------------------------------------------------------------------------- -class PING_SETTINGS -{ +class PING_SETTINGS { public: - PING_SETTINGS(); - virtual ~PING_SETTINGS() {} - const string& GetStrError() const { return errorStr; } - int ParseSettings(const MODULE_SETTINGS & s); + PING_SETTINGS() : pingDelay(0) {} + const std::string & GetStrError() const { return errorStr; } + int ParseSettings(const STG::ModuleSettings & s); int GetPingDelay() const { return pingDelay; } private: - int ParseIntInRange(const string & str, int min, int max, int * val); - int pingDelay; - mutable string errorStr; + mutable std::string errorStr; }; //----------------------------------------------------------------------------- -class PING: public BASE_PLUGIN -{ +class PING : public STG::Plugin { friend class CHG_CURRIP_NOTIFIER_PING; friend class CHG_IPS_NOTIFIER_PING; public: PING(); - virtual ~PING(); - - void SetUsers(USERS * u); - void SetTariffs(TARIFFS *) {} - void SetAdmins(ADMINS *) {} - void SetTraffcounter(TRAFFCOUNTER *) {} - void SetStore(BASE_STORE *) {} - void SetStgSettings(const SETTINGS *) {} - void SetSettings(const MODULE_SETTINGS & s); - int ParseSettings(); - - int Start(); - int Stop(); - int Reload() { return 0; } - bool IsRunning(); - - const string & GetStrError() const; - const string GetVersion() const; - uint16_t GetStartPosition() const; - uint16_t GetStopPosition() const; - - void AddUser(user_iter u); - void DelUser(user_iter u); + ~PING() override; + + void SetUsers(STG::Users * u) override { users = u; } + void SetSettings(const STG::ModuleSettings & s) override { settings = s; } + int ParseSettings() override; + + int Start() override; + int Stop() override; + int Reload(const STG::ModuleSettings & /*ms*/) override { return 0; } + bool IsRunning() override; + + const std::string & GetStrError() const override { return errorStr; } + std::string GetVersion() const override { return "Pinger v.1.01"; } + uint16_t GetStartPosition() const override { return 10; } + uint16_t GetStopPosition() const override { return 10; } + + void AddUser(UserPtr u); + void DelUser(UserPtr u); private: + explicit PING(const PING & rvalue); + PING & operator=(const PING & rvalue); + void GetUsers(); - void SetUserNotifiers(user_iter u); - void UnSetUserNotifiers(user_iter u); + void SetUserNotifiers(UserPtr u); + void UnSetUserNotifiers(UserPtr u); static void * Run(void * d); - mutable string errorStr; + mutable std::string errorStr; PING_SETTINGS pingSettings; - MODULE_SETTINGS settings; - USERS * users; - list usersList; - - /* - ÍÙ ÄÏÌÖÎÙ ÐÅÒÅÐÒÏ×ÅÒÉÔØ ×ÏÚÍÏÖÎÏÓÔØ ÐÉÎÇÏ×ÁÎÉÑ ÀÚÅÒÁ ÐÒÉ ÉÚÍÅÎÅÎÉÉ - ÓÌÅÄÕÀÝÉÈ ÅÇÏ ÐÁÒÁÍÅÔÒÏ×: - - currIP - - ips - */ + STG::ModuleSettings settings; + STG::Users * users; + std::list usersList; + pthread_t thread; pthread_mutex_t mutex; bool nonstop; bool isRunning; mutable STG_PINGER pinger; - list ChgCurrIPNotifierList; - list ChgIPNotifierList; + std::list ChgCurrIPNotifierList; + std::list ChgIPNotifierList; ADD_USER_NONIFIER_PING onAddUserNotifier; DEL_USER_NONIFIER_PING onDelUserNotifier; -}; -//----------------------------------------------------------------------------- -#endif + STG::PluginLogger logger; +};