Skip to content

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

Глобальное переделывание механизма завершения работы.

Текущая версия: любое завершение делается через Activator Для этого сделана специальная функция в UniSetObject::uterminate(). Исправил ошибки некорректного завершения потоков при выходе. Заодно небольшой рефакторинг.
parent e23632d7
Show whitespace changes
Inline Side-by-side
Showing with 713 additions and 605 deletions
Utilities/codegen/ctl-cpp-common.xsl
View file @ e2451a5c
......@@ -293,7 +293,7 @@
<xsl:if test="normalize-space($TESTMODE)!=''">
bool checkTestMode() const noexcept;
</xsl:if>
void waitSM( int wait_msec, uniset::ObjectId testID = uniset::DefaultObjectId );
bool waitSM( int wait_msec, uniset::ObjectId testID = uniset::DefaultObjectId );
uniset::ObjectId getSMTestID() const;
void resetMsg();
......@@ -505,7 +505,13 @@ void <xsl:value-of select="$CLASSNAME"/>_SK::preSysCommand( const SystemMessage*
}
ostate = "StartUp: wait sm ready..";
waitSM(smReadyTimeout);
if( !waitSM(smReadyTimeout) )
{
if( !cancelled )
uterminate();
return;
}
ptStartUpTimeout.reset();
// т.к. для io-переменных важно соблюдать последовательность!
// сперва обновить входы..
......@@ -826,7 +832,7 @@ void <xsl:value-of select="$CLASSNAME"/>_SK::preTimerInfo( const uniset::TimerMe
timerInfo(_tm);
}
// ----------------------------------------------------------------------------
void <xsl:value-of select="$CLASSNAME"/>_SK::waitSM( int wait_msec, ObjectId _testID )
bool <xsl:value-of select="$CLASSNAME"/>_SK::waitSM( int wait_msec, ObjectId _testID )
{
<xsl:if test="normalize-space($TESTMODE)!=''">
if( _testID == DefaultObjectId )
......@@ -837,7 +843,7 @@ void <xsl:value-of select="$CLASSNAME"/>_SK::waitSM( int wait_msec, ObjectId _te
_testID = smTestID;
if( _testID == DefaultObjectId )
return;
return true;
myinfo &lt;&lt; myname &lt;&lt; "(waitSM): waiting SM ready "
&lt;&lt; wait_msec &lt;&lt; " msec"
......@@ -852,8 +858,7 @@ void <xsl:value-of select="$CLASSNAME"/>_SK::waitSM( int wait_msec, ObjectId _te
&lt;&lt; wait_msec &lt;&lt; " мсек";
mycrit &lt;&lt; err.str() &lt;&lt; endl;
std::abort();
// throw uniset::SystemError(err.str());
return false;
}
if( !ui->waitWorking(_testID,wait_msec) )
......@@ -864,9 +869,10 @@ void <xsl:value-of select="$CLASSNAME"/>_SK::waitSM( int wait_msec, ObjectId _te
&lt;&lt; wait_msec &lt;&lt; " мсек";
mycrit &lt;&lt; err.str() &lt;&lt; endl;
std::abort();
// throw uniset::SystemError(err.str());
return false;
}
return true;
}
// ----------------------------------------------------------------------------
std::string <xsl:value-of select="$CLASSNAME"/>_SK::help() const noexcept
......
extensions/IOControl/IOControl.cc
View file @ e2451a5c
......@@ -331,7 +331,13 @@ namespace uniset
// set_signals(true);
UniXML::iterator it(confnode);
waitSM(); // необходимо дождаться, чтобы нормально инициализировать итераторы
if( !waitSM() ) // необходимо дождаться, чтобы нормально инициализировать итераторы
{
if( !cancelled )
uterminate();
return;
}
PassiveTimer pt(UniSetTimer::WaitUpTime);
......@@ -375,7 +381,7 @@ namespace uniset
PassiveTimer ptAct(activateTimeout);
while( !activated && !ptAct.checkTime() )
while( !activated && !cancelled && !ptAct.checkTime() )
{
cout << myname << "(execute): wait activate..." << endl;
msleep(300);
......@@ -387,6 +393,9 @@ namespace uniset
}
}
if( cancelled )
return;
if( !activated )
iocrit << myname << "(execute): ************* don`t activate?! ************" << endl;
......@@ -1345,7 +1354,7 @@ namespace uniset
PassiveTimer ptAct(activateTimeout);
while( !activated && !ptAct.checkTime() )
while( !cancelled && !activated && !ptAct.checkTime() )
{
ioinfo << myname << "(sysCommand): wait activate..." << endl;
msleep(300);
......@@ -1354,6 +1363,9 @@ namespace uniset
break;
}
if( cancelled )
return;
if( !activated )
iocrit << myname << "(sysCommand): ************* don`t activate?! ************" << endl;
......@@ -1419,11 +1431,15 @@ namespace uniset
if( force_out )
return;
waitSM();
if( !waitSM() )
{
if( !cancelled )
uterminate();
}
PassiveTimer ptAct(activateTimeout);
while( !readconf_ok && !ptAct.checkTime() )
while( !cancelled && !readconf_ok && !ptAct.checkTime() )
{
ioinfo << myname << "(askSensors): wait read configuration..." << endl;
msleep(50);
......@@ -1432,6 +1448,9 @@ namespace uniset
break;
}
if( cancelled )
return;
if( !readconf_ok )
iocrit << myname << "(askSensors): ************* don`t read configuration?! ************" << endl;
......@@ -1621,7 +1640,7 @@ namespace uniset
}
// -----------------------------------------------------------------------------
void IOControl::waitSM()
bool IOControl::waitSM()
{
if( !shm->waitSMreadyWithCancellation(smReadyTimeout, cancelled, 50) )
{
......@@ -1632,9 +1651,12 @@ namespace uniset
<< smReadyTimeout << " msec";
iocrit << err.str() << endl;
std::terminate();
}
return false;
}
return true;
}
// -----------------------------------------------------------------------------
void IOControl::buildCardsList()
......
extensions/IOControl/IOControl.h
View file @ e2451a5c
......@@ -342,7 +342,7 @@ namespace uniset
bool readItem( const std::shared_ptr<UniXML>& xml, UniXML::iterator& it, xmlNode* sec );
void buildCardsList();
void waitSM();
bool waitSM();
xmlNode* confnode = { 0 }; /*!< xml-узел в настроечном файле */
......
extensions/LogDB/start_fg.sh 0 → 100755
View file @ e2451a5c
#!/bin/sh
ulimit -Sc 1000000
uniset2-start.sh -f ./uniset2-sqlite-dbserver --confile test.xml --name DBServer1 \
--ulog-add-levels info,crit,warn,level9,system \
--dbserver-buffer-size 100
extensions/LogicProcessor/PassiveLProcessor.cc
View file @ e2451a5c
......@@ -148,10 +148,11 @@ void PassiveLProcessor::sysCommand( const uniset::SystemMessage* sm )
{
case SystemMessage::StartUp:
{
if( !shm->waitSMreadyWithCancellation(smReadyTimeout,cannceled) )
if( !shm->waitSMreadyWithCancellation(smReadyTimeout, cannceled) )
{
dcrit << myname << "(ERR): SM not ready. Terminated... " << endl;
std::terminate();
// std::terminate();
uterminate();
return;
}
......
extensions/ModbusMaster/MBExchange.cc
View file @ e2451a5c
......@@ -300,7 +300,7 @@ namespace uniset
{
}
// -----------------------------------------------------------------------------
void MBExchange::waitSMReady()
bool MBExchange::waitSMReady()
{
// waiting for SM is ready...
int tout = uniset_conf()->getArgInt("--" + prefix + "-sm-ready-timeout", "");
......@@ -318,9 +318,12 @@ namespace uniset
ostringstream err;
err << myname << "(waitSMReady): failed waiting SharedMemory " << ready_timeout << " msec. ==> TERMINATE!";
mbcrit << err.str() << endl;
std::terminate();
}
return false;
}
return true;
}
// -----------------------------------------------------------------------------
void MBExchange::step()
......@@ -348,7 +351,7 @@ namespace uniset
// -----------------------------------------------------------------------------
bool MBExchange::isProcActive() const
{
return activated;
return activated && !canceled;
}
// -----------------------------------------------------------------------------
void MBExchange::setProcActive( bool st )
......@@ -360,6 +363,10 @@ namespace uniset
{
setProcActive(false);
canceled = true;
if( logserv && logserv->isRunning() )
logserv->terminate();
return UniSetObject::deactivateObject();
}
// ------------------------------------------------------------------------------------------
......@@ -3015,8 +3022,8 @@ namespace uniset
if( devices.empty() )
{
mbcrit << myname << "(sysCommand): ************* ITEM MAP EMPTY! terminated... *************" << endl;
//raise(SIGTERM);
std::terminate();
// std::terminate();
uterminate();
return;
}
......@@ -3025,7 +3032,13 @@ namespace uniset
if( !shm->isLocalwork() )
initDeviceList();
waitSMReady();
if( !waitSMReady() )
{
if( !canceled )
uterminate();
return;
}
// подождать пока пройдёт инициализация датчиков
// см. activateObject()
......@@ -3042,7 +3055,11 @@ namespace uniset
}
if( !isProcActive() )
{
mbcrit << myname << "(sysCommand): ************* don`t activate?! ************" << endl;
uterminate();
return;
}
{
uniset::uniset_rwmutex_rlock l(mutex_start);
......@@ -3116,8 +3133,8 @@ namespace uniset
<< activateTimeout << " мсек";
mbcrit << err.str() << endl;
std::terminate(); // прерываем (перезапускаем) процесс...
// throw SystemError(err.str());
// std::terminate(); // прерываем (перезапускаем) процесс...
uterminate();
return;
}
......
extensions/ModbusMaster/MBExchange.h
View file @ e2451a5c
......@@ -303,7 +303,7 @@ namespace uniset
bool isProcActive() const;
void setProcActive( bool st );
void waitSMReady();
bool waitSMReady();
void readConfiguration();
bool readItem( const std::shared_ptr<UniXML>& xml, UniXML::iterator& it, xmlNode* sec );
......
extensions/ModbusMaster/MBTCPMaster.cc
View file @ e2451a5c
......@@ -82,20 +82,13 @@ MBTCPMaster::MBTCPMaster(uniset::ObjectId objId, uniset::ObjectId shmId,
// -----------------------------------------------------------------------------
MBTCPMaster::~MBTCPMaster()
{
if( pollThread )
{
try
if( pollThread && !canceled )
{
pollThread->stop();
canceled = true;
if( pollThread->isRunning() )
pollThread->join();
}
catch( Poco::NullPointerException& ex )
{
}
}
}
// -----------------------------------------------------------------------------
std::shared_ptr<ModbusClient> MBTCPMaster::initMB( bool reopen )
......@@ -149,16 +142,20 @@ void MBTCPMaster::sysCommand( const uniset::SystemMessage* sm )
void MBTCPMaster::final_thread()
{
setProcActive(false);
canceled = true;
}
// -----------------------------------------------------------------------------
void MBTCPMaster::poll_thread()
{
// ждём начала работы..(см. MBExchange::activateObject)
while( !isProcActive() )
while( !isProcActive() && !canceled )
{
uniset::uniset_rwmutex_rlock l(mutex_start);
}
// if( canceled )
// return;
// работаем
while( isProcActive() )
{
......@@ -187,18 +184,20 @@ void MBTCPMaster::poll_thread()
msleep(polltime);
}
dinfo << myname << "(poll_thread): thread finished.." << endl;
}
// -----------------------------------------------------------------------------
bool MBTCPMaster::deactivateObject()
{
setProcActive(false);
canceled = true;
if( pollThread )
{
pollThread->stop();
if( pollThread->isRunning() )
pollThread->join();
}
return MBExchange::deactivateObject();
......
extensions/ModbusMaster/MBTCPMultiMaster.cc
View file @ e2451a5c
......@@ -206,20 +206,11 @@ MBTCPMultiMaster::MBTCPMultiMaster( uniset::ObjectId objId, uniset::ObjectId shm
// -----------------------------------------------------------------------------
MBTCPMultiMaster::~MBTCPMultiMaster()
{
if( pollThread )
{
try
if( pollThread && !canceled )
{
pollThread->stop();
if( pollThread->isRunning() )
pollThread->join();
}
catch( Poco::NullPointerException& ex )
{
}
}
if( checkThread )
{
......@@ -352,6 +343,7 @@ std::shared_ptr<ModbusClient> MBTCPMultiMaster::initMB( bool reopen )
void MBTCPMultiMaster::final_thread()
{
setProcActive(false);
canceled = true;
}
// -----------------------------------------------------------------------------
......@@ -471,7 +463,7 @@ void MBTCPMultiMaster::sysCommand( const uniset::SystemMessage* sm )
void MBTCPMultiMaster::poll_thread()
{
// ждём начала работы..(см. MBExchange::activateObject)
while( !isProcActive() )
while( !isProcActive() && !canceled )
{
uniset::uniset_rwmutex_rlock l(mutex_start);
}
......@@ -590,6 +582,7 @@ void MBTCPMultiMaster::initIterators()
bool MBTCPMultiMaster::deactivateObject()
{
setProcActive(false);
canceled = true;
if( pollThread )
{
......
extensions/ModbusMaster/main.cc
View file @ e2451a5c
......@@ -63,14 +63,12 @@ int main( int argc, const char** argv )
}
catch( const uniset::Exception& ex )
{
dcrit << "(mbtcpmaster): " << ex << std::endl;
cerr << "(mbtcpmaster): " << ex << std::endl;
}
catch(...)
{
std::exception_ptr p = std::current_exception();
std::clog << (p ? p.__cxa_exception_type()->name() : "null") << std::endl;
dcrit << "(mbtcpmaster): catch ..." << std::endl;
cerr << "(mbtcpmaster): catch.." << (p ? p.__cxa_exception_type()->name() : "null") << std::endl;
}
return 1;
......
extensions/ModbusSlave/MBSlave.cc
View file @ e2451a5c
......@@ -537,7 +537,7 @@ namespace uniset
cancelled = true;
}
// -----------------------------------------------------------------------------
void MBSlave::waitSMReady()
bool MBSlave::waitSMReady()
{
// waiting for SM is ready...
int tout = uniset_conf()->getArgInt("--" + prefix + "-sm-ready-timeout", "");
......@@ -555,10 +555,12 @@ namespace uniset
ostringstream err;
err << myname << "(waitSMReady): Не дождались готовности SharedMemory к работе в течение " << ready_timeout << " мсек";
mbcrit << err.str() << endl;
//terminate();
std::terminate();
}
return false;
}
return true;
}
// -----------------------------------------------------------------------------
void MBSlave::execute_rtu()
......@@ -571,15 +573,18 @@ namespace uniset
{
std::unique_lock<std::mutex> locker(mutexStartNotify);
while( !activated )
while( !activated && !cancelled )
startNotifyEvent.wait(locker);
if( cancelled )
return;
}
if( vaddr.empty() )
{
mbcrit << "(execute_rtu): Unknown my modbus addresses!" << endl;
//raise(SIGTERM);
std::terminate();
//std::terminate();
uterminate();
return;
}
......@@ -618,8 +623,8 @@ namespace uniset
if( !tcpserver )
{
mbcrit << myname << "(execute_tcp): DYNAMIC CAST ERROR (mbslot --> ModbusTCPServerSlot)" << std::endl;
//raise(SIGTERM);
std::terminate();
// std::terminate();
uterminate();
return;
}
......@@ -641,8 +646,8 @@ namespace uniset
if( vaddr.empty() )
{
mbcrit << "(execute_tcp): Unknown my modbus addresses!" << endl;
//raise(SIGTERM);
std::terminate();
// std::terminate();
uterminate();
return;
}
......@@ -682,7 +687,8 @@ namespace uniset
mbcrit << myname << "(execute_tcp): error run tcpserver: "
<< tcpserver->getInetAddress()
<< ":" << tcpserver->getInetPort() << " err: not active.." << endl;
std::terminate();
// std::terminate();
uterminate();
return;
}
}
......@@ -942,8 +948,8 @@ namespace uniset
if( iomap.empty() )
{
mbcrit << myname << "(sysCommand): iomap EMPTY! terminated..." << endl;
// raise(SIGTERM);
std::terminate();
// std::terminate();
uterminate();
return;
}
......@@ -953,14 +959,20 @@ namespace uniset
logserv->async_run(logserv_host, logserv_port);
}
waitSMReady();
if( !waitSMReady() )
{
if( !cancelled )
uterminate();
return;
}
// подождать пока пройдёт инициализация датчиков
// см. activateObject()
msleep(initPause);
PassiveTimer ptAct(activateTimeout);
while( !activated && !ptAct.checkTime() )
while( !cancelled && !activated && !ptAct.checkTime() )
{
cout << myname << "(sysCommand): wait activate..." << endl;
msleep(300);
......@@ -969,6 +981,9 @@ namespace uniset
break;
}
if( cancelled )
return;
if( !activated )
{
mbcrit << myname << "(sysCommand): ************* don`t activate?! ************" << endl;
......@@ -1170,6 +1185,9 @@ namespace uniset
{
if( mbslot )
mbslot->terminate();
if( thr )
thr->join();
}
catch( std::exception& ex)
{
......@@ -1177,6 +1195,9 @@ namespace uniset
}
}
if( logserv && logserv->isRunning() )
logserv->terminate();
return UniSetObject::deactivateObject();
}
// ------------------------------------------------------------------------------------------
......@@ -1527,7 +1548,6 @@ namespace uniset
cout << "--prefix-filter-value val - Считывать список опрашиваемых датчиков, только у которых field=value" << endl;
cout << "--prefix-heartbeat-id - Данный процесс связан с указанным аналоговым heartbeat-дачиком." << endl;
cout << "--prefix-heartbeat-max - Максимальное значение heartbeat-счётчика для данного процесса. По умолчанию 10." << endl;
cout << "--prefix-ready-timeout - Время ожидания готовности SM к работе, мсек. (-1 - ждать 'вечно')" << endl;
cout << "--prefix-initPause - Задержка перед инициализацией (время на активизация процесса)" << endl;
cout << "--prefix-force 1 - Читать данные из SM каждый раз, а не по изменению." << endl;
cout << "--prefix-respond-id - respond sensor id" << endl;
......
extensions/ModbusSlave/MBSlave.h
View file @ e2451a5c
......@@ -502,7 +502,7 @@ namespace uniset
virtual void sensorInfo( const uniset::SensorMessage* sm ) override;
virtual void timerInfo( const uniset::TimerMessage* tm ) override;
void askSensors( UniversalIO::UIOCommand cmd );
void waitSMReady();
bool waitSMReady();
virtual void execute_rtu();
virtual void execute_tcp();
virtual void updateStatistics();
......
extensions/ModbusSlave/mbslave.cc
View file @ e2451a5c
......@@ -80,21 +80,15 @@ int main(int argc, const char** argv)
// on_sigchild(SIGTERM);
return 0;
}
catch( const SystemError& err )
{
dcrit << "(mbslave): " << err << endl;
}
catch( const uniset::Exception& ex )
{
dcrit << "(mbslave): " << ex << endl;
}
catch( const std::exception& e )
{
dcrit << "(mbslave): " << e.what() << endl;
cerr << "(mbslave): " << e.what() << endl;
}
catch(...)
{
dcrit << "(mbslave): catch(...)" << endl;
cerr << "(mbslave): catch(...)" << endl;
std::exception_ptr p = std::current_exception();
cerr << (p ? p.__cxa_exception_type()->name() : "null") << std::endl;
}
// on_sigchild(SIGTERM);
......
extensions/RRDServer/RRDServer.cc
View file @ e2451a5c
......@@ -330,7 +330,11 @@ void RRDServer::askSensors( UniversalIO::UIOCommand cmd )
UObject_SK::askSensors(cmd);
// прежде чем заказывать датчики, надо убедиться что SM доступна
waitSM(smReadyTimeout);
if( !waitSM(smReadyTimeout) )
{
uterminate();
return;
}
for( const auto& it : rrdlist )
{
......
extensions/SharedMemory/SharedMemory.cc
View file @ e2451a5c
......@@ -261,16 +261,21 @@ namespace uniset
PassiveTimer ptAct(activateTimeout);
while( !activated && !ptAct.checkTime() )
while( !cancelled && !activated && !ptAct.checkTime() )
{
cout << myname << "(sysCommand): wait activate..." << endl;
msleep(100);
}
if( cancelled )
return;
if( !activated )
{
smcrit << myname << "(sysCommand): Don`t activate [timeout=" << activateTimeout << " msec]! TERMINATE.." << endl;
std::terminate();
// std::terminate();
uterminate();
return;
}
// подождать пока пройдёт инициализация
......@@ -306,6 +311,7 @@ namespace uniset
bool SharedMemory::deactivateObject()
{
workready = false;
cancelled = true;
if( logserv && logserv->isRunning() )
logserv->terminate();
......@@ -904,9 +910,9 @@ namespace uniset
ostringstream err;
err << myname << "(initFromReserv): Not found ID for '" << smName << "'";
smcrit << err.str() << endl;
// throw SystemError(err.str());
//raise(SIGTERM);
std::terminate();
// std::terminate();
uterminate();
return;
}
std::string smNode(it.getProp("node"));
......@@ -921,9 +927,9 @@ namespace uniset
ostringstream err;
err << myname << "(initFromReserv): Not found NodeID for '" << smNode << "'";
smcrit << err.str() << endl;
// throw SystemError(err.str());
//raise(SIGTERM);
std::terminate();
//std::terminate();
uterminate();
return;
}
......
extensions/SharedMemory/SharedMemory.h
View file @ e2451a5c
......@@ -487,8 +487,9 @@ namespace uniset
typedef std::list<HeartBeatInfo> HeartBeatList;
HeartBeatList hblist; // список датчиков "сердцебиения"
std::shared_ptr<WDTInterface> wdt;
std::atomic_bool activated;
std::atomic_bool workready;
std::atomic_bool activated = { false };
std::atomic_bool workready = { false };
std::atomic_bool cancelled = { false };
typedef std::list<uniset::ObjectId> EventList;
EventList elst;
......
extensions/UNetUDP/UNetExchange.cc
View file @ e2451a5c
......@@ -475,7 +475,7 @@ void UNetExchange::startReceivers()
}
}
// -----------------------------------------------------------------------------
void UNetExchange::waitSMReady()
bool UNetExchange::waitSMReady()
{
// waiting for SM is ready...
int tout = uniset_conf()->getArgPInt("--unet-sm-ready-timeout", "", uniset_conf()->getNCReadyTimeout());
......@@ -487,16 +487,19 @@ void UNetExchange::waitSMReady()
else if( tout < 0 )
ready_timeout = UniSetTimer::WaitUpTime;
if( !shm->waitSMreadyWithCancellation(ready_timeout, cannceled, 50) )
if( !shm->waitSMreadyWithCancellation(ready_timeout, cancelled, 50) )
{
if( !cannceled )
if( !cancelled )
{
ostringstream err;
err << myname << "(waitSMReady): Не дождались готовности SharedMemory к работе в течение " << ready_timeout << " мсек";
unetcrit << err.str() << endl;
std::terminate();
}
return false;
}
return true;
}
// -----------------------------------------------------------------------------
void UNetExchange::timerInfo( const TimerMessage* tm )
......@@ -612,14 +615,23 @@ void UNetExchange::sysCommand( const uniset::SystemMessage* sm )
}
}
waitSMReady();
if( !waitSMReady() )
{
if( !cancelled )
{
// std::terminate();
uterminate();
}
return;
}
// подождать пока пройдёт инициализация датчиков
// см. activateObject()
msleep(initPause);
PassiveTimer ptAct(activateTimeout);
while( !activated && !ptAct.checkTime() )
while( !cancelled && !activated && !ptAct.checkTime() )
{
cout << myname << "(sysCommand): wait activate..." << endl;
msleep(300);
......@@ -628,6 +640,9 @@ void UNetExchange::sysCommand( const uniset::SystemMessage* sm )
break;
}
if( cancelled )
return;
if( !activated )
unetcrit << myname << "(sysCommand): ************* don`t activate?! ************" << endl;
......@@ -736,7 +751,8 @@ bool UNetExchange::activateObject()
// ------------------------------------------------------------------------------------------
bool UNetExchange::deactivateObject()
{
cannceled = true;
cancelled = true;
if( activated )
{
unetinfo << myname << "(deactivateObject): disactivate.." << endl;
......
extensions/UNetUDP/UNetExchange.h
View file @ e2451a5c
......@@ -162,7 +162,7 @@ namespace uniset
void sensorInfo( const uniset::SensorMessage* sm ) override;
void timerInfo( const uniset::TimerMessage* tm ) override;
void askSensors( UniversalIO::UIOCommand cmd );
void waitSMReady();
bool waitSMReady();
void receiverEvent( const std::shared_ptr<UNetReceiver>& r, UNetReceiver::Event ev ) noexcept;
virtual bool activateObject() override;
......@@ -194,7 +194,7 @@ namespace uniset
timeout_t steptime = { 1000 }; /*!< периодичность вызова step, [мсек] */
std::atomic_bool activated = { false };
std::atomic_bool cannceled = { false };
std::atomic_bool cancelled = { false };
timeout_t activateTimeout = { 20000 }; // msec
struct ReceiverInfo
......
extensions/UNetUDP/UNetSender.cc
View file @ e2451a5c
......@@ -443,7 +443,6 @@ namespace uniset
<< "(readItem): OVERFLOW! MAX UDP DIGITAL DATA LIMIT! max="
<< UniSetUDP::MaxDCount << endl;
// raise(SIGTERM);
std::terminate();
return false;
}
......@@ -482,7 +481,6 @@ namespace uniset
<< "(readItem): OVERFLOW! MAX UDP ANALOG DATA LIMIT! max="
<< UniSetUDP::MaxACount << endl;
// raise(SIGTERM);
std::terminate();
return false;
}
......@@ -495,7 +493,6 @@ namespace uniset
{
unetcrit << myname
<< "(readItem): Sensor (" << p.id << ")" << sname << " ALREADY ADDED!! ABORT!" << endl;
// raise(SIGTERM);
std::terminate();
return false;
}
......
extensions/UniNetwork/UniExchange.cc
View file @ e2451a5c
......@@ -145,7 +145,7 @@ UniExchange::~UniExchange()
// -----------------------------------------------------------------------------
void UniExchange::execute()
{
if( !shm->waitSMreadyWithCancellation(smReadyTimeout, canncelled, 50) )
if( !shm->waitSMreadyWithCancellation(smReadyTimeout, cancelled, 50) )
{
ostringstream err;
err << myname << "(execute): Не дождались готовности SharedMemory к работе в течение "
......@@ -153,7 +153,9 @@ void UniExchange::execute()
ucrit << err.str() << endl;
//throw SystemError(err.str());
std::terminate();
//std::terminate();
uterminate();
return;
}
PassiveTimer pt(UniSetTimer::WaitUpTime);
......@@ -169,10 +171,13 @@ void UniExchange::execute()
initIterators();
init_ok = true;
while(1)
while( !cancelled )
{
for( auto& it : nlst )
{
if( cancelled )
break;
bool ok = false;
try
......@@ -330,7 +335,7 @@ void UniExchange::askSensors( UniversalIO::UIOCommand cmd )
// -----------------------------------------------------------------------------
bool UniExchange::deactivateObject()
{
canncelled = true;
cancelled = true;
return IOController::deactivateObject();
}
// -----------------------------------------------------------------------------
......
extensions/UniNetwork/UniExchange.h
View file @ e2451a5c
......@@ -144,7 +144,7 @@ namespace uniset
size_t maxIndex = { 0 };
timeout_t smReadyTimeout = { 60000 }; // msec
std::atomic_bool canncelled = { false };
std::atomic_bool cancelled = { false };
private:
};
......
extensions/include/Calibration.h
View file @ e2451a5c
......@@ -130,7 +130,7 @@ namespace uniset
Если range=false, то может быть возвращено значение outOfRange.
*/
long getRawValue( const long cal, bool range = false );
long getRawValue( const long cal, bool range = false ) const;
/*! Возвращает минимальное значение 'y' встретившееся в диаграмме */
inline long getMinRaw() const noexcept
......
extensions/include/UObject_SK.h
View file @ e2451a5c
......@@ -8,7 +8,7 @@
ВСЕ ВАШИ ИЗМЕНЕНИЯ БУДУТ ПОТЕРЯНЫ.
*/
// --------------------------------------------------------------------------
// generate timestamp: 2017-08-31+03:00
// generate timestamp: 2017-09-01+03:00
// -----------------------------------------------------------------------------
#ifndef UObject_SK_H_
#define UObject_SK_H_
......@@ -29,7 +29,7 @@ class UObject_SK:
public uniset::UniSetObject
{
public:
UObject_SK( uniset::ObjectId id, xmlNode* node=uniset::uniset_conf()->getNode("UObject"), const std::string& argprefix="" );
UObject_SK( uniset::ObjectId id, xmlNode* node = uniset::uniset_conf()->getNode("UObject"), const std::string& argprefix = "" );
UObject_SK();
virtual ~UObject_SK();
......@@ -43,54 +43,60 @@ class UObject_SK:
virtual bool setMsg( uniset::ObjectId code, bool state = true ) noexcept;
inline std::shared_ptr<DebugStream> log() noexcept { return mylog; }
inline std::shared_ptr<uniset::LogAgregator> logAgregator() noexcept { return loga; }
inline std::shared_ptr<DebugStream> log() noexcept
{
return mylog;
}
inline std::shared_ptr<uniset::LogAgregator> logAgregator() noexcept
{
return loga;
}
void init_dlog( std::shared_ptr<DebugStream> d ) noexcept;
// "синтаксический сахар"..для логов
#ifndef myinfo
#define myinfo if( log()->debugging(Debug::INFO) ) log()->info()
#endif
#ifndef mywarn
#define mywarn if( log()->debugging(Debug::WARN) ) log()->warn()
#endif
#ifndef mycrit
#define mycrit if( log()->debugging(Debug::CRIT) ) log()->crit()
#endif
#ifndef mylog1
#define mylog1 if( log()->debugging(Debug::LEVEL1) ) log()->level1()
#endif
#ifndef mylog2
#define mylog2 if( log()->debugging(Debug::LEVEL2) ) log()->level2()
#endif
#ifndef mylog3
#define mylog3 if( log()->debugging(Debug::LEVEL3) ) log()->level3()
#endif
#ifndef mylog4
#define mylog4 if( log()->debugging(Debug::LEVEL4) ) log()->level4()
#endif
#ifndef mylog5
#define mylog5 if( log()->debugging(Debug::LEVEL5) ) log()->level5()
#endif
#ifndef mylog6
#define mylog6 if( log()->debugging(Debug::LEVEL6) ) log()->level6()
#endif
#ifndef mylog7
#define mylog7 if( log()->debugging(Debug::LEVEL7) ) log()->level7()
#endif
#ifndef mylog8
#define mylog8 if( log()->debugging(Debug::LEVEL8) ) log()->level8()
#endif
#ifndef mylog9
#define mylog9 if( log()->debugging(Debug::LEVEL9) ) log()->level9()
#endif
#ifndef mylogany
#define mylogany log()->any()
#endif
#ifndef vmonit
#define vmonit( var ) vmon.add( #var, var )
#endif
#ifndef myinfo
#define myinfo if( log()->debugging(Debug::INFO) ) log()->info()
#endif
#ifndef mywarn
#define mywarn if( log()->debugging(Debug::WARN) ) log()->warn()
#endif
#ifndef mycrit
#define mycrit if( log()->debugging(Debug::CRIT) ) log()->crit()
#endif
#ifndef mylog1
#define mylog1 if( log()->debugging(Debug::LEVEL1) ) log()->level1()
#endif
#ifndef mylog2
#define mylog2 if( log()->debugging(Debug::LEVEL2) ) log()->level2()
#endif
#ifndef mylog3
#define mylog3 if( log()->debugging(Debug::LEVEL3) ) log()->level3()
#endif
#ifndef mylog4
#define mylog4 if( log()->debugging(Debug::LEVEL4) ) log()->level4()
#endif
#ifndef mylog5
#define mylog5 if( log()->debugging(Debug::LEVEL5) ) log()->level5()
#endif
#ifndef mylog6
#define mylog6 if( log()->debugging(Debug::LEVEL6) ) log()->level6()
#endif
#ifndef mylog7
#define mylog7 if( log()->debugging(Debug::LEVEL7) ) log()->level7()
#endif
#ifndef mylog8
#define mylog8 if( log()->debugging(Debug::LEVEL8) ) log()->level8()
#endif
#ifndef mylog9
#define mylog9 if( log()->debugging(Debug::LEVEL9) ) log()->level9()
#endif
#ifndef mylogany
#define mylogany log()->any()
#endif
#ifndef vmonit
#define vmonit( var ) vmon.add( #var, var )
#endif
// Вспомогательные функции для удобства логирования
// ------------------------------------------------------------
......@@ -107,16 +113,19 @@ class UObject_SK:
\param id - идентификатор датчика
\param showLinkName - TRUE - выводить SensorName, FALSE - не выводить
*/
std::string str( uniset::ObjectId id, bool showLinkName=true ) const;
std::string str( uniset::ObjectId id, bool showLinkName = true ) const;
/*! Вывод значения входа/выхода в формате: in_xxx(SensorName)=val
\param id - идентификатор датчика
\param showLinkName - TRUE - выводить SensorName, FALSE - не выводить
*/
std::string strval( uniset::ObjectId id, bool showLinkName=true ) const;
std::string strval( uniset::ObjectId id, bool showLinkName = true ) const;
/*! Вывод состояния внутренних переменных */
inline std::string dumpVars(){ return vmon.pretty_str(); }
inline std::string dumpVars()
{
return vmon.pretty_str();
}
// ------------------------------------------------------------
std::string help() const noexcept;
......@@ -152,23 +161,29 @@ class UObject_SK:
virtual void callback() noexcept override;
virtual void processingMessage( const uniset::VoidMessage* msg ) override;
virtual void sysCommand( const uniset::SystemMessage* sm ){};
virtual void askSensors( UniversalIO::UIOCommand cmd ){}
virtual void sensorInfo( const uniset::SensorMessage* sm ) override{}
virtual void timerInfo( const uniset::TimerMessage* tm ) override{}
virtual void sysCommand( const uniset::SystemMessage* sm ) {};
virtual void askSensors( UniversalIO::UIOCommand cmd ) {}
virtual void sensorInfo( const uniset::SensorMessage* sm ) override {}
virtual void timerInfo( const uniset::TimerMessage* tm ) override {}
virtual bool activateObject() override;
virtual bool deactivateObject() override;
virtual std::string getMonitInfo() const { return ""; } /*!< пользовательская информация выводимая в getInfo() */
virtual std::string getTypeOfMessage( int t ) const { return uniset::strTypeOfMessage(t); } /*!< получение названия типа сообщения. Используется в getInfo() */
virtual std::string getMonitInfo() const
{
return ""; /*!< пользовательская информация выводимая в getInfo() */
}
virtual std::string getTypeOfMessage( int t ) const
{
return uniset::strTypeOfMessage(t); /*!< получение названия типа сообщения. Используется в getInfo() */
}
#ifndef DISABLE_REST_API
virtual void httpGetUserData( Poco::JSON::Object::Ptr& jdata ){} /*!< для пользовательских данных в httpGet() */
virtual void httpGetUserData( Poco::JSON::Object::Ptr& jdata ) {} /*!< для пользовательских данных в httpGet() */
virtual Poco::JSON::Object::Ptr httpDumpIO();
virtual Poco::JSON::Object::Ptr httpRequestLog( const Poco::URI::QueryParameters& p );
#endif
// Выполнение очередного шага программы
virtual void step(){}
virtual void step() {}
void preAskSensors( UniversalIO::UIOCommand cmd );
void preSysCommand( const uniset::SystemMessage* sm );
......@@ -176,7 +191,7 @@ class UObject_SK:
virtual void testMode( bool state );
void updateOutputs( bool force );
void waitSM( int wait_msec, uniset::ObjectId testID = uniset::DefaultObjectId );
bool waitSM( int wait_msec, uniset::ObjectId testID = uniset::DefaultObjectId );
uniset::ObjectId getSMTestID() const;
void resetMsg();
......@@ -197,9 +212,15 @@ class UObject_SK:
xmlNode* confnode;
/*! получить числовое свойство из конф. файла по привязанной confnode */
int getIntProp(const std::string& name) { return uniset::uniset_conf()->getIntProp(confnode, name); }
int getIntProp(const std::string& name)
{
return uniset::uniset_conf()->getIntProp(confnode, name);
}
/*! получить текстовое свойство из конф. файла по привязанной confnode */
inline const std::string getProp(const std::string& name) { return uniset::uniset_conf()->getProp(confnode, name); }
inline const std::string getProp(const std::string& name)
{
return uniset::uniset_conf()->getProp(confnode, name);
}
uniset::timeout_t smReadyTimeout; /*!< время ожидания готовности SM */
std::atomic_bool activated = { false };
......@@ -251,10 +272,10 @@ class UObject_SK:
}
};
std::unordered_map<const uniset::ObjectId,size_t, StatHashFn> smStat; /*!< количество сообщений по датчикам */
std::unordered_map<const uniset::ObjectId, size_t, StatHashFn> smStat; /*!< количество сообщений по датчикам */
size_t processingMessageCatchCount = { 0 }; /*!< количество исключений пойманных в processingMessage */
std::unordered_map<long,size_t> msgTypeStat; /*!< количество сообщений по типам */
std::unordered_map<long, size_t> msgTypeStat; /*!< количество сообщений по типам */
std::string ostate = { "" }; /*!< состояние процесса (выводится в getInfo()) */
......
extensions/lib/Calibration.cc
View file @ e2451a5c
......@@ -346,7 +346,7 @@ namespace uniset
sort(cache.begin(), cache.end()); // пересортируем в порядке уменьшения обращений (см. CacheInfo::operator< )
}
// ----------------------------------------------------------------------------
long Calibration::getRawValue( const long cal, bool range )
long Calibration::getRawValue( const long cal, bool range ) const
{
for( auto& it : pvec )
{
......
extensions/lib/SMInterface.cc
View file @ e2451a5c
......@@ -274,7 +274,7 @@ using namespace uniset;
bool SMInterface::waitSMready( int ready_timeout, int pmsec )
{
std::atomic_bool cancelFlag = { false };
return waitSMreadyWithCancellation(ready_timeout,cancelFlag,pmsec);
return waitSMreadyWithCancellation(ready_timeout, cancelFlag, pmsec);
}
// --------------------------------------------------------------------------
bool SMInterface::waitSMworking( uniset::ObjectId sid, int msec, int pmsec )
......
extensions/lib/UObject_SK.cc
View file @ e2451a5c
......@@ -11,7 +11,7 @@
ВСЕ ВАШИ ИЗМЕНЕНИЯ БУДУТ ПОТЕРЯНЫ.
*/
// --------------------------------------------------------------------------
// generate timestamp: 2017-08-31+03:00
// generate timestamp: 2017-09-01+03:00
// -----------------------------------------------------------------------------
#include <memory>
#include <iomanip>
......@@ -32,28 +32,28 @@ using namespace uniset;
// -----------------------------------------------------------------------------
UObject_SK::UObject_SK():
// Инициализация идентификаторов (имена берутся из конф. файла)
// Инициализация идентификаторов (имена берутся из конф. файла)
// Используемые идентификаторы сообщений (имена берутся из конф. файла)
// Используемые идентификаторы сообщений (имена берутся из конф. файла)
// variables (public and proteced)
// variables (public and proteced)
// ------------------
active(false),
// ------------------
active(false),
idHeartBeat(DefaultObjectId),
maxHeartBeat(10),
confnode(0),
smReadyTimeout(0),
activated(false),
askPause(2000),
forceOut(false),
// private variables
idHeartBeat(DefaultObjectId),
maxHeartBeat(10),
confnode(0),
smReadyTimeout(0),
activated(false),
askPause(2000),
forceOut(false),
// private variables
end_private(false)
end_private(false)
{
mycrit << "UObject: init failed!!!!!!!!!!!!!!!" << endl;
throw uniset::Exception( std::string(myname+": init failed!!!") );
throw uniset::Exception( std::string(myname + ": init failed!!!") );
}
// -----------------------------------------------------------------------------
// ( val, confval, default val )
......@@ -61,6 +61,7 @@ static const std::string init3_str( const std::string& s1, const std::string& s2
{
if( !s1.empty() )
return s1;
if( !s2.empty() )
return s2;
......@@ -74,41 +75,41 @@ static uniset::ObjectId init_node( xmlNode* cnode, const std::string& prop )
auto conf = uniset_conf();
if( conf->getProp(cnode,prop).empty() )
if( conf->getProp(cnode, prop).empty() )
return conf->getLocalNode();
return conf->getNodeID(conf->getProp(cnode,prop));
return conf->getNodeID(conf->getProp(cnode, prop));
}
// -----------------------------------------------------------------------------
UObject_SK::UObject_SK( ObjectId id, xmlNode* cnode, const std::string& _argprefix ):
UniSetObject(id),
// Инициализация идентификаторов (имена берутся из конф. файла)
UniSetObject(id),
// Инициализация идентификаторов (имена берутся из конф. файла)
// Используемые идентификаторы сообщений (имена берутся из конф. файла)
// Используемые идентификаторы сообщений (имена берутся из конф. файла)
// variables
// variables
sleep_msec(150),
active(true),
argprefix( (_argprefix.empty() ? myname+"-" : _argprefix) ),
sleep_msec(150),
active(true),
argprefix( (_argprefix.empty() ? myname + "-" : _argprefix) ),
idHeartBeat(DefaultObjectId),
maxHeartBeat(10),
confnode(cnode),
smReadyTimeout(0),
activated(false),
askPause(uniset_conf()->getPIntProp(cnode,"askPause",2000)),
forceOut(false),
idHeartBeat(DefaultObjectId),
maxHeartBeat(10),
confnode(cnode),
smReadyTimeout(0),
activated(false),
askPause(uniset_conf()->getPIntProp(cnode, "askPause", 2000)),
forceOut(false),
end_private(false)
end_private(false)
{
auto conf = uniset_conf();
if( uniset::findArgParam("--print-id-list",uniset_conf()->getArgc(),uniset_conf()->getArgv()) != -1 )
if( uniset::findArgParam("--print-id-list", uniset_conf()->getArgc(), uniset_conf()->getArgv()) != -1 )
{
// abort();
// abort();
}
......@@ -124,10 +125,10 @@ end_private(false)
{
ostringstream s;
s << argprefix << "log";
conf->initLogStream(mylog,s.str());
conf->initLogStream(mylog, s.str());
}
loga = make_shared<LogAgregator>(myname+"-loga");
loga = make_shared<LogAgregator>(myname + "-loga");
loga->add(mylog);
loga->add(ulog());
......@@ -145,12 +146,14 @@ end_private(false)
logserv_port = conf->getArgPInt("--" + argprefix + "logserver-port", it.getProp("logserverPort"), getId());
}
forceOut = conf->getArgPInt("--" + argprefix + "force-out",it.getProp("forceOut"),false);
forceOut = conf->getArgPInt("--" + argprefix + "force-out", it.getProp("forceOut"), false);
string heart = conf->getArgParam("--" + argprefix + "heartbeat-id", it.getProp("heartbeat_id"));
string heart = conf->getArgParam("--" + argprefix + "heartbeat-id",it.getProp("heartbeat_id"));
if( !heart.empty() )
{
idHeartBeat = conf->getSensorID(heart);
if( idHeartBeat == DefaultObjectId )
{
ostringstream err;
......@@ -158,13 +161,14 @@ end_private(false)
throw uniset::SystemError(err.str());
}
int heartbeatTime = conf->getArgPInt("--" + argprefix + "heartbeat-time",it.getProp("heartbeatTime"),conf->getHeartBeatTime());
if( heartbeatTime>0 )
int heartbeatTime = conf->getArgPInt("--" + argprefix + "heartbeat-time", it.getProp("heartbeatTime"), conf->getHeartBeatTime());
if( heartbeatTime > 0 )
ptHeartBeat.setTiming(heartbeatTime);
else
ptHeartBeat.setTiming(UniSetTimer::WaitUpTime);
maxHeartBeat = conf->getArgPInt("--" + argprefix + "heartbeat-max",it.getProp("heartbeat_max"), 10);
maxHeartBeat = conf->getArgPInt("--" + argprefix + "heartbeat-max", it.getProp("heartbeat_max"), 10);
}
// Инициализация значений
......@@ -173,16 +177,18 @@ end_private(false)
si.id = uniset::DefaultObjectId;
si.node = conf->getLocalNode();
sleep_msec = conf->getArgPInt("--" + argprefix + "sleep-msec","150", 150);
sleep_msec = conf->getArgPInt("--" + argprefix + "sleep-msec", "150", 150);
string s_resetTime("");
if( s_resetTime.empty() )
s_resetTime = "500";
resetMsgTime = uni_atoi(init3_str(conf->getArgParam("--" + argprefix + "resetMsgTime"),conf->getProp(cnode,"resetMsgTime"),s_resetTime));
resetMsgTime = uni_atoi(init3_str(conf->getArgParam("--" + argprefix + "resetMsgTime"), conf->getProp(cnode, "resetMsgTime"), s_resetTime));
ptResetMsg.setTiming(resetMsgTime);
int sm_tout = conf->getArgInt("--" + argprefix + "sm-ready-timeout","");
int sm_tout = conf->getArgInt("--" + argprefix + "sm-ready-timeout", "");
if( sm_tout == 0 )
smReadyTimeout = conf->getNCReadyTimeout();
else if( sm_tout < 0 )
......@@ -190,7 +196,7 @@ end_private(false)
else
smReadyTimeout = sm_tout;
smTestID = conf->getSensorID(init3_str(conf->getArgParam("--" + argprefix + "sm-test-id"),conf->getProp(cnode,"smTestID"),""));
smTestID = conf->getSensorID(init3_str(conf->getArgParam("--" + argprefix + "sm-test-id"), conf->getProp(cnode, "smTestID"), ""));
if( smTestID == DefaultObjectId )
......@@ -217,7 +223,7 @@ end_private(false)
// help надо выводить в конце, когда уже все переменные инициализированы по умолчанию
if( uniset::findArgParam("--" + argprefix + "help",uniset_conf()->getArgc(),uniset_conf()->getArgv()) != -1 )
if( uniset::findArgParam("--" + argprefix + "help", uniset_conf()->getArgc(), uniset_conf()->getArgv()) != -1 )
cout << help() << endl;
}
......@@ -269,7 +275,7 @@ bool UObject_SK::setMsg( uniset::ObjectId _code, bool _state ) noexcept
void UObject_SK::resetMsg()
{
mylog8 << myname << "(resetMsg): reset messages.." << endl;
// reset messages
// reset messages
}
// -----------------------------------------------------------------------------
......@@ -298,11 +304,11 @@ Poco::JSON::Object::Ptr UObject_SK::httpDumpIO()
{
Poco::JSON::Object::Ptr jdata = new Poco::JSON::Object();
Poco::JSON::Object::Ptr j_in = uniset::json::make_child(jdata,"in");
Poco::JSON::Object::Ptr j_in = uniset::json::make_child(jdata, "in");
Poco::JSON::Object::Ptr j_out = uniset::json::make_child(jdata,"out");
Poco::JSON::Object::Ptr j_out = uniset::json::make_child(jdata, "out");
......@@ -327,19 +333,23 @@ std::string UObject_SK::dumpIO()
s << endl;
int n = 0;
for( const auto& e: v_in )
for( const auto& e : v_in )
{
s << e;
if( (n++)%2 )
if( (n++) % 2 )
s << std::endl;
}
s << endl;
n = 0;
for( const auto& e: v_out )
for( const auto& e : v_out )
{
s << e;
if( (n++)%2 )
if( (n++) % 2 )
s << std::endl;
}
......@@ -418,14 +428,17 @@ void UObject_SK::preSysCommand( const SystemMessage* _sm )
{
case SystemMessage::WatchDog:
myinfo << myname << "(preSysCommand): WatchDog" << endl;
if( !active || !ptStartUpTimeout.checkTime() )
{
mywarn << myname << "(preSysCommand): игнорируем WatchDog, потому-что только-что стартанули" << endl;
break;
}
case SystemMessage::StartUp:
{
ostate = "StartUp...";
try
{
if( !logserv_host.empty() && logserv_port != 0 && !logserv->isRunning() )
......@@ -445,7 +458,15 @@ void UObject_SK::preSysCommand( const SystemMessage* _sm )
}
ostate = "StartUp: wait sm ready..";
waitSM(smReadyTimeout);
if( !waitSM(smReadyTimeout) )
{
if( !cancelled )
uterminate();
return;
}
ptStartUpTimeout.reset();
// т.к. для io-переменных важно соблюдать последовательность!
// сперва обновить входы..
......@@ -475,9 +496,10 @@ void UObject_SK::preSysCommand( const SystemMessage* _sm )
// переоткрываем логи
mylogany << myname << "(preSysCommand): logRotate" << endl;
string fname( log()->getLogFile() );
if( !fname.empty() )
{
mylog->logFile(fname.c_str(),true);
mylog->logFile(fname.c_str(), true);
mylogany << myname << "(preSysCommand): ***************** mylog LOG ROTATE *****************" << endl;
}
......@@ -532,8 +554,10 @@ uniset::SimpleInfo* UObject_SK::getInfo( const char* userparam )
inf << "statistics: " << endl
<< " processingMessageCatchCount: " << processingMessageCatchCount << endl;
inf << " Type of messages: " << endl;
for( const auto& s: msgTypeStat )
for( const auto& s : msgTypeStat )
inf << " (" << s.first << ")" << setw(10) << getTypeOfMessage(s.first) << ": " << setw(5) << s.second << endl;
inf << endl;
......@@ -541,14 +565,16 @@ uniset::SimpleInfo* UObject_SK::getInfo( const char* userparam )
inf << endl;
auto timers = getTimersList();
inf << "Timers[" << timers.size() << "]:" << endl;
for( const auto& t: timers )
for( const auto& t : timers )
{
inf << " " << setw(15) << getTimerName(t.id) << "[" << t.id << "]: msec="
<< setw(6) << t.tmr.getInterval()
<< " timeleft=" << setw(6) << t.curTimeMS
<< " tick=" << setw(3) << ( t.curTick>=0 ? t.curTick : -1 )
<< " tick=" << setw(3) << ( t.curTick >= 0 ? t.curTick : -1 )
<< endl;
}
inf << endl;
inf << vmon.pretty_str() << endl;
inf << endl;
......@@ -566,49 +592,53 @@ Poco::JSON::Object::Ptr UObject_SK::httpGet( const Poco::URI::QueryParameters& p
Poco::JSON::Object::Ptr json = UniSetObject::httpGet(params);
Poco::JSON::Object::Ptr jdata = json->getObject(myname);
if( !jdata )
jdata = uniset::json::make_child(json,myname);
jdata = uniset::json::make_child(json, myname);
Poco::JSON::Object::Ptr jserv = uniset::json::make_child(jdata, "LogServer");
Poco::JSON::Object::Ptr jserv = uniset::json::make_child(jdata,"LogServer");
if( logserv )
{
jserv->set("host",logserv_host);
jserv->set("port",logserv_port);
jserv->set("state",( logserv->isRunning() ? "RUNNIG" : "STOPPED" ));
jserv->set("host", logserv_host);
jserv->set("port", logserv_port);
jserv->set("state", ( logserv->isRunning() ? "RUNNIG" : "STOPPED" ));
jserv->set("info", logserv->httpGetShortInfo());
}
jdata->set("io", httpDumpIO());
auto timers = getTimersList();
auto jtm = uniset::json::make_child(jdata,"Timers");
auto jtm = uniset::json::make_child(jdata, "Timers");
jtm->set("count", timers.size());
jtm->set("count",timers.size());
for( const auto& t: timers )
for( const auto& t : timers )
{
auto jt = uniset::json::make_child(jtm,to_string(t.id));
auto jt = uniset::json::make_child(jtm, to_string(t.id));
jt->set("id", t.id);
jt->set("name", getTimerName(t.id));
jt->set("msec", t.tmr.getInterval());
jt->set("timeleft", t.curTimeMS);
jt->set("tick", ( t.curTick>=0 ? t.curTick : -1 ));
jt->set("tick", ( t.curTick >= 0 ? t.curTick : -1 ));
}
auto vlist = vmon.getList();
auto jvmon = uniset::json::make_child(jdata,"Variables");
auto jvmon = uniset::json::make_child(jdata, "Variables");
for( const auto& v: vlist )
jvmon->set(v.first,v.second);
for( const auto& v : vlist )
jvmon->set(v.first, v.second);
auto jstat = uniset::json::make_child(jdata,"Statistics");
auto jstat = uniset::json::make_child(jdata, "Statistics");
jstat->set("processingMessageCatchCount", processingMessageCatchCount);
auto jsens = uniset::json::make_child(jstat,"sensors");
for( const auto& s: smStat )
auto jsens = uniset::json::make_child(jstat, "sensors");
for( const auto& s : smStat )
{
std::string sname(ORepHelpers::getShortName( uniset_conf()->oind->getMapName(s.first)));
auto js = uniset::json::make_child(jsens,sname);
auto js = uniset::json::make_child(jsens, sname);
js->set("id", s.first);
js->set("name", sname);
js->set("count", s.second);
......@@ -625,7 +655,7 @@ Poco::JSON::Object::Ptr UObject_SK::httpHelp( const Poco::URI::QueryParameters&
uniset::json::help::object myhelp(myname, UniSetObject::httpGet(params));
// 'log'
uniset::json::help::item cmd("log","show log level");
uniset::json::help::item cmd("log", "show log level");
myhelp.add(cmd);
return myhelp;
......@@ -636,13 +666,13 @@ Poco::JSON::Object::Ptr UObject_SK::httpRequest( const std::string& req, const P
if( req == "log" )
return httpRequestLog(p);
return UniSetObject::httpRequest(req,p);
return UniSetObject::httpRequest(req, p);
}
// -----------------------------------------------------------------------------
Poco::JSON::Object::Ptr UObject_SK::httpRequestLog( const Poco::URI::QueryParameters& p )
{
Poco::JSON::Object::Ptr jret = new Poco::JSON::Object();
jret->set("log",Debug::str(mylog->level()));
jret->set("log", Debug::str(mylog->level()));
return jret;
}
// -----------------------------------------------------------------------------
......@@ -676,7 +706,7 @@ void UObject_SK::preTimerInfo( const uniset::TimerMessage* _tm )
timerInfo(_tm);
}
// ----------------------------------------------------------------------------
void UObject_SK::waitSM( int wait_msec, ObjectId _testID )
bool UObject_SK::waitSM( int wait_msec, ObjectId _testID )
{
......@@ -684,14 +714,14 @@ void UObject_SK::waitSM( int wait_msec, ObjectId _testID )
_testID = smTestID;
if( _testID == DefaultObjectId )
return;
return true;
myinfo << myname << "(waitSM): waiting SM ready "
<< wait_msec << " msec"
<< " testID=" << _testID << endl;
// waitReady можно использовать т.к. датчик это по сути IONotifyController
if( !ui->waitReadyWithCancellation(_testID,wait_msec,cancelled) )
if( !ui->waitReadyWithCancellation(_testID, wait_msec, cancelled) )
{
ostringstream err;
err << myname
......@@ -699,11 +729,10 @@ void UObject_SK::waitSM( int wait_msec, ObjectId _testID )
<< wait_msec << " мсек";
mycrit << err.str() << endl;
std::abort();
// throw uniset::SystemError(err.str());
return false;
}
if( !ui->waitWorking(_testID,wait_msec) )
if( !ui->waitWorking(_testID, wait_msec) )
{
ostringstream err;
err << myname
......@@ -711,9 +740,10 @@ void UObject_SK::waitSM( int wait_msec, ObjectId _testID )
<< wait_msec << " мсек";
mycrit << err.str() << endl;
std::abort();
// throw uniset::SystemError(err.str());
return false;
}
return true;
}
// ----------------------------------------------------------------------------
std::string UObject_SK::help() const noexcept
......@@ -748,39 +778,42 @@ void UObject_SK::callback() noexcept
{
if( !active )
return;
try
{
// проверка таймеров
checkTimers(this);
if( resetMsgTime>0 && trResetMsg.hi(ptResetMsg.checkTime()) )
if( resetMsgTime > 0 && trResetMsg.hi(ptResetMsg.checkTime()) )
{
// cout << myname << ": ********* reset messages *********" << endl;
// cout << myname << ": ********* reset messages *********" << endl;
resetMsg();
}
// обработка сообщений (таймеров и т.п.)
for( unsigned int i=0; i<20; i++ )
for( unsigned int i = 0; i < 20; i++ )
{
auto m = receiveMessage();
if( !m )
break;
processingMessage(m.get());
updateOutputs(forceOut);
// updatePreviousValues();
// updatePreviousValues();
}
// Выполнение шага программы
step();
// "сердцебиение"
if( idHeartBeat!=DefaultObjectId && ptHeartBeat.checkTime() )
if( idHeartBeat != DefaultObjectId && ptHeartBeat.checkTime() )
{
try
{
ui->setValue(idHeartBeat,maxHeartBeat);
ui->setValue(idHeartBeat, maxHeartBeat);
ptHeartBeat.reset();
}
catch( const uniset::Exception& ex )
......@@ -820,7 +853,7 @@ void UObject_SK::setValue( uniset::ObjectId _sid, long _val )
ui->setValue(_sid,_val);
ui->setValue(_sid, _val);
}
// -----------------------------------------------------------------------------
void UObject_SK::updateOutputs( bool _force )
......@@ -842,7 +875,7 @@ void UObject_SK::initFromSM()
// -----------------------------------------------------------------------------
void UObject_SK::askSensor( uniset::ObjectId _sid, UniversalIO::UIOCommand _cmd, uniset::ObjectId _node )
{
ui->askRemoteSensor(_sid,_cmd,_node,getId());
ui->askRemoteSensor(_sid, _cmd, _node, getId());
}
// -----------------------------------------------------------------------------
long UObject_SK::getValue( uniset::ObjectId _sid )
......@@ -864,10 +897,12 @@ long UObject_SK::getValue( uniset::ObjectId _sid )
void UObject_SK::preAskSensors( UniversalIO::UIOCommand _cmd )
{
PassiveTimer ptAct(activateTimeout);
while( !activated && !ptAct.checkTime() )
{
cout << myname << "(preAskSensors): wait activate..." << endl;
msleep(300);
if( activated )
break;
}
......@@ -887,7 +922,7 @@ void UObject_SK::preAskSensors( UniversalIO::UIOCommand _cmd )
{
mycrit << myname << "(preAskSensors): " << ex << endl;
}
catch( const std::exception&ex )
catch( const std::exception& ex )
{
mycrit << myname << "(execute): catch " << ex.what() << endl;
}
......
include/LogServer.h
View file @ e2451a5c
......@@ -43,7 +43,7 @@ namespace uniset
// -------------------------------------------------------------------------
/*! \page pgLogServer Лог сервер
Лог сервер предназначен для возможности удалённого чтения логов (DebugStream).
Ему указывается host и port для прослушивания запросов, которые можно делать при помощи
Ему указывается host и port на котором он отвечает, подключаться можно при помощи
LogReader. Читающих клиентов может быть скольугодно много, на каждого создаётся своя "сессия"(LogSession).
При этом через лог сервер имеется возможность управлять включением или отключением определённых уровней логов,
записью, отключением записи или ротацией файла с логами. DebugStream за которым ведётся "слежение"
......
include/Mutex.h
View file @ e2451a5c
......@@ -23,7 +23,6 @@
// -----------------------------------------------------------------------------------------
#include <string>
#include <memory>
#include <mutex>
#include <Poco/RWLock.h>
// -----------------------------------------------------------------------------------------
namespace uniset
......
include/ORepHelpers.h
View file @ e2451a5c
......@@ -51,14 +51,6 @@ namespace uniset
//! Функция выделения имени из полного имени
const std::string getShortName(const std::string& fullName, const std::string& brk = "/");
//! Проверка на наличие недопустимых символов
char checkBadSymbols(const std::string& str);
/*! Получение строки запрещенных символов в виде '.', '/', и т.д. */
std::string BadSymbolsToStr();
}
// -------------------------------------------------------------------------
} // end of uniset namespace
......
include/UniSetActivator.h
View file @ e2451a5c
......@@ -25,11 +25,9 @@
#include <deque>
#include <memory>
#include <omniORB4/CORBA.h>
#include <ev++.h>
#include "UniSetTypes.h"
#include "UniSetObject.h"
#include "UniSetManager.h"
#include "EventLoopServer.h"
#include "OmniThreadCreator.h"
#include "UHttpRequestHandler.h"
#include "UHttpServer.h"
......@@ -52,15 +50,14 @@ namespace uniset
\endcode
* Активатор в свою очередь сам является менеджером(и объектом) и обладает всеми его свойствами
*
* --uniset-no-use-gdb-for-stacktrace - НЕ ИСПОЛЬЗОВАТЬ gdb для stacktrace
* --uniset-abort-script - скрипт запускаемый при вылете, в качестве аргумента передаётся имя программы и pid
*
* \section act_HttpAPI REST API
* UniSetActivator реализует обработку команд /conf/..
* UniSetActivator выступает в роли http-сервера и релизует первчиную обработку запросов
* и перенаправление их указанным объектам. Помимо этого UniSetActivator реализует обработку команд /conf/..
* Для запуска http-сервера необходимо в аргументах командной строки указать --activator-run-httpserver
* Помимо этого можно задать параметры --activator-httpserver-host и --activator-httpserver-port.
*
*/
class UniSetActivator:
public EventLoopServer,
public UniSetManager
#ifndef DISABLE_REST_API
, public uniset::UHttp::IHttpRequestRegistry
......@@ -72,8 +69,15 @@ namespace uniset
virtual ~UniSetActivator();
// запуск системы
// async = true - асинхронный запуск (создаётся отдельный поток).
void run( bool async );
void stop();
// штатное завершение работы
void shutdown();
// прерывание работы
void terminate();
virtual uniset::ObjectType getType() override
{
......@@ -91,7 +95,7 @@ namespace uniset
protected:
virtual void work();
void work();
// уносим в protected, т.к. Activator должен быть только один..
UniSetActivator();
......@@ -101,19 +105,12 @@ namespace uniset
private:
void init();
static void on_finish_timeout();
static void evsignal( ev::sig& signal, int signo );
virtual void evprepare() override;
virtual void evfinish() override;
static void set_signals( bool set );
std::shared_ptr< OmniThreadCreator<UniSetActivator> > orbthr;
CORBA::ORB_var orb;
ev::sig sigINT;
ev::sig sigTERM;
ev::sig sigABRT;
ev::sig sigQUIT;
#ifndef DISABLE_REST_API
std::shared_ptr<uniset::UHttp::UHttpServer> httpserv;
std::string httpHost = { "" };
......
include/UniSetManager.h
View file @ e2451a5c
......@@ -63,8 +63,6 @@ namespace uniset
UniSetManager( const std::string& name, const std::string& section );
virtual ~UniSetManager();
std::shared_ptr<UniSetManager> get_mptr();
virtual uniset::ObjectType getType() override
{
return uniset::ObjectType("UniSetManager");
......@@ -83,6 +81,7 @@ namespace uniset
PortableServer::POA_ptr getPOA();
PortableServer::POAManager_ptr getPOAManager();
std::shared_ptr<UniSetManager> get_mptr();
protected:
......@@ -134,7 +133,6 @@ namespace uniset
private:
int sig;
UniSetManagerList mlist;
ObjectsList olist;
......
include/UniSetObject.h
View file @ e2451a5c
......@@ -84,8 +84,6 @@ namespace uniset
UniSetObject();
virtual ~UniSetObject();
std::shared_ptr<UniSetObject> get_ptr();
// Функции объявленные в IDL
virtual CORBA::Boolean exist() override;
......@@ -117,6 +115,7 @@ namespace uniset
// -------------- вспомогательные --------------
/*! получить ссылку (на себя) */
uniset::ObjectPtr getRef() const;
std::shared_ptr<UniSetObject> get_ptr();
/*! заказ таймера (вынесена в public, хотя должна была бы быть в protected */
virtual timeout_t askTimer( uniset::TimerId timerid, timeout_t timeMS, clock_t ticks = -1,
......@@ -128,7 +127,6 @@ namespace uniset
std::shared_ptr<UInterface> ui; /*!< универсальный интерфейс для работы с другими процессами */
std::string myname;
std::string section;
std::weak_ptr<UniSetManager> mymngr;
/*! обработка приходящих сообщений */
......@@ -143,7 +141,7 @@ namespace uniset
VoidMessagePtr receiveMessage();
/*! Ожидать сообщения заданное время */
virtual VoidMessagePtr waitMessage( timeout_t msec = UniSetTimer::WaitUpTime );
VoidMessagePtr waitMessage( timeout_t msec = UniSetTimer::WaitUpTime );
/*! прервать ожидание сообщений */
void termWaiting();
......@@ -160,7 +158,8 @@ namespace uniset
//! Деактивиция объекта (переопределяется для необходимых действий при завершении работы)
virtual bool deactivateObject();
// void terminate();
// прерывание работы всей программы (с вызовом shutdown)
void uterminate();
// управление созданием потока обработки сообщений -------
......@@ -220,6 +219,8 @@ namespace uniset
/* удаление ссылки из репозитория объектов */
void unregistration();
void waitFinish();
void initObject();
pid_t msgpid = { 0 }; // pid потока обработки сообщений
......@@ -241,7 +242,7 @@ namespace uniset
MQMutex mqueueMedium;
MQMutex mqueueHi;
std::atomic_bool a_working;
bool a_working;
std::mutex m_working;
std::condition_variable cv_working;
};
......
include/UniSetTypes.h
View file @ e2451a5c
......@@ -53,6 +53,19 @@ namespace uniset
// ---------------------------------------------------------------
// Вспомогательные типы данных и константы
/*! Запрещенные для использования в именах объектов символы */
const char BadSymbols[] = {'.', '/'};
/*! Проверка на наличие недопустимых символов
* Запрещенные символы см. uniset::BadSymbols[]
* \return Если не найдено запрещенных символов то будет возвращен 0, иначе найденный символ
*/
char checkBadSymbols(const std::string& str);
/*! Получение запрещенных символов в виде строки '.', '/', и т.д. */
std::string BadSymbolsToStr();
const ObjectId DefaultObjectId = -1; /*!< Идентификатор объекта по умолчанию */
const ThresholdId DefaultThresholdId = -1; /*!< идентификатор порогов по умолчанию */
const ThresholdId DefaultTimerId = -1; /*!< идентификатор таймера по умолчанию */
......@@ -139,14 +152,10 @@ namespace uniset
/*! Информация об имени объекта */
struct ObjectInfo
{
ObjectInfo() noexcept:
id(DefaultObjectId),
repName(""), textName(""), xmlnode(0) {}
ObjectId id; /*!< идентификатор */
std::string repName; /*!< текстовое имя для регистрации в репозитории */
std::string textName; /*!< текстовое имя */
xmlNode* xmlnode;
ObjectId id = { DefaultObjectId }; /*!< идентификатор */
std::string repName = { "" }; /*!< текстовое имя для регистрации в репозитории */
std::string textName = { "" }; /*!< текстовое имя */
xmlNode* xmlnode = { nullptr };
inline bool operator < ( const ObjectInfo& o ) const
{
......@@ -156,9 +165,6 @@ namespace uniset
typedef std::list<NodeInfo> ListOfNode;
/*! Запрещенные для использования в именах объектов символы */
const char BadSymbols[] = {'.', '/'};
// ---------------------------------------------------------------
// Различные преобразования
......@@ -298,25 +304,6 @@ namespace uniset
// если не задано f_val, то проверяется, что просто f_prop!=""
bool check_filter( UniXML::iterator& it, const std::string& f_prop, const std::string& f_val = "" ) noexcept;
/*! алгоритм копирования элементов последовательности удовлетворяющих условию */
template<typename InputIterator,
typename OutputIterator,
typename Predicate>
OutputIterator copy_if(InputIterator begin,
InputIterator end,
OutputIterator destBegin,
Predicate p)
{
while( begin != end)
{
if( p(*begin) ) &(destBegin++) = *begin;
++begin;
}
return destBegin;
}
// RAII для флагов форматирования ostream..
class ios_fmt_restorer
{
......
include/modbus/ModbusServerSlot.h
View file @ e2451a5c
......@@ -114,7 +114,7 @@ namespace uniset
/*! подключение обработчика 'передача файла' 0x66 */
void connectFileTransfer( FileTransferSlot sl );
virtual void terminate(){}
virtual void terminate() {}
protected:
ReadCoilSlot slReadCoil;
......
src/Core/Configuration.cc
View file @ e2451a5c
......@@ -1452,8 +1452,8 @@ namespace uniset
return uniset::uconf;
}
// atexit( UniSetActivator::normalexit );
// set_terminate( UniSetActivator::normalterminate ); // ловушка для неизвестных исключений
// atexit( UniSetActivator::normalexit );
// set_terminate( UniSetActivator::normalterminate ); // ловушка для неизвестных исключений
string confile = uniset::getArgParam( "--confile", argc, argv, xmlfile );
uniset::uconf = make_shared<Configuration>(argc, argv, confile);
......
src/Core/UInterface.cc
View file @ e2451a5c
......@@ -2376,7 +2376,7 @@ namespace uniset
bool UInterface::waitReady( const uniset::ObjectId id, int msec, int pmsec, const uniset::ObjectId node ) noexcept
{
std::atomic_bool cancelFlag = { false };
return waitReadyWithCancellation(id,msec,cancelFlag,pmsec,node);
return waitReadyWithCancellation(id, msec, cancelFlag, pmsec, node);
}
// -----------------------------------------------------------------------------
bool UInterface::waitWorking( const uniset::ObjectId id, int msec, int pmsec, const uniset::ObjectId node ) noexcept
......
src/Core/UniSetActivator.cc
View file @ e2451a5c
......@@ -56,25 +56,25 @@ static const int TERMINATE_TIMEOUT_SEC = 15; // время отведенное
// ------------------------------------------------------------------------------------------
namespace uniset
{
UniSetActivatorPtr UniSetActivator::inst;
// ---------------------------------------------------------------------------
UniSetActivatorPtr UniSetActivator::Instance()
{
UniSetActivatorPtr UniSetActivator::inst;
// ---------------------------------------------------------------------------
UniSetActivatorPtr UniSetActivator::Instance()
{
if( inst == nullptr )
inst = shared_ptr<UniSetActivator>( new UniSetActivator() );
return inst;
}
}
// ---------------------------------------------------------------------------
UniSetActivator::UniSetActivator():
// ---------------------------------------------------------------------------
UniSetActivator::UniSetActivator():
UniSetManager(uniset::DefaultObjectId)
{
{
UniSetActivator::init();
}
// ------------------------------------------------------------------------------------------
void UniSetActivator::init()
{
}
// ------------------------------------------------------------------------------------------
void UniSetActivator::init()
{
if( getId() == DefaultObjectId )
myname = "UniSetActivator";
......@@ -105,34 +105,28 @@ void UniSetActivator::init()
ucrit << myname << "(init): init poa failed!!!" << endl;
std::terminate();
}
}
sigTERM.set(loop);
sigINT.set(loop);
// sigABRT.set(loop);
sigQUIT.set(loop);
sigINT.set<&UniSetActivator::evsignal>();
sigTERM.set<&UniSetActivator::evsignal>();
// sigABRT.set<&UniSetActivator::evsignal>();
sigQUIT.set<&UniSetActivator::evsignal>();
}
// ------------------------------------------------------------------------------------------
UniSetActivator::~UniSetActivator()
{
// ------------------------------------------------------------------------------------------
UniSetActivator::~UniSetActivator()
{
if( active )
stop();
}
// ------------------------------------------------------------------------------------------
/*!
* Если thread=true то функция создает отдельный поток для обработки приходящих сообщений.
* И передает все ресурсы этого потока orb. А также регистрирует процесс в репозитории.
* \note Только после этого объект становится доступен другим процессам
* А далее выходит...
* Иначе все ресурсы основного потока передаются для обработки приходящих сообщений (и она не выходит)
*
*/
void UniSetActivator::run( bool thread )
{
{
try
{
shutdown();
}
catch(...)
{
std::exception_ptr p = std::current_exception();
cerr << (p ? p.__cxa_exception_type()->name() : "null") << std::endl;
}
}
}
// ------------------------------------------------------------------------------------------
void UniSetActivator::run( bool thread )
{
ulogsys << myname << "(run): создаю менеджер " << endl;
auto aptr = std::static_pointer_cast<UniSetActivator>(get_ptr());
......@@ -149,8 +143,7 @@ void UniSetActivator::run( bool thread )
pman->activate();
msleep(50);
if( !thread )
async_evrun();
set_signals(true);
#ifndef DISABLE_REST_API
......@@ -180,20 +173,21 @@ void UniSetActivator::run( bool thread )
{
uinfo << myname << "(run): запускаемся без создания отдельного потока... " << endl;
work();
evstop();
shutdown();
}
}
// ------------------------------------------------------------------------------------------
/*!
}
// ------------------------------------------------------------------------------------------
/*!
* Функция останавливает работу orb и завершает поток. А так же удаляет ссылку из репозитория.
* \note Объект становится недоступен другим процессам
*/
void UniSetActivator::stop()
{
*/
void UniSetActivator::shutdown()
{
if( !active )
return;
active = false;
set_signals(false);
{
std::unique_lock<std::mutex> lk(g_donemutex);
......@@ -202,16 +196,13 @@ void UniSetActivator::stop()
}
ulogsys << myname << "(stop): deactivate... " << endl;
ulogsys << myname << "(shutdown): deactivate... " << endl;
deactivate();
ulogsys << myname << "(shutdown): deactivate ok. " << endl;
ulogsys << myname << "(stop): deactivate ok. " << endl;
ulogsys << myname << "(stop): discard request..." << endl;
ulogsys << myname << "(shutdown): discard request..." << endl;
pman->discard_requests(true);
ulogsys << myname << "(stop): discard request ok." << endl;
ulogsys << myname << "(shutdown): discard request ok." << endl;
#ifndef DISABLE_REST_API
......@@ -220,29 +211,29 @@ void UniSetActivator::stop()
#endif
ulogsys << myname << "(stop): pman deactivate... " << endl;
ulogsys << myname << "(shutdown): pman deactivate... " << endl;
pman->deactivate(false, true);
ulogsys << myname << "(stop): pman deactivate ok. " << endl;
ulogsys << myname << "(shutdown): pman deactivate ok. " << endl;
try
{
ulogsys << myname << "(stop): shutdown orb... " << endl;
ulogsys << myname << "(shutdown): shutdown orb... " << endl;
if( orb )
orb->shutdown(true);
ulogsys << myname << "(stop): shutdown ok." << endl;
ulogsys << myname << "(shutdown): shutdown ok." << endl;
}
catch( const omniORB::fatalException& fe )
{
ucrit << myname << "(stop): : поймали omniORB::fatalException:" << endl;
ucrit << myname << "(stop): file: " << fe.file() << endl;
ucrit << myname << "(stop): line: " << fe.line() << endl;
ucrit << myname << "(stop): mesg: " << fe.errmsg() << endl;
ucrit << myname << "(shutdown): : поймали omniORB::fatalException:" << endl;
ucrit << myname << "(shutdown): file: " << fe.file() << endl;
ucrit << myname << "(shutdown): line: " << fe.line() << endl;
ucrit << myname << "(shutdown): mesg: " << fe.errmsg() << endl;
}
catch( const std::exception& ex )
{
ucrit << myname << "(stop): " << ex.what() << endl;
ucrit << myname << "(shutdown): " << ex.what() << endl;
}
if( orbthr )
......@@ -257,33 +248,98 @@ void UniSetActivator::stop()
if( g_finish_guard_thread )
g_finish_guard_thread->join();
}
// ------------------------------------------------------------------------------------------
void UniSetActivator::evsignal( ev::sig& signal, int signo )
{
}
// ------------------------------------------------------------------------------------------
void UniSetActivator::terminate()
{
ulogsys << myname << "(terminate): ..." << endl;
kill(getpid(), SIGTERM);
}
// ------------------------------------------------------------------------------------------
static void activator_terminate( int signo )
{
auto act = UniSetActivator::Instance();
act->stop();
}
// ------------------------------------------------------------------------------------------
void UniSetActivator::evprepare()
{
sigINT.start(SIGINT);
sigTERM.start(SIGTERM);
sigABRT.start(SIGABRT);
sigQUIT.start(SIGQUIT);
}
// ------------------------------------------------------------------------------------------
void UniSetActivator::evfinish()
{
sigINT.stop();
sigTERM.stop();
sigABRT.stop();
sigQUIT.stop();
}
// ------------------------------------------------------------------------------------------
void UniSetActivator::work()
{
act->shutdown();
}
// ------------------------------------------------------------------------------------------
void UniSetActivator::on_finish_timeout()
{
std::unique_lock<std::mutex> lk(g_donemutex);
if( g_done )
return;
ulogsys << "(FINISH GUARD THREAD): wait " << TERMINATE_TIMEOUT_SEC << " sec.." << endl << flush;
g_doneevent.wait_for(lk, std::chrono::milliseconds(TERMINATE_TIMEOUT_SEC * 1000), []()
{
return (g_done == true);
} );
if( !g_done )
{
ulogsys << "(FINISH GUARD THREAD): WAIT TIMEOUT "
<< TERMINATE_TIMEOUT_SEC << " sec..KILL *******" << endl << flush;
set_signals(false);
std::abort();
return;
}
ulogsys << "(FINISH GUARD THREAD): [OK]..bye.." << endl;
}
// ------------------------------------------------------------------------------------------
void UniSetActivator::set_signals( bool ask )
{
struct sigaction act; // = { { 0 } };
struct sigaction oact; // = { { 0 } };
memset(&act, 0, sizeof(act));
memset(&act, 0, sizeof(oact));
sigemptyset(&act.sa_mask);
sigemptyset(&oact.sa_mask);
// добавляем сигналы, которые будут игнорироваться
// при обработке сигнала
sigaddset(&act.sa_mask, SIGINT);
sigaddset(&act.sa_mask, SIGTERM);
sigaddset(&act.sa_mask, SIGABRT );
sigaddset(&act.sa_mask, SIGQUIT);
if(ask)
act.sa_handler = activator_terminate;
else
act.sa_handler = SIG_DFL;
sigaction(SIGINT, &act, &oact);
sigaction(SIGTERM, &act, &oact);
sigaction(SIGABRT, &act, &oact);
sigaction(SIGQUIT, &act, &oact);
// SIGSEGV отдельно
sigemptyset(&act.sa_mask);
sigaddset(&act.sa_mask, SIGSEGV);
act.sa_flags = 0;
// act.sa_flags |= SA_RESTART;
act.sa_flags |= SA_RESETHAND;
#if 0
g_sigseg_stack.ss_sp = g_stack_body;
g_sigseg_stack.ss_flags = SS_ONSTACK;
g_sigseg_stack.ss_size = sizeof(g_stack_body);
assert(!sigaltstack(&g_sigseg_stack, nullptr));
act.sa_flags |= SA_ONSTACK;
#endif
// if(ask)
// act.sa_handler = activator_terminate_with_calltrace;
// else
// act.sa_handler = SIG_DFL;
// sigaction(SIGSEGV, &act, &oact);
}
// ------------------------------------------------------------------------------------------
void UniSetActivator::work()
{
ulogsys << myname << "(work): запускаем orb на обработку запросов..." << endl;
try
......@@ -312,38 +368,11 @@ void UniSetActivator::work()
}
ulogsys << myname << "(work): orb thread stopped!" << endl << flush;
}
// ------------------------------------------------------------------------------------------
void UniSetActivator::on_finish_timeout()
{
std::unique_lock<std::mutex> lk(g_donemutex);
if( g_done )
return;
ulogsys << "(FINISH GUARD THREAD): activate... " << endl << flush;
g_doneevent.wait_for(lk, std::chrono::milliseconds(TERMINATE_TIMEOUT_SEC * 1000), []()
{
return (g_done == true);
} );
if( !g_done )
{
ulogsys << "(FINISH GUARD THREAD): WAIT TIMEOUT "
<< TERMINATE_TIMEOUT_SEC << " sec..KILL *******" << endl << flush;
//raise(SIGKILL);
std::abort();
return;
}
ulogsys << "(FINISH GUARD THREAD): [OK]..bye.." << endl;
}
// ------------------------------------------------------------------------------------------
// ------------------------------------------------------------------------------------------
#ifndef DISABLE_REST_API
Poco::JSON::Object::Ptr UniSetActivator::httpGetByName( const string& name, const Poco::URI::QueryParameters& p )
{
Poco::JSON::Object::Ptr UniSetActivator::httpGetByName( const string& name, const Poco::URI::QueryParameters& p )
{
if( name == myname )
return httpGet(p);
......@@ -356,10 +385,10 @@ Poco::JSON::Object::Ptr UniSetActivator::httpGetByName( const string& name, cons
err << "Object '" << name << "' not found";
throw uniset::NameNotFound(err.str());
}
// ------------------------------------------------------------------------------------------
Poco::JSON::Array::Ptr UniSetActivator::httpGetObjectsList( const Poco::URI::QueryParameters& p )
{
}
// ------------------------------------------------------------------------------------------
Poco::JSON::Array::Ptr UniSetActivator::httpGetObjectsList( const Poco::URI::QueryParameters& p )
{
Poco::JSON::Array::Ptr jdata = new Poco::JSON::Array();
std::vector<std::shared_ptr<UniSetObject>> vec;
......@@ -373,10 +402,10 @@ Poco::JSON::Array::Ptr UniSetActivator::httpGetObjectsList( const Poco::URI::Que
jdata->add(o->getName());
return jdata;
}
// ------------------------------------------------------------------------------------------
Poco::JSON::Object::Ptr UniSetActivator::httpHelpByName( const string& name, const Poco::URI::QueryParameters& p )
{
}
// ------------------------------------------------------------------------------------------
Poco::JSON::Object::Ptr UniSetActivator::httpHelpByName( const string& name, const Poco::URI::QueryParameters& p )
{
if( name == myname )
return httpHelp(p);
......@@ -388,10 +417,10 @@ Poco::JSON::Object::Ptr UniSetActivator::httpHelpByName( const string& name, con
ostringstream err;
err << "Object '" << name << "' not found";
throw uniset::NameNotFound(err.str());
}
// ------------------------------------------------------------------------------------------
Poco::JSON::Object::Ptr UniSetActivator::httpRequestByName( const string& name, const std::string& req, const Poco::URI::QueryParameters& p)
{
}
// ------------------------------------------------------------------------------------------
Poco::JSON::Object::Ptr UniSetActivator::httpRequestByName( const string& name, const std::string& req, const Poco::URI::QueryParameters& p)
{
if( name == myname )
return httpRequest(req, p);
......@@ -408,9 +437,9 @@ Poco::JSON::Object::Ptr UniSetActivator::httpRequestByName( const string& name,
ostringstream err;
err << "Object '" << name << "' not found";
throw uniset::NameNotFound(err.str());
}
// ------------------------------------------------------------------------------------------
}
// ------------------------------------------------------------------------------------------
#endif // #ifndef DISABLE_REST_API
// ------------------------------------------------------------------------------------------
// ------------------------------------------------------------------------------------------
} // end of namespace uniset
// ------------------------------------------------------------------------------------------
src/Core/UniSetManager.cc
View file @ e2451a5c
......@@ -87,15 +87,13 @@ class OPush: public unary_function< const std::shared_ptr<uniset::UniSetObject>&
// ------------------------------------------------------------------------------------------
UniSetManager::UniSetManager():
UniSetObject(uniset::DefaultObjectId),
sig(0),
olistMutex("UniSetManager_olistMutex"),
mlistMutex("UniSetManager_mlistMutex")
{
}
// ------------------------------------------------------------------------------------------
UniSetManager::UniSetManager( ObjectId id ):
UniSetObject(id),
sig(0)
UniSetObject(id)
{
olistMutex.setName(myname + "_olistMutex");
mlistMutex.setName(myname + "_mlistMutex");
......@@ -104,8 +102,7 @@ UniSetManager::UniSetManager( ObjectId id ):
// ------------------------------------------------------------------------------------------
UniSetManager::UniSetManager(const string& name, const string& section):
UniSetObject(name, section),
sig(0)
UniSetObject(name, section)
{
olistMutex.setName(myname + "_olistMutex");
mlistMutex.setName(myname + "_mlistMutex");
......@@ -132,7 +129,7 @@ void UniSetManager::initPOA( const std::weak_ptr<UniSetManager>& rmngr )
ostringstream err;
err << myname << "(initPOA): failed weak_ptr !!";
ucrit << err.str() << endl;
throw SystemError(err.str());
throw uniset::SystemError(err.str());
}
if( CORBA::is_nil(pman) )
......@@ -144,7 +141,12 @@ void UniSetManager::initPOA( const std::weak_ptr<UniSetManager>& rmngr )
poa = m->getPOA();
if( CORBA::is_nil(poa) )
ucrit << myname << "(initPOA): failed init poa " << endl;
{
ostringstream err;
err << myname << "(initPOA): failed init poa ";
ucrit << err.str() << endl;
throw uniset::SystemError(err.str());
}
// Инициализация самого менеджера и его подобъектов
UniSetObject::init(rmngr);
......@@ -589,43 +591,6 @@ bool UniSetManager::removeManager( const std::shared_ptr<UniSetManager>& child )
}
// ------------------------------------------------------------------------------------------
#if 0
const std::shared_ptr<UniSetManager> UniSetManager::itemM( const ObjectId id )
{
{
//lock
uniset_rwmutex_rlock lock(mlistMutex);
for( const auto& li : mlist )
{
if ( li->getId() == id )
return li;
}
} // unlock
return nullptr; // std::shared_ptr<UniSetManager>();
}
// ------------------------------------------------------------------------------------------
const std::shared_ptr<UniSetObject> UniSetManager::itemO( const ObjectId id )
{
{
//lock
uniset_rwmutex_rlock lock(olistMutex);
for( const auto& li : olist )
{
if ( li->getId() == id )
return li;
}
} // unlock
return nullptr; // std::shared_ptr<UniSetObject>();
}
#endif
// ------------------------------------------------------------------------------------------
int UniSetManager::getObjectsInfo( const std::shared_ptr<UniSetManager>& mngr, SimpleInfoSeq* seq,
int begin, const long uplimit, const char* userparam )
......
src/Core/UniSetObject.cc
View file @ e2451a5c
......@@ -36,6 +36,7 @@
#include "UInterface.h"
#include "UniSetObject.h"
#include "UniSetManager.h"
#include "UniSetActivator.h"
#include "Debug.h"
// ------------------------------------------------------------------------------------------
......@@ -59,7 +60,6 @@ namespace uniset
tmr = CREATE_TIMER;
myname = "noname";
section = "nonameSection";
initObject();
}
// ------------------------------------------------------------------------------------------
......@@ -74,18 +74,12 @@ namespace uniset
ui = make_shared<UInterface>(id);
tmr = CREATE_TIMER;
if (myid >= 0)
{
string myfullname = ui->getNameById(id);
myname = ORepHelpers::getShortName(myfullname);
section = ORepHelpers::getSectionName(myfullname);
}
if( myid != DefaultObjectId )
setID(id);
else
{
threadcreate = false;
myid = uniset::DefaultObjectId;
myname = "UnknownUniSetObject";
section = "UnknownSection";
}
initObject();
......@@ -106,15 +100,8 @@ namespace uniset
tmr = CREATE_TIMER;
myname = section + "/" + name;
myid = ui->getIdByName(myname);
if( myid == DefaultObjectId )
{
uwarn << "name: my ID not found!" << endl;
throw Exception(name + ": my ID not found!");
}
setID(myid);
initObject();
ui->initBackId(myid);
}
// ------------------------------------------------------------------------------------------
......@@ -129,11 +116,10 @@ namespace uniset
// ------------------------------------------------------------------------------------------
void UniSetObject::initObject()
{
a_working = ATOMIC_VAR_INIT(0);
// a_working = ATOMIC_VAR_INIT(0);
active = ATOMIC_VAR_INIT(0);
refmutex.setName(myname + "_refmutex");
// mutex_act.setName(myname + "_mutex_act");
auto conf = uniset_conf();
......@@ -167,12 +153,11 @@ namespace uniset
// ------------------------------------------------------------------------------------------
void UniSetObject::setID( uniset::ObjectId id )
{
if( myid != uniset::DefaultObjectId )
throw ObjectNameAlready("ObjectId already set(setID)");
if( isActive() )
throw ObjectNameAlready("Set ID error: ObjectId is active..");
string myfullname = ui->getNameById(id);
myname = ORepHelpers::getShortName(myfullname);
section = ORepHelpers::getSectionName(myfullname);
myid = id;
ui->initBackId(myid);
}
......@@ -332,12 +317,33 @@ namespace uniset
}
catch(...)
{
uwarn << myname << ": don`t registration in object repository" << endl;
std::exception_ptr p = std::current_exception();
uwarn << myname << ": don`t registration in object repository"
<< " err: " << (p ? p.__cxa_exception_type()->name() : "unknown")
<< endl;
}
regOK = false;
}
// ------------------------------------------------------------------------------------------
void UniSetObject::waitFinish()
{
// поток завершаем в конце, после пользовательских deactivateObject()
if( !thr )
return;
std::unique_lock<std::mutex> lk(m_working);
// cv_working.wait_for(lk, std::chrono::milliseconds(workingTerminateTimeout), [&](){ return (a_working == false); } );
cv_working.wait(lk, [ = ]()
{
return a_working == false;
});
if( thr->isRunning() )
thr->join();
}
// ------------------------------------------------------------------------------------------
CORBA::Boolean UniSetObject::exist()
{
return true;
......@@ -550,10 +556,12 @@ namespace uniset
return true;
}
// ------------------------------------------------------------------------------------------
// void UniSetObject::terminate()
// {
// deactivate();
// }
void UniSetObject::uterminate()
{
// setActive(false);
auto act = UniSetActivator::Instance();
act->terminate();
}
// ------------------------------------------------------------------------------------------
void UniSetObject::thread(bool create)
{
......@@ -615,7 +623,8 @@ namespace uniset
unregistration();
PortableServer::ObjectId_var oid = poamngr->servant_to_id(static_cast<PortableServer::ServantBase*>(this));
poamngr->deactivate_object(oid);
uinfo << myname << "(disacivate): finished..." << endl;
uinfo << myname << "(deactivate): finished..." << endl;
waitFinish();
return true;
}
}
......@@ -643,19 +652,6 @@ namespace uniset
uwarn << myname << "(deactivate): " << ex.what() << endl;
}
if( thr )
{
std::unique_lock<std::mutex> lk(m_working);
// cv_working.wait_for(lk, std::chrono::milliseconds(workingTerminateTimeout), [&](){ return (a_working == false); } );
if( a_working )
cv_working.wait(lk);
if( a_working )
thr->stop();
}
return false;
}
......@@ -812,6 +808,9 @@ namespace uniset
if( m )
processingMessage(m.get());
if( !isActive() )
return;
sleepTime = checkTimers(this);
}
catch( const uniset::Exception& ex )
......
src/Core/UniSetTypes.cc
View file @ e2451a5c
......@@ -626,3 +626,32 @@ timespec uniset::now_to_timespec()
return to_timespec(d);
}
// -------------------------------------------------------------------------
char uniset::checkBadSymbols( const string& str )
{
for ( const auto& c: str )
{
for( size_t k = 0; k < sizeof(BadSymbols); k++ )
{
if ( c == BadSymbols[k] )
return (char)BadSymbols[k];
}
}
return 0;
}
// ---------------------------------------------------------------------------------------------------------------
string uniset::BadSymbolsToStr()
{
string bad = "";
for( size_t i = 0; i < sizeof(BadSymbols); i++ )
{
bad += "'" +
bad += BadSymbols[i];
bad += "', ";
}
return bad;
}
// ---------------------------------------------------------------------------------------------------------------
src/ObjectRepository/ORepHelpers.cc
View file @ e2451a5c
......@@ -224,41 +224,5 @@ namespace uniset
}
// ---------------------------------------------------------------------------------------------------------------
/*
* Запрещенные символы см. uniset::BadSymbols[]
* \return Если не найдено запрещенных символов то будет возвращен 0, иначе найденный символ
*/
char checkBadSymbols( const string& str )
{
using namespace uniset;
for ( size_t i = 0; i < str.length(); i++)
{
for(unsigned int k = 0; k < sizeof(BadSymbols); k++)
{
if ( str[i] == BadSymbols[k] )
return (char)BadSymbols[k];
}
}
return 0;
}
// ---------------------------------------------------------------------------------------------------------------
string BadSymbolsToStr()
{
string bad = "";
for( size_t i = 0; i < sizeof(uniset::BadSymbols); i++ )
{
bad += "'";
bad += uniset::BadSymbols[i];
bad += "', ";
}
return bad;
}
// ---------------------------------------------------------------------------------------------------------------
}
}
src/ObjectRepository/ObjectRepository.cc
View file @ e2451a5c
......@@ -103,7 +103,7 @@ throw(ORepFailed, ObjectNameAlready, InvalidObjectName, NameNotFound)
}
// Проверка корректности имени
char bad = ORepHelpers::checkBadSymbols(name);
char bad = uniset::checkBadSymbols(name);
if( bad != 0 )
{
......@@ -452,7 +452,7 @@ bool ObjectRepository::isExist( const ObjectPtr& oref ) const
bool ObjectRepository::createSection(const string& name, const string& in_section) const
throw(ORepFailed, InvalidObjectName)
{
char bad = ORepHelpers::checkBadSymbols(name);
char bad = uniset::checkBadSymbols(name);
if (bad != 0)
{
......
src/Processes/IOController.cc
View file @ e2451a5c
......@@ -118,7 +118,8 @@ void IOController::activateInit()
catch( const uniset::Exception& ex )
{
ucrit << myname << "(activateInit): " << ex << endl;
std::terminate();
//std::terminate();
uterminate();
}
}
}
......
src/Processes/IONotifyController.cc
View file @ e2451a5c
......@@ -829,7 +829,8 @@ void IONotifyController::readDump()
// и безопаснее "вылететь", чем запустится, т.к. часть датчиков не будет работать
// как ожидается.
ucrit << myname << "(IONotifyController::readDump): " << ex.what() << endl;
std::terminate(); // std::abort();
//std::terminate(); // std::abort();
uterminate();
}
}
// --------------------------------------------------------------------------------------------------------------
......
src/Processes/ProxyManager.cc
View file @ e2451a5c
......@@ -107,7 +107,8 @@ bool ProxyManager::activateObject()
catch( const uniset::Exception& ex )
{
ucrit << myname << "(activate): " << ex << endl;
std::terminate();
//std::terminate();
uterminate();
}
}
......
src/Various/Mutex.cc
View file @ e2451a5c
......@@ -109,7 +109,7 @@ uniset_rwmutex_wrlock::~uniset_rwmutex_wrlock()
//catch( Poco::SystemException& ex )
catch( std::exception& ex )
{
std::terminate();
std::abort();
}
}
// -------------------------------------------------------------------------------------------
......@@ -127,7 +127,7 @@ uniset_rwmutex_rlock::~uniset_rwmutex_rlock()
}
catch( std::exception& ex )
{
std::terminate();
std::abort();
}
}
// -----------------------------------------------------------------------------
src/Various/SMonitor.cc
View file @ e2451a5c
......@@ -70,13 +70,15 @@ void SMonitor::sysCommand( const SystemMessage* sm )
{
cerr << myname << ":(askSensor): " << ex << endl;
// raise(SIGTERM);
std::terminate();
//std::terminate();
uterminate();
}
catch(...)
{
cerr << myname << ": НЕ СМОГ ЗАКАЗТЬ датчики " << endl;
// raise(SIGTERM);
std::terminate();
//std::terminate();
uterminate();
}
}
}
......
uniset2.includes
View file @ e2451a5c
......@@ -16,7 +16,6 @@ extensions/tests/SMemoryTest
extensions/UNetUDP
extensions/UniNetwork
include
include/libxml2/libxml
include/modbus
python/lib/pyUniSet
src/Log
......@@ -29,3 +28,5 @@ Utilities/NullController
/usr/include/sigc++-2.0
/usr/include/omniORB4
/usr/include/Poco
/usr/include/c++/5
/usr/include/libxml2/libxml
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