Contact: silvermy@ornl.gov
Run Type: PEDESTAL or PHYSICS or STANDALONE
- DA Type: LDC
+ DA Type: LDC (PEDESTAL), MON (PHYSICS or STANDALONE)
Number of events needed: ~1000
Input Files: argument list
Output Files: RESULT_FILE=EMCALCalibPedestal.root, to be exported to the DAQ FXS
#define FILE_ID "EMCALCalibPedestal"
#define AliDebugLevel() -1
#define FILE_ClassName "emcCalibPedestal"
+const int kNRCU = 2;
+/* LOCAL_DEBUG is used to bypass daq* calls, for local testing */
+// #define LOCAL_DEBUG 1 // comment out to run normally
extern "C" {
#include <daqDA.h>
#include "stdio.h"
#include "stdlib.h"
+// ROOT includes
+#include <TFile.h>
+#include <TROOT.h>
+#include <TPluginManager.h>
+#include <TSystem.h>
+
//
//AliRoot includes
//
#include "AliRawReaderDate.h"
#include "AliRawEventHeaderBase.h"
#include "AliCaloRawStream.h"
+#include "AliCaloAltroMapping.h"
#include "AliLog.h"
//
// EMC calibration-helper algorithm includes
//
#include "AliCaloCalibPedestal.h"
-#include <TFile.h> // ROOT
/*
- Main routine, EMC pedestal detector algorithm to be run on EMC LDC
+ Main routine, EMC pedestal detector algorithm
Arguments: list of DATE raw data files
*/
if (argc<2) {
printf("Wrong number of arguments\n");
- return -1;
+ return -1;
}
+ /* magic line - for TStreamerInfo */
+ gROOT->GetPluginManager()->AddHandler("TVirtualStreamerInfo",
+ "*",
+ "TStreamerInfo",
+ "RIO",
+ "TStreamerInfo()");
+
int i, status;
/* log start of process */
printf("monitorDeclareMp() failed : %s\n",monitorDecodeError(status));
return -1;
}
+ /* define wait event timeout - 1s max */
+ monitorSetNowait();
+ monitorSetNoWaitNetworkTimeout(1000);
+
+ /* Retrieve mapping files from DAQ DB */
+ const char* mapFiles[kNRCU] = {"RCU0.data","RCU1.data"};
+
+ for(Int_t iFile=0; iFile<kNRCU; iFile++) {
+ int failed = daqDA_DB_getFile(mapFiles[iFile], mapFiles[iFile]);
+ if(failed) {
+ printf("Cannot retrieve file %d : %s from DAQ DB. Exit now..\n",
+ iFile, mapFiles[iFile]);
+#ifdef LOCAL_DEBUG
+#else
+ return -1;
+#endif
+ }
+ }
+
+ /* Open mapping files */
+ AliCaloAltroMapping *mapping[kNRCU];
+ TString path = "./";
+ path += "RCU";
+ TString path2;
+ for(Int_t i = 0; i < kNRCU; i++) {
+ path2 = path;
+ path2 += i;
+ path2 += ".data";
+ mapping[i] = new AliCaloAltroMapping(path2.Data());
+ }
+
+ /* set up our analysis class */
+ AliCaloCalibPedestal * calibPedestal = new AliCaloCalibPedestal(AliCaloCalibPedestal::kEmCal); // pedestal and noise calibration
+ calibPedestal->SetAltroMapping( mapping );
- AliCaloCalibPedestal * calibPedestal = new
- AliCaloCalibPedestal(AliCaloCalibPedestal::kEmCal); // pedestal and noise calibration
+ AliRawReader *rawReader = NULL;
+ int nevents=0;
/* loop over RAW data files */
- int nevents=0;
for ( i=1; i<argc; i++ ) {
/* define data source : this is argument i */
printf("Processing file %s\n", argv[i]);
-
- AliRawReader *rawReader = new AliRawReaderDate(argv[i]);
- AliCaloRawStream *in = new AliCaloRawStream(rawReader,"EMCAL");
- AliRawEventHeaderBase *aliHeader=NULL;
+ status=monitorSetDataSource( argv[i] );
+ if (status!=0) {
+ printf("monitorSetDataSource() failed. Error=%s. Exiting ...\n", monitorDecodeError(status));
+ return -1;
+ }
/* read until EOF */
- while ( rawReader->NextEvent() ) {
+ struct eventHeaderStruct *event;
+ eventTypeType eventT;
+
+ for ( ; ; ) { // infinite loop
/* check shutdown condition */
if (daqDA_checkShutdown()) {break;}
- aliHeader = (AliRawEventHeaderBase*) rawReader->GetEventHeader();
-
- // select physics and calibration events now (only calibration in future)
- // For running on testbeam files: we don't have any event classifications then: commented out selection with //DS below
- //DS if ( aliHeader->Get("Type") == AliRawEventHeaderBase::kPhysicsEvent || aliHeader->Get("Type") == AliRawEventHeaderBase::kCalibrationEvent ) {
-
- nevents++;
-
- // Pedestal calibration
- calibPedestal->ProcessEvent(in);
- //DS } // event selection
- } // loop over all events in file
- /* cleanup the reading handles */
- delete in;
- delete rawReader;
+ /* get next event (blocking call until timeout) */
+ status=monitorGetEventDynamic((void **)&event);
+ if (status==MON_ERR_EOF) {
+ 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;
+ }
+
+ /* retry if got no event */
+ if (event==NULL) {
+ continue;
+ }
+ eventT = event->eventType; // just shorthand
+
+ /* skip start/end of run events */
+ if ( (eventT != physicsEvent) && (eventT != calibrationEvent) ) {
+ continue;
+ }
+
+ nevents++; // count how many acceptable events we have
+
+ // Pedestal calibration
+ rawReader = new AliRawReaderDate((void*)event);
+ calibPedestal->ProcessEvent(rawReader);
+ delete rawReader;
+
+ /* free resources */
+ free(event);
+
+ } //until EOF
} // loop over files
//
printf("Could not save the object to file \"%s\".\n", RESULT_FILE);
}
- /* store the result file on FES */
- status = daqDA_FES_storeFile(RESULT_FILE, FILE_ID);
-
// see if we can delete our analysis helper also
delete calibPedestal;
+ for(Int_t iFile=0; iFile<kNRCU; iFile++) {
+ if (mapping[iFile]) delete mapping[iFile];
+ }
+
+ /* store the result file on FES */
+#ifdef LOCAL_DEBUG
+#else
+ status = daqDA_FES_storeFile(RESULT_FILE, FILE_ID);
+#endif
return status;
}
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff