plugin/roc/ReadoutApplication.h (r4864/r4186)

Go to the documentation of this file.

/********************************************************************
 * 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 ROC_READOUTAPPLICATION_H
#define ROC_READOUTAPPLICATION_H

#include "dabc/Application.h"
#include "dabc/threads.h"
#include "dabc/MemoryPool.h"
#include "dabc/Manager.h"
#include "dabc/Module.h"

#include "roc/Factory.h"
#include "roc/Board.h"
#include "roc/Commands.h"
#include "roc/BoardsVector.h"

// #include "../plugins/ezca/ezca/Definitions.h"
// need this to compile if ezca was not build

namespace roc {

   class ReadoutApplication : public dabc::Application {
      public:
         ReadoutApplication();
         virtual ~ReadoutApplication();

         virtual bool IsModulesRunning();


         bool DoRawReadout() const { return fRawReadout; }

         bool DoSuperCombiner() const { return fSuperCombiner; }

         int   NumRocs() const { return Par(roc::xmlNumRocs).AsInt(1); }

         std::string RocAddr(int index = 0) const;

         int   NumSusibo() const { return Par(roc::xmlNumSusibo).AsInt(0); }

         int SusiboAddr(int index = 0) const;

         int   NumSlaves() const { return Par(roc::xmlNumSlaves).AsInt(0); }

         std::string SlaveAddr(int index = 0) const;

         int   NumMbs() const { return Par(roc::xmlNumMbs).AsInt(0); }

         std::string MbsAddr(int index = 0) const;

         int NumTRBs() const { return Par(roc::xmlNumTRBs).AsInt(0); }

         std::string TRBAddr(int index = 0) const;

         std::string DataServerKind() const;

         std::string OutputFileName() const { return Par(xmlRawFile).AsStdStr(); }

         std::string EpicsStreamNode() const { return Par(roc::xmlEpicsStreamNode).AsStdStr(); }

         std::string EpicsTransportNode() const { return Par(roc::xmlEpicsTransportNode).AsStdStr(); }

         virtual bool CreateAppModules();

         virtual bool AfterAppModulesStopped();
         
         virtual bool BeforeAppModulesDestroyed();

         virtual int SMCommandTimeout() const { return 20; }

         virtual int ExecuteCommand(dabc::Command cmd);

         bool CreateRawOpticInput(const std::string& portname, const std::string& rocaddr, bool isfirstoptic, int numoptics);

         bool CreateRawUdpInput(const std::string& portname, const std::string& rocaddr, int rocindx);

         static bool CreateRocCombiner(const char* modulename, 
                                       bool bnetmode,
                                       const char* inppoolname,
                                       const char* outpoolname,
                                       unsigned buffersize,
                                       int numoutputs,
                                       bool skiperrordata,
                                       roc::BoardsVector& brds);

      protected:

         roc::BoardsVector         fRocBrds; 
         enum ECalibrationState { calNONE, calOFF, calON };

         bool  fRawReadout;     
         bool  fSuperCombiner; 
         bool  fDoMeasureADC; 
         bool  fCheckSlavesConn; 
         int   fFirstSlavePort;  
         bool  fMasterNode;   
         std::string fServerOutPort; 
         std::string fFileOutPort; 
         ECalibrationState fCalibrState;

         bool SwitchCalibrationMode(bool on);

         bool ConnectSlave(int nslave, int ninp);

         virtual void ProcessParameterEvent(const dabc::ParameterEvent& evnt);

         virtual double ProcessTimeout(double last_diff);

         bool StartFile(const std::string& filename);
         bool StopFile();

         int   NumOpticRocs();
         int   NumUdpRocs();




   };
}

#endif