RunModule.h

Go to the documentation of this file.

// $Id: RunModule.h 4601 2020-10-02 09:11:11Z 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 STREAM_RunModule
#define STREAM_RunModule
 
#ifndef DABC_ModuleAsync
#include "dabc/ModuleAsync.h"
#endif
 
#include "dabc/timing.h"
 
 
namespace stream {
 
   class DabcProcMgr;
 
 
   class RunModule : public dabc::ModuleAsync {
 
   protected:
      int          fParallel; 
      void        *fInitFunc; 
      int          fStopMode; 
      DabcProcMgr *fProcMgr;
      std::string  fAsf;
      std::string  fFileUrl;  
      bool         fDidMerge;
      long unsigned fTotalSize;
      long unsigned fTotalEvnts;
      long unsigned fTotalOutEvnts;
      int           fDefaultFill;   
 
      virtual int ExecuteCommand(dabc::Command cmd);
 
      virtual void OnThreadAssigned();
 
      bool ProcessNextEvent(void* evnt, unsigned evntsize);
 
      bool ProcessNextBuffer();
 
      bool RedistributeBuffers();
 
      void ProduceMergedHierarchy();
 
      void SaveHierarchy(dabc::Buffer buf);
 
      void GenerateEOF(dabc::Buffer buf);
 
   public:
      RunModule(const std::string &name, dabc::Command cmd = nullptr);
      virtual ~RunModule();
 
      virtual bool ProcessRecv(unsigned port);
 
      virtual bool ProcessSend(unsigned) { return RedistributeBuffers(); }
 
      virtual void ProcessTimerEvent(unsigned);
 
      virtual void BeforeModuleStart();
 
      virtual void AfterModuleStop();
   };
}
 
 
#endif