X-Git-Url: http://git.uio.no/git/?a=blobdiff_plain;f=SHUTTLE%2FAliShuttle.h;h=3b94944cac748000827529501c60424cd0e8bdf2;hb=171c6702917ceb6c7e688f078876c1b3db3b33e6;hp=0ca82eaee65e958b3ff5b5a468b243fa993b746b;hpb=2c15234ce57fa8b951f1714556a191165bde25c7;p=u%2Fmrichter%2FAliRoot.git diff --git a/SHUTTLE/AliShuttle.h b/SHUTTLE/AliShuttle.h index 0ca82eaee65..3b94944cac7 100644 --- a/SHUTTLE/AliShuttle.h +++ b/SHUTTLE/AliShuttle.h @@ -25,15 +25,15 @@ 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: enum DCSType {kAlias=0, kDP}; + enum TestMode { kNone = 0, kSkipDCS = 1, kErrorDCS = 2, kErrorFXSSources = 4, kErrorFXSFiles = 8, kErrorOCDB = 16, kErrorStorage = 32, kErrorGrid = 64 }; + enum EMailTarget { kDCSEMail = 0, kFXSEMail, kPPEMail }; AliShuttle(const AliShuttleConfig* config, UInt_t timeout = 5000, Int_t retries = 5); virtual ~AliShuttle(); @@ -51,84 +51,96 @@ public: Int_t GetCurrentRun() const; UInt_t GetCurrentStartTime() const; UInt_t GetCurrentEndTime() const; + UInt_t GetCurrentTimeCreated() const; + UInt_t GetCurrentYear() const; + + const char* GetLHCPeriod() const; - virtual UInt_t Store(const AliCDBPath& path, TObject* object, AliCDBMetaData* metaData, + virtual Bool_t Store(const AliCDBPath& path, TObject* object, AliCDBMetaData* metaData, Int_t validityStart = 0, Bool_t validityInfinite = kFALSE); - virtual UInt_t StoreReferenceData(const AliCDBPath& path, TObject* object, AliCDBMetaData* metaData); + virtual Bool_t StoreReferenceData(const AliCDBPath& path, TObject* object, AliCDBMetaData* metaData); + virtual Bool_t StoreReferenceFile(const char* detector, const char* localFile, const char* gridFileName); + virtual Bool_t StoreRunMetadataFile(const char* localFile, const char* gridFileName); virtual const char* GetFile(Int_t system, const char* detector, const char* id, const char* source); - virtual TList* GetFileSources(Int_t system, const char* detector, const char* id); + virtual TList* GetFileSources(Int_t system, const char* detector, const char* id = 0); + virtual TList* GetFileIDs(Int_t system, const char* detector, const char* source); virtual const char* GetRunParameter(const char* lbEntry); + virtual UInt_t GetStartTimeDCSQuery(); + virtual UInt_t GetEndTimeDCSQuery(); + virtual AliCDBEntry* GetFromOCDB(const char* detector, const AliCDBPath& path); + virtual const char* GetRunType(); + virtual Bool_t GetHLTStatus(); + virtual const char* GetTriggerConfiguration(); virtual void Log(const char* detector, const char* message); - static TString GetMainCDB () {return fgkMainCDB;} + void SetLogbookEntry(AliShuttleLogbookEntry* entry) {fLogbookEntry=entry;} + + void SetTestMode(TestMode testMode) { fTestMode = testMode; } + void SetReadTestModeFromLog(Bool_t flag) { fReadTestMode = flag; } + + 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 const char* GetShuttleTempDir() {return fgkShuttleTempDir;} - - Bool_t Connect(Int_t system); + static void SetShuttleTempDir (const char* tmpDir); + static void SetShuttleLogDir (const char* logDir); private: AliShuttle(const AliShuttle& other); AliShuttle& operator= (const AliShuttle& other); - UInt_t ProcessCurrentDetector(); + Int_t ProcessCurrentDetector(); AliShuttleLogbookEntry* QueryRunParameters(Int_t run); Bool_t QueryShuttleLogbook(const char* whereClause, TObjArray& entries); + void CountOpenRuns(); Bool_t RetrieveConditionsData(const TObjArray& shuttleLogbookEntries); - 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(); - - 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); - - const char* GetHLTFileName(const char* detector, const char* id, const char* source); -// Bool_t RetrieveHLTFile(const char* daqFileName, const char* localFileName; - TList* GetHLTFileSources(const char* detector, const char* id); - - UInt_t WriteToCDB(const char* mainUri, const char* localUri, - const AliCDBPath& path, TObject* object, AliCDBMetaData* metaData, - Int_t validityStart = 0, Bool_t validityInfinite = kFALSE); - - 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); - - void SetLastAction(const char* action); + TMap* GetValueSet(const char* host, Int_t port, const TSeqCollection* entries, + DCSType type, Int_t valueSet); + + Bool_t RetrieveFile(UInt_t system, const char* daqFileName, const char* localFileName); + + Bool_t UpdateTable(); + Bool_t UpdateTableSkippedCase(const char* detector="ALL"); + Bool_t UpdateTableFailCase(); + + Bool_t StoreLocally(const TString& localUri, const AliCDBPath& path, TObject* object, + AliCDBMetaData* metaData, Int_t validityStart = 0, Bool_t validityInfinite = kFALSE); + + Bool_t StoreOCDB(); + Int_t StoreOCDB(const TString& uri); + Bool_t CopyFileLocally(const char* localFile, const TString& target); + Bool_t CopyFilesToGrid(const char* type); + void CleanLocalStorage(const TString& uri); + Bool_t CleanReferenceStorage(const char* detector); + void RemoveFile(const char* filename); + const char* GetRefFilePrefix(const char* base, const char* detector); + + 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(EMailTarget target, Int_t system = -1); + Int_t GetMem(Int_t pid); + + TString GetLogFileName(const char* detector) const; + + void SetLastAction(const char* action); + + void SendAlive(); + void SendMLDetInfo(); + void SendMLRunInfo(const char* status); + virtual Bool_t TouchFile(); const AliShuttleConfig* fConfig; // pointer to configuration object - 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 const char* fgkShuttleTempDir; // base path of SHUTTLE temp folder - static const char* fgkShuttleLogDir; // path of SHUTTLE log folder - UInt_t fTimeout; // DCS server connection timeout parameter Int_t fRetries; // Number of DCS server connection retries @@ -136,13 +148,14 @@ private: AliShuttleLogbookEntry* fLogbookEntry; //! current Shuttle logbook entry TString fCurrentDetector; // current detector + Bool_t fFirstProcessing; // processing this detector the first time in this run TSQLServer *fServer[4]; // pointer to the three FXS + Run & Shuttle logbook servers Bool_t fFXSCalled[3]; // FXS call status TList fFXSlist[3]; // List of files retrieved from each FXS + Int_t fFXSError; // Variable to keep track of any FXS errors; contains -1 for no error, kDAQ, kDCS, kHLT otherwise AliCDBEntry* fStatusEntry; // last CDB entry containing a AliShuttleStatus retrieved - Bool_t fGridError; // Grid storage error flag TMutex* fMonitoringMutex; // mutex to lock the monitoring class members UInt_t fLastActionTime; // time of last action for monitoring @@ -150,8 +163,12 @@ private: Bool_t fFirstUnprocessed[AliShuttleInterface::kNDetectors]; // array of flags for first unprocessed dets - //TODO Test only, remove later ! - static Bool_t fgkProcessDCS; // flag to enable DCS archive data processing + TMonaLisaWriter* fMonaLisa; // ML instance that sends the processing information + + TestMode fTestMode; // sets test mode flags, that e.g. simulate a dcs error etc. + Bool_t fReadTestMode; // Reads the test mode from the log entry of the given run (only for test) + + Bool_t fOutputRedirected; // is the output redirected to a file ClassDef(AliShuttle, 0); };