event.hh

Go to the documentation of this file.

// Copyright (c) 2018, Joseph Mirabel
// Authors: Joseph Mirabel (joseph.mirabel@laas.fr)
 
#ifndef __SOT_EVENT_H__
#define __SOT_EVENT_H__
 
#include <dynamic-graph/command-bind.h>
#include <dynamic-graph/command-getter.h>
#include <dynamic-graph/command-setter.h>
#include <dynamic-graph/entity.h>
#include <dynamic-graph/pool.h>
#include <dynamic-graph/signal-ptr.h>
#include <dynamic-graph/signal-time-dependent.h>
#include <dynamic-graph/signal.h>
 
#include <sot/core/config.hh>
 
namespace dynamicgraph {
namespace sot {
 
class SOT_CORE_DLLAPI Event : public dynamicgraph::Entity {
  DYNAMIC_GRAPH_ENTITY_DECL();
 
  Event(const std::string &name)
      : Entity(name),
        checkSOUT("Event(" + name + ")::output(bool)::check"),
        conditionSIN(NULL, "Event(" + name + ")::input(bool)::condition"),
        lastVal_(2),  // lastVal_ should be different true and false.
        timeSinceUp_(0),
        repeatAfterNIterations_(0) {
    checkSOUT.setFunction(boost::bind(&Event::check, this, _1, _2));
    signalRegistration(conditionSIN);
    signalRegistration(checkSOUT);
 
    using command::makeCommandVoid1;
    std::string docstring =
        "\n"
        "    Add a signal\n";
    addCommand("addSignal",
               makeCommandVoid1(*this, &Event::addSignal, docstring));
 
    docstring =
        "\n"
        "    Get list of signals\n";
    addCommand("list", new command::Getter<Event, std::string>(
                           *this, &Event::getSignalsByName, docstring));
 
    docstring =
        "\n"
        "    Repease event if input signal remains True for a while\n"
        "      Input: number of iterations before repeating output\n."
        "        0 for no repetition";
    addCommand("repeat", new command::Setter<Event, sigtime_t>(
                             *this, &Event::repeat, docstring));
  }
 
  ~Event() {}
 
  virtual std::string getDocString() const {
    return "Send an event when the input changes\n\n"
           "  The signal triggered is called whenever the condition is "
           "satisfied.\n";
  }
 
  void addSignal(const std::string &signal) {
    std::istringstream iss(signal);
    triggers.push_back(&PoolStorage::getInstance()->getSignal(iss));
  }
 
  // Returns the Python string representation of the list of signal names.
  std::string getSignalsByName() const {
    std::ostringstream oss;
    oss << "(";
    for (Triggers_t::const_iterator _sig = triggers.begin();
         _sig != triggers.end(); ++_sig)
      oss << '\'' << (*_sig)->getName() << "\', ";
    oss << ")";
    return oss.str();
  }
 
  void repeat(const sigtime_t &nbIterations) {
    repeatAfterNIterations_ = nbIterations;
  }
 
 private:
  typedef SignalBase<sigtime_t> *Trigger_t;
  typedef std::vector<Trigger_t> Triggers_t;
 
  bool &check(bool &ret, const int64_t &time);
 
  Signal<bool, sigtime_t> checkSOUT;
 
  Triggers_t triggers;
  SignalPtr<bool, sigtime_t> conditionSIN;
 
  bool lastVal_;
  sigtime_t timeSinceUp_, repeatAfterNIterations_;
};
}  // namespace sot
}  // namespace dynamicgraph
#endif  // __SOT_EVENT_H__