LogicalEventSorterBase.hpp

Go to the documentation of this file.

 
#ifndef H_POTTU_LOGICAL_EVENT_SORTER_BASE
#define H_POTTU_LOGICAL_EVENT_SORTER_BASE
 
#include "ContextBase.hpp"
#include "DetectorEvent.hpp"
#include "LogicalEventCollector.hpp"
#include "SharedResourcePool.hpp"
 
namespace pottu {
 
    template <class Ev, class Tr>
    class LogicalEventSorterBase : public StageDetectorEvent {
    public:
    using logical_event_pool_t = SharedResourcePool<Ev>;
    using logical_event_handle_t = typename logical_event_pool_t::logical_event_handle_t; 
 
 
    LogicalEventSorterBase( const std::string &name, int triggerDeadTime, int eventDelay, int maxEventLength )
        : _ctxh(ContextBase::getActive().createHandle(name.c_str())),
          _eventCollector( *this, _triggerer, triggerDeadTime, eventDelay, maxEventLength )
        {}
 
    
    /*****************************************************
     * process()
     *****************************************************/
    void process( std::vector<DetectorEvent> &data ) noexcept {
        // Just for statistics... proci is automatically destroyed at
        // the end of process().
        auto proci = _ctxh->processInstance();
    
        // Creates logical events and calls methods:
        //  - constructAndProcessLogicalEvent()
        //  - onTimeOrderError()
        // These must be available in this class!
        _eventCollector.feed( data );
    }
 
 
    int64_t getEventMaxLength() const { return _eventCollector._maxEventLength; }
 
 
    int64_t getEventDelay() const { return _eventCollector._eventDelay; }
 
 
    int64_t getTriggerDeadtime() const { return _eventCollector._triggerDeadTime; }
    
    protected:
 
    friend class LogicalEventCollector<LogicalEventSorterBase,Tr>;
 
    virtual void onTimeOrderError() noexcept = 0;
    
    virtual void constructAndProcessLogicalEvent( std::deque<pottu::DetectorEvent>::iterator first,
                              std::deque<pottu::DetectorEvent>::iterator last,
                              int64_t triggerTime,
                              int64_t eventStartTime, int64_t eventStopTime ) noexcept = 0;
 
    
    logical_event_handle_t getNewEvent() noexcept {
        return _logicalEventPool.get();
    }
 
    ContextHandle *context() noexcept { return _ctxh; }
    
    // This handle just takes care of some debug printing and taking
    // time of processing for statistics.
    ContextHandle                 *_ctxh;
 
    // Pool for new logical events. Using pool decreases heap
    // allocations dramatically and speeds up program.
    logical_event_pool_t           _logicalEventPool;
 
    // Class and instance defining the trigger condition. Used by
    // _eventCollector.
    Tr                             _triggerer;
 
    // Pottu class collecting DetectorEvents into logical events. Uses
    // _triggerer.
    LogicalEventCollector<LogicalEventSorterBase,Tr>    _eventCollector;
 
    };
 
    
}
 
 
#endif