Adding Generate method to build a store with identical values (Laurent)

[u/mrichter/AliRoot.git] / SHUTTLE / AliShuttle.h

diff --git a/SHUTTLE/AliShuttle.h b/SHUTTLE/AliShuttle.h
index 93f07a0bf9dc687265a1a7fededdeb437ca1f0df..bd3c6746f3c698e4aff9da6d047013f6c6dc091e 100644 (file)
--- a/SHUTTLE/AliShuttle.h
+++ b/SHUTTLE/AliShuttle.h
@@ -25,11 +25,9 @@ class TObject;
 class AliShuttleConfig;
 class AliShuttleLogbookEntry;
 class AliPreprocessor;
-class AliCDBMetaData;
 class TSQLServer;
-class AliCDBEntry;
-class AliCDBPath;
 class TMutex;
+class TMonaLisaWriter;
 
 class AliShuttle: public AliShuttleInterface {
 public:
@@ -59,28 +57,24 @@ public:
                const char* id, const char* source);
        virtual TList* GetFileSources(Int_t system, const char* detector, const char* id);
        virtual const char* GetRunParameter(const char* lbEntry);
+       virtual AliCDBEntry* GetFromOCDB(const AliCDBPath& path);
+       virtual const char* GetRunType(const char* detCode);
        virtual void Log(const char* detector, const char* message);
 
-       static TString GetMainCDB () {return fgkMainCDB;}
+       //TODO Test only, remove later !
+       void SetProcessDCS(Bool_t process) {fgkProcessDCS = process;}
+       void SetLogbookEntry(AliShuttleLogbookEntry* entry) {fLogbookEntry=entry;}
+
+       Bool_t Connect(Int_t system);
+
        static void SetMainCDB (TString mainCDB) {fgkMainCDB = mainCDB;}
-       static TString GetLocalCDB () {return fgkLocalCDB;}
        static void SetLocalCDB (TString localCDB) {fgkLocalCDB = localCDB;}
 
-       static TString GetMainRefStorage() {return fgkMainRefStorage;}
        static void SetMainRefStorage (TString mainRefStorage) {fgkMainRefStorage = mainRefStorage;}
-       static TString GetLocalRefStorage() {return fgkLocalRefStorage;}
        static void SetLocalRefStorage (TString localRefStorage) {fgkLocalRefStorage = localRefStorage;}
 
-       //TODO Test only, remove later !
-       void SetProcessDCS(Bool_t process) {fgkProcessDCS = process;}
-       void SetLogbookEntry(AliShuttleLogbookEntry* entry) {fLogbookEntry=entry;}
-
        static void SetShuttleTempDir (const char* tmpDir);
-       static const char* GetShuttleTempDir() {return fgkShuttleTempDir.Data();}
        static void SetShuttleLogDir (const char* logDir);
-       static const char* GetShuttleLogDir() {return fgkShuttleLogDir.Data();}
-
-       Bool_t Connect(Int_t system);
 
 private:
        AliShuttle(const AliShuttle& other);
@@ -95,20 +89,9 @@ private:
        Bool_t GetValueSet(const char* host, Int_t port, const char* alias,
                                TObjArray* result, DCSType type);
 
-       const char* GetDAQFileName(const char* detector, const char* id, const char* source);
-       Bool_t RetrieveDAQFile(const char* daqFileName, const char* localFileName);
-       TList* GetDAQFileSources(const char* detector, const char* id);
-       Bool_t UpdateDAQTable();
+       Bool_t RetrieveFile(UInt_t system, const char* daqFileName, const char* localFileName);
 
-       const char* GetDCSFileName(const char* detector, const char* id, const char* source);
-//     Bool_t RetrieveDCSFile(const char* daqFileName const char* localFileName);
-       TList* GetDCSFileSources(const char* detector, const char* id);
-//     Bool_t UpdateDCSTable();
-
-       const char* GetHLTFileName(const char* detector, const char* id, const char* source);
-       Bool_t RetrieveHLTFile(const char* hltFileName, const char* localFileName);
-       TList* GetHLTFileSources(const char* detector, const char* id);
-       Bool_t UpdateHLTTable();
+       Bool_t UpdateTable();
 
        UInt_t WriteToCDB(const char* mainUri, const char* localUri,
                                const AliCDBPath& path, TObject* object, AliCDBMetaData* metaData,
@@ -117,23 +100,20 @@ private:
        Bool_t TryToStoreAgain();
        Bool_t TryToStoreAgain(TString& storageType);
 
-       AliShuttleStatus* ReadShuttleStatus();
-       Bool_t WriteShuttleStatus(AliShuttleStatus* status);
-       Bool_t ContinueProcessing();
-       void UpdateShuttleStatus(AliShuttleStatus::Status newStatus, Bool_t increaseCount = kFALSE);
-       Bool_t UpdateShuttleLogbook(const char* detector, const char* status=0);
+       AliShuttleStatus* ReadShuttleStatus();
+       Bool_t WriteShuttleStatus(AliShuttleStatus* status);
+       Bool_t ContinueProcessing();
+       void UpdateShuttleStatus(AliShuttleStatus::Status newStatus, Bool_t increaseCount = kFALSE);
+       Bool_t UpdateShuttleLogbook(const char* detector, const char* status=0);
        Bool_t SendMail();
 
-       void SetLastAction(const char* action);
+       void SetLastAction(const char* action);
+       
+       void SendMLInfo();
 
-       const AliShuttleConfig* fConfig;        // pointer to configuration object
+       void SetRunType();
 
-       static TString      fgkMainCDB;         // URI of the main (Grid) CDB storage
-       static TString      fgkLocalCDB;                //! URI of the local backup CDB storage
-       static TString      fgkMainRefStorage;  // URI of the main (Grid) REFERENCE storage
-       static TString      fgkLocalRefStorage; // URI of the local REFERENCE storage
-       static TString      fgkShuttleTempDir;  // base path of SHUTTLE temp folder
-       static TString      fgkShuttleLogDir;   // path of SHUTTLE log folder
+       const AliShuttleConfig* fConfig;        // pointer to configuration object
 
        UInt_t fTimeout;        // DCS server connection timeout parameter
        Int_t fRetries;         // Number of DCS server connection retries
@@ -156,6 +136,8 @@ private:
 
        Bool_t fFirstUnprocessed[AliShuttleInterface::kNDetectors];       // array of flags for first unprocessed dets
 
+       TMonaLisaWriter* fMonaLisa;  // ML instance that sends the processing information
+
        //TODO Test only, remove later !
        static Bool_t fgkProcessDCS; // flag to enable DCS archive data processing