run.h

Go to the documentation of this file.

// Copyright (c) 2024 anabrid GmbH
// Contact: https://www.anabrid.com/licensing/
// SPDX-License-Identifier: MIT OR GPL-2.0-or-later
 
#pragma once
 
#include <ArduinoJson.h>
#include <queue>
#include <string>
 
#include "daq/base.h"
#include "mode/mode.h"
 
namespace run {
 
enum class RunState { NEW, ERROR, DONE, QUEUED, TAKE_OFF, IC, OP, OP_END, TMP_HALT, _COUNT __attribute__((unused))
};
 
constexpr const char* RunStateNames[static_cast<unsigned int>(RunState::_COUNT)] = {
    "NEW", "ERROR", "DONE", "QUEUED", "TAKE_OFF", "IC", "OP", "OP_END", "TMP_HALT"
};
 
class RunStateChange {
public:
  unsigned long long t;
  RunState old;
  RunState new_;
};
 
class RunConfig {
public:
  uint64_t ic_time = 100'000;           
  uint64_t op_time = 500'000'000;       
  bool halt_on_overload = false;        
  bool streaming = false;               
  bool repetitive = false;              
  bool write_run_state_changes = true;  
  bool calibrate = false;               
 
  static RunConfig from_json(JsonObjectConst &json);
};
 
class Run {
public:
  const std::string id;           
  RunConfig config;               
  RunState state = RunState::NEW; 
  daq::DAQConfig daq_config;      
 
protected:
  std::queue<RunStateChange, std::array<RunStateChange, 7>> history;
 
public:
  Run(std::string id, const RunConfig &config, const daq::DAQConfig &daq_config);
  Run(std::string id, const RunConfig &config);
  static Run from_json(JsonObjectConst &json);
 
  RunStateChange to(RunState new_state, unsigned int t = 0);
 
};
 
class RunStateChangeHandler {
public:
  virtual void handle(run::RunStateChange change, const run::Run &run) = 0;
};
 
class RunDataHandler {
public:
  volatile bool first_data = false;
  volatile bool last_data = false;
  virtual void init() {};
  virtual void handle(volatile uint32_t *data, size_t outer_count, size_t inner_count, const run::Run &run) = 0;
  virtual void stream(volatile uint32_t *buffer, run::Run &run) = 0;
  virtual void prepare(Run& run) = 0;
};
 
} // namespace run