]> git.uio.no Git - u/mrichter/AliRoot.git/blobdiff - SHUTTLE/AliShuttleConfig.h
AliDCSClient "multiSplit" option added in the DCS configuration
[u/mrichter/AliRoot.git] / SHUTTLE / AliShuttleConfig.h
index 7d3477b5d1e8e8a947e44af327713722adef623c..7f0bf23771d0d5f2068c49b3d0c8f83d4e0fc0c1 100644 (file)
@@ -35,6 +35,8 @@ public:
        const char* GetDAQlbPass() const {return fDAQlbPass.Data();}
        const char* GetDAQlbDB() const {return fDAQlbDB.Data();}
        const char* GetDAQlbTable() const {return fDAQlbTable.Data();}
+       const char* GetShuttlelbTable() const {return fShuttlelbTable.Data();}
+       const char* GetRunTypelbTable() const {return fRunTypelbTable.Data();}
 
        const char* GetFXSHost(Int_t system) const {return fFXSHost[system].Data();}
        UInt_t      GetFXSPort(Int_t system) const {return fFXSPort[system];}
@@ -51,14 +53,24 @@ public:
        Int_t GetMaxRetries() const { return fMaxRetries; }
 
        Int_t GetPPTimeOut() const { return fPPTimeOut; }
+       Int_t GetPPMaxMem() const { return fPPMaxMem; }
 
-  const TObjArray* GetDetectors() const;
+       const TObjArray* GetDetectors() const;
 
        Bool_t HasDetector(const char* detector) const;
-       const char* GetDCSHost(const char* detector) const;
-       Int_t GetDCSPort(const char* detector) const;
-       const TObjArray* GetDCSAliases(const char* detector) const;
-       const TObjArray* GetDCSDataPoints(const char* detector) const;
+       
+       Int_t GetNServers(const char* detector) const;
+       
+       const char* GetDCSHost(const char* detector, Int_t iServ) const;
+       Int_t GetDCSPort(const char* detector, Int_t iServ) const;
+       
+       Int_t GetMultiSplit(const char* detector, Int_t iServ) const;
+       
+       const TObjArray* GetDCSAliases(const char* detector, Int_t iServ) const;
+       const TObjArray* GetDCSDataPoints(const char* detector, Int_t iServ) const;
+       const TObjArray* GetCompactDCSAliases(const char* detector, Int_t iServ) const;
+       const TObjArray* GetCompactDCSDataPoints(const char* detector, Int_t iServ) const;
+       
        const TObjArray* GetResponsibles(const char* detector) const;
        Bool_t StrictRunOrder(const char* detector) const;
 
@@ -71,42 +83,84 @@ public:
 
 private:
 
-       class AliShuttleConfigHolder: public TObject {
+       class AliShuttleDCSConfigHolder: public TObject {
        public:
-               AliShuttleConfigHolder(const TLDAPEntry* entry);
-               ~AliShuttleConfigHolder();
-
-               const char* GetDetector() const {return fDetector.Data();}
-               const char* GetDCSHost() const {return fDCSHost.Data();}
+               AliShuttleDCSConfigHolder(const TLDAPEntry* entry);
+               ~AliShuttleDCSConfigHolder();
+               
+               const char* GetDCSHost() const {return fDCSHost;}
                Int_t GetDCSPort() const {return fDCSPort;}
+               Int_t GetMultiSplit() const {return fMultiSplit;}
+               
                const TObjArray* GetDCSAliases() const {return fDCSAliases;}
                const TObjArray* GetDCSDataPoints() const {return fDCSDataPoints;}
-               const TObjArray* GetResponsibles() const {return fResponsibles;}
+               const TObjArray* GetCompactDCSAliases() const {return fDCSAliasesComp;}
+               const TObjArray* GetCompactDCSDataPoints() const {return fDCSDataPointsComp;}
+               
+               void ExpandAndAdd(TObjArray* target, const char* entry);
+               Bool_t IsValid() const {return fIsValid;}
 
+       private:
+               AliShuttleDCSConfigHolder(const AliShuttleDCSConfigHolder& other);  // not implemented
+               AliShuttleDCSConfigHolder& operator= (const AliShuttleDCSConfigHolder& other);  // not implemented
+
+               TString fDCSHost;       // Host name of the DCS server
+               Int_t   fDCSPort;       // port of the DCS server
+               Int_t   fMultiSplit;     // N. of DPs to be queried in each query chunk
+               TObjArray* fDCSAliases; // List of DCS aliases to be retrieved
+               TObjArray* fDCSDataPoints;     // List of DCS data points to be retrieved
+               TObjArray* fDCSAliasesComp;    // Compact list of DCS aliases to be printed
+               TObjArray* fDCSDataPointsComp; // Compact list of DCS data points to be printed
+               Bool_t  fIsValid;              // flag for the validity of the configuration
+
+               ClassDef(AliShuttleDCSConfigHolder, 0);
+       };
+
+       class AliShuttleDetConfigHolder: public TObject {
+       public:
+               AliShuttleDetConfigHolder(const TLDAPEntry* entry);
+               ~AliShuttleDetConfigHolder();
+
+               const char* GetDetector() const {return fDetector.Data();}
+               const TObjArray* GetDCSConfig() const {return fDCSConfig;}
+               void AddDCSConfig(AliShuttleDCSConfigHolder* holder);
+
+               Int_t GetNServers() const {return fDCSConfig ? fDCSConfig->GetEntries() : 0;}
+               
+               const char* GetDCSHost(Int_t iServ) const;
+               Int_t GetDCSPort(Int_t iServ) const;
+               Int_t GetMultiSplit(Int_t iServ) const;
+               
+               const TObjArray* GetDCSAliases(Int_t iServ) const;
+               const TObjArray* GetDCSDataPoints(Int_t iServ) const;
+               const TObjArray* GetCompactDCSAliases(Int_t iServ) const;
+               const TObjArray* GetCompactDCSDataPoints(Int_t iServ) const;
+               
+               const TObjArray* GetResponsibles() const {return fResponsibles;}                
                Bool_t IsValid() const {return fIsValid;}
                Bool_t SkipDCSQuery() const {return fSkipDCSQuery;}
                Bool_t StrictRunOrder() const {return fStrictRunOrder;}
 
-               void ExpandAndAdd(TObjArray* target, const char* entry);
-
        private:
+               AliShuttleDetConfigHolder(const AliShuttleDetConfigHolder& other);  // not implemented
+               AliShuttleDetConfigHolder& operator= (const AliShuttleDetConfigHolder& other);  // not implemented
+
                TString fDetector;      // Detector name
-               TString fDCSHost;       // Host name of the DCS server
-               Int_t   fDCSPort;       // port of the DCS server
-               TObjArray* fDCSAliases; // List of DCS aliases to be retrieved
-               TObjArray* fDCSDataPoints; // List of DCS data points to be retrieved
+               TObjArray* fDCSConfig;  // Array of DCS configuration objects (AliShuttleDCSConfigHolder)
                TObjArray* fResponsibles; // List of email addresses of the detector's responsible(s)
                Bool_t fIsValid;        // flag for the validity of the configuration
                Bool_t fSkipDCSQuery;   // flag - if TRUE (-> DCS config empty) skip DCS archive data query
                Bool_t fStrictRunOrder; // flag - if TRUE connect data in a strict run ordering
 
-
-               ClassDef(AliShuttleConfigHolder, 0);
+               ClassDef(AliShuttleDetConfigHolder, 0);
        };
 
 
-       Bool_t fIsValid;                //! flag for the validity of the configuration
-
+       UInt_t SetGlobalConfig(TList* globalList);
+       UInt_t SetSysConfig(TList* sysList);
+       UInt_t SetDetConfig(TList* detList, TList* dcsList);
+       UInt_t SetHostConfig(TList* hostList);
+       
        TString fConfigHost;            //! Host of the Shuttle configuration LDAP server
 
        TString fDAQlbHost;             //! Host of the DAQ logbook MySQL Server
@@ -114,7 +168,9 @@ private:
        TString fDAQlbUser;             //! username of the DAQ logbook MySQL Server
        TString fDAQlbPass;             //! password of the DAQ logbook MySQL Server
        TString fDAQlbDB;               //! DB name of the DAQ logbook MySQL Server
-       TString fDAQlbTable;            //! Table name of the DAQ logbook MySQL Server
+       TString fDAQlbTable;            //! Table name of the DAQ logbook 
+       TString fShuttlelbTable;        //! Table name of the Shuttle logbook
+       TString fRunTypelbTable;        //! Table name of the Run typr logbook
 
        TString fFXSHost[3];            //! Host of the [DAQ, DCS, HLT] File eXchange Server
        UInt_t  fFXSPort[3];            //! Port of the [DAQ, DCS, HLT] File eXchange Server
@@ -130,7 +186,8 @@ private:
 
        Int_t fMaxRetries;        // number of retries of a failed preprocessor
 
-       Int_t fPPTimeOut;         // timeout until a preprocessor is canceled
+       Int_t fPPTimeOut;         // timeout until a preprocessor is killed
+       Int_t fPPMaxMem;          // maximum allowed memory until a preprocessor is killed
 
        TMap fDetectorMap;              //! Map of the detector-by-detector configuration
        TObjArray fDetectorList;        //! List of detectors with valid configuration
@@ -138,6 +195,7 @@ private:
        TString fShuttleInstanceHost;   //! Instance of the SHUTTLE
        TObjArray fProcessedDetectors;  //! list of the detector to be processed by this machine
        Bool_t fProcessAll;             //! flag indicating that all detectors will be processed
+       Bool_t fIsValid;                //! flag for the validity of the configuration
 
        ClassDef(AliShuttleConfig, 0);
 };