X-Git-Url: https://git.stg.codes/stg.git/blobdiff_plain/fdee6fdb88e79929c952fea956fa57e5780804cf..46b0747592074017ff0ea4b33d4a7194235886e5:/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 deleted file mode 100644 index aaf5514c..00000000 --- a/projects/stargazer/plugins/other/smux/smux.h +++ /dev/null @@ -1,114 +0,0 @@ -#ifndef __SMUX_H__ -#define __SMUX_H__ - -#include - -#include -#include - -#include "asn1/SMUX-PDUs.h" -#include "asn1/ObjectSyntax.h" - -#include "stg/os_int.h" -#include "stg/plugin.h" -#include "stg/module_settings.h" -#include "stg/users.h" -#include "stg/tariffs.h" - -#include "sensors.h" -#include "types.h" - -extern "C" PLUGIN * GetPlugin(); - -class USER; -class SETTINGS; -class SMUX; - -typedef bool (SMUX::*SMUXPacketHandler)(const SMUX_PDUs_t * pdus); -typedef bool (SMUX::*PDUsHandler)(const PDUs_t * pdus); -typedef std::map SMUXHandlers; -typedef std::map PDUsHandlers; -//----------------------------------------------------------------------------- -class SMUX_SETTINGS { -public: - SMUX_SETTINGS(); - virtual ~SMUX_SETTINGS() {} - const std::string & GetStrError() const { return errorStr; } - int ParseSettings(const MODULE_SETTINGS & s); - - uint32_t GetIP() const { return ip; } - uint16_t GetPort() const { return port; } - const std::string GetPassword() const { return password; } - -private: - mutable std::string errorStr; - - uint32_t ip; - uint16_t port; - std::string password; -}; -//----------------------------------------------------------------------------- -class SMUX : public PLUGIN { -public: - SMUX(); - virtual ~SMUX(); - - void SetUsers(USERS * u) { users = u; } - void SetTariffs(TARIFFS * t) { tariffs = t; } - void SetAdmins(ADMINS *) {} - void SetTraffcounter(TRAFFCOUNTER *) {} - void SetStore(STORE *) {} - void SetStgSettings(const SETTINGS *) {} - void SetSettings(const MODULE_SETTINGS & s) { settings = s; } - int ParseSettings(); - - int Start(); - int Stop(); - int Reload() { return 0; } - bool IsRunning() { return running && !stopped; } - - const std::string & GetStrError() const { return errorStr; } - const std::string GetVersion() const { return "Stg SMUX Plugin 1.1"; } - uint16_t GetStartPosition() const { return 100; } - uint16_t GetStopPosition() const { return 100; } - -private: - static void * Runner(void * d); - void Run(); - bool PrepareNet(); - - bool DispatchPDUs(const SMUX_PDUs_t * pdus); - - bool CloseHandler(const SMUX_PDUs_t * pdus); - bool RegisterResponseHandler(const SMUX_PDUs_t * pdus); - bool PDUsRequestHandler(const SMUX_PDUs_t * pdus); - bool CommitOrRollbackHandler(const SMUX_PDUs_t * pdus); - - bool GetRequestHandler(const PDUs_t * pdus); - bool GetNextRequestHandler(const PDUs_t * pdus); - bool SetRequestHandler(const PDUs_t * pdus); - - USERS * users; - TARIFFS * tariffs; - - mutable std::string errorStr; - SMUX_SETTINGS smuxSettings; - MODULE_SETTINGS settings; - - pthread_t thread; - pthread_mutex_t mutex; - bool running; - bool stopped; - - int sock; - - SMUXHandlers smuxHandlers; - PDUsHandlers pdusHandlers; - Sensors sensors; - -}; -//----------------------------------------------------------------------------- - -extern "C" PLUGIN * GetPlugin(); - -#endif