#include <ModbusTCPServer.h>

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

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

[см. легенду]

Классы
struct	SessionInfo

Открытые типы
typedef std::list< SessionInfo >	Sessions
typedef sigc::signal< void >	TimerSignal
Открытые типы унаследованные от uniset::ModbusServer
typedef sigc::signal< ModbusRTU::mbErrCode, const std::unordered_set< ModbusRTU::ModbusAddr >, timeout_t >	PreReceiveSignal
typedef sigc::signal< void, ModbusRTU::mbErrCode >	PostReceiveSignal
typedef std::unordered_map< ModbusRTU::mbErrCode, size_t >	ExchangeErrorMap

Открытые члены
	ModbusTCPServer (const std::string &addr, int port=502)
bool	run (const std::unordered_set< ModbusRTU::ModbusAddr > &vmbaddr)
bool	async_run (const std::unordered_set< ModbusRTU::ModbusAddr > &vmbaddr)
virtual void	terminate () override
virtual bool	isActive () const override
void	setMaxSessions (size_t num)
size_t	getMaxSessions () const noexcept
void	setSessionTimeout (timeout_t msec)
timeout_t	getSessionTimeout () const noexcept
size_t	getCountSessions () const noexcept
void	getSessions (Sessions &lst)
std::string	getInetAddress () const noexcept
int	getInetPort () const noexcept
size_t	getConnectionCount () const noexcept
TimerSignal	signal_timer ()
void	setTimer (timeout_t msec)
timeout_t	getTimer () const noexcept
void	setSocketTimeout (timeout_t msec)
timeout_t	getSocketTimeout () const noexcept
Открытые члены унаследованные от uniset::EventLoopServer
bool	evIsActive () const noexcept
Открытые члены унаследованные от uniset::ModbusServer
void	initLog (uniset::Configuration *conf, const std::string &name, const std::string &logfile="")
void	setLog (std::shared_ptr< DebugStream > dlog)
std::shared_ptr< DebugStream >	log ()
ModbusRTU::mbErrCode	receive (const std::unordered_set< ModbusRTU::ModbusAddr > &vaddr, timeout_t msecTimeout)
virtual ModbusRTU::mbErrCode	receive_one (const ModbusRTU::ModbusAddr addr, timeout_t msec)
PreReceiveSignal	signal_pre_receive ()
PostReceiveSignal	signal_post_receive ()
timeout_t	setAfterSendPause (timeout_t msec)
timeout_t	setReplyTimeout (timeout_t msec)
void	setRecvTimeout (timeout_t msec)
void	setSleepPause (timeout_t msec)
void	setCRCNoCheckit (bool set)
bool	isCRCNoCheckit () const
void	setCleanBeforeSend (bool set)
bool	getCleanBeforeSend () const
virtual void	cleanupChannel ()
ExchangeErrorMap	getErrorMap ()
size_t	getErrCount (ModbusRTU::mbErrCode e) const
size_t	resetErrCount (ModbusRTU::mbErrCode e, size_t set=0)
size_t	getAskCount () const noexcept
void	resetAskCounter ()

Защищенные типы
typedef std::list< std::shared_ptr< ModbusTCPSession > >	SessionList

Защищенные члены
virtual void	iowait (timeout_t msec) override
virtual ModbusRTU::mbErrCode	realReceive (const std::unordered_set< ModbusRTU::ModbusAddr > &vaddr, timeout_t msecTimeout) override
virtual void	evprepare () override
virtual void	evfinish () override
virtual void	ioAccept (ev::io &watcher, int revents)
void	onTimer (ev::timer &t, int revents)
void	onSocketTimeout (ev::timer &t, int revents)
void	onSocketResetTimeout (ev::async &watcher, int revents) noexcept
void	sessionFinished (const ModbusTCPSession *s)
virtual size_t	getNextData (unsigned char *buf, int len) override
virtual ModbusRTU::mbErrCode	sendData (unsigned char *buf, int len) override
virtual void	setChannelTimeout (timeout_t msec) override
Защищенные члены унаследованные от uniset::EventLoopServer
bool	async_evrun (size_t waitRunningTimeout_msec=60000)
void	evstop ()
bool	evrun ()
Защищенные члены унаследованные от uniset::ModbusServer
virtual ModbusRTU::mbErrCode	readCoilStatus (const ModbusRTU::ReadCoilMessage &query, ModbusRTU::ReadCoilRetMessage &reply)=0
virtual ModbusRTU::mbErrCode	readInputStatus (const ModbusRTU::ReadInputStatusMessage &query, ModbusRTU::ReadInputStatusRetMessage &reply)=0
virtual ModbusRTU::mbErrCode	readOutputRegisters (const ModbusRTU::ReadOutputMessage &query, ModbusRTU::ReadOutputRetMessage &reply)=0
virtual ModbusRTU::mbErrCode	readInputRegisters (const ModbusRTU::ReadInputMessage &query, ModbusRTU::ReadInputRetMessage &reply)=0
virtual ModbusRTU::mbErrCode	forceSingleCoil (const ModbusRTU::ForceSingleCoilMessage &query, ModbusRTU::ForceSingleCoilRetMessage &reply)=0
virtual ModbusRTU::mbErrCode	writeOutputSingleRegister (const ModbusRTU::WriteSingleOutputMessage &query, ModbusRTU::WriteSingleOutputRetMessage &reply)=0
virtual ModbusRTU::mbErrCode	forceMultipleCoils (const ModbusRTU::ForceCoilsMessage &query, ModbusRTU::ForceCoilsRetMessage &reply)=0
virtual ModbusRTU::mbErrCode	writeOutputRegisters (const ModbusRTU::WriteOutputMessage &query, ModbusRTU::WriteOutputRetMessage &reply)=0
virtual ModbusRTU::mbErrCode	diagnostics (const ModbusRTU::DiagnosticMessage &query, ModbusRTU::DiagnosticRetMessage &reply)=0
virtual ModbusRTU::mbErrCode	read4314 (const ModbusRTU::MEIMessageRDI &query, ModbusRTU::MEIMessageRetRDI &reply)=0
virtual ModbusRTU::mbErrCode	journalCommand (const ModbusRTU::JournalCommandMessage &query, ModbusRTU::JournalCommandRetMessage &reply)=0
virtual ModbusRTU::mbErrCode	setDateTime (const ModbusRTU::SetDateTimeMessage &query, ModbusRTU::SetDateTimeRetMessage &reply)=0
virtual ModbusRTU::mbErrCode	remoteService (const ModbusRTU::RemoteServiceMessage &query, ModbusRTU::RemoteServiceRetMessage &reply)=0
virtual ModbusRTU::mbErrCode	fileTransfer (const ModbusRTU::FileTransferMessage &query, ModbusRTU::FileTransferRetMessage &reply)=0
virtual ModbusRTU::mbErrCode	send (ModbusRTU::ModbusMessage &buf)
virtual ModbusRTU::mbErrCode	make_adu_header (ModbusRTU::ModbusMessage &request)
virtual ModbusRTU::mbErrCode	post_send_request (ModbusRTU::ModbusMessage &request)
virtual ModbusRTU::mbErrCode	processing (ModbusRTU::ModbusMessage &buf)
ModbusRTU::mbErrCode	recv (const std::unordered_set< ModbusRTU::ModbusAddr > &vaddr, ModbusRTU::ModbusMessage &buf, timeout_t timeout)
ModbusRTU::mbErrCode	recv_pdu (ModbusRTU::ModbusMessage &rbuf, timeout_t timeout)
void	printProcessingTime ()

Защищенные данные
int	port = { 0 }
std::string	iaddr
std::string	myname
std::queue< unsigned char >	qrecv
ModbusRTU::MBAPHeader	curQueryHeader
std::mutex	sMutex
SessionList	slist
bool	ignoreAddr = { false }
size_t	maxSessions = { 100 }
size_t	sessCount = { 0 }
size_t	connCount = { 0 }
timeout_t	sessTimeout = { 10000 }
ev::io	io
ev::timer	ioTimer
std::shared_ptr< UTCPSocket >	sock
ev::timer	sockTimeout
timeout_t	socketTimeout_msec = { UniSetTimer::WaitUpTime }
double	tmSockTimeout = { 0.0 }
ev::async	asyncResetSockTimeout
std::unordered_set< ModbusRTU::ModbusAddr >	vmbaddr
TimerSignal	m_timer_signal
timeout_t	tmTime_msec = { UniSetTimer::WaitUpTime }
double	tmTime = { 0.0 }
PassiveTimer	ptWait
Защищенные данные унаследованные от uniset::EventLoopServer
ev::dynamic_loop	loop
Защищенные данные унаследованные от uniset::ModbusServer
std::timed_mutex	recvMutex
timeout_t	recvTimeOut_ms = { 50 }
timeout_t	replyTimeout_ms = { 2000 }
timeout_t	aftersend_msec = { 0 }
timeout_t	sleepPause_msec = { 10 }
bool	crcNoCheckit = { false }
bool	cleanBeforeSend = { false }
PassiveTimer	tmProcessing
std::shared_ptr< DebugStream >	dlog
size_t	askCount = { 0 }
ExchangeErrorMap	errmap
PreReceiveSignal	m_pre_signal
PostReceiveSignal	m_post_signal

Дополнительные унаследованные члены
Открытые статические члены унаследованные от uniset::ModbusServer
static std::unordered_set< ModbusRTU::ModbusAddr >	addr2vaddr (ModbusRTU::ModbusAddr &mbaddr)
static bool	checkAddr (const std::unordered_set< ModbusRTU::ModbusAddr > &vaddr, const ModbusRTU::ModbusAddr addr)
static std::string	vaddr2str (const std::unordered_set< ModbusRTU::ModbusAddr > &vaddr)
static ModbusRTU::mbErrCode	replySetDateTime (const ModbusRTU::SetDateTimeMessage &query, ModbusRTU::SetDateTimeRetMessage &reply, std::shared_ptr< DebugStream > dlog=nullptr)
static ModbusRTU::mbErrCode	replyFileTransfer (const std::string &fname, const ModbusRTU::FileTransferMessage &query, ModbusRTU::FileTransferRetMessage &reply, std::shared_ptr< DebugStream > dlog=nullptr)

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

ModbusTCPServer Реализация сервера на основе libev. Поддерживается "много" соединений (постоянных). Хоть класс и наследуется от ModbusServer на самом деле он не реализует его функции, каждое соединение обслуживается классом ModbusTCPSession. Но собственно реализация функций одна на всех, это следует учитывать при реализации обработчиков, т.к.из многих "соединений" будут вызываться одни и те же обработчики.

Методы

◆ async_run()

bool uniset::ModbusTCPServer::async_run ( const std::unordered_set< ModbusRTU::ModbusAddr > & vmbaddr )

Асинхронный запуск сервера (создаётся отдельный поток)

Возвращает: TRUE - если поток успешно удалось запустить

◆ evfinish()

void uniset::ModbusTCPServer::evfinish ( )

overrideprotectedvirtual

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

◆ evprepare()

void uniset::ModbusTCPServer::evprepare ( )

overrideprotectedvirtual

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

◆ getCountSessions()

size_t uniset::ModbusTCPServer::getCountSessions ( ) const

noexcept

текущее количество подключений

◆ getNextData()

virtual size_t uniset::ModbusTCPServer::getNextData	(	unsigned char *	buf,
		int	len )

inlineoverrideprotectedvirtual

get next data block from channel or recv buffer

Аргументы

begin	- get from position
buf	- buffer for data
len	- size of buf

Возвращает: real data lenght ( must be <= len )

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

◆ iowait()

void uniset::ModbusTCPServer::iowait ( timeout_t msec )

overrideprotectedvirtual

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

◆ isActive()

bool uniset::ModbusTCPServer::isActive ( ) const

overridevirtual

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

◆ realReceive()

mbErrCode uniset::ModbusTCPServer::realReceive	(	const std::unordered_set< ModbusRTU::ModbusAddr > &	vaddr,
		timeout_t	msecTimeout )

overrideprotectedvirtual

реализация получения очередного сообщения

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

◆ run()

bool uniset::ModbusTCPServer::run ( const std::unordered_set< ModbusRTU::ModbusAddr > & vmbaddr )

Запуск сервера. Функция не возвращает управление. Но может быть прервана вызовом terminate()

Возвращает: FALSE - если не удалось запустить

◆ sendData()

virtual ModbusRTU::mbErrCode uniset::ModbusTCPServer::sendData	(	unsigned char *	buf,
		int	len )

inlineoverrideprotectedvirtual

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

◆ setChannelTimeout()

virtual void uniset::ModbusTCPServer::setChannelTimeout ( timeout_t msec )

inlineoverrideprotectedvirtual

set timeout for receive data

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

◆ setSessionTimeout()

void uniset::ModbusTCPServer::setSessionTimeout ( timeout_t msec )

установить timeout для поддержания соединения с "клиентом" (Default: 10 сек)

◆ terminate()

void uniset::ModbusTCPServer::terminate ( )

overridevirtual

остановить поток выполнения (см. run или async_run)

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

Классы

Открытые типы

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

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

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

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

Дополнительные унаследованные члены

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

Методы

◆ async_run()

◆ evfinish()

◆ evprepare()

◆ getCountSessions()

◆ getNextData()

◆ iowait()

◆ isActive()

◆ realReceive()

◆ run()

◆ sendData()

◆ setChannelTimeout()

◆ setSessionTimeout()

◆ terminate()