diff --git a/fairmq/plugins/DDS/DDS.cxx b/fairmq/plugins/DDS/DDS.cxx index 40c1e537..93cee8e3 100644 --- a/fairmq/plugins/DDS/DDS.cxx +++ b/fairmq/plugins/DDS/DDS.cxx @@ -40,7 +40,7 @@ DDS::DDS(const string& name, const Plugin::Version version, const string& mainta , fConnectingChans() , fStopMutex() , fStopCondition() - , fCommands({ "BIND", "CONNECT", "INIT TASK", "RUN", "STOP", "RESET TASK", "RESET DEVICE", "SHUTDOWN", "STARTUP" }) + , fTransitions({ "BIND", "CONNECT", "INIT TASK", "RUN", "STOP", "RESET TASK", "RESET DEVICE" }) , fControllerThread() , fEvents() , fEventsMutex() @@ -326,7 +326,7 @@ auto DDS::SubscribeForCustomCommands() -> void } else { fDDSCustomCmd.send(id + ": could not queue " + cmd + " transition", to_string(senderId)); } - } else if (fCommands.find(cmd) != fCommands.end()) { + } else if (fTransitions.find(cmd) != fTransitions.end()) { if (ChangeDeviceState(ToDeviceStateTransition(cmd))) { fDDSCustomCmd.send(id + ": queued " + cmd + " transition", to_string(senderId)); } else { diff --git a/fairmq/plugins/DDS/DDS.h b/fairmq/plugins/DDS/DDS.h index ae1d7839..9f2eb91b 100644 --- a/fairmq/plugins/DDS/DDS.h +++ b/fairmq/plugins/DDS/DDS.h @@ -89,7 +89,7 @@ class DDS : public Plugin std::mutex fStopMutex; std::condition_variable fStopCondition; - const std::set fCommands; + const std::set fTransitions; std::thread fControllerThread; std::queue fEvents;