Commit ea92b79b authored by Pavel Vainerman's avatar Pavel Vainerman

Мелкие правки кода и комментариев

parent 7520b17c
......@@ -41,6 +41,9 @@ Debug:
LogServer:
- подумать насчёт буфера для хранения последних n-сообщений (с возможностью вытащить через REST API)
Modbus:
- разобраться с big/little endian (вместо SWAP_SHORT)
HTTP API:
- список объектов возвращать с их типом (чтобы можно было SM вычислять)
- Сделать возможность настраивать параметры httpserver-а из командной строки (количество потоков и т.п.)
......
......@@ -506,6 +506,9 @@ rm -f %buildroot%_libdir/*.la
%exclude %_pkgconfigdir/libUniSet2.pc
# history of current unpublished changes
- minor fixes
- MBSlave: Now does not terminate when socket is not open
- Configuration: Now does not terminate when endPoint is not available
%changelog
* Tue May 09 2017 Pavel Vainerman <pv@altlinux.ru> 2.6-alt18
......
......@@ -52,10 +52,11 @@ namespace uniset
uniset_rwmutex( uniset_rwmutex&& r ) = default;
uniset_rwmutex& operator=(uniset_rwmutex&& r) = default;
inline std::string name()
inline std::string name() const
{
return nm;
}
inline void setName( const std::string& name )
{
nm = name;
......
......@@ -43,9 +43,9 @@ namespace uniset
class UniSetTimer
{
public:
virtual ~UniSetTimer() {};
virtual ~UniSetTimer() {}
virtual bool checkTime() const noexcept = 0; /*!< проверка наступления заданного времени */
virtual bool checkTime() const noexcept = 0; /*!< проверка наступления заданного времени */
virtual timeout_t setTiming( timeout_t msec ) noexcept = 0; /*!< установить таймер и запустить */
virtual void reset() noexcept = 0; /*!< перезапустить таймер */
......
......@@ -98,12 +98,11 @@ IOController::InitSignal IOController::signal_init()
// ------------------------------------------------------------------------------------------
void IOController::activateInit()
{
// Разрегистрируем аналоговые датчики
for( auto li = ioList.begin(); li != ioList.end(); ++li )
for( auto&& io: ioList )
{
try
{
auto s = li->second;
auto s = io.second;
// Проверка зависимостей
if( s->d_si.id != DefaultObjectId )
......@@ -209,7 +208,7 @@ void IOController::localSetUndefinedState( IOStateList::iterator& li,
}
catch(...) {}
// потом глобольное, но конкретно для 'undefchange'
// потом глобальное, но конкретно для 'undefchange'
try
{
if( changed )
......@@ -474,11 +473,12 @@ void IOController::dumpToDB()
{
// lock
// uniset_mutex_lock lock(ioMutex, 100);
for( auto li = ioList.begin(); li != ioList.end(); ++li )
for( auto&& usi: ioList )
{
if ( !li->second->dbignore )
auto& s = usi.second;
if ( !s->dbignore )
{
SensorMessage sm( std::move(li->second->makeSensorMessage()) );
SensorMessage sm( std::move(s->makeSensorMessage()) );
logging(sm);
}
}
......
......@@ -710,7 +710,7 @@ void IONotifyController::send( ConsumerListInfo& lst, const uniset::SensorMessag
continue;
}
for( int i = 0; i < sendAttemtps; i++ ) // на каждый объект по две попытки послать
for( int i = 0; i < sendAttemtps; i++ )
{
try
{
......
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