UniSet
2.6.0
|
Открытые члены | |
RTUExchange (uniset::ObjectId objId, uniset::ObjectId shmID, const std::shared_ptr< SharedMemory > &ic=nullptr, const std::string &prefix="rs") | |
![]() | |
MBExchange (uniset::ObjectId objId, uniset::ObjectId shmID, const std::shared_ptr< SharedMemory > &ic=nullptr, const std::string &prefix="mb") | |
void | printMap (RTUDeviceMap &d) |
void | execute () |
std::shared_ptr< LogAgregator > | getLogAggregator () |
std::shared_ptr< DebugStream > | log () |
virtual uniset::SimpleInfo * | getInfo (const char *userparam=0) override |
![]() | |
UniSetObject (const std::string &name, const std::string §ion) | |
UniSetObject (uniset::ObjectId id) | |
std::shared_ptr< UniSetObject > | get_ptr () |
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::SimpleInfo * | apiRequest (const char *query) override |
virtual void | push (const uniset::TransportMessage &msg) override |
поместить сообщение в очередь | |
virtual Poco::JSON::Object::Ptr | httpGet (const Poco::URI::QueryParameters &p) override |
virtual Poco::JSON::Object::Ptr | httpHelp (const Poco::URI::QueryParameters &p) override |
uniset::ObjectPtr | getRef () const |
virtual timeout_t | askTimer (uniset::TimerId timerid, timeout_t timeMS, clock_t ticks=-1, uniset::Message::Priority p=uniset::Message::High) override |
![]() | |
timeout_t | checkTimers (UniSetObject *obj) |
timeout_t | getTimeInterval (uniset::TimerId timerid) |
timeout_t | getTimeLeft (uniset::TimerId timerid) |
![]() | |
virtual Poco::JSON::Object::Ptr | httpRequest (const std::string &req, const Poco::URI::QueryParameters &p) |
Открытые статические члены | |
static std::shared_ptr < RTUExchange > | init_rtuexchange (int argc, const char *const *argv, uniset::ObjectId shmID, const std::shared_ptr< SharedMemory > &ic=nullptr, const std::string &prefix="rs") |
static void | help_print (int argc, const char *const *argv) |
![]() | |
static DeviceType | getDeviceType (const std::string &dtype) |
static std::ostream & | print_plist (std::ostream &os, const PList &p) |
Защищенные члены | |
virtual void | step () override |
virtual bool | poll () override |
virtual std::shared_ptr < ModbusClient > | initMB (bool reopen=false) override |
virtual bool | initDeviceInfo (RTUDeviceMap &m, ModbusRTU::ModbusAddr a, UniXML::iterator &it) override |
![]() | |
virtual void | sysCommand (const uniset::SystemMessage *msg) override |
virtual void | sensorInfo (const uniset::SensorMessage *sm) override |
virtual void | timerInfo (const uniset::TimerMessage *tm) override |
virtual void | askSensors (UniversalIO::UIOCommand cmd) |
virtual void | initOutput () |
virtual void | sigterm (int signo) override |
virtual bool | activateObject () override |
Активизация объекта (переопределяется для необходимых действий после активизации) | |
virtual void | initIterators () |
virtual void | initValues () |
void | firstInitRegisters () |
bool | preInitRead (InitList::iterator &p) |
bool | initSMValue (ModbusRTU::ModbusData *data, int count, RSProperty *p) |
bool | pollRTU (std::shared_ptr< RTUDevice > &dev, RegMap::iterator &it) |
void | updateSM () |
void | updateRTU (RegMap::iterator &it) |
void | updateMTR (RegMap::iterator &it) |
void | updateRTU188 (RegMap::iterator &it) |
void | updateRSProperty (RSProperty *p, bool write_only=false) |
virtual void | updateRespondSensors () |
bool | checkUpdateSM (bool wrFunc, long devMode) |
bool | checkPoll (bool wrFunc) const |
bool | checkProcActive () const |
void | setProcActive (bool st) |
void | waitSMReady () |
void | readConfiguration () |
bool | readItem (const std::shared_ptr< UniXML > &xml, UniXML::iterator &it, xmlNode *sec) |
bool | initItem (UniXML::iterator &it) |
void | initDeviceList () |
void | initOffsetList () |
std::shared_ptr< RTUDevice > | addDev (RTUDeviceMap &dmap, ModbusRTU::ModbusAddr a, UniXML::iterator &it) |
std::shared_ptr< RegInfo > | addReg (std::shared_ptr< RegMap > &devices, ModbusRTU::RegID id, ModbusRTU::ModbusData r, UniXML::iterator &it, std::shared_ptr< RTUDevice > dev) |
RSProperty * | addProp (PList &plist, RSProperty &&p) |
bool | initMTRitem (UniXML::iterator &it, std::shared_ptr< RegInfo > &p) |
bool | initRTU188item (UniXML::iterator &it, std::shared_ptr< RegInfo > &p) |
bool | initRSProperty (RSProperty &p, UniXML::iterator &it) |
bool | initRegInfo (std::shared_ptr< RegInfo > &r, UniXML::iterator &it, std::shared_ptr< RTUDevice > &dev) |
bool | initRTUDevice (std::shared_ptr< RTUDevice > &d, UniXML::iterator &it) |
virtual bool | initDeviceInfo (RTUDeviceMap &m, ModbusRTU::ModbusAddr a, UniXML::iterator &it) |
std::string | initPropPrefix (const std::string &def_prop_prefix="") |
void | rtuQueryOptimization (RTUDeviceMap &m) |
![]() | |
virtual void | processingMessage (const uniset::VoidMessage *msg) |
VoidMessagePtr | receiveMessage () |
virtual VoidMessagePtr | waitMessage (timeout_t msec=UniSetTimer::WaitUpTime) |
void | termWaiting () |
size_t | countMessages () |
size_t | getCountOfLostMessages () const |
virtual bool | deactivateObject () |
Деактивиция объекта (переопределяется для необходимых действий перед деактивацией) | |
void | terminate () |
void | thread (bool create) |
void | offThread () |
void | onThread () |
virtual void | callback () |
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_conf (const std::string &req, const Poco::URI::QueryParameters &p) |
Poco::JSON::Object::Ptr | request_conf_name (const std::string &name, const std::string &props) |
![]() | |
virtual std::string | getTimerName (int id) |
TimersList | getTimersList () |
Защищенные данные | |
std::shared_ptr< ModbusRTUMaster > | mbrtu |
std::mutex | mbMutex |
std::string | devname |
ComPort::Speed | defSpeed |
bool | use485F |
bool | transmitCtl |
![]() | |
bool | allInitOK |
RTUDeviceMap | devices |
InitList | initRegList |
xmlNode * | cnode = { 0 } |
std::string | s_field |
std::string | s_fvalue |
std::shared_ptr< SMInterface > | shm |
timeout_t | initPause = { 3000 } |
uniset::uniset_rwmutex | mutex_start |
bool | force = { false } |
bool | force_out = { false } |
bool | mbregFromID = { false } |
timeout_t | polltime = { 100 } |
timeout_t | sleepPause_msec |
size_t | maxQueryCount = { ModbusRTU::MAXDATALEN } |
PassiveTimer | ptHeartBeat |
uniset::ObjectId | sidHeartBeat = { uniset::DefaultObjectId } |
long | maxHeartBeat = { 10 } |
IOController::IOStateList::iterator | itHeartBeat |
uniset::ObjectId | test_id = { uniset::DefaultObjectId } |
uniset::ObjectId | sidExchangeMode = { uniset::DefaultObjectId } |
IOController::IOStateList::iterator | itExchangeMode |
long | exchangeMode = {emNone} |
std::atomic_bool | activated = { false } |
timeout_t | activateTimeout = { 20000 } |
bool | noQueryOptimization = { false } |
bool | no_extimer = { false } |
std::string | prefix |
timeout_t | stat_time = { 0 } |
size_t | poll_count = { 0 } |
PassiveTimer | ptStatistic |
std::string | statInfo = { "" } |
std::string | prop_prefix |
std::shared_ptr< ModbusClient > | mb |
timeout_t | recv_timeout = { 500 } |
timeout_t | default_timeout = { 5000 } |
timeout_t | aftersend_pause = { 0 } |
PassiveTimer | ptReopen |
Trigger | trReopen |
PassiveTimer | ptInitChannel |
ThresholdList | thrlist |
std::string | defaultMBtype |
std::string | defaultMBaddr |
bool | defaultMBinitOK = { false } |
std::shared_ptr< LogAgregator > | loga |
std::shared_ptr< DebugStream > | mblog |
std::shared_ptr< LogServer > | logserv |
std::string | logserv_host = {""} |
int | logserv_port = {0} |
const std::shared_ptr < SharedMemory > | ic |
VMonitor | vmon |
size_t | ncycle = { 0 } |
![]() | |
std::shared_ptr< UInterface > | ui |
std::string | myname |
std::string | section |
std::weak_ptr< UniSetManager > | mymngr |
![]() | |
timeout_t | sleepTime |
Additional Inherited Members | |
![]() | |
enum | ExchangeMode { emNone = 0, emWriteOnly = 1, emReadOnly = 2, emSkipSaveToSM = 3, emSkipExchange = 4 } |
enum | DeviceType { dtUnknown, dtRTU, dtMTR, dtRTU188 } |
enum | Timer { tmExchange } |
typedef std::list< RSProperty > | PList |
typedef std::map < ModbusRTU::RegID, std::shared_ptr< RegInfo > > | RegMap |
typedef std::unordered_map < ModbusRTU::ModbusAddr, std::shared_ptr< RTUDevice > > | RTUDeviceMap |
![]() | |
static const int | NoSafetyState = -1 |
![]() | |
typedef std::list< InitRegInfo > | InitList |
typedef std::list< IOBase > | ThresholdList |
|
static |
глобальная функция для вывода help-а
Переопределяет метод предка uniset::MBExchange.
|
static |
глобальная функция для инициализации объекта