Commit 54c59247 authored by Pavel Vainerman's avatar Pavel Vainerman

(ModbusServer): сделал (всё-таки отдельную) функцию работы с одим адрсесом

receive_one()
parent e25e16f7
...@@ -13,7 +13,7 @@ ...@@ -13,7 +13,7 @@
Name: libuniset2 Name: libuniset2
Version: 2.2 Version: 2.2
Release: alt6 Release: alt7
Summary: UniSet - library for building distributed industrial control systems Summary: UniSet - library for building distributed industrial control systems
...@@ -456,6 +456,9 @@ mv -f %buildroot%python_sitelibdir_noarch/* %buildroot%python_sitelibdir/%oname ...@@ -456,6 +456,9 @@ mv -f %buildroot%python_sitelibdir_noarch/* %buildroot%python_sitelibdir/%oname
# .. # ..
%changelog %changelog
* Mon Oct 05 2015 Pavel Vainerman <pv@altlinux.ru> 2.2-alt7
- (ModbusServer): rename receive(ModbusAddress addr..) --> receive_one(ModbusAddress addr..)
* Mon Oct 05 2015 Pavel Vainerman <pv@altlinux.ru> 2.2-alt6 * Mon Oct 05 2015 Pavel Vainerman <pv@altlinux.ru> 2.2-alt6
- (ModbusServer): add helper function addr2vaddr() - (ModbusServer): add helper function addr2vaddr()
......
...@@ -34,9 +34,6 @@ class ModbusRTUSlave: ...@@ -34,9 +34,6 @@ class ModbusRTUSlave:
virtual ModbusRTU::mbErrCode receive( const std::unordered_set<ModbusRTU::ModbusAddr>& vmbaddr, timeout_t msecTimeout ) override; virtual ModbusRTU::mbErrCode receive( const std::unordered_set<ModbusRTU::ModbusAddr>& vmbaddr, timeout_t msecTimeout ) override;
// перегруженная версия
virtual ModbusRTU::mbErrCode receive( ModbusRTU::ModbusAddr addr, timeout_t msec ) override;
virtual void cleanupChannel() override virtual void cleanupChannel() override
{ {
if(port) port->cleanupChannel(); if(port) port->cleanupChannel();
......
...@@ -31,8 +31,8 @@ class ModbusServer ...@@ -31,8 +31,8 @@ class ModbusServer
*/ */
virtual ModbusRTU::mbErrCode receive( const std::unordered_set<ModbusRTU::ModbusAddr>& vaddr, timeout_t msecTimeout ) = 0; virtual ModbusRTU::mbErrCode receive( const std::unordered_set<ModbusRTU::ModbusAddr>& vaddr, timeout_t msecTimeout ) = 0;
// перегруженная версия с "одним" адресом // версия с "одним" адресом
virtual ModbusRTU::mbErrCode receive( ModbusRTU::ModbusAddr addr, timeout_t msec ); virtual ModbusRTU::mbErrCode receive_one( const ModbusRTU::ModbusAddr addr, timeout_t msec );
/*! Проверка входит ли данный адрес в список /*! Проверка входит ли данный адрес в список
* \param vaddr - вектор адресов * \param vaddr - вектор адресов
......
...@@ -26,9 +26,6 @@ class ModbusTCPServer: ...@@ -26,9 +26,6 @@ class ModbusTCPServer:
/*! Однопоточная обработка (каждый запрос последовательно), с разрывом соединения в конце */ /*! Однопоточная обработка (каждый запрос последовательно), с разрывом соединения в конце */
virtual ModbusRTU::mbErrCode receive( const std::unordered_set<ModbusRTU::ModbusAddr>& vmbaddr, timeout_t msecTimeout ) override; virtual ModbusRTU::mbErrCode receive( const std::unordered_set<ModbusRTU::ModbusAddr>& vmbaddr, timeout_t msecTimeout ) override;
// перегруженная версия
virtual ModbusRTU::mbErrCode receive( ModbusRTU::ModbusAddr addr, timeout_t msec ) override;
/*! Многопоточная обработка (создаётся по потоку для каждого "клиента") /*! Многопоточная обработка (создаётся по потоку для каждого "клиента")
\return TRUE - если запрос пришёл \return TRUE - если запрос пришёл
\return FALSE - если timeout \return FALSE - если timeout
......
...@@ -112,11 +112,6 @@ mbErrCode ModbusRTUSlave::receive(const std::unordered_set<ModbusAddr>& vmbaddr, ...@@ -112,11 +112,6 @@ mbErrCode ModbusRTUSlave::receive(const std::unordered_set<ModbusAddr>& vmbaddr,
return processing(buf); return processing(buf);
} }
// -------------------------------------------------------------------------------- // --------------------------------------------------------------------------------
mbErrCode ModbusRTUSlave::receive(ModbusAddr addr, timeout_t msec)
{
return ModbusServer::receive(addr,msec);
}
// --------------------------------------------------------------------------------
ComPort::Speed ModbusRTUSlave::getSpeed() ComPort::Speed ModbusRTUSlave::getSpeed()
{ {
if( port == NULL ) if( port == NULL )
......
...@@ -1502,7 +1502,7 @@ std::unordered_set<ModbusAddr> ModbusServer::addr2vaddr(ModbusAddr& mbaddr) ...@@ -1502,7 +1502,7 @@ std::unordered_set<ModbusAddr> ModbusServer::addr2vaddr(ModbusAddr& mbaddr)
return std::move(v); return std::move(v);
} }
// ------------------------------------------------------------------------- // -------------------------------------------------------------------------
mbErrCode ModbusServer::receive( ModbusAddr a, timeout_t msec ) mbErrCode ModbusServer::receive_one( ModbusAddr a, timeout_t msec )
{ {
auto v = addr2vaddr(a); auto v = addr2vaddr(a);
return receive(v,msec); return receive(v,msec);
......
...@@ -232,12 +232,6 @@ mbErrCode ModbusTCPServer::receive(const std::unordered_set<ModbusAddr>& vmbaddr ...@@ -232,12 +232,6 @@ mbErrCode ModbusTCPServer::receive(const std::unordered_set<ModbusAddr>& vmbaddr
return res; return res;
} }
// -------------------------------------------------------------------------------- // --------------------------------------------------------------------------------
mbErrCode ModbusTCPServer::receive(ModbusAddr addr, timeout_t msec)
{
return ModbusServer::receive(addr,msec);
}
// --------------------------------------------------------------------------------
void ModbusTCPServer::setChannelTimeout( timeout_t msec ) void ModbusTCPServer::setChannelTimeout( timeout_t msec )
{ {
tcp.setTimeout(msec); tcp.setTimeout(msec);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment