user_plugin_static.cpp

Go to the documentation of this file.

#include <proto/main.pb.h>
 
#include <plugin/static.h>
#include <run/run.h>
#include <protocol/protocol.h>
#include <protocol/protocol_oob.h>
 
constexpr uint16_t bufsize = 300;
uint16_t *results = nullptr;
size_t cur_run = 0;
run::Run *reprun = nullptr;
 
void tear_down() {
    delete reprun;
    delete results;
    cur_run = 0;
}
 
/*
class MonteCarloHandler : public msg::handlers::MessageHandler {
public:
  int handle(JsonObjectConst msg_in, utils::StreamingJson &msg_out) override {
    if(msg_in.containsKey("run_delete"))
      tear_down();
 
    if(msg_in.containsKey("run_config")) {
      auto run_config_json = msg_in["run_config"].as<JsonObjectConst>();
      auto run_config = run::RunConfig::from_pb(run_config_json);
      if(reprun)
          tear_down();
 
 
      reprun = new run::Run(
        "monte_carlo",
        run_config,
        std::make_unique<client::RunStateChangeNotificationHandler>(msg_out.output),
        std::make_unique<client::RunDataNotificationHandler>(msg_out.output),
        daq::DAQConfig::silence()
      );
    }
 
    return success;
  }
};*/
 
void static_plugin::setup() {
    //msg::handlers::Registry::get().set("monte_carlo", new MonteCarloHandler(), net::auth::SecurityLevel::RequiresLogin);
}
 
void static_plugin::loop() {
  if(!reprun) return;
 
  if(!results) {
    results = new uint16_t[bufsize]; // because RAM2 has more of leftover
  }
 
  // carry out the next run, not streaming any data during run.
  // TODO: Add carrier reference to plugins and fix this call
  auto carrier = static_cast<carrier::Carrier*>(nullptr);
  reprun->run(*carrier);
  // sample exactly one channel at end of run.
  results[cur_run++] = daq::sample_raw()[0];
 
  if(cur_run < bufsize) return;
 
  // stream out the results, reusing existing infrastructure.
  //reprun->streaming_run_data_notification_handler->handle(results, bufsize, 1, *reprun);
  cur_run = 0;
}