MdModuleRejector.h

Go to the documentation of this file.

#ifndef _MdModuleRejectorAG_MdModuleRejector_h_
#define _MdModuleRejectorAG_MdModuleRejector_h_

#include <fwk/VModule.h>
#include <utl/TimeStamp.h>
#include <map>
#include <utility>
#include <boost/tuple/tuple.hpp>

namespace evt {
  class Event;
}

namespace utl {
  class TimeStamp;
}

namespace MdModuleRejectorAG {

  class MdModuleRejector : public fwk::VModule {

  public:
    fwk::VModule::ResultFlag Init();
    fwk::VModule::ResultFlag Run(evt::Event& event);
    fwk::VModule::ResultFlag Finish();

  private:

    // Data structure holding: start timestamp, end timestamp, counter id, and module id
    typedef std::multimap< utl::TimeStamp, boost::tuple<utl::TimeStamp, size_t, size_t> > ParentMap;

    class TimeRangeMap : public ParentMap
    {
    public:
      typedef std::vector< std::pair<size_t,size_t>  > IdCollection;  // counter id and module id

      IdCollection
      GetBadStations(const utl::TimeStamp& time)
        const
      {
        ParentMap::const_iterator it = upper_bound(time); // first key larger than time

        if (it == begin())
          return IdCollection();

        IdCollection ids;
        do {
          --it;
          if (it->first <= time && time <= it->second.get<0>()) {
            size_t counterId = it->second.get<1>();
            size_t moduleId = it->second.get<2>();
            ids.push_back(std::make_pair(counterId, moduleId));
          }
        } while (it!=begin());
        return ids;
      }
    };

    TimeRangeMap fRejectMap;

    REGISTER_MODULE("MdModuleRejectorAG", MdModuleRejector);

  };

}

#endif

// Configure (x)emacs for this file ...
// Local Variables:
// mode: c++
// End: