JEventTable.hh

Go to the documentation of this file.

#ifndef __JRUNCONTROL__JEVENTTABLE__
#define __JRUNCONTROL__JEVENTTABLE__

#include <string>
#include <map>

#include "JNet/JPrefix.hh"
#include "JDAQ/JDAQTags.hh"
#include "JRuncontrol/JDAQCHSM.hh"


/**
 * \author mdejong
 */

namespace KM3NETDAQ {


  /**
   * Type definition of a DAQ event.
   */
  typedef  JDAQStateMachine::ev_daq_event   JDAQEvent_t;


  /**
   * Event table.
   *
   * This class consists of a STL map<key,value> in which the key corresponds to
   * the unique combination of a ControlHost tag and an event name.
   * The associated value points to the corresponding event.
   */
  class JEventTable :
    public std::map<std::string, JDAQStateMachine::ev_daq_event*>
  {
  public:

    typedef  std::map<std::string, JDAQStateMachine::ev_daq_event*>    JMap_t;


    /**
     * Default constructor.
     */
    JEventTable() :
      JMap_t()
    {}


    /**
     * Get key for a given tag and event.
     *
     * \param  tag          tag
     * \param  event        event
     * \return              key
     */
    static std::string getKey(const JNET::JTag& tag, const CHSM::event& event)
    {
      return getKey(tag, event.name());
    }


    /**
     * Get key for a given tag and event name.
     *
     * \param  tag          tag
     * \param  event_name   event name
     * \return              key
     */
    static std::string getKey(const JNET::JTag& tag, const std::string& event_name) 
    {
      return tag.toString() + getTokenDelimeter() + event_name;
    }


    /**
     * Insert entry in table.
     *
     * \param  tag          tag
     * \param  event        event
     */
    void insert(const JNET::JTag& tag, JDAQEvent_t& event) 
    {
      JMap_t::insert(make_pair(getKey(tag,event), &event));
    }


    /**
     * Replace entry in table.
     *
     * \param  oldTag       old tag
     * \param  newTag       new tag
     * \param  event        event
     */
    void replace(const JNET::JTag& oldTag, 
                 const JNET::JTag& newTag, 
                 JDAQEvent_t&      event) 
    {
      iterator i = JMap_t::find(getKey(oldTag,event));
      
      if (i != this->end())
        this->erase(i);
      
      insert(newTag, event);
    }


    /**
     * Find entry.
     *
     * \param  tag          tag
     * \param  event_name   event name
     */
    const_iterator find(const JNET::JTag& tag, const std::string& event_name) const
    {
      return JMap_t::find(getKey(tag,event_name));
    }
  };


  /**
   * Convert event table to ControlHost subscription.
   *
   * \param  event_table  event table
   * \return              subscription
   */
  inline JNET::JSubscriptionList getSubscription(const JEventTable& event_table)
  {
    using namespace JNET;
    using std::string;

    JSubscriptionList buffer;
    
    for (JEventTable::const_iterator i = event_table.begin(); i != event_table.end(); ++i) {
      
      string            key = i->first;
      string::size_type pos = key.find_first_of(TOKEN_DELIMETER);
      
      if (pos != string::npos) {
        buffer.add(JSubscriptionAll(key.substr(0, pos)));
      }
    }
    
    return buffer;
  }
}

#endif