EpicsInput.h

Go to the documentation of this file.

// $Id: EpicsInput.h 4464 2020-04-15 12:14:20Z 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 EZCA_EPICSINPUT_H
#define EZCA_EPICSINPUT_H
 
#ifndef DABC_DataIO
#include "dabc/DataIO.h"
#endif
 
#include "dabc/logging.h"
 
#include <string>
#include <vector>
#include <cstdint>
 
 
namespace ezca {
 
   class EpicsInput: public dabc::DataInput {
      protected:
         std::string fName;
 
         /* timeout (in seconds) for readout polling. */
         double fTimeout;
 
         /* full id number for epics subevent*/
         unsigned fSubeventId;
 
         long fLastFlagValue;
 
         long fEventNumber;
 
         long fCounter;
 
         double fEzcaTimeout;
 
         int fEzcaRetryCnt;
 
         bool fEzcaDebug;
 
         bool fEzcaAutoError;
 
         /* the update flag record is looked at for all read attempts
          * only if this one switches to some "updated" state,
          * all the rest of the set up variables are requested
          * and put into the output buffer*/
         std::string fUpdateFlagRecord;
 
         /* the id number of the current dataset, i.e. the mbs event number*/
         std::string fIDNumberRecord;
 
         /* name of the dabc command receiver that shall be informed
          * whenever the PVs are updated*/
         std::string fUpdateCommandReceiver;
 
         /* contains names of all long integer values to be requested*/
         std::vector<std::string> fLongRecords;
         std::vector<long> fLongValues;
         std::vector<bool> fLongRes;
 
         /* contains names of all double  values to be requested*/
         std::vector<std::string> fDoubleRecords;
         std::vector<double> fDoubleValues;
         std::vector<bool> fDoubleRes;
 
         void ResetDescriptors()
         {
            fUpdateFlagRecord = "";
            fIDNumberRecord = "";
            fUpdateCommandReceiver="";
            fLongRecords.clear();
            fLongValues.clear();
            fLongRes.clear();
            fDoubleRecords.clear();
            fDoubleValues.clear();
            fDoubleRes.clear();
         }
 
         unsigned NumLongRecords() const { return fLongRecords.size(); }
 
         const std::string &GetLongRecord(unsigned i) const { return fLongRecords[i]; }
 
         unsigned NumDoubleRecords() const { return fDoubleRecords.size(); }
 
         const std::string &GetDoubleRecord(unsigned i) const { return fDoubleRecords[i]; }
 
         /* Wrapper for ezca get with long values. Contains error message handling.
          * Returns ezca error code.*/
         int CA_GetLong(const std::string &name, long& val);
 
         /* Wrapper for ezca get with double values. Contains error message handling
          * Returns ezca error code.*/
         int CA_GetDouble(const std::string &name, double& val);
 
         std::string CA_ErrorString();
 
         const char* CA_RetCode(int ret);
 
         bool Close();
 
      public:
         EpicsInput(const std::string &name = "");
         virtual ~EpicsInput();
 
         virtual bool Read_Init(const dabc::WorkerRef& wrk, const dabc::Command& cmd);
 
         virtual unsigned Read_Size();
         virtual unsigned Read_Complete(dabc::Buffer& buf);
 
         virtual double Read_Timeout() { return fTimeout; }
   };
 
}
 
#endif