From 02fb1e061aef7764d090f0018ba587c3386bda04 Mon Sep 17 00:00:00 2001 From: Maxim Mamontov Date: Mon, 25 Jul 2011 18:27:32 +0300 Subject: [PATCH] Old files removed --- .../stargazer/plugins/other/smux/snmp.cpp | 676 ------------------ projects/stargazer/plugins/other/smux/snmp.h | 112 --- 2 files changed, 788 deletions(-) delete mode 100644 projects/stargazer/plugins/other/smux/snmp.cpp delete mode 100644 projects/stargazer/plugins/other/smux/snmp.h diff --git a/projects/stargazer/plugins/other/smux/snmp.cpp b/projects/stargazer/plugins/other/smux/snmp.cpp deleted file mode 100644 index 8e1113e3..00000000 --- a/projects/stargazer/plugins/other/smux/snmp.cpp +++ /dev/null @@ -1,676 +0,0 @@ -#include -#include -#include - -#include -#include -#include -#include - -#include -#include - -#include "asn1/OpenPDU.h" -#include "asn1/ClosePDU.h" -#include "asn1/RReqPDU.h" -#include "asn1/GetRequest-PDU.h" -#include "asn1/GetResponse-PDU.h" -#include "asn1/VarBindList.h" -#include "asn1/VarBind.h" -#include "asn1/OBJECT_IDENTIFIER.h" -#include "asn1/ber_decoder.h" -#include "asn1/der_encoder.h" - -#include "snmp.h" -#include "stg/common.h" - -bool WaitPackets(int sd); - -std::string OI2String(OBJECT_IDENTIFIER_t * oi) -{ -std::string res; - -int arcs[1024]; -int count = OBJECT_IDENTIFIER_get_arcs(oi, arcs, sizeof(arcs[0]), 1024); - -if (count > 1024) - return ""; - -for (int i = 0; i < count; ++i) - { - res += "."; - std::string arc; - strprintf(&arc, "%d", arcs[i]); - res += arc; - } - -return res; -} - -bool String2OI(const std::string & str, OBJECT_IDENTIFIER_t * oi) -{ -size_t left = 0, pos = 0, arcPos = 0; -int arcs[1024]; -pos = str.find_first_of('.', left); -if (pos == 0) - { - left = 1; - pos = str.find_first_of('.', left); - } -while (pos != std::string::npos) - { - int arc = 0; - if (str2x(str.substr(left, left - pos), arc)) - { - return false; - } - arcs[arcPos++] = arc; - left = pos + 1; - pos = str.find_first_of('.', left); - } -if (left < str.length()) - { - int arc = 0; - if (str2x(str.substr(left, left - pos), arc)) - { - return false; - } - arcs[arcPos++] = arc; - } -printfd(__FILE__, "String2OI() - arcPos: %d\n", arcPos); -OBJECT_IDENTIFIER_set_arcs(oi, arcs, sizeof(arcs[0]), arcPos); -return true; -} - -class SNMP_AGENT_CREATOR -{ -private: - SNMP_AGENT * snmpAgent; - -public: - SNMP_AGENT_CREATOR() - : snmpAgent(new SNMP_AGENT()) - { - }; - ~SNMP_AGENT_CREATOR() - { - printfd(__FILE__, "SNMP_AGENT_CREATOR::~SNMP_AGENT_CREATOR()\n"); - delete snmpAgent; - }; - - SNMP_AGENT * GetPlugin() - { - return snmpAgent; - }; -}; - -SNMP_AGENT_CREATOR sac; - -PLUGIN * GetPlugin() -{ -return sac.GetPlugin(); -} - -int SendOpenPDU(int fd) -{ -const char * description = "Stg SNMP Agent"; -//int oid[] = {1, 3, 6, 1, 4, 1, 38313, 1, 5, 2, 1, 1}; -asn_enc_rval_t error; -OpenPDU_t msg; - -memset(&msg, 0, sizeof(msg)); - -msg.present = OpenPDU_PR_simple; -asn_long2INTEGER(&msg.choice.simple.version, SimpleOpen__version_version_1); -/*OBJECT_IDENTIFIER_set_arcs(&msg.choice.simple.identity, - oid, - sizeof(oid[0]), - 7);*/ -if (!String2OI(".1.3.6.1.4.1.38313", &msg.choice.simple.identity)) - { - printfd(__FILE__, "SendOpenPDU() - failed to convert string to OBJECT_IDENTIFIER\n"); - return -1; - } -OCTET_STRING_fromString(&msg.choice.simple.description, - description); -OCTET_STRING_fromString(&msg.choice.simple.password, - ""); - -char buffer[1024]; -error = der_encode_to_buffer(&asn_DEF_OpenPDU, &msg, buffer, sizeof(buffer)); - -if (error.encoded == -1) - { - printfd(__FILE__, "Could not encode OpenPDU (at %s)\n", - error.failed_type ? error.failed_type->name : "unknown"); - return -1; - } -else - { - write(fd, buffer, error.encoded); - printfd(__FILE__, "OpenPDU encoded successfully to %d bytes\n", error.encoded); - } -return 0; -} - -int SendClosePDU(int fd) -{ -ClosePDU_t msg; - -memset(&msg, 0, sizeof(msg)); - -asn_long2INTEGER(&msg, ClosePDU_goingDown); - -char buffer[1024]; -asn_enc_rval_t error; -error = der_encode_to_buffer(&asn_DEF_ClosePDU, &msg, buffer, sizeof(buffer)); - -if (error.encoded == -1) - { - printfd(__FILE__, "Could not encode ClosePDU (at %s)\n", - error.failed_type ? error.failed_type->name : "unknown"); - return -1; - } -else - { - write(fd, buffer, error.encoded); - printfd(__FILE__, "ClosePDU encoded successfully\n"); - } -return 0; -} - -int SendRReqPDU(int fd) -{ -int oid[] = {1, 3, 6, 1, 4, 1, 38313, 1}; -asn_enc_rval_t error; -RReqPDU_t msg; - -memset(&msg, 0, sizeof(msg)); - -msg.priority = 0; -asn_long2INTEGER(&msg.operation, RReqPDU__operation_readOnly); -OBJECT_IDENTIFIER_set_arcs(&msg.subtree, - oid, - sizeof(oid[0]), - 8); - -char buffer[1024]; -error = der_encode_to_buffer(&asn_DEF_RReqPDU, &msg, buffer, sizeof(buffer)); - -if (error.encoded == -1) - { - printfd(__FILE__, "Could not encode RReqPDU (at %s)\n", - error.failed_type ? error.failed_type->name : "unknown"); - return -1; - } -else - { - write(fd, buffer, error.encoded); - printfd(__FILE__, "RReqPDU encoded successfully to %d bytes\n", error.encoded); - } -return 0; -} - -int SendGetResponsePDU(int fd, GetResponse_PDU_t * getResponse) -{ -asn_enc_rval_t error; - -char buffer[1024]; -error = der_encode_to_buffer(&asn_DEF_GetResponse_PDU, getResponse, buffer, sizeof(buffer)); - -if (error.encoded == -1) - { - printfd(__FILE__, "Could not encode GetResponsePDU (at %s)\n", - error.failed_type ? error.failed_type->name : "unknown"); - return -1; - } -else - { - write(fd, buffer, error.encoded); - printfd(__FILE__, "GetResponsePDU encoded successfully to %d bytes\n", error.encoded); - } -return 0; -} - -int SendGetResponseErrorPDU(int fd, const PDU_t * getRequest, int errorStatus, int errorIndex) -{ -asn_enc_rval_t error; -GetResponse_PDU_t msg; - -memset(&msg, 0, sizeof(msg)); - -msg.request_id = getRequest->request_id; -asn_long2INTEGER(&msg.error_status, errorStatus); -asn_long2INTEGER(&msg.error_index, errorIndex); - -char buffer[1024]; -error = der_encode_to_buffer(&asn_DEF_GetResponse_PDU, &msg, buffer, sizeof(buffer)); - -if (error.encoded == -1) - { - printfd(__FILE__, "Could not encode GetResponsePDU for error (at %s)\n", - error.failed_type ? error.failed_type->name : "unknown"); - return -1; - } -else - { - write(fd, buffer, error.encoded); - printfd(__FILE__, "GetResponsePDU for error encoded successfully to %d bytes\n", error.encoded); - } -return 0; -} - -SMUX_PDUs_t * RecvSMUXPDUs(int fd) -{ -char buffer[1024]; -SMUX_PDUs_t * pdus = NULL; - -memset(buffer, 0, sizeof(buffer)); - -size_t length = read(fd, buffer, sizeof(buffer)); -if (length < 1) - return NULL; -asn_dec_rval_t error; -error = ber_decode(0, &asn_DEF_SMUX_PDUs, (void **)&pdus, buffer, length); -if(error.code != RC_OK) - { - printfd(__FILE__, "Failed to decode PDUs at byte %ld\n", - (long)error.consumed); - return NULL; - } -return pdus; -} - -int ParseIntInRange(const std::string & str, - int min, - int max, - int * val) -{ -if (str2x(str.c_str(), *val)) - { - return -1; - } -if (*val < min || *val > max) - { - return -1; - } -return 0; -} - -SNMP_AGENT_SETTINGS::SNMP_AGENT_SETTINGS() - : ip(0), - port(0) -{} - -int SNMP_AGENT_SETTINGS::ParseSettings(const MODULE_SETTINGS & s) -{ -PARAM_VALUE pv; -std::vector::const_iterator pvi; -int p; -/////////////////////////// -pv.param = "Port"; -pvi = std::find(s.moduleParams.begin(), s.moduleParams.end(), pv); -if (pvi == s.moduleParams.end()) - { - errorStr = "Parameter \'Port\' not found."; - printfd(__FILE__, "Parameter 'Port' not found\n"); - return -1; - } -if (ParseIntInRange(pvi->value[0], 2, 65535, &p)) - { - errorStr = "Cannot parse parameter \'Port\': " + errorStr; - printfd(__FILE__, "Cannot parse parameter 'Port'\n"); - return -1; - } -port = p; - -pv.param = "Password"; -pvi = std::find(s.moduleParams.begin(), s.moduleParams.end(), pv); -if (pvi == s.moduleParams.end()) - { - errorStr = "Parameter \'Password\' not found."; - printfd(__FILE__, "Parameter 'Password' not found\n"); - password = ""; - } -else - { - password = pvi->value[0]; - } - -pv.param = "Server"; -pvi = std::find(s.moduleParams.begin(), s.moduleParams.end(), pv); -if (pvi == s.moduleParams.end()) - { - errorStr = "Parameter \'Server\' not found."; - printfd(__FILE__, "Parameter 'Server' not found\n"); - return -1; - } -ip = inet_strington(pvi->value[0]); - -return 0; -} - -SNMP_AGENT::SNMP_AGENT() - : PLUGIN(), - users(NULL), - tariffs(NULL), - running(false), - stopped(true), - sock(-1) -{ -pthread_mutex_init(&mutex, NULL); - -smuxHandlers[SMUX_PDUs_PR_close] = &SNMP_AGENT::CloseHandler; -smuxHandlers[SMUX_PDUs_PR_registerResponse] = &SNMP_AGENT::RegisterResponseHandler; -smuxHandlers[SMUX_PDUs_PR_pdus] = &SNMP_AGENT::PDUsHandler; -smuxHandlers[SMUX_PDUs_PR_commitOrRollback] = &SNMP_AGENT::CommitOrRollbackHandler; - -pdusHandlers[PDUs_PR_get_request] = &SNMP_AGENT::GetRequestHandler; -pdusHandlers[PDUs_PR_get_next_request] = &SNMP_AGENT::GetNextRequestHandler; -pdusHandlers[PDUs_PR_set_request] = &SNMP_AGENT::SetRequestHandler; -} - -SNMP_AGENT::~SNMP_AGENT() -{ -Sensors::iterator it; -for (it = sensors.begin(); it != sensors.end(); ++it) - delete it->second; -printfd(__FILE__, "SNMP_AGENT::~SNMP_AGENT()\n"); -pthread_mutex_destroy(&mutex); -} - -int SNMP_AGENT::ParseSettings() -{ -return snmpAgentSettings.ParseSettings(settings); -} - -int SNMP_AGENT::Start() -{ -if (PrepareNet()) - return -1; - -// Users -sensors[".1.3.6.1.4.1.38313.1.1.1"] = new TotalUsersSensor(*users); -sensors[".1.3.6.1.4.1.38313.1.1.2"] = new ConnectedUsersSensor(*users); -sensors[".1.3.6.1.4.1.38313.1.1.3"] = new AuthorizedUsersSensor(*users); -sensors[".1.3.6.1.4.1.38313.1.1.4"] = new AlwaysOnlineUsersSensor(*users); -sensors[".1.3.6.1.4.1.38313.1.1.5"] = new NoCashUsersSensor(*users); -sensors[".1.3.6.1.4.1.38313.1.1.7"] = new DisabledDetailStatsUsersSensor(*users); -sensors[".1.3.6.1.4.1.38313.1.1.8"] = new DisabledUsersSensor(*users); -sensors[".1.3.6.1.4.1.38313.1.1.9"] = new PassiveUsersSensor(*users); -sensors[".1.3.6.1.4.1.38313.1.1.10"] = new CreditUsersSensor(*users); -sensors[".1.3.6.1.4.1.38313.1.1.11"] = new FreeMbUsersSensor(*users); -sensors[".1.3.6.1.4.1.38313.1.1.12"] = new TariffChangeUsersSensor(*users); -// Tariffs -sensors[".1.3.6.1.4.1.38313.1.2.1"] = new TotalTariffsSensor(*tariffs); - -if (!running) - { - if (pthread_create(&thread, NULL, Runner, this)) - { - errorStr = "Cannot create thread."; - printfd(__FILE__, "Cannot create thread\n"); - return -1; - } - } - -return 0; -} - -int SNMP_AGENT::Stop() -{ -printfd(__FILE__, "SNMP_AGENT::Stop() - Before\n"); -running = false; - -if (!stopped) - { - //5 seconds to thread stops itself - for (int i = 0; i < 25 && !stopped; i++) - { - struct timespec ts = {0, 200000000}; - nanosleep(&ts, NULL); - } - - //after 5 seconds waiting thread still running. now killing it - if (!stopped) - { - printfd(__FILE__, "SNMP_AGENT::Stop() - failed to stop thread, killing it\n"); - if (pthread_kill(thread, SIGINT)) - { - errorStr = "Cannot kill thread."; - printfd(__FILE__, "SNMP_AGENT::Stop() - Cannot kill thread\n"); - return -1; - } - printfd(__FILE__, "SNMP_AGENT::Stop() - killed Run\n"); - } - } - -pthread_join(thread, NULL); - -close(sock); - -printfd(__FILE__, "SNMP_AGENT::Stop() - After\n"); -return 0; -} - -void * SNMP_AGENT::Runner(void * d) -{ -SNMP_AGENT * snmpAgent = static_cast(d); - -snmpAgent->Run(); - -return NULL; -} - -void SNMP_AGENT::Run() -{ -SendOpenPDU(sock); -SendRReqPDU(sock); -running = true; -stopped = false; -printfd(__FILE__, "SNMP_AGENT::Run() - Before\n"); -while(running) - { - if (WaitPackets(sock)) - { - SMUX_PDUs_t * pdus = RecvSMUXPDUs(sock); - if (pdus) - DispatchPDUs(pdus); - } - if (!running) - break; - } -printfd(__FILE__, "SNMP_AGENT::Run() - After\n"); -SendClosePDU(sock); -stopped = true; -} - -bool SNMP_AGENT::PrepareNet() -{ -sock = socket(AF_INET, SOCK_STREAM, 0); - -if (sock < 0) - { - errorStr = "Cannot create socket."; - printfd(__FILE__, "Cannot create socket\n"); - return true; - } - -struct sockaddr_in addr; - -addr.sin_family = AF_INET; -addr.sin_port = htons(snmpAgentSettings.GetPort()); -addr.sin_addr.s_addr = snmpAgentSettings.GetIP(); - -if (connect(sock, reinterpret_cast(&addr), sizeof(addr))) - { - errorStr = "Cannot connect."; - printfd(__FILE__, "Cannot connect. Message: '%s'\n", strerror(errno)); - return true; - } - -return false; -} - -bool WaitPackets(int sd) -{ -fd_set rfds; -FD_ZERO(&rfds); -FD_SET(sd, &rfds); - -struct timeval tv; -tv.tv_sec = 0; -tv.tv_usec = 500000; - -int res = select(sd + 1, &rfds, NULL, NULL, &tv); -if (res == -1) // Error - { - if (errno != EINTR) - { - printfd(__FILE__, "Error on select: '%s'\n", strerror(errno)); - } - return false; - } - -if (res == 0) // Timeout - { - return false; - } - -return true; -} - -bool SNMP_AGENT::DispatchPDUs(const SMUX_PDUs_t * pdus) -{ -SMUXHandlers::iterator it; -it = smuxHandlers.find(pdus->present); -if (it != smuxHandlers.end()) - { - return (this->*(it->second))(pdus); - } -else - { - switch (pdus->present) - { - case SMUX_PDUs_PR_NOTHING: - printfd(__FILE__, "PDUs: nothing\n"); - break; - case SMUX_PDUs_PR_open: - printfd(__FILE__, "PDUs: open\n"); - break; - case SMUX_PDUs_PR_registerRequest: - printfd(__FILE__, "PDUs: registerRequest\n"); - break; - default: - printfd(__FILE__, "PDUs: undefined\n"); - } - asn_fprint(stderr, &asn_DEF_SMUX_PDUs, pdus); - } -return false; -} - -bool SNMP_AGENT::CloseHandler(const SMUX_PDUs_t * pdus) -{ -printfd(__FILE__, "SNMP_AGENT::CloseHandler()\n"); -asn_fprint(stderr, &asn_DEF_SMUX_PDUs, pdus); -return false; -} - -bool SNMP_AGENT::RegisterResponseHandler(const SMUX_PDUs_t * pdus) -{ -printfd(__FILE__, "SNMP_AGENT::RegisterResponseHandler()\n"); -asn_fprint(stderr, &asn_DEF_SMUX_PDUs, pdus); -return false; -} - -bool SNMP_AGENT::PDUsHandler(const SMUX_PDUs_t * pdus) -{ -printfd(__FILE__, "SNMP_AGENT::PDUsHandler()\n"); -asn_fprint(stderr, &asn_DEF_SMUX_PDUs, pdus); -PDUsHandlers::iterator it; -it = pdusHandlers.find(pdus->choice.pdus.present); -if (it != pdusHandlers.end()) - { - return (this->*(it->second))(&pdus->choice.pdus); - } -else - { - switch (pdus->present) - { - case PDUs_PR_NOTHING: - printfd(__FILE__, "SNMP_AGENT::PDUsHandler() - nothing\n"); - break; - case PDUs_PR_get_response: - printfd(__FILE__, "SNMP_AGENT::PDUsHandler() - get response\n"); - break; - case PDUs_PR_trap: - printfd(__FILE__, "SNMP_AGENT::PDUsHandler() - trap\n"); - break; - default: - printfd(__FILE__, "SNMP_AGENT::PDUsHandler() - undefined\n"); - } - } -return false; -} - -bool SNMP_AGENT::CommitOrRollbackHandler(const SMUX_PDUs_t * pdus) -{ -printfd(__FILE__, "SNMP_AGENT::CommitOrRollbackHandler()\n"); -asn_fprint(stderr, &asn_DEF_SMUX_PDUs, pdus); -return false; -} - -bool SNMP_AGENT::GetRequestHandler(const PDUs_t * pdus) -{ -printfd(__FILE__, "SNMP_AGENT::GetRequestHandler()\n"); -asn_fprint(stderr, &asn_DEF_PDUs, pdus); -const GetRequest_PDU_t * getRequest = &pdus->choice.get_request; -GetResponse_PDU_t msg; -VarBindList_t * varBindList = &msg.variable_bindings; -memset(&msg, 0, sizeof(msg)); - -msg.request_id = getRequest->request_id; -asn_long2INTEGER(&msg.error_status, 0); -asn_long2INTEGER(&msg.error_index, 0); - -const VarBindList_t * vbl = &getRequest->variable_bindings; -for (int i = 0; i < vbl->list.count; ++i) - { - VarBind_t * vb = getRequest->variable_bindings.list.array[i]; - Sensors::iterator it; - it = sensors.find(OI2String(&vb->name)); - if (it == sensors.end()) - { - SendGetResponseErrorPDU(sock, getRequest, PDU__error_status_noSuchName, i); - return true; - } - - VarBind_t newVb; - memset(&newVb, 0, sizeof(newVb)); - - newVb.name = vb->name; - it->second->GetValue(&newVb.value); - - ASN_SEQUENCE_ADD(varBindList, &newVb); - } - -SendGetResponsePDU(sock, &msg); -asn_fprint(stderr, &asn_DEF_PDU, &msg); -return false; -} - -bool SNMP_AGENT::GetNextRequestHandler(const PDUs_t * pdus) -{ -printfd(__FILE__, "SNMP_AGENT::GetNextRequestHandler()\n"); -asn_fprint(stderr, &asn_DEF_PDUs, pdus); -return false; -} - -bool SNMP_AGENT::SetRequestHandler(const PDUs_t * pdus) -{ -printfd(__FILE__, "SNMP_AGENT::SetRequestHandler()\n"); -asn_fprint(stderr, &asn_DEF_PDUs, pdus); -SendGetResponseErrorPDU(sock, &pdus->choice.set_request, PDU__error_status_readOnly, 0); -return false; -} - diff --git a/projects/stargazer/plugins/other/smux/snmp.h b/projects/stargazer/plugins/other/smux/snmp.h deleted file mode 100644 index 540bd3d7..00000000 --- a/projects/stargazer/plugins/other/smux/snmp.h +++ /dev/null @@ -1,112 +0,0 @@ -#ifndef __SNMP_AGENT_H__ -#define __SNMP_AGENT_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" - -extern "C" PLUGIN * GetPlugin(); - -class USER; -class SETTINGS; -class SNMP_AGENT; - -typedef bool (SNMP_AGENT::*SMUXPacketHandler)(const SMUX_PDUs_t * pdus); -typedef bool (SNMP_AGENT::*PDUsHandler)(const PDUs_t * pdus); -typedef std::map SMUXHandlers; -typedef std::map PDUsHandlers; -//----------------------------------------------------------------------------- -class SNMP_AGENT_SETTINGS { -public: - SNMP_AGENT_SETTINGS(); - virtual ~SNMP_AGENT_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 SNMP_AGENT : public PLUGIN { -public: - SNMP_AGENT(); - virtual ~SNMP_AGENT(); - - 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 SNMP Agent 1.0"; } - 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 PDUsHandler(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; - SNMP_AGENT_SETTINGS snmpAgentSettings; - 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 -- 2.43.2