FdUpTimeFileManager.h

Go to the documentation of this file.

#ifndef _fdet_FdUpTimeFileManager_h_
#define _fdet_FdUpTimeFileManager_h_

#include <det/ValidityStamp.h>


class TTree;


struct UpTimePeriod {
  unsigned int fGpsStart = 0;
  unsigned int fGpsStop = 0;
  TFile* fRootFilePtr = nullptr;
  TTree* fDataTree = nullptr;
  TTree* fHeaderTree = nullptr;
  double fFileVersion = 0;
  UpTimePeriod() = default;
  UpTimePeriod(TFile* const f);
  bool operator<(const UpTimePeriod& x) const { return fGpsStart < x.fGpsStart; }
};


namespace fdet {

  class FdUpTimeFileManager : public det::VManager {

  public:
    FdUpTimeFileManager() = default;
    virtual ~FdUpTimeFileManager() = default;

    VMANAGER_GETDATA_NOTFOUND(bool)
    //VMANAGER_GETDATA_NOTFOUND(unsigned long long int)
    VMANAGER_GETDATA_NOTFOUND(std::string)
    VMANAGER_GETDATA_NOTFOUND(std::list<int>)
    VMANAGER_GETDATA_NOTFOUND(std::list<std::pair<int, int> >)
    VMANAGER_GETDATA_NOTFOUND(std::vector<double>)
    VMANAGER_GETDATA_NOTFOUND(std::vector<int>)
    VMANAGER_GETDATA_NOTFOUND(std::vector<std::string>)
    VMANAGER_GETDATA_NOTFOUND(std::vector<bool>)
    VMANAGER_GETDATA_NOTFOUND(std::list<double>)
    VMANAGER_GETDATA_NOTFOUND(std::list<std::string>)
    VMANAGER_GETDATA_NOTFOUND(utl::TabulatedFunction)
    VMANAGER_GETDATA_NOTFOUND(utl::TabulatedFunctionComplexLgAmpPhase)
    VMANAGER_GETDATA_NOTFOUND(std::map<int, utl::TabulatedFunction>)
    VMANAGER_GETDATA_NOTFOUND(std::map<std::string, double>)

    virtual Status GetData(double& returnData,
                           const std::string& componentProperty,
                           const std::string& componentName,
                           const IndexMap& componentIndex) const;

    virtual Status GetData(int& returnData,
                           const std::string& componentProperty,
                           const std::string& componentName,
                           const IndexMap& componentIndex) const
    { return GetOkFlag(returnData, componentProperty, componentName, componentIndex); }

    void Init(const std::string& configLink);

  private:
    void Initialize();

    Status GetOkFlag(int& returnData,
                     const std::string& componentProperty,
                     const std::string& componentName,
                     const IndexMap& componentIndex) const;

    Status GetUpTimeFraction(double& returnData,
                             const std::string& componentProperty,
                             const std::string& componentName,
                             const IndexMap& componentIndex) const;

    Status GetVetoFraction(double& returnData,
                             const std::string& componentProperty,
                             const std::string& componentName,
                             const IndexMap& componentIndex) const;

    Status GetChannelData(double& returnData,
                          const std::string& componentProperty,
                          const std::string& componentName,
                          const IndexMap& componentIndex) const;

    int GetEyeIndex(const IndexMap& componentIndex) const;
    int GetTelIndex(const IndexMap& componentIndex) const;
    int GetChannelIndex(const IndexMap& componentIndex) const;
    bool ReadData() const;

    VMANAGER_GETDATA_HANDLE_DENIED

    int fVerbosity = 0;
    std::vector<std::string> fFileList;
    std::vector<std::string>::const_iterator fRootFileIterator;
    std::vector<UpTimePeriod> fUpTimeVector;
    std::vector<UpTimePeriod>::const_iterator fUpTimeVectorIterator;

    // number of pixels per telescope (as used in AugerUpTime-tree)
    static const unsigned int kNPixelPerTel = 440;

    // data cache
    mutable det::ValidityStamp fDataValidity;
    mutable std::map<int, int> fEyeStatus;
    mutable std::map<int, int> fTelescopeStatus;
    mutable std::map<int, double> fEyeUpTimeFraction;
    mutable std::map<int, double> fFDASVetoFraction;
    mutable std::map<int, double> fCDASVetoFraction;
    mutable std::map<int, double> fTelescopeUpTimeFraction;

    struct ChannelInfo {
      ChannelInfo(unsigned int v, unsigned int t, unsigned int b)
        : fVariance(v), fThreshold(t), fBaseline(b) { }
      unsigned short fVariance = 0;
      unsigned short fThreshold = 0;
      unsigned short fBaseline = 0;
    };

    mutable std::map<int, std::vector<ChannelInfo>> fChannelInfo;
    mutable int fCDASStatus;
    mutable double fCDASUpTimeFraction;
    // index map
    static const double fgSearchMapBinning;
    typedef std::pair<unsigned int, unsigned int> IndexEntry;
    typedef std::pair<IndexEntry, UpTimePeriod> IndexRecord;
    typedef std::vector<IndexRecord> IndexVector;
    typedef IndexVector::const_iterator IndexVectorIterator;
    typedef std::map<unsigned int, IndexVector> Index;
    typedef Index::iterator IndexIterator;
    typedef Index::const_iterator ConstIndexIterator;
    Index fIndexHeadered;
    Index fIndexUnheadered;

  };

}


#endif