Класс uniset::MBTCPMultiMaster

#include <MBTCPMultiMaster.h>

Граф наследования:uniset::MBTCPMultiMaster:

Граф связей класса uniset::MBTCPMultiMaster:

Открытые члены
	MBTCPMultiMaster (uniset::ObjectId objId, xmlNode *cnode, uniset::ObjectId shmID, const std::shared_ptr< SharedMemory > &ic=nullptr, const std::string &prefix="mbtcp")
virtual uniset::SimpleInfo *	getInfo (const char *userparam=0) override
Открытые члены унаследованные от uniset::MBExchange
	MBExchange (uniset::ObjectId objId, xmlNode *confnode, uniset::ObjectId shmID, const std::shared_ptr< SharedMemory > &ic=nullptr, const std::string &prefix="mb")
void	execute ()
std::shared_ptr< LogAgregator >	getLogAggregator ()
std::shared_ptr< DebugStream >	log ()
bool	reload (const std::string &confile)
Открытые члены унаследованные от 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::SimpleInfo *	apiRequest (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< UniSetObject >	get_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< MBTCPMultiMaster >	init_mbmaster (int argc, const char *const *argv, uniset::ObjectId shmID, const std::shared_ptr< SharedMemory > &ic=nullptr, const std::string &prefix="mbtcp")
static void	help_print (int argc, const char *const *argv)
Открытые статические члены унаследованные от uniset::MBExchange
static void	help_print (int argc, const char *const *argv)
static uint8_t	firstBit (uint16_t mask)
static uint16_t	getBits (uint16_t value, uint16_t mask, uint8_t offset)
static uint16_t	setBits (uint16_t value, uint16_t set, uint16_t mask, uint8_t offset)
static uint16_t	forceSetBits (uint16_t value, uint16_t set, uint16_t mask, uint8_t offset)

Защищенные члены
virtual void	sysCommand (const uniset::SystemMessage *sm) override
virtual void	initIterators () override
virtual std::shared_ptr< ModbusClient >	initMB (bool reopen=false) override
virtual Poco::JSON::Object::Ptr	httpGetMyInfo (Poco::JSON::Object::Ptr root) override
virtual bool	deactivateObject () override
	Деактивация объекта (переопределяется для необходимых действий при завершении работы).
virtual bool	reconfigure (const std::shared_ptr< uniset::UniXML > &xml, const std::shared_ptr< uniset::MBConfig > &mbconf) override
void	initCheckConnectionParameters ()
void	initGateList (uniset::UniXML::iterator it, const std::shared_ptr< uniset::MBConfig > &mbconf)
void	poll_thread ()
void	check_thread ()
void	final_thread ()
Защищенные члены унаследованные от uniset::MBExchange
virtual void	step ()
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 bool	activateObject () override
	Активизация объекта (переопределяется для необходимых действий после активизации).
virtual void	initValues ()
virtual Poco::JSON::Object::Ptr	httpHelp (const Poco::URI::QueryParameters &p) override
virtual Poco::JSON::Object::Ptr	httpRequest (const UHttp::HttpRequestContext &ctx) override
Poco::JSON::Object::Ptr	httpModeGet (const Poco::URI::QueryParameters &p)
Poco::JSON::Object::Ptr	httpModeSet (const Poco::URI::QueryParameters &p)
Poco::JSON::Object::Ptr	httpModeSupported (const Poco::URI::QueryParameters &)
Poco::JSON::Object::Ptr	httpMode (const Poco::URI::QueryParameters &p)
Poco::JSON::Object::Ptr	httpReload (const Poco::URI::QueryParameters &p)
virtual Poco::JSON::Object::Ptr	httpGetParam (const Poco::URI::QueryParameters &p)
virtual Poco::JSON::Object::Ptr	httpSetParam (const Poco::URI::QueryParameters &p)
virtual Poco::JSON::Object::Ptr	httpStatus ()
Poco::JSON::Object::Ptr	httpGet (const Poco::URI::QueryParameters &p)
Poco::JSON::Object::Ptr	httpRegisters (const Poco::URI::QueryParameters &p)
Poco::JSON::Object::Ptr	httpDevices (const Poco::URI::QueryParameters &p)
Poco::JSON::Object::Ptr	httpTakeControl (Poco::Net::HTTPServerResponse &resp, const Poco::URI::QueryParameters &p)
Poco::JSON::Object::Ptr	httpReleaseControl (const Poco::URI::QueryParameters &p)
void	firstInitRegisters ()
bool	preInitRead (MBConfig::InitList::iterator &p)
bool	initSMValue (ModbusRTU::ModbusData *data, int count, MBConfig::RSProperty *p)
virtual bool	poll ()
bool	pollRTU (std::shared_ptr< MBConfig::RTUDevice > &dev, MBConfig::RegMap::iterator &it)
void	updateSM ()
void	updateRTU (MBConfig::RegMap::iterator &it)
void	updateMTR (MBConfig::RegMap::iterator &it)
void	updateRTU188 (MBConfig::RegMap::iterator &it)
void	updateRSProperty (MBConfig::RSProperty *p, bool write_only=false)
virtual void	updateRespondSensors ()
bool	isUpdateSM (bool wrFunc, long devMode) const noexcept
bool	isPollEnabled (bool wrFunc) const noexcept
bool	isSafeMode (std::shared_ptr< MBConfig::RTUDevice > &dev) const noexcept
bool	isProcActive () const
void	setProcActive (bool st)
bool	waitSMReady ()
bool	readItem (const std::shared_ptr< UniXML > &xml, UniXML::iterator &it, xmlNode *sec)
bool	initItem (UniXML::iterator &it)
void	initOffsetList ()
std::string	initPropPrefix (const std::string &def_prop_prefix)
Защищенные члены унаследованные от uniset::UniSetObject
virtual void	processingMessage (const uniset::VoidMessage *msg)
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 ()
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)
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)
virtual Poco::JSON::Object::Ptr	request_params_get (const std::string &req, const Poco::URI::QueryParameters &p)
virtual Poco::JSON::Object::Ptr	request_params_set (const std::string &req, const Poco::URI::QueryParameters &p)
Защищенные члены унаследованные от uniset::LT_Object
virtual std::string	getTimerName (int id) const
TimersList	getTimersList () const

Защищенные данные
uniset::uniset_rwmutex	mbMutex
bool	force_disconnect
timeout_t	checktime
timeout_t	defaultIgnoreTimeout
timeout_t	channelTimeout
Защищенные данные унаследованные от uniset::MBExchange
bool	httpControlAllow = { false }
std::atomic_bool	httpControlActive = { false }
bool	httpEnabledSetParams = { false }
bool	allInitOK
xmlNode *	cnode = { 0 }
std::shared_ptr< SMInterface >	shm
timeout_t	initPause = { 3000 }
uniset::uniset_rwmutex	mutex_start
bool	force = { false }
bool	force_out = { false }
PassiveTimer	ptHeartBeat
uniset::ObjectId	sidHeartBeat = { uniset::DefaultObjectId }
long	maxHeartBeat = { 10 }
IOController::IOStateList::iterator	itHeartBeat
uniset::ObjectId	sidTestSMReady = {uniset::DefaultObjectId }
uniset::ObjectId	sidExchangeMode = { uniset::DefaultObjectId }
IOController::IOStateList::iterator	itExchangeMode
std::atomic< MBConfig::ExchangeMode >	exchangeMode = { MBConfig::emNone }
std::atomic< MBConfig::ExchangeMode >	sensorExchangeMode = { MBConfig::emNone }
std::atomic_bool	activated = { false }
std::atomic_bool	canceled = { false }
timeout_t	activateTimeout = { 20000 }
bool	notUseExchangeTimer = { false }
timeout_t	stat_time = { 0 }
size_t	poll_count = { 0 }
PassiveTimer	ptStatistic
std::string	statInfo = { "" }
std::shared_ptr< ModbusClient >	mb
PassiveTimer	ptReopen
Trigger	trReopen
PassiveTimer	ptInitChannel
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< uniset::MBConfig >	mbconf
uniset::uniset_rwmutex	mutex_conf
Защищенные данные унаследованные от uniset::UniSetObject
std::shared_ptr< UInterface >	ui
std::string	myname
std::weak_ptr< UniSetManager >	mymngr
Защищенные данные унаследованные от uniset::LT_Object
timeout_t	sleepTime

Дополнительные унаследованные члены
Открытые типы унаследованные от uniset::MBExchange
enum	Timer { tmExchange }
Защищенные типы унаследованные от uniset::LT_Object
typedef std::deque< TimerInfo >	TimersList

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

Реализация Modbus TCP MultiMaster для обмена с многими ModbusRTU устройствами

через один modbus tcp шлюз, доступный по нескольким ip-адресам.

Чтобы не зависеть от таймаутов TCP соединений, которые могут неопределённо зависать

на создании соединения с недоступным хостом. Обмен вынесен в отдельный поток. При этом в этом же потоке обновляются данные в SM. В свою очередь информация о датчиках связи обновляется в основном потоке (чтобы не зависеть от TCP).

Методы

deactivateObject()

bool MBTCPMultiMaster::deactivateObject ( )

overrideprotectedvirtual

Деактивация объекта (переопределяется для необходимых действий при завершении работы).

Переопределяет метод предка uniset::MBExchange.

getInfo()

uniset::SimpleInfo * MBTCPMultiMaster::getInfo ( const char * userparam = 0 )

overridevirtual

Переопределяет метод предка uniset::MBExchange.

httpGetMyInfo()

Poco::JSON::Object::Ptr MBTCPMultiMaster::httpGetMyInfo ( Poco::JSON::Object::Ptr root )

overrideprotectedvirtual

Переопределяет метод предка uniset::MBExchange.

init_mbmaster()

std::shared_ptr< MBTCPMultiMaster > MBTCPMultiMaster::init_mbmaster ( int argc, const char *const * argv, uniset::ObjectId shmID, const std::shared_ptr< SharedMemory > & ic = nullptr, const std::string & prefix = "mbtcp" )

static

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

initIterators()

void MBTCPMultiMaster::initIterators ( )

overrideprotectedvirtual

Переопределяет метод предка uniset::MBExchange.

initMB()

std::shared_ptr< ModbusClient > MBTCPMultiMaster::initMB ( bool reopen = false )

overrideprotectedvirtual

Замещает uniset::MBExchange.

reconfigure()

bool MBTCPMultiMaster::reconfigure ( const std::shared_ptr< uniset::UniXML > & xml, const std::shared_ptr< uniset::MBConfig > & mbconf )

overrideprotectedvirtual

Переопределяет метод предка uniset::MBExchange.

sysCommand()

void MBTCPMultiMaster::sysCommand ( const uniset::SystemMessage * sm )

overrideprotectedvirtual

Переопределяет метод предка uniset::MBExchange.