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

Remove obsolete state machine code

Browse Source
This commit is contained in:
Alexey Rybalchenko 2019-03-12 11:14:24 +01:00 committed by Dennis Klein
parent dd02c01c36
commit 74881d27e3
1 changed files with 0 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
fairmq/StateMachine.cxx
View File

@ -168,7 +168,6 @@ struct Machine_ : public state_machine_def<Machine_>
Machine_() Machine_()
: fLastTransitionResult(true) : fLastTransitionResult(true)
, fNewStatePending(false) , fNewStatePending(false)
, fWorkOngoing(false)
{} {}
virtual ~Machine_() {} virtual ~Machine_() {}
@ -259,9 +258,7 @@ struct Machine_ : public state_machine_def<Machine_>
mutex fStateMtx; mutex fStateMtx;
atomic<bool> fNewStatePending; atomic<bool> fNewStatePending;
atomic<bool> fWorkOngoing;
condition_variable fNewStatePendingCV; condition_variable fNewStatePendingCV;
condition_variable fWorkDoneCV;
boost::signals2::signal<void(const State)> fStateChangeSignal; boost::signals2::signal<void(const State)> fStateChangeSignal;
boost::signals2::signal<void(const State)> fStateHandleSignal; boost::signals2::signal<void(const State)> fStateHandleSignal;
@ -284,7 +281,6 @@ struct Machine_ : public state_machine_def<Machine_>
LOG(state) << fState << " ---> " << fNewState; LOG(state) << fState << " ---> " << fNewState;
fState = static_cast<State>(fNewState); fState = static_cast<State>(fNewState);
fNewStatePending = false; fNewStatePending = false;
fWorkOngoing = true;
if (fState == State::Exiting || fState == State::Error) { if (fState == State::Exiting || fState == State::Error) {
stop = true; stop = true;
@ -293,12 +289,6 @@ struct Machine_ : public state_machine_def<Machine_>
CallStateChangeCallbacks(fState); CallStateChangeCallbacks(fState);
CallStateHandler(fState); CallStateHandler(fState);
{
lock_guard<mutex> lock(fStateMtx);
fWorkOngoing = false;
fWorkDoneCV.notify_one();
}
} }
if (fState == State::Error) { if (fState == State::Error) {
@ -477,8 +467,6 @@ void StateMachine::ProcessWork()
lock_guard<mutex> lock(fsm->fStateMtx); lock_guard<mutex> lock(fsm->fStateMtx);
fsm->fState = State::Error; fsm->fState = State::Error;
fsm->CallStateChangeCallbacks(State::Error); fsm->CallStateChangeCallbacks(State::Error);
fsm->fWorkOngoing = false;
fsm->fWorkDoneCV.notify_one();
} }
ChangeState(Transition::ErrorFound); ChangeState(Transition::ErrorFound);
throw; throw;