+/*
+TPC DA for online calibration
+
+Contact: Haavard.Helstrup@cern.ch
+Link:
+Run Type: PEDESTAL
+DA Type: LDC
+Number of events needed: 100
+Input Files:
+Output Files: tpcPedestal.root, to be exported to the DAQ FXS
+fileId: pedestals
+Trigger types used: CALIBRATION_EVENT
+
+*/
+
/*
TPCda_pedestal.cxx - calibration algorithm for TPC pedestal runs
10/06/2007 sylvain.chapeland@cern.ch : first version - clean skeleton based on DAQ DA case1
+19/10/2007 christian.lippmann@cern.ch : Possibility to write output to ASCII file
+24/10/2007 christian.lippmann@cern.ch : Including pedestal calibration for time bins
+23/11/2007 christian.lippmann@cern.ch : Fix in order to avoid streamer problems in case of
+ invalid ROOTSTYS. The famous magic line provided by Rene.
+28/11/2007 christian.lippmann@cern.ch : TPC mapping file is read from DaqDetDB
contact: marian.ivanov@cern.ch
-
This process reads RAW data from the files provided as command line arguments
and save results in a file (named from RESULT_FILE define - see below).
*/
-#define RESULT_FILE "tpcPedestal.root"
-
+#define RESULT_FILE "tpcPedestal.root"
+#define FILE_ID "pedestals"
+#define MAPPING_FILE "tpcMapping.root"
+#define AliDebugLevel() -1
extern "C" {
#include <daqDA.h>
}
#include "event.h"
#include "monitor.h"
-#include <stdio.h>
-#include <stdlib.h>
-#include <fstream.h>
+
+#include "stdio.h"
+#include "stdlib.h"
+#include <fstream>
//
//Root includes
//
-#include <TFile.h>
+#include "TFile.h"
+#include "TArrayF.h"
+#include "TROOT.h"
+#include "TPluginManager.h"
//
//AliRoot includes
#include "AliTPCCalPad.h"
#include "AliMathBase.h"
#include "TTreeStream.h"
+#include "AliLog.h"
+#include "TSystem.h"
//
// TPC calibration algorithm includes
//
#include "AliTPCCalibPedestal.h"
-
-
-
-/* Main routine
- Arguments: list of DATE raw data files
+/*
+ Main routine, TPC pedestal detector algorithm to be run on TPC LDC
+ Arguments: list of DATE raw data files
*/
+
int main(int argc, char **argv) {
+ //
+ // Main for TPC pedestal detector algorithm
+ //
- int i,status;
- AliTPCCalibPedestal calibPedestal; // pedestal and noise calibration
+ AliLog::SetClassDebugLevel("AliTPCRawStream",-5);
+ AliLog::SetClassDebugLevel("AliRawReaderDate",-5);
+ AliLog::SetClassDebugLevel("AliTPCAltroMapping",-5);
+ AliLog::SetModuleDebugLevel("RAW",-5);
+
+ Bool_t timeAnalysis = kTRUE;
if (argc<2) {
printf("Wrong number of arguments\n");
return -1;
}
+ /* magic line */
+ gROOT->GetPluginManager()->AddHandler("TVirtualStreamerInfo",
+ "*",
+ "TStreamerInfo",
+ "RIO",
+ "TStreamerInfo()");
+ int i, status;
/* log start of process */
printf("TPC DA started - %s\n",__FILE__);
-
/* declare monitoring program */
status=monitorDeclareMp( __FILE__ );
if (status!=0) {
return -1;
}
+ AliTPCmapper *mapping = 0; // The TPC mapping
+
+ if (!mapping){
+ /* copy locally the mapping file from daq detector config db */
+ status = daqDA_DB_getFile(MAPPING_FILE,"./tpcMapping.root");
+ if (status) {
+ printf("Failed to get mapping file (%s) from DAQdetDB, status=%d\n", MAPPING_FILE, status);
+ printf("Continue anyway ... maybe it works?\n"); // !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
+ return -1; // temporarily uncommented for testing on pcald47 !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
+ }
+
+ /* open the mapping file and retrieve mapping object */
+ TFile *fileMapping = new TFile(MAPPING_FILE, "read");
+ mapping = (AliTPCmapper*) fileMapping->Get("tpcMapping");
+ delete fileMapping;
+ }
+
+ if (mapping == 0) {
+ printf("Failed to get mapping object from %s. ...\n", MAPPING_FILE);
+ //return -1;
+ } else {
+ printf("Got mapping object from %s\n", MAPPING_FILE);
+ }
+ AliTPCCalibPedestal calibPedestal; // pedestal and noise calibration
+ calibPedestal.SetRangeTime(60,940); // set time bin range
+ calibPedestal.SetTimeAnalysis(timeAnalysis); // pedestal(t) calibration
+ if (mapping){
+ calibPedestal.SetAltroMapping(mapping->GetAltroMapping()); // Use altro mapping we got from daqDetDb
+ }
/* loop over RAW data files */
int nevents=0;
- for(i=1;i<argc;i++) {
+ for ( i=1; i<argc; i++ ) {
/* define data source : this is argument i */
printf("Processing file %s\n", argv[i]);
status=monitorSetDataSource( argv[i] );
if (status!=0) {
- printf("monitorSetDataSource() failed : %s\n",monitorDecodeError(status));
+ printf("monitorSetDataSource() failed. Error=%s. Exiting ...\n", monitorDecodeError(status));
return -1;
}
/* read until EOF */
- for(;;) {
+ for ( ; ; ) {
struct eventHeaderStruct *event;
/* check shutdown condition */
/* get next event (blocking call until timeout) */
status=monitorGetEventDynamic((void **)&event);
if (status==MON_ERR_EOF) {
- printf ("End of File %d detected\n",i);
- break; /* end of monitoring file has been reached */
+ printf ("End of File %d (%s) detected\n", i, argv[i]);
+ break; /* end of monitoring file has been reached */
}
-
if (status!=0) {
- printf("monitorGetEventDynamic() failed : %s\n",monitorDecodeError(status));
- break;
+ printf("monitorGetEventDynamic() failed : %s\n",monitorDecodeError(status));
+ break;
}
+ /* skip start/end of run events */
+ if ( (event->eventType != physicsEvent) && (event->eventType != calibrationEvent) )
+ continue;
+
/* retry if got no event */
- if (event==NULL) {
- continue;
- }
+ if (event==NULL)
+ continue;
+
nevents++;
// Pedestal calibration
AliRawReader *rawReader = new AliRawReaderDate((void*)event);
calibPedestal.ProcessEvent(rawReader);
+ //calibPedestal.ProcessEventFast(rawReader); // fast data reader
delete rawReader;
/* free resources */
}
}
- calibPedestal.Analyse();
- printf ("%d events processed\n",nevents);
+ //
+ // Analyse pedestals and write them to rootfile
+ //
- TFile * fileTPC = new TFile (RESULT_FILE,"recreate");
- calibPedestal.Write("calibPedestal");
+ calibPedestal.Analyse();
+ calibPedestal.AnalyseTime(nevents);
+ printf ("%d physics/calibration events processed.\n",nevents);
+
+ TFile *fileTPC = new TFile(RESULT_FILE, "recreate");
+ calibPedestal.Write("tpcCalibPedestal");
delete fileTPC;
- printf("Wrote %s\n",RESULT_FILE);
+ printf("Wrote %s.\n",RESULT_FILE);
+
+ /* store the result file on FES */
+
+ status=daqDA_FES_storeFile(RESULT_FILE,FILE_ID);
+ if (status) {
+ status = -2;
+ }
- // Prepare files for local ALTRO configuration through DDL
- AliTPCmapper mapping;
- ofstream out;
+ //
+ // Now prepare ASCII files for local ALTRO configuration through DDL.
+ //
+
+ ofstream pedfile;
+ ofstream noisefile;
+ ofstream pedmemfile;
char filename[255];
- sprintf(filename,"Pedestals.data");
- out.open(filename);
+ sprintf(filename,"tpcPedestals.data");
+ pedfile.open(filename);
+ sprintf(filename,"tpcNoise.data");
+ noisefile.open(filename);
+ sprintf(filename,"tpcPedestalMem.data");
+ pedmemfile.open(filename);
+
+ TArrayF **timePed = calibPedestal.GetTimePedestals(); // pedestal values for each time bin
- Int_t ctr = 0;
+ Int_t ctr_channel = 0;
+ Int_t ctr_altro = 0;
+ Int_t ctr_pattern = 0;
- out << 10 << endl; // PEDESTALS
- for ( int roc = 0; roc <= 71; roc++ ) {
+ pedfile << 10 << std::endl; // mark file to contain PEDESTALS per channel
+ noisefile << 11 << std::endl; // mark file to contain NOISE per altro
+ pedmemfile << 12 << std::endl; // mark file to contain PEDESTALs per time bin
+
+ for ( Int_t roc = 0; roc < 72; roc++ ) {
if ( !calibPedestal.GetCalRocPedestal(roc) ) continue;
- Int_t side = mapping.GetSideFromRoc(roc);
- Int_t sec = mapping.GetSectorFromRoc(roc);
- printf("**Analysing ROC %d (side %d, sector %d) ...\n", roc, side, sec);
- for ( int row = 0; row < mapping.GetNpadrows(roc); row++ ) {
- for ( int pad = 0; pad < mapping.GetNpads(roc, row); pad++ ) {
- Int_t rcu = mapping.GetRcu(roc, row, pad);
- Int_t hwadd = mapping.GetHWAddress(roc, row, pad);
- Float_t ped = calibPedestal.GetCalRocPedestal(roc)->GetValue(row,pad);
- out << ctr << "\t" << side << "\t" << sec << "\t" << rcu << "\t" << hwadd << "\t" << ped << std::endl;
- ctr++;
- }
- }
- }
+ Int_t side = mapping->GetSideFromRoc(roc);
+ Int_t sector = mapping->GetSectorFromRoc(roc);
+ //printf("Analysing ROC %d (side %d, sector %d) ...\n", roc, side, sector);
+ Int_t nru = mapping->IsIROC(roc) ? 2 : 4;
+ for ( int rcu = 0; rcu < nru; rcu++ ) {
+ Int_t patch = mapping->IsIROC(roc) ? rcu : rcu+2;
+ for ( int branch = 0; branch < 2; branch++ ) {
+ for ( int fec = 0; fec < mapping->GetNfec(patch, branch); fec++ ) {
+ for ( int altro = 0; altro < 8; altro++ ) {
+ Float_t rms = 0.;
+ Float_t ctr = 0.;
+ for ( int channel = 0; channel < 16; channel++ ) {
+ Int_t hwadd = mapping->CodeHWAddress(branch, fec, altro, channel);
+ Int_t row = mapping->GetPadRow(patch, hwadd); // row in a ROC
+ Int_t globalrow = mapping->GetGlobalPadRow(patch, hwadd); // row in full sector
+ Int_t pad = mapping->GetPad(patch, hwadd);
+ Float_t ped = calibPedestal.GetCalRocPedestal(roc)->GetValue(row,pad);
+ // fixed pedestal
+ if ( ped > 1.e-10 ) {
+ pedfile << ctr_channel << "\t" << side << "\t" << sector << "\t" << patch << "\t"
+ << hwadd << "\t" << ped << std::endl;
+ ctr_channel++;
+ }
+ // pedestal(t)
+ if ( timePed && fabs(timePed[globalrow][pad].GetSum()) > 1e-10 ) {
+ pedmemfile << ctr_pattern << "\t" << side << "\t" << sector << "\t" << patch
+ << "\t" << hwadd;
+ for ( Int_t timebin = 0; timebin < 1024; timebin++ )
+ pedmemfile << "\t" << timePed[globalrow][pad].At(timebin);
+ pedmemfile << std::endl;
+ ctr_pattern++;
+ }
+ // rms=noise
+ Float_t rms2 = calibPedestal.GetCalRocRMS(roc)->GetValue(row,pad);
+ if ( rms2 > 1.e-10 ) { rms += rms2; ctr += 1.; }
+ } // end channel for loop
+ // noise data (rms) averaged over all channels in this ALTRO.
+ Int_t hwadd = mapping->CodeHWAddress(branch, fec, altro, 0);
+ if ( ctr > 1.e-10 ) {
+ noisefile << ctr_altro << "\t" << side << "\t" << sector << "\t" << patch << "\t"
+ << hwadd << "\t" << rms/ctr << std::endl;
+ ctr_altro++;
+ }
+ } // end altro for loop
+ } // end fec for loop
+ } // end branch for loop
+ } // end rcu for loop
+ } // end roc loop
+
+ pedfile.close();
+ noisefile.close();
+ pedmemfile.close();
+ printf("Wrote ASCII files.\n");
- out.close();
return status;
}
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff