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

#ifndef ALI_SHUTTLE_TRIGGER_H
#define ALI_SHUTTLE_TRIGGER_H

/* Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
 * See cxx source for full Copyright notice                               */

/* $Id$ */

//
// This class is to deal with DAQ LogBook and DAQ end run notification.
// It executes AliShuttle for retrieval of conditions data.
//

#include <TObject.h>
#include <TSysEvtHandler.h>
#include <TMutex.h>
#include <TCondition.h>


class AliCDBStorage;
class AliShuttle;
class AliShuttleConfig;

class AliShuttleTrigger;
class DATENotifier;

class TerminateSignalHandler: public TSignalHandler {
	
	AliShuttleTrigger* fTrigger;
public:
	TerminateSignalHandler(AliShuttleTrigger* trigger, ESignals signal):
		TSignalHandler(signal, kFALSE), fTrigger(trigger) {}

	virtual Bool_t Notify();

	ClassDef(TerminateSignalHandler, 0)
};

class AliShuttleTrigger: public TObject {
public:
	AliShuttleTrigger(const AliShuttleConfig* config,
			AliCDBStorage* storage, UInt_t timeout = 5000,
			Int_t retries = 5);
	~AliShuttleTrigger();

	AliShuttle* GetShuttle() {return fShuttle;}

	Bool_t Collect(Int_t run);
	Bool_t CollectNew();
	Bool_t CollectAll();
	
	virtual Bool_t Notify();
	void Terminate();

	void Run();

private:

	class DATEEntry: public TObject {
		Int_t fRun;
		UInt_t fStartTime;
		UInt_t fEndTime;
	public:
		DATEEntry(Int_t run, UInt_t startTime, UInt_t endTime):
			fRun(run), fStartTime(startTime), fEndTime(endTime) {}

		Int_t GetRun() {return fRun;}
		UInt_t GetStartTime() {return fStartTime;}
		UInt_t GetEndTime() {return fEndTime;}

		ClassDef(DATEEntry, 0)
	};

	Bool_t RetrieveDATEEntries(const char* whereClause, TObjArray& entries,
			Int_t& lastRun);
	Bool_t RetrieveConditionsData(const TObjArray& dateEntries);

	const AliShuttleConfig* fConfig;
	AliCDBStorage* fStorage;

	AliShuttle* fShuttle;

	Bool_t fNotified;
	Bool_t fTerminate;

	TMutex fMutex;
	TCondition fCondition;

	TerminateSignalHandler fQuitSignalHandler;
	TerminateSignalHandler fInterruptSignalHandler;


	ClassDef(AliShuttleTrigger, 0)
};

#endif
Commit	Line	Data
d477ad88	1	#ifndef ALI_SHUTTLE_TRIGGER_H
	2	#define ALI_SHUTTLE_TRIGGER_H
	3
	4	/* Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
	5	* See cxx source for full Copyright notice */
	6
	7	/* $Id$ */
	8
	9	//
	10	// This class is to deal with DAQ LogBook and DAQ end run notification.
	11	// It executes AliShuttle for retrieval of conditions data.
	12	//
	13
	14	#include <TObject.h>
	15	#include <TSysEvtHandler.h>
	16	#include <TMutex.h>
	17	#include <TCondition.h>
	18
	19
	20	class AliCDBStorage;
	21	class AliShuttle;
	22	class AliShuttleConfig;
	23
	24	class AliShuttleTrigger;
	25	class DATENotifier;
	26
	27	class TerminateSignalHandler: public TSignalHandler {
	28
	29	AliShuttleTrigger* fTrigger;
	30	public:
	31	TerminateSignalHandler(AliShuttleTrigger* trigger, ESignals signal):
	32	TSignalHandler(signal, kFALSE), fTrigger(trigger) {}
	33
	34	virtual Bool_t Notify();
	35
	36	ClassDef(TerminateSignalHandler, 0)
	37	};
	38
	39	class AliShuttleTrigger: public TObject {
	40	public:
	41	AliShuttleTrigger(const AliShuttleConfig* config,
	42	AliCDBStorage* storage, UInt_t timeout = 5000,
	43	Int_t retries = 5);
	44	~AliShuttleTrigger();
	45
	46	AliShuttle* GetShuttle() {return fShuttle;}
	47
	48	Bool_t Collect(Int_t run);
	49	Bool_t CollectNew();
	50	Bool_t CollectAll();
	51
	52	virtual Bool_t Notify();
	53	void Terminate();
	54
	55	void Run();
	56
	57	private:
	58
	59	class DATEEntry: public TObject {
	60	Int_t fRun;
	61	UInt_t fStartTime;
	62	UInt_t fEndTime;
	63	public:
	64	DATEEntry(Int_t run, UInt_t startTime, UInt_t endTime):
65	fRun(run), fStartTime(startTime), fEndTime(endTime) {}
66
67	Int_t GetRun() {return fRun;}
68	UInt_t GetStartTime() {return fStartTime;}
69	UInt_t GetEndTime() {return fEndTime;}
70
71	ClassDef(DATEEntry, 0)
72	};
73
74	Bool_t RetrieveDATEEntries(const char* whereClause, TObjArray& entries,
75	Int_t& lastRun);
76	Bool_t RetrieveConditionsData(const TObjArray& dateEntries);
77
78	const AliShuttleConfig* fConfig;
79	AliCDBStorage* fStorage;
80
81	AliShuttle* fShuttle;
82
83	Bool_t fNotified;
84	Bool_t fTerminate;
85
86	TMutex fMutex;
87	TCondition fCondition;
88
89	TerminateSignalHandler fQuitSignalHandler;
90	TerminateSignalHandler fInterruptSignalHandler;
91
92
93	ClassDef(AliShuttleTrigger, 0)
94	};
95
96	#endif