QApolloDbBase.hh

Go to the documentation of this file.

#ifndef _QAPOLLO_DB_BASE_HH_
#define _QAPOLLO_DB_BASE_HH_

#include <string>

#include "QDbDefs.hh"
#include "QCuore.hh"
#include "QDb.hh"
#include "QApolloDbCache.hh"

class QApolloDbBase : public QDb {
public:

  virtual ~QApolloDbBase();

private:
  
  enum EnvVarName_t {
    DbHost_s,
    DbPort_s,
    DbUser_s,
    DbPwd_s,
    DbName_s
  };
  
  enum DbMode_t {
    UndefMode_s  = 0,       
    MasterMode_s = 1L << 1, 
    TuningMode_s = 1L << 2, 
    GuiMode_s    = 1L << 3, 
    ReadMode_s   = 1L << 4  
  };

  QApolloDbBase(); 

  
  static QApolloDbBase& Get();

  inline bool Undefined() const { return (UndefMode_s == fMode); }

  bool Reset(unsigned short settingsBasket, unsigned int runNumber);

  bool Reset(unsigned short settingsBasket);

  bool Reset();

  bool ResetRun();
  


  const std::map<unsigned short,std::string>& CrateMap() const 
  { return fActiveCrates; }
  

   short GetListOfChannels(std::vector<unsigned short>& chList,
                           unsigned short profileId = 0);
   
  unsigned short GetMapping(std::map<unsigned short, QDaqChannel>& cMap);

  unsigned short GetActiveChannels(std::map<unsigned short, QDaqChannel>& cMap,
                                   QDaqChannel::SettingsType_t what);

  int GetBoards(unsigned short                        crateId, 
                std::map<unsigned short,std::string>& boards );

  int GetActiveChannels(unsigned short              crateId, 
                        unsigned short              slot, 
                        QDaqChannel::SettingsType_t what,
                        std::vector<QDaqChannel>&   v );

  void GetListOfTriggers(unsigned short lg, std::vector<std::string>& trgList);

  const QVdt& GetTrgParameter(unsigned short     trgIndex,
                              const std::string& par_name, 
                              unsigned short     lg=0);
  const std::map<std::string,QVdt>& GetTrgParameters(unsigned short trgIndex, 
                                                     unsigned short lg);
   
  bool Dump(unsigned short crateId, bool dump);

  inline unsigned int GetCurrentRunNumber() const {return gRunNumber;}

  inline unsigned short GetCurrentProfile() const { return fProfile; }

  inline RunType GetCurrentRunType() const { return fRunType; }

   unsigned int GetPulserPeriod();

  void GetRunTypes(std::map<unsigned short, std::string>& runTypes);

  void GetRuns(std::vector<unsigned int>& runs);

   unsigned int GetLastRun();

   void 
   GetSettingsBaskets(unsigned short                            howMany,
                      std::map<std::string,std::vector<QVdt> >& basketsMap);

   unsigned short 
   GetSettingsBasketIds(std::vector<unsigned short>& baskets);

   unsigned short GetSettingsBasket(unsigned short id, std::string& comment);



  void UpdateStart(unsigned short shifterSet);

  void UpdateStop(StopStatus_t stopStatus, unsigned short shifterSet, 
                  unsigned short nFiles);

  
  void ChangeDefaultSettingsBasket(unsigned short newDefault);

   void InsertStartComments(const std::string& comment);

   void InsertStopComments(const std::string& comment);


  void Clear();

  void Init();

  void GuessCurrentRun();

  void InsertNewRun();

  void UndoInsertRun();

   void SanitizeRunsTable();

  bool LoadHardwareProfile(unsigned short crateId);

  void Load(QDaqChannel::SettingsType_t what);

  void Load(QDaqChannel::SettingsType_t what, unsigned short crateId);

  void LoadHwSettings(QDaqChannel::SettingsType_t setType, 
                      unsigned short              crateId);

  void LoadTriggerSettings(unsigned short crateId);

  void LoadDefaultTriggerSettings();

  static std::string GetDbEnv(EnvVarName_t name);

   std::string EscapeString(const std::string& inputString,
                            const char&        toBeEscaped,
                            const char&        escapeChar) const;

   std::string CleanString(const std::string& inputString) const;

   RunType String2RunType(const std::string& s) const;

  static bool gCanWrite;
  static unsigned int gRunNumber;
  static unsigned short gSettingsBasket;
  unsigned short fProfile;
  unsigned short fDaqSet;
  unsigned short fTrgSet;
  unsigned short fFESet;
  unsigned short fBesSet;
  RunType fRunType;
  unsigned short fPulserSet;
  std::map<unsigned short,std::string> fActiveCrates;
  std::map<unsigned short,unsigned short> fActiveChannels;
  std::vector<unsigned short> fLoadedHwCrates;
  std::vector<unsigned short> fLoadedTrgCrates;
  std::vector<unsigned short> fLoadedDaqCrates;
  std::vector<unsigned short> fLoadedBesCrates;
  std::vector<unsigned short> fLoadedFECrates;
  std::vector<unsigned short> fLoadedPulserCrates;
  QApolloDbCache fCache;

  unsigned short fMode;

  bool fRunningMode;

  /* lower bound (excluded) for run numbers allowed for a given detector */
   const unsigned int fLowerRunExcluded;
  /* upper bound (excluded) for run numbers allowed for a given detector */
   const unsigned int fUpperRunExcluded;

  friend class QApolloDb;
  friend class QApolloDbServer;
  friend class QApolloDbGui;
  friend class QApolloDbDaq;
  friend class QApolloDbSlow;
};
                
#endif // _QAPOLLO_DB_BASE_HH_

---