Mirror/FairMQ
1
0
Fork 0
mirror of https://github.com/FairRootGroup/FairMQ.git synced 2025-10-13 08:41:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

Handle errors in static and interactive controllers

Browse Source
This commit is contained in:
Alexey Rybalchenko 2018-10-09 16:41:09 +02:00 committed by Dennis Klein
parent 45354f268b
commit bde12f58b2
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
fairmq/plugins/Control.cxx
View File

@ -209,6 +209,11 @@ try
} }
} }
if (GetCurrentDeviceState() == DeviceState::Error)
{
throw DeviceErrorState("Controlled device transitioned to error state.");
}
if (fDeviceShutdownRequested) if (fDeviceShutdownRequested)
{ {
break; break;
@ -273,6 +278,11 @@ try
{ {
fNewEvent.wait_for(lock, chrono::milliseconds(50)); fNewEvent.wait_for(lock, chrono::milliseconds(50));
} }
if (fEvents.front() == DeviceState::Error)
{
throw DeviceErrorState("Controlled device transitioned to error state.");
}
} }
RunShutdownSequence(); RunShutdownSequence();