symmetri.h

Go to the documentation of this file.

#pragma once

 
#include <set>
 
#include "symmetri/callback.h"
#include "symmetri/tasks.h"
#include "symmetri/types.h"
 
namespace symmetri {

struct Petri;

class PetriNet final {
 public:
  PetriNet(const std::set<std::string> &petri_net_xmls,
           const std::string &case_id, std::shared_ptr<TaskSystem> threadpool,
           const Marking &goal_marking = {},
           const PriorityTable &priorities = {});

  PetriNet(const Net &net, const std::string &case_id,
           std::shared_ptr<TaskSystem> threadpool,
           const Marking &initial_marking, const Marking &goal_marking = {},
           const PriorityTable &priorities = {});

  std::function<void()> getInputTransitionHandle(
      const std::string &transition) const noexcept;

  void registerCallback(const std::string &transition,
                        Callback &&callback) const noexcept;

  template <typename T, typename... Args>
  void registerCallbackInPlace(const std::string &transition,
                               Args &&...args) const noexcept {
    if (impl == nullptr || s.empty()) {
      return;
    }
    s.emplace_back(identity<T>{}, std::forward<Args>(args)...);
    *getCallbackItr(transition) = std::move(s.back());
    s.pop_back();  }

  Marking getMarking() const noexcept;

  bool reuseApplication(const std::string &case_id);
 
  friend Token(symmetri::fire)(const PetriNet &);
  friend void(symmetri::cancel)(const PetriNet &);
  friend void(symmetri::pause)(const PetriNet &);
  friend void(symmetri::resume)(const PetriNet &);
  friend Eventlog(symmetri::getLog)(const PetriNet &);
 
 private:
  std::vector<Callback>::iterator getCallbackItr(
      const std::string &transition_name) const;
 
  const std::shared_ptr<Petri> impl;  
  std::vector<Callback> &s;
};
 
}  // namespace symmetri