[u/mrichter/AliRoot.git] / TRIGGER / AliTRIPreprocessor.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.                  *
 **************************************************************************/

/* $Id$*/

// Trigger preprocessor class. 
// According to the TriggerDetectorMask read from the logbook_trigger_clusters
// DAQ table, the triggering detectors are identified, and the 
// corresponding procedure is called.
// Data are stored in the OCDB, in /TRIGGER/<DET>/<level3>, where
// <DET> correspond to the triggering detector,
// and <level3> is defined in the detector procedure

#include "AliTRIPreprocessor.h"

#include "AliCDBMetaData.h"
#include "AliCDBEntry.h"
#include "AliLog.h"
#include "AliITSTriggerConditions.h"

#include "AliTOFFEEReader.h"
#include "AliTOFTriggerMask.h"
          
#include <TTimeStamp.h>
#include <TObjString.h>
#include <TList.h>
#include <TROOT.h>
#include <TSystem.h>

ClassImp(AliTRIPreprocessor)

// names of detectors/systems in the DETECTORS_MAP in /date/db/detCodes.h
const char* AliTRIPreprocessor::fgkDetectorsMapName[AliTRIPreprocessor::kNDetectorsMap] = {"SPD"/*0*/, "SDD"/*1*/, "SSD"/*2*/, "TPC"/*3*/, "TRD"/*4*/, 
									       "TOF"/*5*/, "HMP"/*6*/, "PHS"/*7*/, "CPV"/*8*/, "PMD"/*9*/, 
									       "MCH"/*10*/,"MTR"/*11*/,"FMD"/*12*/,"T00"/*13*/,"V00"/*14*/, 
									       "ZDC"/*15*/,"ACO"/*16*/,"TRI"/*17*/,"EMC"/*18*/,"TST"/*19*/, 
									       ""/*20*/,   ""/*21*/,   ""/*22*/,   ""/*23*/,   ""/*24*/,   
									       ""/*25*/,   ""/*26*/,   ""/*27*/,   ""/*28*/,   "GRP"/*29*/, 
									       "HLT"/*30*/};

//______________________________________________________________________________________________
AliTRIPreprocessor::AliTRIPreprocessor(AliShuttleInterface* shuttle) :
  AliPreprocessor("TRI", shuttle),
  fShuttle(shuttle)

{
	//
	// constructor
	//
	
	AddRunType("PHYSICS");
	AddRunType("STANDALONE_PULSER");
}

//______________________________________________________________________________________________
AliTRIPreprocessor::~AliTRIPreprocessor()
{
	//
	// destructor
	//
}

//______________________________________________________________________________________________
void AliTRIPreprocessor::Initialize(Int_t run, UInt_t startTime,
	UInt_t endTime)
{

	//
	// Initialize preprocessor
	//

	AliPreprocessor::Initialize(run, startTime, endTime);

	Log(Form("\n\tRun %d \n\tStartTime %s \n\tEndTime %s", run,
		TTimeStamp(startTime).AsString(),
		TTimeStamp(endTime).AsString()));

}

//______________________________________________________________________________________________
Bool_t AliTRIPreprocessor::ProcessDCS()
{
	//
	// DCS data are never needed
	//
	
	return kFALSE;
}

//______________________________________________________________________________________________
UInt_t AliTRIPreprocessor::Process(TMap* /*dcsAliasMap*/)
{

	// Procees function:
	// After reading the TriggerDetectorMask, the
	// corresponding triggering detector procedures to 
	// process the trigger data are called.

	typedef Short_t (AliTRIPreprocessor::*AliProcessTriggerData)();
	const AliProcessTriggerData processTriggerDataArray[AliTRIPreprocessor::kNDetectorsMap]= { 
		&AliTRIPreprocessor::ProcessSPDTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessTOFTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData,
		&AliTRIPreprocessor::ProcessEmptyTriggerData}; 


	// getting the list of triggering detectors from DAQ logbook

	TString triggerDetectorMask = (TString)GetTriggerDetectorMask();
	Int_t result=0;
	if (!triggerDetectorMask.IsNull()){
		Int_t length = triggerDetectorMask.Length();
		Log(Form("mask = %s", triggerDetectorMask.Data()));
		  for (Int_t i = 0; i<length; i++){
			AliDebug(2,Form("%d-th bit = %c in index %d",i,triggerDetectorMask[length-1-i],length-1-i));
			if (triggerDetectorMask[length-1-i] == '1'){
				Log("****************************************");
				Log(Form("Processing Trigger data for %s",fgkDetectorsMapName[i]));
				Log("****************************************");
			       
				result+=(this->*processTriggerDataArray[i])();
			}
		}
	}

	// result should be 0 to end successfully

	return result;

}
//______________________________________________________________________________________________
Short_t AliTRIPreprocessor::ProcessSPDTriggerData() 
{
	//
	// Processing SPD Trigger Data
	//
	
	Log("************** Processing SPD Trigger data... **************");

	// Read new conditions from dcs fxs
	AliITSTriggerConditions* newCond = new AliITSTriggerConditions();
	TString fxsID = "pit_conditions";
	TList* list = GetFileSources(kDCS, fxsID.Data());
	if (!list) {
		AliError("FXS file not found.");
		return 1;
	}
	UInt_t nFiles = 0;
	while (list->At(nFiles)!=NULL) {
		TObjString* fileNameEntry = (TObjString*) list->At(nFiles);
		TString fileName = GetFile(kDCS, fxsID.Data(), fileNameEntry->GetString().Data());
		if (fileName.IsNull()) {
			Log(Form("GetFile failed to retrieve file %s.",fileNameEntry->GetString().Data()));
			return 1;
		}
		if (nFiles==0) newCond->ReadFromTextFile(fileName.Data());
		nFiles++;
	}
	if (nFiles!=1) {
		AliWarning(Form("Found %d files with id %s (expected exactly 1).",nFiles,fxsID.Data()));
	}
	
	// Read old conditions from ocdb
	AliITSTriggerConditions* oldCond = NULL;
	AliCDBEntry* pitCond = GetFromOCDB("SPD", "PITConditions");
	if (pitCond) {
		oldCond = (AliITSTriggerConditions*) pitCond->GetObject();
		if (!oldCond) {
			AliError("AliCDBEntry::GetObject() returned NULL.");
			return 1;
		}
	}
	else {
		Log("Old conditions not found in database.");
	}
	
	// Do we need to update db?
	Bool_t doUpdate = kTRUE;
	if (oldCond) {
		// compare to see if there were any changes...
		if (newCond->IsEqualTo(oldCond)) {
			Log("Old conditions equal to new conditions. Do nothing.");
			doUpdate = kFALSE;
		}
	}
	
	if (doUpdate) {
		// store new conditions in ocdb
		AliCDBMetaData metaData;
		metaData.SetResponsible("Henrik Tydesjo");
		metaData.SetComment("Created by Trigger PreProcessor");
		if (!Store("SPD", "PITConditions", newCond, &metaData, 0, kTRUE)) {
			Log("Failed to store conditions data.");
			return 1;
		}
		Log("Database updated.");
	}
	
	delete newCond;
	
	Log("************************* ...done.*************************");

	return 0; // 0 means success
	
}
//______________________________________________________________________________________________
Short_t AliTRIPreprocessor::ProcessTOFTriggerData() 
{
	//
	// Processing TOF Trigger Data
	//

	Log("************** Processing TOF Trigger data... **************");

	const char * nameFile = GetFile(kDCS,"TofFeeLightMap", ""); 
	AliInfo(Form("toffeeLight file name = %s",nameFile));
	if (nameFile == NULL) {
	  return 1;
	} 
	AliTOFFEEReader feeReader;
	feeReader.LoadFEElightConfig(nameFile);
	feeReader.ParseFEElightConfig();
	AliTOFTriggerMask triggerMask;
	triggerMask.SetTriggerMaskArray(feeReader.GetTriggerMaskArray());

	AliCDBMetaData metaData;
	metaData.SetBeamPeriod(0);
	metaData.SetResponsible("Roberto Preghenella");
	metaData.SetComment("TOF trigger mask");
	if (!Store("TOF", "TriggerMask", &triggerMask, &metaData, 0, kTRUE)) {
	  Log("error while storing TriggerMask object");
	  return 1;
	}
	Log("TriggerMask object successfully stored");

	Log("************************* ...done.*************************");
	return 0;
}
//______________________________________________________________________________________________
Short_t AliTRIPreprocessor::ProcessEmptyTriggerData() 
{
	//
	// Processing TOF Trigger Data
	//

	Log("************** Trigger data Processing not yet implemented **************");
	return 0;
}
Commit	Line	Data
b48d2542	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	/* $Id$*/
	17
	18	// Trigger preprocessor class.
	19	// According to the TriggerDetectorMask read from the logbook_trigger_clusters
	20	// DAQ table, the triggering detectors are identified, and the
	21	// corresponding procedure is called.
	22	// Data are stored in the OCDB, in /TRIGGER/<DET>/<level3>, where
	23	// <DET> correspond to the triggering detector,
	24	// and <level3> is defined in the detector procedure
	25
	26	#include "AliTRIPreprocessor.h"
	27
	28	#include "AliCDBMetaData.h"
	29	#include "AliCDBEntry.h"
	30	#include "AliLog.h"
	31	#include "AliITSTriggerConditions.h"
15129f36	32
	33	#include "AliTOFFEEReader.h"
	34	#include "AliTOFTriggerMask.h"
b48d2542	35
	36	#include <TTimeStamp.h>
	37	#include <TObjString.h>
	38	#include <TList.h>
	39	#include <TROOT.h>
	40	#include <TSystem.h>
	41
	42	ClassImp(AliTRIPreprocessor)
	43
	44	// names of detectors/systems in the DETECTORS_MAP in /date/db/detCodes.h
	45	const char* AliTRIPreprocessor::fgkDetectorsMapName[AliTRIPreprocessor::kNDetectorsMap] = {"SPD"/0/, "SDD"/1/, "SSD"/2/, "TPC"/3/, "TRD"/4/,
	46	"TOF"/5/, "HMP"/6/, "PHS"/7/, "CPV"/8/, "PMD"/9/,
	47	"MCH"/10/,"MTR"/11/,"FMD"/12/,"T00"/13/,"V00"/14/,
	48	"ZDC"/15/,"ACO"/16/,"TRI"/17/,"EMC"/18/,"TST"/19/,
	49	""/20/, ""/21/, ""/22/, ""/23/, ""/24/,
	50	""/25/, ""/26/, ""/27/, ""/28/, "GRP"/29/,
	51	"HLT"/30/};
	52
	53	//______________________________________________________________________________________________
	54	AliTRIPreprocessor::AliTRIPreprocessor(AliShuttleInterface* shuttle) :
	55	AliPreprocessor("TRI", shuttle),
	56	fShuttle(shuttle)
	57
	58	{
	59	//
	60	// constructor
	61	//
	62
	63	AddRunType("PHYSICS");
82abc1df	64	AddRunType("STANDALONE_PULSER");
b48d2542	65	}
	66
	67	//______________________________________________________________________________________________
	68	AliTRIPreprocessor::~AliTRIPreprocessor()
	69	{
	70	//
	71	// destructor
	72	//
	73	}
	74
	75	//______________________________________________________________________________________________
	76	void AliTRIPreprocessor::Initialize(Int_t run, UInt_t startTime,
	77	UInt_t endTime)
	78	{
	79
	80	//
	81	// Initialize preprocessor
	82	//
	83
	84	AliPreprocessor::Initialize(run, startTime, endTime);
	85
	86	Log(Form("\n\tRun %d \n\tStartTime %s \n\tEndTime %s", run,
	87	TTimeStamp(startTime).AsString(),
	88	TTimeStamp(endTime).AsString()));
	89
	90	}
	91
	92	//______________________________________________________________________________________________
	93	Bool_t AliTRIPreprocessor::ProcessDCS()
	94	{
	95	//
	96	// DCS data are never needed
	97	//
	98
	99	return kFALSE;
	100	}
	101
	102	//______________________________________________________________________________________________
	103	UInt_t AliTRIPreprocessor::Process(TMap* /dcsAliasMap/)
	104	{
	105
	106	// Procees function:
	107	// After reading the TriggerDetectorMask, the
	108	// corresponding triggering detector procedures to
	109	// process the trigger data are called.
	110
	111	typedef Short_t (AliTRIPreprocessor::*AliProcessTriggerData)();
	112	const AliProcessTriggerData processTriggerDataArray[AliTRIPreprocessor::kNDetectorsMap]= {
	113	&AliTRIPreprocessor::ProcessSPDTriggerData,
c2f1e26c	114	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	115	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	116	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	117	&AliTRIPreprocessor::ProcessEmptyTriggerData,
15129f36	118	&AliTRIPreprocessor::ProcessTOFTriggerData,
c2f1e26c	119	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	120	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	121	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	122	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	123	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	124	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	125	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	126	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	127	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	128	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	129	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	130	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	131	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	132	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	133	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	134	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	135	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	136	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	137	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	138	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	139	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	140	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	141	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	142	&AliTRIPreprocessor::ProcessEmptyTriggerData,
	143	&AliTRIPreprocessor::ProcessEmptyTriggerData};
b48d2542	144
	145
	146	// getting the list of triggering detectors from DAQ logbook
	147
	148	TString triggerDetectorMask = (TString)GetTriggerDetectorMask();
	149	Int_t result=0;
	150	if (!triggerDetectorMask.IsNull()){
	151	Int_t length = triggerDetectorMask.Length();
	152	Log(Form("mask = %s", triggerDetectorMask.Data()));
	153	for (Int_t i = 0; i<length; i++){
	154	AliDebug(2,Form("%d-th bit = %c in index %d",i,triggerDetectorMask[length-1-i],length-1-i));
	155	if (triggerDetectorMask[length-1-i] == '1'){
c2f1e26c	156	Log("****************************************");
	157	Log(Form("Processing Trigger data for %s",fgkDetectorsMapName[i]));
	158	Log("****************************************");
	159
b48d2542	160	result+=(this->*processTriggerDataArray[i])();
	161	}
	162	}
	163	}
	164
	165	// result should be 0 to end successfully
	166
	167	return result;
	168
	169	}
	170	//______________________________________________________________________________________________
	171	Short_t AliTRIPreprocessor::ProcessSPDTriggerData()
	172	{
	173	//
	174	// Processing SPD Trigger Data
	175	//
	176
	177	Log("************ Processing SPD Trigger data... ************");
	178
	179	// Read new conditions from dcs fxs
	180	AliITSTriggerConditions* newCond = new AliITSTriggerConditions();
53aef915	181	TString fxsID = "pit_conditions";
b48d2542	182	TList* list = GetFileSources(kDCS, fxsID.Data());
	183	if (!list) {
	184	AliError("FXS file not found.");
	185	return 1;
	186	}
	187	UInt_t nFiles = 0;
	188	while (list->At(nFiles)!=NULL) {
	189	TObjString* fileNameEntry = (TObjString*) list->At(nFiles);
	190	TString fileName = GetFile(kDCS, fxsID.Data(), fileNameEntry->GetString().Data());
	191	if (fileName.IsNull()) {
	192	Log(Form("GetFile failed to retrieve file %s.",fileNameEntry->GetString().Data()));
	193	return 1;
	194	}
	195	if (nFiles==0) newCond->ReadFromTextFile(fileName.Data());
	196	nFiles++;
	197	}
	198	if (nFiles!=1) {
	199	AliWarning(Form("Found %d files with id %s (expected exactly 1).",nFiles,fxsID.Data()));
	200	}
	201
	202	// Read old conditions from ocdb
	203	AliITSTriggerConditions* oldCond = NULL;
	204	AliCDBEntry* pitCond = GetFromOCDB("SPD", "PITConditions");
	205	if (pitCond) {
	206	oldCond = (AliITSTriggerConditions*) pitCond->GetObject();
	207	if (!oldCond) {
	208	AliError("AliCDBEntry::GetObject() returned NULL.");
	209	return 1;
	210	}
	211	}
	212	else {
	213	Log("Old conditions not found in database.");
	214	}
	215
	216	// Do we need to update db?
	217	Bool_t doUpdate = kTRUE;
	218	if (oldCond) {
	219	// compare to see if there were any changes...
	220	if (newCond->IsEqualTo(oldCond)) {
	221	Log("Old conditions equal to new conditions. Do nothing.");
	222	doUpdate = kFALSE;
	223	}
	224	}
	225
	226	if (doUpdate) {
	227	// store new conditions in ocdb
	228	AliCDBMetaData metaData;
	229	metaData.SetResponsible("Henrik Tydesjo");
	230	metaData.SetComment("Created by Trigger PreProcessor");
	231	if (!Store("SPD", "PITConditions", newCond, &metaData, 0, kTRUE)) {
	232	Log("Failed to store conditions data.");
	233	return 1;
	234	}
	235	Log("Database updated.");
	236	}
	237
	238	delete newCond;
	239
	240	Log("*********************** ...done.***********************");
	241
	242	return 0; // 0 means success
	243
	244	}
	245	//______________________________________________________________________________________________
246	Short_t AliTRIPreprocessor::ProcessTOFTriggerData()
247	{
248	//
249	// Processing TOF Trigger Data
250	//
251
252	Log("************ Processing TOF Trigger data... ************");
15129f36	253
	254	const char * nameFile = GetFile(kDCS,"TofFeeLightMap", "");
	255	AliInfo(Form("toffeeLight file name = %s",nameFile));
	256	if (nameFile == NULL) {
	257	return 1;
	258	}
	259	AliTOFFEEReader feeReader;
	260	feeReader.LoadFEElightConfig(nameFile);
	261	feeReader.ParseFEElightConfig();
	262	AliTOFTriggerMask triggerMask;
	263	triggerMask.SetTriggerMaskArray(feeReader.GetTriggerMaskArray());
	264
	265	AliCDBMetaData metaData;
	266	metaData.SetBeamPeriod(0);
	267	metaData.SetResponsible("Roberto Preghenella");
	268	metaData.SetComment("TOF trigger mask");
	269	if (!Store("TOF", "TriggerMask", &triggerMask, &metaData, 0, kTRUE)) {
	270	Log("error while storing TriggerMask object");
	271	return 1;
	272	}
	273	Log("TriggerMask object successfully stored");
	274
b48d2542	275	Log("*********************** ...done.***********************");
	276	return 0;
	277	}
c2f1e26c	278	//______________________________________________________________________________________________
	279	Short_t AliTRIPreprocessor::ProcessEmptyTriggerData()
	280	{
	281	//
	282	// Processing TOF Trigger Data
	283	//
	284
	285	Log("************ Trigger data Processing not yet implemented ************");
	286	return 0;
	287	}
b48d2542	288
b48d2542	289