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

Reproducer for control misbehavior

Browse Source
This commit is contained in:
Giulio Eulisse 2022-08-26 09:37:42 +02:00
parent 2500771689
commit 57625858df
1 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
examples/1-1/sampler.cxx
View File

@ -8,8 +8,9 @@
#include <fairmq/Device.h> #include <fairmq/Device.h>
#include <fairmq/runDevice.h> #include <fairmq/runDevice.h>
#include <functional>
#include <string> #include <string>
#include <vector>
namespace bpo = boost::program_options; namespace bpo = boost::program_options;
@ -17,6 +18,21 @@ struct Sampler : fair::mq::Device
{ {
void InitTask() override void InitTask() override
{ {
static std::vector<std::string> transitions = {"END", "RESET DEVICE", "RESET TASK", "STOP"};
static bool isRunning = false;
std::function<void(const fair::mq::State)> stateWatcher =
[this](const fair::mq::State state) -> void {
if (state == fair::mq::State::Running) {
isRunning = true;
}
if (isRunning) {
LOG(info) << "Switching to " << transitions.back() << std::endl;
assert(transitions.empty() == false);
ChangeState(transitions.back());
transitions.pop_back();
}
};
this->SubscribeToStateChange("dpl", stateWatcher);
// Get the fText and fMaxIterations values from the command line options (via fConfig) // Get the fText and fMaxIterations values from the command line options (via fConfig)
fText = fConfig->GetProperty<std::string>("text"); fText = fConfig->GetProperty<std::string>("text");
fMaxIterations = fConfig->GetProperty<uint64_t>("max-iterations"); fMaxIterations = fConfig->GetProperty<uint64_t>("max-iterations");