mirror of
https://github.com/FairRootGroup/FairMQ.git
synced 2025-10-13 16:46:47 +00:00
Tests for MQ examples
This commit is contained in:
parent
221d2567f0
commit
eeb994a584
|
@ -559,8 +559,6 @@ void FairMQDevice::RunWrapper()
|
||||||
|
|
||||||
Run();
|
Run();
|
||||||
}
|
}
|
||||||
|
|
||||||
PostRun();
|
|
||||||
}
|
}
|
||||||
catch (const out_of_range& oor)
|
catch (const out_of_range& oor)
|
||||||
{
|
{
|
||||||
|
@ -574,6 +572,8 @@ void FairMQDevice::RunWrapper()
|
||||||
ChangeState(internal_READY);
|
ChangeState(internal_READY);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
PostRun();
|
||||||
|
|
||||||
rateLogger.join();
|
rateLogger.join();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -291,6 +291,8 @@ struct FairMQFSM_ : public msmf::state_machine_def<FairMQFSM_>
|
||||||
{
|
{
|
||||||
fsm.fStateChangeCallback(READY);
|
fsm.fStateChangeCallback(READY);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fsm.Unblock();
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user