Skip to content

U
uniset2
Commit bef27bf8 authored by Pavel Vainerman's avatar Pavel Vainerman
Browse files
Options

(MB): начало работы над SafeMode - управление безопасным значением для датчиков.

parent e43016b1
Show whitespace changes
Inline Side-by-side
Showing with 113 additions and 34 deletions
extensions/IOControl/IOControl.cc
View file @ bef27bf8
...@@ -32,7 +32,7 @@ namespace uniset ...@@ -32,7 +32,7 @@ namespace uniset
os << "(" << inf.si.id << ")" << uniset_conf()->oind->getMapName(inf.si.id) os << "(" << inf.si.id << ")" << uniset_conf()->oind->getMapName(inf.si.id)
<< " card=" << inf.ncard << " channel=" << inf.channel << " subdev=" << inf.subdev << " card=" << inf.ncard << " channel=" << inf.channel << " subdev=" << inf.subdev
<< " aref=" << inf.aref << " range=" << inf.range << " aref=" << inf.aref << " range=" << inf.range
<< " default=" << inf.defval << " safety=" << inf.safety; << " default=" << inf.defval << " safeval=" << inf.safeval;
if( inf.cal.minRaw != inf.cal.maxRaw ) if( inf.cal.minRaw != inf.cal.maxRaw )
os << inf.cal; os << inf.cal;
...@@ -543,7 +543,7 @@ namespace uniset ...@@ -543,7 +543,7 @@ namespace uniset
ComediInterface* card = cards.getCard(it->ncard); ComediInterface* card = cards.getCard(it->ncard);
if( card == NULL || it->subdev == DefaultSubdev || it->channel == DefaultChannel ) if( card == NULL || it->subdev == IOBase::DefaultSubdev || it->channel == IOBase::DefaultChannel )
return; return;
if( it->si.id == DefaultObjectId ) if( it->si.id == DefaultObjectId )
...@@ -761,7 +761,7 @@ namespace uniset ...@@ -761,7 +761,7 @@ namespace uniset
inf.subdev = it.getIntProp("subdev"); inf.subdev = it.getIntProp("subdev");
if( inf.subdev < 0 ) if( inf.subdev < 0 )
inf.subdev = DefaultSubdev; inf.subdev = IOBase::DefaultSubdev;
string jack = it.getProp("jack"); string jack = it.getProp("jack");
...@@ -778,7 +778,7 @@ namespace uniset ...@@ -778,7 +778,7 @@ namespace uniset
else if( jack == "J5" ) else if( jack == "J5" )
inf.subdev = 4; inf.subdev = 4;
else else
inf.subdev = DefaultSubdev; inf.subdev = IOBase::DefaultSubdev;
} }
std::string prop_prefix( prefix + "_" ); std::string prop_prefix( prefix + "_" );
...@@ -893,17 +893,17 @@ namespace uniset ...@@ -893,17 +893,17 @@ namespace uniset
try try
{ {
if( it.subdev == DefaultSubdev || it.safety == NoSafety ) if( it.subdev == IOBase::DefaultSubdev || it.safeval == IOBase::UnusedSafeValue )
continue; continue;
if( it.stype == UniversalIO::DO || it.lamp ) if( it.stype == UniversalIO::DO || it.lamp )
{ {
bool set = it.invert ? !((bool)it.safety) : (bool)it.safety; bool set = it.invert ? !((bool)it.safeval) : (bool)it.safeval;
card->setDigitalChannel(it.subdev, it.channel, set); card->setDigitalChannel(it.subdev, it.channel, set);
} }
else if( it.stype == UniversalIO::AO ) else if( it.stype == UniversalIO::AO )
{ {
card->setAnalogChannel(it.subdev, it.channel, it.safety, it.range, it.aref); card->setAnalogChannel(it.subdev, it.channel, it.safeval, it.range, it.aref);
} }
} }
catch( const std::exception& ex ) catch( const std::exception& ex )
...@@ -928,7 +928,7 @@ namespace uniset ...@@ -928,7 +928,7 @@ namespace uniset
ComediInterface* card = cards.getCard(it.ncard); ComediInterface* card = cards.getCard(it.ncard);
if( card == NULL || it.subdev == DefaultSubdev || it.channel == DefaultChannel ) if( card == NULL || it.subdev == IOBase::DefaultSubdev || it.channel == IOBase::DefaultChannel )
continue; continue;
try try
...@@ -954,12 +954,12 @@ namespace uniset ...@@ -954,12 +954,12 @@ namespace uniset
for( auto& it : iomap ) for( auto& it : iomap )
{ {
if( it.subdev == DefaultSubdev ) if( it.subdev == IOBase::DefaultSubdev )
continue; continue;
ComediInterface* card = cards.getCard(it.ncard); ComediInterface* card = cards.getCard(it.ncard);
if( card == NULL || it.subdev == DefaultSubdev || it.channel == DefaultChannel ) if( card == NULL || it.subdev == IOBase::DefaultSubdev || it.channel == IOBase::DefaultChannel )
continue; continue;
try try
...@@ -995,7 +995,7 @@ namespace uniset ...@@ -995,7 +995,7 @@ namespace uniset
for( auto& io : lst ) for( auto& io : lst )
{ {
if( io->subdev == DefaultSubdev || io->channel == DefaultChannel ) if( io->subdev == IOBase::DefaultSubdev || io->channel == IOBase::DefaultChannel )
continue; continue;
ComediInterface* card = cards.getCard(io->ncard); ComediInterface* card = cards.getCard(io->ncard);
...@@ -1080,17 +1080,17 @@ namespace uniset ...@@ -1080,17 +1080,17 @@ namespace uniset
try try
{ {
if( it.subdev == DefaultSubdev || it.safety == NoSafety ) if( it.subdev == IOBase::DefaultSubdev || it.safeval == IOBase::UnusedSafeValue )
continue; continue;
if( it.stype == UniversalIO::DO || it.lamp ) if( it.stype == UniversalIO::DO || it.lamp )
{ {
bool set = it.invert ? !((bool)it.safety) : (bool)it.safety; bool set = it.invert ? !((bool)it.safeval) : (bool)it.safeval;
card->setDigitalChannel(it.subdev, it.channel, set); card->setDigitalChannel(it.subdev, it.channel, set);
} }
else if( it.stype == UniversalIO::AO ) else if( it.stype == UniversalIO::AO )
{ {
card->setAnalogChannel(it.subdev, it.channel, it.safety, it.range, it.aref); card->setAnalogChannel(it.subdev, it.channel, it.safeval, it.range, it.aref);
} }
} }
catch( const uniset::Exception& ex ) catch( const uniset::Exception& ex )
...@@ -1393,7 +1393,7 @@ namespace uniset ...@@ -1393,7 +1393,7 @@ namespace uniset
ComediInterface* card = cards.getCard(it.ncard); ComediInterface* card = cards.getCard(it.ncard);
if( card == NULL || it.subdev == DefaultSubdev || it.channel == DefaultChannel ) if( card == NULL || it.subdev == IOBase::DefaultSubdev || it.channel == IOBase::DefaultChannel )
continue; continue;
if( it.stype == UniversalIO::AO || it.stype == UniversalIO::DO ) if( it.stype == UniversalIO::AO || it.stype == UniversalIO::DO )
...@@ -1475,7 +1475,7 @@ namespace uniset ...@@ -1475,7 +1475,7 @@ namespace uniset
// и сразу зажигаем, чтобы не было паузы // и сразу зажигаем, чтобы не было паузы
// (так комфортнее выглядит для оператора) // (так комфортнее выглядит для оператора)
if( it.ignore || it.subdev == DefaultSubdev || it.channel == DefaultChannel ) if( it.ignore || it.subdev == IOBase::DefaultSubdev || it.channel == IOBase::DefaultChannel )
break; break;
ComediInterface* card = cards.getCard(it.ncard); ComediInterface* card = cards.getCard(it.ncard);
...@@ -1496,7 +1496,7 @@ namespace uniset ...@@ -1496,7 +1496,7 @@ namespace uniset
// и сразу зажигаем, чтобы не было паузы // и сразу зажигаем, чтобы не было паузы
// (так комфортнее выглядит для оператора) // (так комфортнее выглядит для оператора)
if( it.ignore || it.subdev == DefaultSubdev || it.channel == DefaultChannel ) if( it.ignore || it.subdev == IOBase::DefaultSubdev || it.channel == IOBase::DefaultChannel )
break; break;
ComediInterface* card = cards.getCard(it.ncard); ComediInterface* card = cards.getCard(it.ncard);
...@@ -1517,7 +1517,7 @@ namespace uniset ...@@ -1517,7 +1517,7 @@ namespace uniset
// и сразу зажигаем, чтобы не было паузы // и сразу зажигаем, чтобы не было паузы
// (так комфортнее выглядит для оператора) // (так комфортнее выглядит для оператора)
if( it.ignore || it.subdev == DefaultSubdev || it.channel == DefaultChannel ) if( it.ignore || it.subdev == IOBase::DefaultSubdev || it.channel == IOBase::DefaultChannel )
break; break;
ComediInterface* card = cards.getCard(it.ncard); ComediInterface* card = cards.getCard(it.ncard);
......
extensions/ModbusMaster/MBExchange.cc
View file @ bef27bf8
...@@ -221,6 +221,37 @@ namespace uniset ...@@ -221,6 +221,37 @@ namespace uniset
} }
} }
if( findArgParam("--" + prefix + "-safemode-reset-if-not-repond", conf->getArgc(), conf->getArgv()) != -1 )
{
safeMode = safeResetIfNotRespond;
vmonit(safeMode);
}
string safemode = conf->getArgParam("--" + prefix + "-safemode-external-control-sid", it.getProp("safeModeExternalControl"));
if( !safemode.empty() )
{
sidSafeModeExternal = conf->getSensorID(emode);
if( sidSafeModeExternal == DefaultObjectId )
{
ostringstream err;
err << myname << ": ID not found for " << safemode;
mbcrit << myname << "(init): " << err.str() << endl;
throw SystemError(err.str());
}
// если указан датчик, то
safeMode = safeExternalControl;
vmonit(safeMode);
}
string safemodeValue = conf->getArgParam("--" + prefix + "-safemode-external-control-value", it.getProp("safeModeExternalControlValue"));
if( !safemodeValue.empty() )
valueSafeModeExternal = uni_atoi(safemodeValue);
vmonit(valueSafeModeExternal);
activateTimeout = conf->getArgPInt("--" + prefix + "-activate-timeout", 20000); activateTimeout = conf->getArgPInt("--" + prefix + "-activate-timeout", 20000);
vmonit(allInitOK); vmonit(allInitOK);
...@@ -281,6 +312,11 @@ namespace uniset ...@@ -281,6 +312,11 @@ namespace uniset
cout << "--prefix-default-mbinit-ok 0,1 - Флаг инициализации. 1 - не ждать первого обмена с устройством, а сохранить при старте в SM значение 'default'" << endl; cout << "--prefix-default-mbinit-ok 0,1 - Флаг инициализации. 1 - не ждать первого обмена с устройством, а сохранить при старте в SM значение 'default'" << endl;
cout << "--prefix-query-max-count max - Максимальное количество запрашиваемых за один раз регистров (При условии no-query-optimization=0). По умолчанию: " << ModbusRTU::MAXDATALEN << "." << endl; cout << "--prefix-query-max-count max - Максимальное количество запрашиваемых за один раз регистров (При условии no-query-optimization=0). По умолчанию: " << ModbusRTU::MAXDATALEN << "." << endl;
cout << endl; cout << endl;
cout << "SafeMode:";
cout << "--prefix-safemode-reset-if-not-respond - Включить режим сброса значений в safeval, при пропадании связи с устройством" << endl;
cout << "--prefix-safemode-external-control-sid id - Управление сбросом значений в безопасное состояние по внешнему датчику." << endl;
cout << "--prefix-safemode-external-control-value val - Значение срабатывания для датчика управления сбросом. Default: 1" << endl;
cout << endl;
cout << " Logs: " << endl; cout << " Logs: " << endl;
cout << "--prefix-log-... - log control" << endl; cout << "--prefix-log-... - log control" << endl;
cout << " add-levels ... " << endl; cout << " add-levels ... " << endl;
...@@ -294,6 +330,7 @@ namespace uniset ...@@ -294,6 +330,7 @@ namespace uniset
cout << "--prefix-logserver-port num - listen port. Default: ID" << endl; cout << "--prefix-logserver-port num - listen port. Default: ID" << endl;
cout << LogServer::help_print("prefix-logserver") << endl; cout << LogServer::help_print("prefix-logserver") << endl;
} }
// ----------------------------------------------------------------------------- // -----------------------------------------------------------------------------
MBExchange::~MBExchange() MBExchange::~MBExchange()
{ {
...@@ -2455,7 +2492,7 @@ namespace uniset ...@@ -2455,7 +2492,7 @@ namespace uniset
<< " tcp_mbreg=" << ModbusRTU::dat2str(ri->mbreg) << "(" << (int)ri->mbreg << ")" << " tcp_mbreg=" << ModbusRTU::dat2str(ri->mbreg) << "(" << (int)ri->mbreg << ")"
<< " conflict with sensors " << sl.str() << endl; << " conflict with sensors " << sl.str() << endl;
abort(); // ABORT PROGRAM!!!! std::abort(); // ABORT PROGRAM!!!!
return false; return false;
} }
...@@ -2468,7 +2505,7 @@ namespace uniset ...@@ -2468,7 +2505,7 @@ namespace uniset
mbcrit << myname << "(initItem): FAILED! Sharing SAVE (mbreg=" mbcrit << myname << "(initItem): FAILED! Sharing SAVE (mbreg="
<< ModbusRTU::dat2str(ri->mbreg) << "(" << (int)ri->mbreg << ") already used)!" << ModbusRTU::dat2str(ri->mbreg) << "(" << (int)ri->mbreg << ") already used)!"
<< " IGNORE --> " << it.getProp("name") << endl; << " IGNORE --> " << it.getProp("name") << endl;
abort(); // ABORT PROGRAM!!!! std::abort(); // ABORT PROGRAM!!!!
return false; return false;
} }
} }
...@@ -2675,7 +2712,7 @@ namespace uniset ...@@ -2675,7 +2712,7 @@ namespace uniset
<< " nbit=" << p.nbit << " nbit=" << p.nbit
<< " nbyte=" << p.nbyte << " nbyte=" << p.nbyte
<< " rnum=" << p.rnum << " rnum=" << p.rnum
<< " safety=" << p.safety << " safeval=" << p.safeval
<< " invert=" << p.invert; << " invert=" << p.invert;
if( p.stype == UniversalIO::AI || p.stype == UniversalIO::AO ) if( p.stype == UniversalIO::AI || p.stype == UniversalIO::AO )
...@@ -2934,6 +2971,20 @@ namespace uniset ...@@ -2934,6 +2971,20 @@ namespace uniset
mbwarn << myname << "(askSensors): 'sidExchangeMode' catch..." << std::endl; mbwarn << myname << "(askSensors): 'sidExchangeMode' catch..." << std::endl;
} }
try
{
if( sidSafeModeExternal != DefaultObjectId )
shm->askSensor(sidSafeModeExternal, cmd);
}
catch( uniset::Exception& ex )
{
mbwarn << myname << "(askSensors): " << ex << std::endl;
}
catch(...)
{
mbwarn << myname << "(askSensors): 'sidSafeModeExternal' catch..." << std::endl;
}
for( auto it1 = devices.begin(); it1 != devices.end(); ++it1 ) for( auto it1 = devices.begin(); it1 != devices.end(); ++it1 )
{ {
auto d = it1->second; auto d = it1->second;
...@@ -3287,6 +3338,20 @@ namespace uniset ...@@ -3287,6 +3338,20 @@ namespace uniset
return os; return os;
} }
// ----------------------------------------------------------------------------- // -----------------------------------------------------------------------------
ostream& operator<<( ostream& os, const MBExchange::SafeMode& sm )
{
if( sm == MBExchange::safeNone )
return os << "safeNone";
if( sm == MBExchange::safeResetIfNotRespond )
return os << "safeResetIfNotRespond";
if( sm == MBExchange::safeExternalControl )
return os << "safeExternalControl";
return os;
}
// -----------------------------------------------------------------------------
uniset::SimpleInfo* MBExchange::getInfo( const char* userparam ) uniset::SimpleInfo* MBExchange::getInfo( const char* userparam )
{ {
uniset::SimpleInfo_var i = UniSetObject::getInfo(userparam); uniset::SimpleInfo_var i = UniSetObject::getInfo(userparam);
......
extensions/ModbusMaster/MBExchange.h
View file @ bef27bf8
...@@ -74,9 +74,18 @@ namespace uniset ...@@ -74,9 +74,18 @@ namespace uniset
emSkipSaveToSM = 3, /*!< не писать данные в SM (при этом работают и read и write функции) */ emSkipSaveToSM = 3, /*!< не писать данные в SM (при этом работают и read и write функции) */
emSkipExchange = 4 /*!< отключить обмен */ emSkipExchange = 4 /*!< отключить обмен */
}; };
friend std::ostream& operator<<( std::ostream& os, const ExchangeMode& em ); friend std::ostream& operator<<( std::ostream& os, const ExchangeMode& em );
/*! Режимы работы процесса обмена */
enum SafeMode
{
safeNone = 0, /*!< не использовать безопасный режим (по умолчанию) */
safeResetIfNotRespond = 1, /*!< выставлять безопасное значение, если пропала связь с устройством */
safeExternalControl = 2 /*!< управление сбросом по внешнему датчику */
};
friend std::ostream& operator<<( std::ostream& os, const SafeMode& em );
enum DeviceType enum DeviceType
{ {
dtUnknown, /*!< неизвестный */ dtUnknown, /*!< неизвестный */
...@@ -357,6 +366,11 @@ namespace uniset ...@@ -357,6 +366,11 @@ namespace uniset
IOController::IOStateList::iterator itExchangeMode; IOController::IOStateList::iterator itExchangeMode;
long exchangeMode = {emNone}; /*!< режим работы см. ExchangeMode */ long exchangeMode = {emNone}; /*!< режим работы см. ExchangeMode */
long safeMode = { safeNone }; /*!< режим безопасного состояния см. SafeMode */
uniset::ObjectId sidSafeModeExternal = { uniset::DefaultObjectId }; /*!< иденидентификатор для датчика безопасного режима */
IOController::IOStateList::iterator itSafeModeExternal;
long valueSafeModeExternal = { 1 };
std::atomic_bool activated = { false }; std::atomic_bool activated = { false };
timeout_t activateTimeout = { 20000 }; // msec timeout_t activateTimeout = { 20000 }; // msec
bool noQueryOptimization = { false }; bool noQueryOptimization = { false };
......
extensions/ModbusSlave/MBSlave.cc
View file @ bef27bf8
...@@ -1619,7 +1619,7 @@ namespace uniset ...@@ -1619,7 +1619,7 @@ namespace uniset
<< " stype=" << p.stype << " stype=" << p.stype
<< " wnum=" << p.wnum << " wnum=" << p.wnum
<< " nbyte=" << p.nbyte << " nbyte=" << p.nbyte
<< " safety=" << p.safety << " safeval=" << p.safeval
<< " invert=" << p.invert << " invert=" << p.invert
<< " regID=" << p.regID; << " regID=" << p.regID;
......
extensions/include/IOBase.h
View file @ bef27bf8
...@@ -30,13 +30,13 @@ ...@@ -30,13 +30,13 @@
namespace uniset namespace uniset
{ {
// ----------------------------------------------------------------------------- // -----------------------------------------------------------------------------
static const int DefaultSubdev = -1;
static const int DefaultChannel = -1;
static const int NoSafety = -1;
// -----------------------------------------------------------------------------
/*! Свойства переменной в/в */ /*! Свойства переменной в/в */
struct IOBase struct IOBase
{ {
static const int DefaultSubdev = -1;
static const int DefaultChannel = -1;
static const int UnusedSafeValue = -1; // значение обозначающее, не использовать safe value
// т.к. IOBase содержит rwmutex с запрещённым конструктором копирования // т.к. IOBase содержит rwmutex с запрещённым конструктором копирования
// приходится здесь тоже объявлять разрешенными только операции "перемещения" // приходится здесь тоже объявлять разрешенными только операции "перемещения"
IOBase( const IOBase& r ) = delete; IOBase( const IOBase& r ) = delete;
...@@ -53,7 +53,7 @@ namespace uniset ...@@ -53,7 +53,7 @@ namespace uniset
value(0), value(0),
craw(0), craw(0),
cprev(0), cprev(0),
safety(0), safeval(0),
defval(0), defval(0),
df(1), df(1),
nofilter(false), nofilter(false),
...@@ -108,7 +108,7 @@ namespace uniset ...@@ -108,7 +108,7 @@ namespace uniset
long value; /*!< текущее значение */ long value; /*!< текущее значение */
long craw; /*!< текущее 'сырое' значение до калибровки */ long craw; /*!< текущее 'сырое' значение до калибровки */
long cprev; /*!< предыдущее значение после калибровки */ long cprev; /*!< предыдущее значение после калибровки */
long safety; /*!< безопасное состояние при завершении процесса */ long safeval; /*!< безопасное значение */
long defval; /*!< состояние по умолчанию (при запуске) */ long defval; /*!< состояние по умолчанию (при запуске) */
DigitalFilter df; /*!< реализация программного фильтра */ DigitalFilter df; /*!< реализация программного фильтра */
......
extensions/lib/IOBase.cc
View file @ bef27bf8
...@@ -28,7 +28,7 @@ namespace uniset ...@@ -28,7 +28,7 @@ namespace uniset
{ {
return os << "(" << inf.si.id << ")" << uniset_conf()->oind->getMapName(inf.si.id) return os << "(" << inf.si.id << ")" << uniset_conf()->oind->getMapName(inf.si.id)
<< " default=" << inf.defval << " default=" << inf.defval
<< " safety=" << inf.safety << " safeval=" << inf.safeval
<< " stype=" << inf.stype << " stype=" << inf.stype
<< " calibration=" << inf.cal << " calibration=" << inf.cal
<< " cdiagram=" << ( inf.cdiagram ? inf.cdiagram->getName() : "null" ) << " cdiagram=" << ( inf.cdiagram ? inf.cdiagram->getName() : "null" )
...@@ -632,7 +632,7 @@ namespace uniset ...@@ -632,7 +632,7 @@ namespace uniset
} }
} }
b->safety = initIntProp(it, "safety", prefix, init_prefix_only, NoSafety); b->safeval = initIntProp(it, "safeval", prefix, init_prefix_only, UnusedSafeValue);
b->stype = uniset::getIOType(initProp(it, "iotype", prefix, init_prefix_only)); b->stype = uniset::getIOType(initProp(it, "iotype", prefix, init_prefix_only));
...@@ -814,7 +814,7 @@ namespace uniset ...@@ -814,7 +814,7 @@ namespace uniset
b.value = value; b.value = value;
b.craw = craw; b.craw = craw;
b.cprev = cprev; b.cprev = cprev;
b.safety = safety; b.safeval = safeval;
b.defval = defval; b.defval = defval;
b.df = df; b.df = df;
b.nofilter = nofilter; b.nofilter = nofilter;
...@@ -853,7 +853,7 @@ namespace uniset ...@@ -853,7 +853,7 @@ namespace uniset
value = b.value; value = b.value;
craw = b.craw; craw = b.craw;
cprev = b.cprev; cprev = b.cprev;
safety = b.safety; safeval = b.safeval;
defval = b.defval; defval = b.defval;
df = b.df; df = b.df;
nofilter = b.nofilter; nofilter = b.nofilter;
......
extensions/tests/test_iobase.cc
View file @ bef27bf8
...@@ -30,7 +30,7 @@ TEST_CASE("[IOBase]: default constructor", "[iobase][extensions]") ...@@ -30,7 +30,7 @@ TEST_CASE("[IOBase]: default constructor", "[iobase][extensions]")
CHECK( ib.value == 0 ); CHECK( ib.value == 0 );
CHECK( ib.craw == 0 ); CHECK( ib.craw == 0 );
CHECK( ib.cprev == 0 ); /*!< предыдущее значение после калибровки */ CHECK( ib.cprev == 0 ); /*!< предыдущее значение после калибровки */
CHECK( ib.safety == 0 ); /*!< безопасное состояние при завершении процесса */ CHECK( ib.safeval == 0 ); /*!< безопасное состояние при завершении процесса */
CHECK( ib.defval == 0 ); /*!< состояние по умолчанию (при запуске) */ CHECK( ib.defval == 0 ); /*!< состояние по умолчанию (при запуске) */
CHECK( ib.nofilter == 0 ); /*!< отключение фильтра */ CHECK( ib.nofilter == 0 ); /*!< отключение фильтра */
......
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