TokenManager.hpp

Go to the documentation of this file.

 
#ifndef TRIGGER_SRC_TRIGGER_TOKENMANAGER_HPP_
#define TRIGGER_SRC_TRIGGER_TOKENMANAGER_HPP_
 
#include "LivetimeCounter.hpp"
 
#include "dfmessages/TriggerDecisionToken.hpp"
#include "dfmessages/Types.hpp"
#include "iomanager/Receiver.hpp"
 
#include <atomic>
#include <chrono>
#include <memory>
#include <set>
#include <string>
#include <thread>
 
namespace dunedaq {
namespace trigger {

class TokenManager
{
public:
  TokenManager(const std::string& connection_name,
               int initial_tokens,
               daqdataformats::run_number_t run_number,
               std::shared_ptr<LivetimeCounter> livetime_counter);
 
  virtual ~TokenManager();
 
  TokenManager(TokenManager const&) = delete;
  TokenManager(TokenManager&&) = default;
  TokenManager& operator=(TokenManager const&) = delete;
  TokenManager& operator=(TokenManager&&) = default;

  int get_n_tokens() const;

  bool triggers_allowed() const { return get_n_tokens() > 0; }

  void trigger_sent(dfmessages::trigger_number_t);
 
private:
  // The main thread
  void receive_token(dfmessages::TriggerDecisionToken& token);
 
  std::string m_connection_name;
 
  // Are we running?
  std::atomic<bool> m_running_flag;
  // How many tokens are currently available?
  std::atomic<int> m_n_tokens;
 
  // The currently-in-flight trigger decisions, and a mutex to guard it
  std::set<dfmessages::trigger_number_t> m_open_trigger_decisions;
  std::mutex m_open_trigger_decisions_mutex;
 
  daqdataformats::run_number_t m_run_number;
  std::shared_ptr<LivetimeCounter> m_livetime_counter;
 
  // open strigger report time
  std::chrono::time_point<std::chrono::steady_clock> m_open_trigger_time;
 
  // the IOManager receiver instance
  std::shared_ptr<iomanager::ReceiverConcept<dfmessages::TriggerDecisionToken>> m_token_receiver;
};
 
} // namespace trigger
} // namespace dunedaq
 
#endif // TRIGGER_SRC_TRIGGER_TOKENMANAGER_HPP_