SorterModule.h

Go to the documentation of this file.

// $Id: SorterModule.h 3862 2018-05-11 10:06:18Z linev $
 
/************************************************************
 * The Data Acquisition Backbone Core (DABC)                *
 ************************************************************
 * Copyright (C) 2009 -                                     *
 * GSI Helmholtzzentrum fuer Schwerionenforschung GmbH      *
 * Planckstr. 1, 64291 Darmstadt, Germany                   *
 * Contact:  http://dabc.gsi.de                             *
 ************************************************************
 * This software can be used under the GPL license          *
 * agreements as stated in LICENSE.txt file                 *
 * which is part of the distribution.                       *
 ************************************************************/
 
#ifndef HADAQ_SorterModule
#define HADAQ_SorterModule
 
#ifndef DABC_ModuleAsync
#include "dabc/ModuleAsync.h"
#endif
 
#ifndef DABC_Pointer
#include "dabc/Pointer.h"
#endif
 
#include <vector>
 
namespace hadaq {
 
 
   class SorterModule : public dabc::ModuleAsync {
 
   public:
         struct SubsRec {
            void*     subevnt;  
            uint32_t  trig;     
            uint32_t  buf;      
            uint32_t  sz;       
         };
 
         struct SubsComp {
            SorterModule* m;
            SubsComp(SorterModule* _m) : m(_m) {}
            // use in std::sort for sorting elements of std::vector<SubsRec>
            bool operator() (const SubsRec& l,const SubsRec& r) { return m->Diff(l.trig, r.trig) > 0; }
         };
 
 
      int       fFlushCnt;
      int       fBufCnt;          
      int       fLastRet;         
      uint32_t  fTriggersRange;   
      uint32_t  fLastTrigger;     
      unsigned  fNextBufIndx;     
      unsigned  fReadyBufIndx;    
      std::vector<SubsRec> fSubs; 
      dabc::Buffer fOutBuf;       
      dabc::Pointer fOutPtr;      
 
      void DecremntInputIndex(unsigned cnt=1);
 
      bool RemoveUsedSubevents(unsigned num);
 
      bool retransmit();
 
      virtual int ExecuteCommand(dabc::Command cmd);
 
   public:
      SorterModule(const std::string &name, dabc::Command cmd = nullptr);
 
      virtual bool ProcessBuffer(unsigned) { return retransmit(); }
 
      virtual bool ProcessRecv(unsigned) { return retransmit(); }
 
      virtual bool ProcessSend(unsigned) { return retransmit(); }
 
      virtual void ProcessTimerEvent(unsigned);
 
      int Diff(uint32_t trig1, uint32_t trig2)
      {
         int res = (int) (trig2) - trig1;
         if (res > ((int) fTriggersRange)/2) return res - fTriggersRange;
         if (res < ((int) fTriggersRange)/-2) return res + fTriggersRange;
         return res;
      }
 
 
   };
 
}
 
 
#endif