Skip to content

Commit 27f4d79

Browse files
committed
Allow FSM window name to change on start transition
1 parent f989400 commit 27f4d79

File tree

2 files changed

+14
-7
lines changed

2 files changed

+14
-7
lines changed

otsdaq/GatewaySupervisor/GatewaySupervisor.cc

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4886,7 +4886,8 @@ try
48864886
<< ") "
48874887
"to control progress, please transition to "
48884888
<< RunControlStateMachine::HALTED_STATE_NAME << " using the active "
4889-
<< "State Machine '" << activeStateMachineWindowName_ << ".'" << __E__;
4889+
<< "State Machine '" << activeStateMachineWindowName_ << "' (UID: " << activeStateMachineName_
4890+
<< ")." << __E__;
48904891
__SS_THROW__;
48914892
}
48924893
else // clear active state machine
@@ -5294,6 +5295,12 @@ try
52945295
parameters.addParameter(
52955296
"RunNumber",
52965297
runNumber); // will be cached in activeStateMachineRunNumber_ in transitionStarting()
5298+
5299+
if(activeStateMachineWindowName_ != fsmWindowName)
5300+
{
5301+
__SUP_COUT__ << "Running fsm window name '" << fsmWindowName << "' is now the active state machine window." << __E__;
5302+
activeStateMachineWindowName_ = fsmWindowName;
5303+
}
52975304
} //end Start transition
52985305
else if(!(command == RunControlStateMachine::HALT_TRANSITION_NAME ||
52995306
command == RunControlStateMachine::SHUTDOWN_TRANSITION_NAME ||

otsdaq/GatewaySupervisor/GatewaySupervisor.h

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -238,13 +238,13 @@ class WorkLoopManager;
238238
//===================
239239
BroadcastThreadStruct(BroadcastThreadStruct &&b)
240240
: threadIndex_(b.threadIndex_)
241-
, exitThread_(b.exitThread_)
242-
, working_(b.working_)
243-
, workToDo_(b.workToDo_)
244-
, error_(b.error_)
245-
, hardCancelRequested_(b.hardCancelRequested_)
241+
, exitThread_(b.exitThread_.load())
242+
, working_(b.working_.load())
243+
, workToDo_(b.workToDo_.load())
244+
, error_(b.error_.load())
245+
, hardCancelRequested_(b.hardCancelRequested_.load())
246246
, pthreadId_(b.pthreadId_)
247-
, hasPthreadId_(b.hasPthreadId_)
247+
, hasPthreadId_(b.hasPthreadId_.load())
248248
{
249249
} // end BroadcastThreadStruct move constructor()
250250

0 commit comments

Comments
 (0)