DDASSorter.h

Go to the documentation of this file.

/*
    This software is Copyright by the Board of Trustees of Michigan
    State University (c) Copyright 2017.
 
    You may use this software under the terms of the GNU public license
    (GPL).  The terms of this license are described at:
 
     http://www.gnu.org/licenses/gpl.txt
 
     Authors:
             Ron Fox
             Giordano Cerriza
             NSCL
             Michigan State University
             East Lansing, MI 48824-1321
*/
 
#ifndef DDASSORTER_H
#define DDASSORTER_H
 
#include <deque>
 
#include <CRingBufferChunkAccess.h>
 
class CRingBuffer;
 
namespace DDASReadout {
class BufferArena;
class ReferenceCountedBuffer;
class ZeroCopyHit;
class HitManager;
} // namespace DDASReadout
 
typedef struct _RingItemHeader *pRingItemHeader;
 
class DDASSorter {
private:
  CRingBuffer &m_source;              
  CRingBuffer &m_sink;                
  DDASReadout::HitManager *m_pHits;   
  DDASReadout::BufferArena *m_pArena; 
  std::deque<DDASReadout::ZeroCopyHit *> m_hits; 
  uint32_t m_sid;                                
  double m_lastEmittedTimestamp; 
 
public:
  DDASSorter(CRingBuffer &source, CRingBuffer &sink, float window = 10.0);
  ~DDASSorter();
 
  void operator()();
 
private:
  void processChunk(CRingBufferChunkAccess::Chunk &chunk);
  void outputRingItem(pRingItemHeader pItem);
  void processHits(pRingItemHeader pItem);
  void flushHitManager();
  DDASReadout::ZeroCopyHit *allocateHit();
  void freeHit(DDASReadout::ZeroCopyHit *pHit);
  void outputHit(DDASReadout::ZeroCopyHit *pHit);
};
 
#endif