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

/**************************************************************************
 * Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
 *                                                                        *
 * Author: The ALICE Off-line Project.                                    *
 * Contributors are mentioned in the code where appropriate.              *
 *                                                                        *
 * Permission to use, copy, modify and distribute this software and its   *
 * documentation strictly for non-commercial purposes is hereby granted   *
 * without fee, provided that the above copyright notice appears in all   *
 * copies and that both the copyright notice and this permission notice   *
 * appear in the supporting documentation. The authors make no claims     *
 * about the suitability of this software for any purpose. It is          *
 * provided "as is" without express or implied warranty.                  *
 **************************************************************************/

/*
 $Log$
 Revision 1.9  2006/08/08 14:19:29  jgrosseo
 Update to shuttle classes (Alberto)

 - Possibility to set the full object's path in the Preprocessor's and
 Shuttle's  Store functions
 - Possibility to extend the object's run validity in the same classes
 ("startValidity" and "validityInfinite" parameters)
 - Implementation of the StoreReferenceData function to store reference
 data in a dedicated CDB storage.

 Revision 1.8  2006/07/21 07:37:20  jgrosseo
 last run is stored after each run

 Revision 1.7  2006/07/20 09:54:40  jgrosseo
 introducing status management: The processing per subdetector is divided into several steps,
 after each step the status is stored on disk. If the system crashes in any of the steps the Shuttle
 can keep track of the number of failures and skips further processing after a certain threshold is
 exceeded. These thresholds can be configured in LDAP.

 Revision 1.6  2006/07/19 10:09:55  jgrosseo
 new configuration, accesst to DAQ FES (Alberto)

 Revision 1.5  2006/07/10 13:01:41  jgrosseo
 enhanced storing of last sucessfully processed run (alberto)

 Revision 1.4  2006/07/04 14:59:57  jgrosseo
 revision of AliDCSValue: Removed wrapper classes, reduced storage size per value by factor 2

 Revision 1.3  2006/06/12 09:11:16  jgrosseo
 coding conventions (Alberto)

 Revision 1.2  2006/06/06 14:26:40  jgrosseo
 o) removed files that were moved to STEER
 o) shuttle updated to follow the new interface (Alberto)

 Revision 1.1  2006/03/07 07:52:34  hristov
 New version (B.Yordanov)

 Revision 1.5  2005/11/21 09:03:48  byordano
 one more print added

 Revision 1.4  2005/11/20 10:12:37  byordano
 comments added to AliShuttleTrigger

 */


// 
// This class is to deal with DAQ LogBook and DAQ "end of run" notification.
// It has severeal two modes:
// 	1) syncrhnized - Collect(), CollectNew() and CollectAll methods
// 	2) asynchronized - Run() - starts listening for DAQ "end of run"
// 		notification by DIM service.
//

#include "AliShuttleTrigger.h"

#include <TSQLServer.h>
#include <TSQLResult.h>
#include <TSQLRow.h>
#include <TObjArray.h>
#include <TSystem.h>

#include "AliLog.h"
#include "AliCDBManager.h"
#include "AliCDBStorage.h"
#include "AliCDBEntry.h"

#include "AliDCSValue.h"
#include "AliShuttleConfig.h"
#include "AliShuttle.h"
#include "DATENotifier.h"

ClassImp(TerminateSignalHandler)

//______________________________________________________________________
TerminateSignalHandler::TerminateSignalHandler(const TerminateSignalHandler& /*other*/):
TSignalHandler(), fTrigger()
{
// copy constructor (not implemented)

}

//______________________________________________________________________
TerminateSignalHandler &TerminateSignalHandler::operator=(const TerminateSignalHandler& /*other*/)
{
// assignment operator (not implemented)

return *this;
}

//______________________________________________________________________________________________
Bool_t TerminateSignalHandler::Notify() 
{
// Sentd terminate command to the Shuttle trigger

	AliInfo("Terminate signal received ...");
	fTrigger->Terminate();

	return kTRUE;
}

//______________________________________________________________________________________________
//______________________________________________________________________________________________

ClassImp(AliShuttleTrigger)

//______________________________________________________________________________________________
AliShuttleTrigger::AliShuttleTrigger(const AliShuttleConfig* config,
		UInt_t timeout, Int_t retries):
	fConfig(config), fShuttle(NULL),
	fNotified(kFALSE), fTerminate(kFALSE), fLastRun(0),
	fMutex(), fCondition(&fMutex),
	fQuitSignalHandler(this, kSigQuit),
	fInterruptSignalHandler(this, kSigInterrupt)
{
	//
	// config - pointer to the AliShuttleConfig object which represents
	// the configuration
	// mainStorage - pointer to AliCDBStorage for the undelying CDBStorage
	// localStorage (local) CDB storage to be used if mainStorage is unavailable
	//

	fShuttle = new AliShuttle(config, timeout, retries);

	gSystem->AddSignalHandler(&fQuitSignalHandler);
	gSystem->AddSignalHandler(&fInterruptSignalHandler);
}


//______________________________________________________________________
AliShuttleTrigger::AliShuttleTrigger(const AliShuttleTrigger& /*other*/):
	TObject(), fConfig(), fShuttle(NULL),
	fNotified(kFALSE), fTerminate(kFALSE), fLastRun(0),
	fMutex(), fCondition(&fMutex),
	fQuitSignalHandler(this, kSigQuit),
	fInterruptSignalHandler(this, kSigInterrupt)

{
// copy constructor (not implemented)

}

//______________________________________________________________________
AliShuttleTrigger &AliShuttleTrigger::operator=(const AliShuttleTrigger& /*other*/)
{
// assignment operator (not implemented)

return *this;
}


//______________________________________________________________________________________________
AliShuttleTrigger::~AliShuttleTrigger() 
{
// destructor

	gSystem->RemoveSignalHandler(&fQuitSignalHandler);
	gSystem->RemoveSignalHandler(&fInterruptSignalHandler);

	delete fShuttle;
}

//______________________________________________________________________________________________
Bool_t AliShuttleTrigger::Notify() {
	//
	// Trigger CollectNew() methods in asynchronized (listen) mode.
	// Usually called automaticly by DATENotifier on "end of run" 
	// notification event.
	//

	fMutex.Lock();

	fNotified = kTRUE;
	fCondition.Signal();

	fMutex.UnLock();

	return kTRUE;
}

//______________________________________________________________________________________________
void AliShuttleTrigger::Terminate() {
	//
	// Stop triggers listen mode and exist from Run()
	// Usually called automaticly by TerminateSignalHandler.
	//

	fTerminate = kTRUE;
	fCondition.Signal();
}

//______________________________________________________________________________________________
void AliShuttleTrigger::Run() {
	//
	// AliShuttleTrigger main loop for asynchronized (listen) mode.
	// It spawns DIM service listener and waits for DAQ "end of run"
	// notification. Calls CollectNew() on notification.
	//

	fTerminate = kFALSE;

	DATENotifier* notifier = new DATENotifier(this, "/DATE/LOGBOOK/UPDATE");

	while (1) {
	
		fMutex.Lock();

		while (!(fNotified || fTerminate)) {
			fCondition.Wait();
		}

		fNotified = kFALSE;
		
		fMutex.UnLock();

		if (fTerminate) {
			AliInfo("Terminated.");
			break;		
		}
	
		CollectNew();
	}

	delete notifier;
}

//______________________________________________________________________________________________
Bool_t AliShuttleTrigger::RetrieveDATEEntries(const char* whereClause,
		TObjArray& entries)
{
// Retrieve start time and end time for all runs in the DAQ logbook
// that aren't processed yet

	TString sqlQuery;
	sqlQuery = Form("select run, time_start, time_end from logbook %s order by run",
		whereClause);

	TSQLServer* aServer;
	TString logbookHost=Form("mysql://%s", fConfig->GetDAQlbHost());

	aServer = TSQLServer::Connect(logbookHost,
			fConfig->GetDAQlbUser(),
			fConfig->GetDAQlbPass());
	if (!aServer) {
		AliError("Can't establish connection to DAQ log book DB!");
		return kFALSE;
	}

	aServer->GetTables("REFSYSLOG");

	TSQLResult* aResult;
	aResult = aServer->Query(sqlQuery);
	if (!aResult) {
		AliError(Form("Can't execute query <%s>!", sqlQuery.Data()));
		delete aServer;
		return kFALSE;
	}

	if (aResult->GetFieldCount() != 3) {
		AliError("Invalid SQL result field number!");
		delete aResult;
		delete aServer;
		return kFALSE;
	}

	TSQLRow* aRow;
	while ((aRow = aResult->Next())) {
		TString runString(aRow->GetField(0), aRow->GetFieldLength(0));
		Int_t run = runString.Atoi();

		TString startTimeString(aRow->GetField(1),
				aRow->GetFieldLength(1));
		Int_t startTime = startTimeString.Atoi();
		if (!startTime) {
			AliWarning(Form("Zero StartTime for run <%d>!", run));
			AliWarning("Going to skip this run!");
			continue;
		}

		TString endTimeString(aRow->GetField(2),
				aRow->GetFieldLength(2));
		Int_t endTime = endTimeString.Atoi();
		if (!endTime) {
			AliWarning(Form("Zero EndTime for run <%d>!", run));
			AliWarning("Going to skip this run!");
			continue;
		}

		if (startTime > endTime) {
			AliWarning(Form("StartTime bigger than EndTime for run <%d>", run));
			AliWarning("Going to skip this run!");
			continue;
		}

		entries.AddLast(new AliShuttleTriggerDATEEntry(run, startTime, endTime));
		delete aRow;
	}

	delete aResult;

	aServer->Close();
	delete aServer;

	entries.SetOwner(1);

	return kTRUE;
}

//______________________________________________________________________________________________
Bool_t AliShuttleTrigger::RetrieveConditionsData(const TObjArray& dateEntries, Bool_t updateLastRun)
{
  // Retrieve conditions data for all runs that aren't processed yet

  Bool_t hasError = kFALSE;

  TIter iter(&dateEntries);
  AliShuttleTriggerDATEEntry* anEntry;

  while ((anEntry = (AliShuttleTriggerDATEEntry*) iter.Next()))
  {
    if (!fShuttle->Process(anEntry->GetRun(),
        anEntry->GetStartTime(),
        anEntry->GetEndTime()))
    {
        hasError = kTRUE;
    }

    if (!hasError && updateLastRun && fLastRun < anEntry->GetRun())
    {
      fLastRun = anEntry->GetRun();
      WriteLastRun();
    }
  }

  return hasError == kFALSE;
}

//______________________________________________________________________________________________
Bool_t AliShuttleTrigger::ReadLastRun()
{
  // reads the last processed run from local CDB

  AliCDBEntry* cdbEntry = AliCDBManager::Instance()->GetStorage(AliShuttle::GetLocalCDB())
        ->Get("/SHUTTLE/SYSTEM/LASTRUN", 0);

  if (cdbEntry)
  {
    TObject* anObject = cdbEntry->GetObject();
    if (anObject == NULL || anObject->IsA() != AliDCSValue::Class())
    {
      AliError("Invalid last run object stored to CDB!");
      return kFALSE;
    }
    AliDCSValue* dcsValue = (AliDCSValue*) anObject;
    fLastRun = dcsValue->GetInt();

    delete cdbEntry;
  }
  else
  {
    AliFatal("No last run number stored. Please set first. Aborting");
    return kFALSE;
  }

  AliInfo(Form("Last run number <%d>", fLastRun));

  return kTRUE;
}

//______________________________________________________________________________________________
Bool_t AliShuttleTrigger::WriteLastRun()
{
  // writes the last succesfully processed run to local CDB

  AliDCSValue lastRunObj(fLastRun, 0);
  AliCDBMetaData metaData;
  AliCDBId cdbID(AliCDBPath("SHUTTLE", "SYSTEM", "LASTRUN"), 0, 0);

  UInt_t result = AliCDBManager::Instance()->GetStorage(AliShuttle::GetLocalCDB())
      ->Put(&lastRunObj, cdbID, &metaData);

  if (!result) {
    AliError("Can't store last run to CDB!");
    return kFALSE;
  }

  return kTRUE;
}

//______________________________________________________________________________________________
Bool_t AliShuttleTrigger::SetNewLastRun(Int_t run)
{
  // sets a new run manually, use with caution!

  fShuttle->Log("SHUTTLE", Form("Setting last run manually to %d", run));

  fLastRun = run;
  return WriteLastRun();
}

//______________________________________________________________________________________________
Bool_t AliShuttleTrigger::Collect(Int_t run)
{
	//
	// Collects conditions date for the given run.
	//

	AliInfo(Form("Collecting conditions data for run <%d> ...", run));

	TString whereClause("where run = ");
	whereClause += run;

	TObjArray dateEntries;
	if (!RetrieveDATEEntries(whereClause, dateEntries)) {
		AliError("Can't retrieve entries from DAQ log book.");
		return kFALSE;
        }

	if (!dateEntries.GetEntriesFast()) {
		AliError(Form("There isn't entry for run <%d> in DAQ log book!",
			run));
		return kFALSE;
	}

	if (dateEntries.GetEntriesFast() > 1) {
		AliError(Form("There is more than one entry for run <%d> in DAQ log book", run));
		return kFALSE;
	}

	if (!RetrieveConditionsData(dateEntries, kFALSE)) {
		AliError("An error occured during conditions data retrieval!");
		return kFALSE;
	}

	return kTRUE;
}

//______________________________________________________________________________________________
Bool_t AliShuttleTrigger::CollectNew()
{
	//
	// Collects conditions data for all new run written to DAQ LogBook.
	//

	AliInfo("Collecting conditions data for new runs ...");

  if (!ReadLastRun())
  {
    AliError("Retrieving of last run failed");
    return kFALSE;
  }

	TString whereClause("where run > ");
	whereClause += fLastRun;

	TObjArray dateEntries;
	if (!RetrieveDATEEntries(whereClause, dateEntries)) {
		AliError("Can't retrieve entries from DAQ log book.");
		return kFALSE;
	}

	if (!RetrieveConditionsData(dateEntries, kTRUE)) {
		AliError("Process of at least one run failed!");
		// return kFALSE;
	}

	return kTRUE;
}

//______________________________________________________________________________________________
Bool_t AliShuttleTrigger::CollectAll()
{
	//
	// Collects conditions data for all run written in DAQ LogBook.
	//

  if (!ReadLastRun())
  {
    AliError("Retrieving of last run failed");
    return kFALSE;
  }

	AliInfo("Collecting conditions data for all runs ...");

	TObjArray dateEntries;
	if (!RetrieveDATEEntries("", dateEntries)) {
		AliError("Can't retrieve entries from DAQ log book.");
		return kFALSE;
	}

	if (!RetrieveConditionsData(dateEntries, kTRUE)) {
		AliError("An error occured during conditions data retrieval!");
		return kFALSE;
	}

	return kTRUE;
}
Commit	Line	Data
d477ad88	1	/**************************************************************************
	2	* Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
	3	* *
	4	* Author: The ALICE Off-line Project. *
	5	* Contributors are mentioned in the code where appropriate. *
	6	* *
	7	* Permission to use, copy, modify and distribute this software and its *
	8	* documentation strictly for non-commercial purposes is hereby granted *
	9	* without fee, provided that the above copyright notice appears in all *
	10	* copies and that both the copyright notice and this permission notice *
	11	* appear in the supporting documentation. The authors make no claims *
	12	* about the suitability of this software for any purpose. It is *
	13	* provided "as is" without express or implied warranty. *
	14	**************************************************************************/
	15
	16	/*
	17	$Log$
4f0ab988	18	Revision 1.9 2006/08/08 14:19:29 jgrosseo
	19	Update to shuttle classes (Alberto)
	20
	21	- Possibility to set the full object's path in the Preprocessor's and
	22	Shuttle's Store functions
	23	- Possibility to extend the object's run validity in the same classes
	24	("startValidity" and "validityInfinite" parameters)
	25	- Implementation of the StoreReferenceData function to store reference
	26	data in a dedicated CDB storage.
	27
84090f85	28	Revision 1.8 2006/07/21 07:37:20 jgrosseo
	29	last run is stored after each run
	30
7bfb2090	31	Revision 1.7 2006/07/20 09:54:40 jgrosseo
	32	introducing status management: The processing per subdetector is divided into several steps,
	33	after each step the status is stored on disk. If the system crashes in any of the steps the Shuttle
	34	can keep track of the number of failures and skips further processing after a certain threshold is
	35	exceeded. These thresholds can be configured in LDAP.
	36
5164a766	37	Revision 1.6 2006/07/19 10:09:55 jgrosseo
	38	new configuration, accesst to DAQ FES (Alberto)
	39
57f50b3c	40	Revision 1.5 2006/07/10 13:01:41 jgrosseo
	41	enhanced storing of last sucessfully processed run (alberto)
	42
a7160fe9	43	Revision 1.4 2006/07/04 14:59:57 jgrosseo
	44	revision of AliDCSValue: Removed wrapper classes, reduced storage size per value by factor 2
	45
45a493ce	46	Revision 1.3 2006/06/12 09:11:16 jgrosseo
	47	coding conventions (Alberto)
	48
58bc3020	49	Revision 1.2 2006/06/06 14:26:40 jgrosseo
	50	o) removed files that were moved to STEER
	51	o) shuttle updated to follow the new interface (Alberto)
	52
b948db8d	53	Revision 1.1 2006/03/07 07:52:34 hristov
	54	New version (B.Yordanov)
	55
d477ad88	56	Revision 1.5 2005/11/21 09:03:48 byordano
	57	one more print added
	58
	59	Revision 1.4 2005/11/20 10:12:37 byordano
	60	comments added to AliShuttleTrigger
	61
	62	*/
	63
	64
	65	//
	66	// This class is to deal with DAQ LogBook and DAQ "end of run" notification.
	67	// It has severeal two modes:
	68	// 1) syncrhnized - Collect(), CollectNew() and CollectAll methods
b948db8d	69	// 2) asynchronized - Run() - starts listening for DAQ "end of run"
d477ad88	70	// notification by DIM service.
	71	//
	72
	73	#include "AliShuttleTrigger.h"
	74
	75	#include <TSQLServer.h>
	76	#include <TSQLResult.h>
	77	#include <TSQLRow.h>
	78	#include <TObjArray.h>
	79	#include <TSystem.h>
	80
	81	#include "AliLog.h"
b948db8d	82	#include "AliCDBManager.h"
d477ad88	83	#include "AliCDBStorage.h"
	84	#include "AliCDBEntry.h"
	85
45a493ce	86	#include "AliDCSValue.h"
d477ad88	87	#include "AliShuttleConfig.h"
	88	#include "AliShuttle.h"
	89	#include "DATENotifier.h"
	90
	91	ClassImp(TerminateSignalHandler)
b948db8d	92
58bc3020	93	//______________________________________________________________________
58bc3020	94	TerminateSignalHandler::TerminateSignalHandler(const TerminateSignalHandler& /other/):
4f0ab988	95	TSignalHandler(), fTrigger()
58bc3020	96	{
	97	// copy constructor (not implemented)
	98
	99	}
	100
	101	//______________________________________________________________________
	102	TerminateSignalHandler &TerminateSignalHandler::operator=(const TerminateSignalHandler& /other/)
	103	{
	104	// assignment operator (not implemented)
	105
	106	return *this;
	107	}
	108
b948db8d	109	//______________________________________________________________________________________________
58bc3020	110	Bool_t TerminateSignalHandler::Notify()
	111	{
	112	// Sentd terminate command to the Shuttle trigger
d477ad88	113
	114	AliInfo("Terminate signal received ...");
	115	fTrigger->Terminate();
	116
	117	return kTRUE;
	118	}
	119
58bc3020	120	//______________________________________________________________________________________________
	121	//______________________________________________________________________________________________
	122
d477ad88	123	ClassImp(AliShuttleTrigger)
b948db8d	124
b948db8d	125	//______________________________________________________________________________________________
d477ad88	126	AliShuttleTrigger::AliShuttleTrigger(const AliShuttleConfig* config,
b948db8d	127	UInt_t timeout, Int_t retries):
b948db8d	128	fConfig(config), fShuttle(NULL),
4f0ab988	129	fNotified(kFALSE), fTerminate(kFALSE), fLastRun(0),
	130	fMutex(), fCondition(&fMutex),
	131	fQuitSignalHandler(this, kSigQuit),
d477ad88	132	fInterruptSignalHandler(this, kSigInterrupt)
	133	{
	134	//
	135	// config - pointer to the AliShuttleConfig object which represents
	136	// the configuration
b948db8d	137	// mainStorage - pointer to AliCDBStorage for the undelying CDBStorage
b948db8d	138	// localStorage (local) CDB storage to be used if mainStorage is unavailable
d477ad88	139	//
d477ad88	140
b948db8d	141	fShuttle = new AliShuttle(config, timeout, retries);
d477ad88	142
	143	gSystem->AddSignalHandler(&fQuitSignalHandler);
	144	gSystem->AddSignalHandler(&fInterruptSignalHandler);
	145	}
	146
58bc3020	147
	148
	149	//______________________________________________________________________
	150	AliShuttleTrigger::AliShuttleTrigger(const AliShuttleTrigger& /other/):
4f0ab988	151	TObject(), fConfig(), fShuttle(NULL),
	152	fNotified(kFALSE), fTerminate(kFALSE), fLastRun(0),
	153	fMutex(), fCondition(&fMutex),
	154	fQuitSignalHandler(this, kSigQuit),
	155	fInterruptSignalHandler(this, kSigInterrupt)
	156
58bc3020	157	{
	158	// copy constructor (not implemented)
	159
	160	}
	161
	162	//______________________________________________________________________
	163	AliShuttleTrigger &AliShuttleTrigger::operator=(const AliShuttleTrigger& /other/)
	164	{
	165	// assignment operator (not implemented)
	166
	167	return *this;
	168	}
	169
	170
	171
	172
	173
b948db8d	174	//______________________________________________________________________________________________
58bc3020	175	AliShuttleTrigger::~AliShuttleTrigger()
	176	{
	177	// destructor
d477ad88	178
	179	gSystem->RemoveSignalHandler(&fQuitSignalHandler);
	180	gSystem->RemoveSignalHandler(&fInterruptSignalHandler);
	181
	182	delete fShuttle;
	183	}
	184
b948db8d	185	//______________________________________________________________________________________________
d477ad88	186	Bool_t AliShuttleTrigger::Notify() {
	187	//
	188	// Trigger CollectNew() methods in asynchronized (listen) mode.
	189	// Usually called automaticly by DATENotifier on "end of run"
	190	// notification event.
	191	//
	192
	193	fMutex.Lock();
	194
	195	fNotified = kTRUE;
	196	fCondition.Signal();
	197
	198	fMutex.UnLock();
	199
	200	return kTRUE;
	201	}
	202
b948db8d	203	//______________________________________________________________________________________________
d477ad88	204	void AliShuttleTrigger::Terminate() {
	205	//
	206	// Stop triggers listen mode and exist from Run()
	207	// Usually called automaticly by TerminateSignalHandler.
	208	//
	209
	210	fTerminate = kTRUE;
	211	fCondition.Signal();
	212	}
	213
b948db8d	214	//______________________________________________________________________________________________
d477ad88	215	void AliShuttleTrigger::Run() {
	216	//
	217	// AliShuttleTrigger main loop for asynchronized (listen) mode.
	218	// It spawns DIM service listener and waits for DAQ "end of run"
	219	// notification. Calls CollectNew() on notification.
	220	//
	221
	222	fTerminate = kFALSE;
	223
	224	DATENotifier* notifier = new DATENotifier(this, "/DATE/LOGBOOK/UPDATE");
	225
	226	while (1) {
	227
	228	fMutex.Lock();
	229
	230	while (!(fNotified \|\| fTerminate)) {
	231	fCondition.Wait();
	232	}
	233
	234	fNotified = kFALSE;
	235
	236	fMutex.UnLock();
	237
	238	if (fTerminate) {
	239	AliInfo("Terminated.");
	240	break;
	241	}
	242
	243	CollectNew();
	244	}
	245
	246	delete notifier;
	247	}
	248
b948db8d	249	//______________________________________________________________________________________________
d477ad88	250	Bool_t AliShuttleTrigger::RetrieveDATEEntries(const char* whereClause,
a7160fe9	251	TObjArray& entries)
58bc3020	252	{
	253	// Retrieve start time and end time for all runs in the DAQ logbook
	254	// that aren't processed yet
d477ad88	255
d477ad88	256	TString sqlQuery;
57f50b3c	257	sqlQuery = Form("select run, time_start, time_end from logbook %s order by run",
57f50b3c	258	whereClause);
d477ad88	259
d477ad88	260	TSQLServer* aServer;
57f50b3c	261	TString logbookHost=Form("mysql://%s", fConfig->GetDAQlbHost());
57f50b3c	262
b948db8d	263	aServer = TSQLServer::Connect(logbookHost,
57f50b3c	264	fConfig->GetDAQlbUser(),
57f50b3c	265	fConfig->GetDAQlbPass());
d477ad88	266	if (!aServer) {
	267	AliError("Can't establish connection to DAQ log book DB!");
	268	return kFALSE;
	269	}
57f50b3c	270
b948db8d	271	aServer->GetTables("REFSYSLOG");
d477ad88	272
	273	TSQLResult* aResult;
	274	aResult = aServer->Query(sqlQuery);
	275	if (!aResult) {
	276	AliError(Form("Can't execute query <%s>!", sqlQuery.Data()));
	277	delete aServer;
	278	return kFALSE;
	279	}
	280
	281	if (aResult->GetFieldCount() != 3) {
	282	AliError("Invalid SQL result field number!");
	283	delete aResult;
	284	delete aServer;
	285	return kFALSE;
	286	}
	287
d477ad88	288	TSQLRow* aRow;
	289	while ((aRow = aResult->Next())) {
	290	TString runString(aRow->GetField(0), aRow->GetFieldLength(0));
	291	Int_t run = runString.Atoi();
	292
	293	TString startTimeString(aRow->GetField(1),
	294	aRow->GetFieldLength(1));
	295	Int_t startTime = startTimeString.Atoi();
	296	if (!startTime) {
	297	AliWarning(Form("Zero StartTime for run <%d>!", run));
	298	AliWarning("Going to skip this run!");
	299	continue;
	300	}
	301
	302	TString endTimeString(aRow->GetField(2),
	303	aRow->GetFieldLength(2));
	304	Int_t endTime = endTimeString.Atoi();
	305	if (!endTime) {
	306	AliWarning(Form("Zero EndTime for run <%d>!", run));
	307	AliWarning("Going to skip this run!");
	308	continue;
	309	}
	310
	311	if (startTime > endTime) {
	312	AliWarning(Form("StartTime bigger than EndTime for run <%d>", run));
	313	AliWarning("Going to skip this run!");
	314	continue;
	315	}
	316
58bc3020	317	entries.AddLast(new AliShuttleTriggerDATEEntry(run, startTime, endTime));
d477ad88	318	delete aRow;
	319	}
	320
	321	delete aResult;
57f50b3c	322
a7160fe9	323	aServer->Close();
d477ad88	324	delete aServer;
	325
	326	entries.SetOwner(1);
	327
	328	return kTRUE;
	329	}
	330
b948db8d	331	//______________________________________________________________________________________________
7bfb2090	332	Bool_t AliShuttleTrigger::RetrieveConditionsData(const TObjArray& dateEntries, Bool_t updateLastRun)
58bc3020	333	{
7bfb2090	334	// Retrieve conditions data for all runs that aren't processed yet
	335
	336	Bool_t hasError = kFALSE;
	337
	338	TIter iter(&dateEntries);
	339	AliShuttleTriggerDATEEntry* anEntry;
	340
	341	while ((anEntry = (AliShuttleTriggerDATEEntry*) iter.Next()))
	342	{
	343	if (!fShuttle->Process(anEntry->GetRun(),
	344	anEntry->GetStartTime(),
	345	anEntry->GetEndTime()))
	346	{
	347	hasError = kTRUE;
	348	}
	349
	350	if (!hasError && updateLastRun && fLastRun < anEntry->GetRun())
	351	{
	352	fLastRun = anEntry->GetRun();
	353	WriteLastRun();
	354	}
	355	}
	356
	357	return hasError == kFALSE;
	358	}
	359
	360	//______________________________________________________________________________________________
	361	Bool_t AliShuttleTrigger::ReadLastRun()
	362	{
	363	// reads the last processed run from local CDB
	364
84090f85	365	AliCDBEntry* cdbEntry = AliCDBManager::Instance()->GetStorage(AliShuttle::GetLocalCDB())
7bfb2090	366	->Get("/SHUTTLE/SYSTEM/LASTRUN", 0);
	367
	368	if (cdbEntry)
	369	{
	370	TObject* anObject = cdbEntry->GetObject();
	371	if (anObject == NULL \|\| anObject->IsA() != AliDCSValue::Class())
	372	{
	373	AliError("Invalid last run object stored to CDB!");
	374	return kFALSE;
	375	}
	376	AliDCSValue* dcsValue = (AliDCSValue*) anObject;
	377	fLastRun = dcsValue->GetInt();
	378
	379	delete cdbEntry;
	380	}
	381	else
	382	{
	383	AliFatal("No last run number stored. Please set first. Aborting");
	384	return kFALSE;
	385	}
	386
	387	AliInfo(Form("Last run number <%d>", fLastRun));
	388
	389	return kTRUE;
	390	}
d477ad88	391
7bfb2090	392	//______________________________________________________________________________________________
	393	Bool_t AliShuttleTrigger::WriteLastRun()
	394	{
	395	// writes the last succesfully processed run to local CDB
	396
	397	AliDCSValue lastRunObj(fLastRun, 0);
	398	AliCDBMetaData metaData;
	399	AliCDBId cdbID(AliCDBPath("SHUTTLE", "SYSTEM", "LASTRUN"), 0, 0);
	400
84090f85	401	UInt_t result = AliCDBManager::Instance()->GetStorage(AliShuttle::GetLocalCDB())
7bfb2090	402	->Put(&lastRunObj, cdbID, &metaData);
	403
	404	if (!result) {
	405	AliError("Can't store last run to CDB!");
	406	return kFALSE;
	407	}
	408
	409	return kTRUE;
	410	}
	411
	412	//______________________________________________________________________________________________
	413	Bool_t AliShuttleTrigger::SetNewLastRun(Int_t run)
	414	{
	415	// sets a new run manually, use with caution!
	416
	417	fShuttle->Log("SHUTTLE", Form("Setting last run manually to %d", run));
	418
	419	fLastRun = run;
	420	return WriteLastRun();
d477ad88	421	}
d477ad88	422
b948db8d	423	//______________________________________________________________________________________________
a7160fe9	424	Bool_t AliShuttleTrigger::Collect(Int_t run)
58bc3020	425	{
d477ad88	426	//
	427	// Collects conditions date for the given run.
	428	//
	429
	430	AliInfo(Form("Collecting conditions data for run <%d> ...", run));
	431
	432	TString whereClause("where run = ");
	433	whereClause += run;
	434
d477ad88	435	TObjArray dateEntries;
a7160fe9	436	if (!RetrieveDATEEntries(whereClause, dateEntries)) {
d477ad88	437	AliError("Can't retrieve entries from DAQ log book.");
	438	return kFALSE;
	439	}
	440
	441	if (!dateEntries.GetEntriesFast()) {
	442	AliError(Form("There isn't entry for run <%d> in DAQ log book!",
	443	run));
	444	return kFALSE;
	445	}
	446
	447	if (dateEntries.GetEntriesFast() > 1) {
	448	AliError(Form("There is more than one entry for run <%d> in DAQ log book", run));
	449	return kFALSE;
	450	}
	451
7bfb2090	452	if (!RetrieveConditionsData(dateEntries, kFALSE)) {
d477ad88	453	AliError("An error occured during conditions data retrieval!");
	454	return kFALSE;
	455	}
	456
	457	return kTRUE;
	458	}
	459
b948db8d	460	//______________________________________________________________________________________________
7bfb2090	461	Bool_t AliShuttleTrigger::CollectNew()
58bc3020	462	{
d477ad88	463	//
	464	// Collects conditions data for all new run written to DAQ LogBook.
	465	//
	466
	467	AliInfo("Collecting conditions data for new runs ...");
	468
7bfb2090	469	if (!ReadLastRun())
	470	{
	471	AliError("Retrieving of last run failed");
	472	return kFALSE;
	473	}
d477ad88	474
d477ad88	475	TString whereClause("where run > ");
7bfb2090	476	whereClause += fLastRun;
d477ad88	477
d477ad88	478	TObjArray dateEntries;
a7160fe9	479	if (!RetrieveDATEEntries(whereClause, dateEntries)) {
d477ad88	480	AliError("Can't retrieve entries from DAQ log book.");
	481	return kFALSE;
	482	}
	483
7bfb2090	484	if (!RetrieveConditionsData(dateEntries, kTRUE)) {
a7160fe9	485	AliError("Process of at least one run failed!");
	486	// return kFALSE;
	487	}
b948db8d	488
d477ad88	489	return kTRUE;
	490	}
	491
b948db8d	492	//______________________________________________________________________________________________
7bfb2090	493	Bool_t AliShuttleTrigger::CollectAll()
58bc3020	494	{
d477ad88	495	//
	496	// Collects conditions data for all run written in DAQ LogBook.
	497	//
	498
7bfb2090	499	if (!ReadLastRun())
	500	{
	501	AliError("Retrieving of last run failed");
	502	return kFALSE;
	503	}
	504
d477ad88	505	AliInfo("Collecting conditions data for all runs ...");
d477ad88	506
d477ad88	507	TObjArray dateEntries;
a7160fe9	508	if (!RetrieveDATEEntries("", dateEntries)) {
d477ad88	509	AliError("Can't retrieve entries from DAQ log book.");
	510	return kFALSE;
	511	}
	512
7bfb2090	513	if (!RetrieveConditionsData(dateEntries, kTRUE)) {
d477ad88	514	AliError("An error occured during conditions data retrieval!");
	515	return kFALSE;
	516	}
	517
	518	return kTRUE;
	519	}
	520