[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 <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");
}

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