UniSet 2.44.3
Класс uniset::RRDServer

#include <RRDServer.h>

Граф наследования:uniset::RRDServer:
Граф связей класса uniset::RRDServer:

Классы

struct  DSInfo
struct  RRDInfo

Открытые члены

 RRDServer (uniset::ObjectId objId, xmlNode *cnode, uniset::ObjectId shmID, const std::shared_ptr< SharedMemory > &ic=nullptr, const std::string &prefix="rrd")
std::shared_ptr< LogAgregatorgetLogAggregator ()
std::shared_ptr< DebugStreamlog ()
Открытые члены унаследованные от UObject_SK
 UObject_SK (uniset::ObjectId id, xmlNode *node=uniset::uniset_conf() ->getNode("UObject"), const std::string &argprefix="", xmlNode *globalConfNode=nullptr)
long getValue (uniset::ObjectId sid)
void setValue (uniset::ObjectId sid, long value)
void askSensor (uniset::ObjectId sid, UniversalIO::UIOCommand, uniset::ObjectId node=uniset::uniset_conf() ->getLocalNode())
virtual uniset::SimpleInfogetInfo (const char *userparam) override
std::shared_ptr< DebugStreamlog () noexcept
std::shared_ptr< uniset::LogAgregatorlogAgregator () noexcept
void init_dlog (std::shared_ptr< DebugStream > d) noexcept
std::string dumpVars ()
std::string help () const noexcept
virtual Poco::JSON::Object::Ptr httpRequest (const uniset::UHttp::HttpRequestContext &ctx) override
virtual Poco::JSON::Object::Ptr httpHelp (const Poco::URI::QueryParameters &p) override
Открытые члены унаследованные от uniset::UniSetObject
 UniSetObject (const std::string &name, const std::string &section)
 UniSetObject (uniset::ObjectId id)
virtual CORBA::Boolean exist () override
virtual uniset::ObjectId getId () override
const uniset::ObjectId getId () const
std::string getName () const
virtual uniset::ObjectType getType () override
const std::string getStrType ()
virtual uniset::SimpleInfoapiRequest (const char *query) override
virtual void push (const uniset::TransportMessage &msg) override
 поместить сообщение в очередь
virtual void pushMessage (const char *msg, ::CORBA::Long mtype, const ::uniset::Timespec &tm, const ::uniset::ProducerInfo &pi, ::CORBA::Long priority, ::CORBA::Long consumer) override
 поместить текстовое сообщение в очередь
uniset::ObjectPtr getRef () const
std::shared_ptr< UniSetObjectget_ptr ()
virtual timeout_t askTimer (uniset::TimerId timerid, timeout_t timeMS, clock_t ticks=-1, uniset::Message::Priority p=uniset::Message::High) override
Открытые члены унаследованные от uniset::LT_Object
timeout_t checkTimers (UniSetObject *obj)
timeout_t getTimeInterval (uniset::TimerId timerid) const
timeout_t getTimeLeft (uniset::TimerId timerid) const

Открытые статические члены

static std::shared_ptr< RRDServer > init_rrdstorage (int argc, const char *const *argv, uniset::ObjectId shmID, const std::shared_ptr< SharedMemory > &ic=nullptr, const std::string &prefix="rrd")
static void help_print (int argc, const char *const *argv)

Открытые атрибуты

const size_t RRD_MAX_DSNAME_LEN = 19

Защищенные типы

typedef std::unordered_map< uniset::ObjectId, std::shared_ptr< DSInfo > > DSMap
typedef std::vector< std::shared_ptr< DSInfo > > DSList
typedef std::vector< RRDInfoRRDList
Защищенные типы унаследованные от uniset::LT_Object
typedef std::deque< TimerInfoTimersList

Защищенные члены

virtual void askSensors (UniversalIO::UIOCommand cmd) override
virtual void sensorInfo (const uniset::SensorMessage *sm) override
virtual void timerInfo (const uniset::TimerMessage *tm) override
virtual void sysCommand (const uniset::SystemMessage *sm) override
void initRRD (xmlNode *cnode, int tmID)
Защищенные члены унаследованные от UObject_SK
virtual void callback () noexcept override
virtual void processingMessage (const uniset::VoidMessage *msg) override
virtual bool activateObject () override
 Активизация объекта (переопределяется для необходимых действий после активизации).
virtual bool deactivateObject () override
 Деактивация объекта (переопределяется для необходимых действий при завершении работы).
virtual std::string getMonitInfo () const
virtual std::string getTypeOfMessage (int t) const
virtual void httpGetUserData (Poco::JSON::Object::Ptr &jdata)
virtual Poco::JSON::Object::Ptr httpDumpIO ()
virtual Poco::JSON::Object::Ptr httpRequestLog (const Poco::URI::QueryParameters &p)
virtual Poco::JSON::Object::Ptr request_params_set (const std::string &req, const Poco::URI::QueryParameters &p) override
virtual Poco::JSON::Object::Ptr request_params_get (const std::string &req, const Poco::URI::QueryParameters &p) override
void preAskSensors (UniversalIO::UIOCommand cmd)
void preSysCommand (const uniset::SystemMessage *sm)
bool waitSM (int wait_msec, uniset::ObjectId testID=uniset::DefaultObjectId)
uniset::ObjectId getSMTestID () const
int getIntProp (const std::string &name)
const std::string getProp (const std::string &name)
Защищенные члены унаследованные от uniset::UniSetObject
virtual void onTextMessage (const uniset::TextMessage *tm)
VoidMessagePtr receiveMessage ()
VoidMessagePtr waitMessage (timeout_t msec=UniSetTimer::WaitUpTime)
void termWaiting ()
size_t countMessages ()
size_t getCountOfLostMessages () const
void uterminate ()
void thread (bool create)
void offThread ()
void onThread ()
void setID (uniset::ObjectId id)
void setThreadPriority (Poco::Thread::Priority p)
void setMaxSizeOfMessageQueue (size_t s)
size_t getMaxSizeOfMessageQueue () const
bool isActive () const
void setActive (bool set)
virtual Poco::JSON::Object::Ptr httpGetMyInfo (Poco::JSON::Object::Ptr root)
Poco::JSON::Object::Ptr request_configure (const std::string &req, const Poco::URI::QueryParameters &p)
Poco::JSON::Object::Ptr request_configure_get (const std::string &req, const Poco::URI::QueryParameters &p)
Poco::JSON::Object::Ptr request_configure_by_name (const std::string &name, const std::string &props)
Poco::JSON::Object::Ptr request_params (const std::string &req, const Poco::URI::QueryParameters &p)
Защищенные члены унаследованные от uniset::LT_Object
virtual std::string getTimerName (int id) const
TimersList getTimersList () const

Защищенные данные

std::shared_ptr< SMInterfaceshm
RRDList rrdlist
Защищенные данные унаследованные от UObject_SK
bool active
const std::string argprefix
uniset::ObjectId smTestID
uniset::PassiveTimer ptHeartBeat
uniset::ObjectId idHeartBeat
long maxHeartBeat
xmlNode * confnode
uniset::timeout_t smReadyTimeout
std::atomic_bool activated = { false }
std::atomic_bool canceled = { false }
uniset::timeout_t activateTimeout
uniset::PassiveTimer ptStartUpTimeout
int askPause
IOController_i::SensorInfo si
std::shared_ptr< uniset::LogAgregatorloga
std::shared_ptr< DebugStreammylog
std::shared_ptr< uniset::LogServerlogserv
std::string logserv_host = {""}
int logserv_port = {0}
uniset::VMonitor vmon
Защищенные данные унаследованные от uniset::UniSetObject
std::shared_ptr< UInterfaceui
std::string myname
std::weak_ptr< UniSetManager > mymngr
Защищенные данные унаследованные от uniset::LT_Object
timeout_t sleepTime

Подробное описание

Реализация хранения на основе RRD

Методы

◆ askSensors()

void RRDServer::askSensors ( UniversalIO::UIOCommand cmd)
overrideprotectedvirtual

Переопределяет метод предка UObject_SK.

◆ help_print()

void RRDServer::help_print ( int argc,
const char *const * argv )
static

глобальная функция для вывода help-а

◆ init_rrdstorage()

std::shared_ptr< RRDServer > RRDServer::init_rrdstorage ( int argc,
const char *const * argv,
uniset::ObjectId shmID,
const std::shared_ptr< SharedMemory > & ic = nullptr,
const std::string & prefix = "rrd" )
static

глобальная функция для инициализации объекта

◆ sensorInfo()

void RRDServer::sensorInfo ( const uniset::SensorMessage * sm)
overrideprotectedvirtual

Переопределяет метод предка UObject_SK.

◆ sysCommand()

void RRDServer::sysCommand ( const uniset::SystemMessage * sm)
overrideprotectedvirtual

Переопределяет метод предка UObject_SK.

◆ timerInfo()

void RRDServer::timerInfo ( const uniset::TimerMessage * tm)
overrideprotectedvirtual

Переопределяет метод предка UObject_SK.

Данные класса

◆ RRD_MAX_DSNAME_LEN

const size_t uniset::RRDServer::RRD_MAX_DSNAME_LEN = 19

максимальная длинна имени в RRD