[u/mrichter/AliRoot.git] / PHOS / PHOSLEDda.cxx

/*
contact: Boris.Polishchuk@cern.ch
link: see comments in the $ALICE_ROOT/PHOS/AliPHOSRcuDA1.cxx
reference run: /castor/cern.ch/alice/phos/2007/10/04/18/07000008249001.1000.root
run type: STANDALONE
DA type: MON 
number of events needed: 1000
input files: RCU0.data  RCU1.data  RCU2.data  RCU3.data
Output files: PHOS_Module2_LED.root
Trigger types used: CALIBRATION_EVENT
*/


#include "event.h"
#include "monitor.h"
extern "C" {
#include "daqDA.h"
}

#include <stdio.h>
#include <stdlib.h>

#include <TSystem.h>
#include <TROOT.h>
#include <TPluginManager.h>

#include "AliRawReader.h"
#include "AliRawReaderDate.h"
#include "AliPHOSRcuDA1.h"
#include "AliPHOSRawFitterv0.h"
#include "AliCaloAltroMapping.h"
#include "AliCaloRawStreamV3.h"


/* Main routine
      Arguments: 
      1- monitoring data source
*/
int main(int argc, char **argv) {

  gROOT->GetPluginManager()->AddHandler("TVirtualStreamerInfo",
					"*",
					"TStreamerInfo",
					"RIO",
					"TStreamerInfo()");

  int status;
  
  if (argc!=2) {
    printf("Wrong number of arguments\n");
    return -1;
  }

  /* Retrieve ZS parameters from DAQ DB */
  const char* zsfile = "zs.txt";
  int failZS = daqDA_DB_getFile(zsfile, zsfile);
  
  Int_t offset,threshold;
  
  if(!failZS) {
    FILE *f = fopen(zsfile,"r");
    int scan = fscanf(f,"%d %d",&offset,&threshold);
  }

  /* Retrieve mapping files from DAQ DB */ 
  const char* mapFiles[4] = {"RCU0.data","RCU1.data","RCU2.data","RCU3.data"};

  for(Int_t iFile=0; iFile<4; iFile++) {
    int failed = daqDA_DB_getFile(mapFiles[iFile], mapFiles[iFile]);
    if(failed) { 
      printf("Cannot retrieve file %s from DAQ DB. Exit.\n",mapFiles[iFile]);
      return -1;
    }
  }
  
  /* Open mapping files */
  AliAltroMapping *mapping[4];
  TString path = "./";
  path += "RCU";
  TString path2;
  for(Int_t i = 0; i < 4; i++) {
    path2 = path;
    path2 += i;
    path2 += ".data";
    mapping[i] = new AliCaloAltroMapping(path2.Data());
  }
  

  /* define data source : this is argument 1 */  
  status=monitorSetDataSource( argv[1] );
  if (status!=0) {
    printf("monitorSetDataSource() failed : %s\n",monitorDecodeError(status));
    return -1;
  }


  /* declare monitoring program */
  status=monitorDeclareMp( __FILE__ );
  if (status!=0) {
    printf("monitorDeclareMp() failed : %s\n",monitorDecodeError(status));
    return -1;
  }


  /* define wait event timeout - 1s max */
  monitorSetNowait();
  monitorSetNoWaitNetworkTimeout(1000);
  
   /* init some counters */
  int nevents_physics=0;
  int nevents_total=0;
  
  AliRawReader *rawReader = NULL;
  AliPHOSRcuDA1* dAs[5];
  
  for(Int_t iMod=0; iMod<5; iMod++) {
    dAs[iMod] = 0;
  }

  Float_t e[64][56][2];
  Float_t t[64][56][2];
  
  for(Int_t iX=0; iX<64; iX++) {
    for(Int_t iZ=0; iZ<56; iZ++) {
      for(Int_t iGain=0; iGain<2; iGain++) {
        e[iX][iZ][iGain] = 0.;
        t[iX][iZ][iGain] = 0.;
      }
    }
  }
  
  Int_t cellX    = -1;
  Int_t cellZ    = -1;
  Int_t nBunches =  0;
  Int_t nFired   = -1;
  Int_t sigStart, sigLength;
  Int_t caloFlag;
  

  TH1I fFiredCells("fFiredCells","Number of fired cells per event",100,0,1000);

  /* main loop (infinite) */
  for(;;) {
    struct eventHeaderStruct *event;
    eventTypeType eventT;
  
    /* check shutdown condition */
    if (daqDA_checkShutdown()) {break;}
    
    /* get next event (blocking call until timeout) */
    status=monitorGetEventDynamic((void **)&event);
    if (status==MON_ERR_EOF) {
      printf ("End of File detected\n");
      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;
    }


    /* use event - here, just write event id to result file */
    eventT=event->eventType;
    
    if (eventT==PHYSICS_EVENT) {
      
      nFired = 0;
      
      rawReader = new AliRawReaderDate((void*)event);
      AliCaloRawStreamV3 stream(rawReader,"PHOS",mapping);
      AliPHOSRawFitterv0 fitter;
      fitter.SubtractPedestals(kTRUE); // assume that data is non-ZS

      if(!failZS) {
	fitter.SubtractPedestals(kFALSE);
	fitter.SetAmpOffset(offset);
	fitter.SetAmpThreshold(threshold);
      }
      
      while (stream.NextDDL()) {
	while (stream.NextChannel()) {
	  
	  cellX    = stream.GetCellX();
	  cellZ    = stream.GetCellZ();
	  caloFlag = stream.GetCaloFlag();  // 0=LG, 1=HG, 2=TRU
	  
	  if(caloFlag!=0 && caloFlag!=1) continue; //TRU data!
	  
	  // In case of oscillating signals with ZS, a channel can have several bunches
	  nBunches = 0;
	  while (stream.NextBunch()) {
	    nBunches++;
	    if (nBunches > 1) continue;
	    sigStart  = stream.GetStartTimeBin();
	    sigLength = stream.GetBunchLength();
	    fitter.SetChannelGeo(stream.GetModule(),cellX,cellZ,caloFlag);
	    fitter.Eval(stream.GetSignals(),sigStart,sigLength);
	  } // End of NextBunch()
	  
	  if(nBunches>1) continue;
	  
	  e[cellX][cellZ][caloFlag] = fitter.GetEnergy();
	  t[cellX][cellZ][caloFlag] = fitter.GetTime();
	  
	  if(caloFlag==1 && fitter.GetEnergy()>40)
	    nFired++;
	}
	
	if(stream.GetModule()<0 || stream.GetModule()>4) continue;
	
	if(dAs[stream.GetModule()])
	  dAs[stream.GetModule()]->FillHistograms(e,t);
	else {
	  dAs[stream.GetModule()] = new AliPHOSRcuDA1(stream.GetModule(),-1,0);
	  dAs[stream.GetModule()]->FillHistograms(e,t);
	} 
	
	for(Int_t iX=0; iX<64; iX++) {
	  for(Int_t iZ=0; iZ<56; iZ++) {
	    for(Int_t iGain=0; iGain<2; iGain++) {
	      e[iX][iZ][iGain] = 0.;
	      t[iX][iZ][iGain] = 0.;
	    }
	  }
	}
	
      }
      
      fFiredCells.Fill(nFired);
      
      delete rawReader;     
      nevents_physics++;
    }
    
    nevents_total++;
    
    /* free resources */
    free(event);
    
    /* exit when last event received, no need to wait for TERM signal */
    if (eventT==END_OF_RUN) {
      printf("EOR event detected\n");
      break;
    }
  }
  
  for(Int_t i = 0; i < 4; i++) delete mapping[i];  
  
  /* Be sure that all histograms are saved */
  
  const TH2F* h2=0;
  const TH1F* h1=0;
  char localfile[128];

  Int_t nGood=0;    // >10 entries in peak
  Int_t nMax=-111;  // max. number of entries in peak
  Int_t iXmax=-1;
  Int_t iZmax=-1;
  Int_t iModMax=-1;
  
  for(Int_t iMod=0; iMod<5; iMod++) {
    if(!dAs[iMod]) continue;
  
    printf("DA1 for module %d detected.\n",iMod);
    sprintf(localfile,"PHOS_Module%d_LED.root",iMod);
    TFile* f = new TFile(localfile,"recreate");
    
    for(Int_t iX=0; iX<64; iX++) {
      for(Int_t iZ=0; iZ<56; iZ++) {
	
	h1 = dAs[iMod]->GetHgLgRatioHistogram(iX,iZ); // High Gain/Low Gain ratio
	if(h1) {
	  if(h1->GetMaximum()>10.) nGood++;
	  if(h1->GetMaximum()>nMax) {
	    nMax = (Int_t)h1->GetMaximum(); iXmax=iX; iZmax=iZ; iModMax=iMod;
	  }
	  h1->Write(); 
	}
      
	for(Int_t iGain=0; iGain<2; iGain++) {
	  h2 = dAs[iMod]->GetTimeEnergyHistogram(iX,iZ,iGain); // Time vs Energy
	  if(h2) h2->Write();
	}
      
      }
    }
    
    fFiredCells.Write();
    f->Close();
    
    /* Store output files to the File Exchange Server */
    daqDA_FES_storeFile(localfile,"LED");
  }
  
  printf("%d physics events of %d total processed.\n",nevents_physics,nevents_total);
  printf("%d histograms has >10 entries in maximum, max. is %d entries ",nGood,nMax);
  printf("(module,iX,iZ)=(%d,%d,%d)",iModMax,iXmax,iZmax);
  printf("\n");

  return status;
}
Commit	Line	Data
68aaec35	1	/*
	2	contact: Boris.Polishchuk@cern.ch
	3	link: see comments in the $ALICE_ROOT/PHOS/AliPHOSRcuDA1.cxx
	4	reference run: /castor/cern.ch/alice/phos/2007/10/04/18/07000008249001.1000.root
	5	run type: STANDALONE
	6	DA type: MON
	7	number of events needed: 1000
	8	input files: RCU0.data RCU1.data RCU2.data RCU3.data
	9	Output files: PHOS_Module2_LED.root
	10	Trigger types used: CALIBRATION_EVENT
	11	*/
	12
	13
	14	#include "event.h"
	15	#include "monitor.h"
	16	extern "C" {
	17	#include "daqDA.h"
	18	}
	19
	20	#include <stdio.h>
	21	#include <stdlib.h>
	22
	23	#include <TSystem.h>
	24	#include <TROOT.h>
	25	#include <TPluginManager.h>
	26
	27	#include "AliRawReader.h"
	28	#include "AliRawReaderDate.h"
	29	#include "AliPHOSRcuDA1.h"
8083e819	30	#include "AliPHOSRawFitterv0.h"
68aaec35	31	#include "AliCaloAltroMapping.h"
8083e819	32	#include "AliCaloRawStreamV3.h"
68aaec35	33
	34
	35	/* Main routine
	36	Arguments:
	37	1- monitoring data source
	38	*/
	39	int main(int argc, char **argv) {
	40
	41	gROOT->GetPluginManager()->AddHandler("TVirtualStreamerInfo",
	42	"*",
	43	"TStreamerInfo",
	44	"RIO",
	45	"TStreamerInfo()");
	46
	47	int status;
	48
	49	if (argc!=2) {
	50	printf("Wrong number of arguments\n");
	51	return -1;
	52	}
	53
f4333ce5	54	/* Retrieve ZS parameters from DAQ DB */
	55	const char* zsfile = "zs.txt";
	56	int failZS = daqDA_DB_getFile(zsfile, zsfile);
	57
	58	Int_t offset,threshold;
	59
	60	if(!failZS) {
	61	FILE *f = fopen(zsfile,"r");
	62	int scan = fscanf(f,"%d %d",&offset,&threshold);
	63	}
	64
68aaec35	65	/* Retrieve mapping files from DAQ DB */
	66	const char* mapFiles[4] = {"RCU0.data","RCU1.data","RCU2.data","RCU3.data"};
	67
	68	for(Int_t iFile=0; iFile<4; iFile++) {
	69	int failed = daqDA_DB_getFile(mapFiles[iFile], mapFiles[iFile]);
	70	if(failed) {
	71	printf("Cannot retrieve file %s from DAQ DB. Exit.\n",mapFiles[iFile]);
	72	return -1;
	73	}
	74	}
	75
	76	/* Open mapping files */
	77	AliAltroMapping *mapping[4];
	78	TString path = "./";
	79	path += "RCU";
	80	TString path2;
	81	for(Int_t i = 0; i < 4; i++) {
	82	path2 = path;
	83	path2 += i;
	84	path2 += ".data";
	85	mapping[i] = new AliCaloAltroMapping(path2.Data());
	86	}
	87
	88
	89	/* define data source : this is argument 1 */
	90	status=monitorSetDataSource( argv[1] );
	91	if (status!=0) {
	92	printf("monitorSetDataSource() failed : %s\n",monitorDecodeError(status));
	93	return -1;
	94	}
	95
	96
	97	/* declare monitoring program */
	98	status=monitorDeclareMp( __FILE__ );
	99	if (status!=0) {
	100	printf("monitorDeclareMp() failed : %s\n",monitorDecodeError(status));
	101	return -1;
	102	}
	103
	104
	105	/* define wait event timeout - 1s max */
	106	monitorSetNowait();
	107	monitorSetNoWaitNetworkTimeout(1000);
	108
	109	/* init some counters */
	110	int nevents_physics=0;
	111	int nevents_total=0;
d62e649a	112
68aaec35	113	AliRawReader *rawReader = NULL;
d62e649a	114	AliPHOSRcuDA1* dAs[5];
68aaec35	115
d62e649a	116	for(Int_t iMod=0; iMod<5; iMod++) {
	117	dAs[iMod] = 0;
	118	}
	119
68aaec35	120	Float_t e[64][56][2];
68aaec35	121	Float_t t[64][56][2];
2905f08d	122
	123	for(Int_t iX=0; iX<64; iX++) {
	124	for(Int_t iZ=0; iZ<56; iZ++) {
	125	for(Int_t iGain=0; iGain<2; iGain++) {
	126	e[iX][iZ][iGain] = 0.;
	127	t[iX][iZ][iGain] = 0.;
	128	}
	129	}
	130	}
	131
8083e819	132	Int_t cellX = -1;
	133	Int_t cellZ = -1;
	134	Int_t nBunches = 0;
	135	Int_t nFired = -1;
	136	Int_t sigStart, sigLength;
d62e649a	137	Int_t caloFlag;
d62e649a	138
7708b003	139
7708b003	140	TH1I fFiredCells("fFiredCells","Number of fired cells per event",100,0,1000);
68aaec35	141
	142	/* main loop (infinite) */
	143	for(;;) {
	144	struct eventHeaderStruct *event;
	145	eventTypeType eventT;
	146
	147	/* check shutdown condition */
	148	if (daqDA_checkShutdown()) {break;}
	149
	150	/* get next event (blocking call until timeout) */
	151	status=monitorGetEventDynamic((void **)&event);
	152	if (status==MON_ERR_EOF) {
	153	printf ("End of File detected\n");
	154	break; /* end of monitoring file has been reached */
	155	}
	156
	157	if (status!=0) {
	158	printf("monitorGetEventDynamic() failed : %s\n",monitorDecodeError(status));
	159	break;
	160	}
	161
	162	/* retry if got no event */
	163	if (event==NULL) {
	164	continue;
	165	}
	166
	167
	168	/* use event - here, just write event id to result file */
	169	eventT=event->eventType;
	170
	171	if (eventT==PHYSICS_EVENT) {
	172
7708b003	173	nFired = 0;
d62e649a	174
68aaec35	175	rawReader = new AliRawReaderDate((void*)event);
8083e819	176	AliCaloRawStreamV3 stream(rawReader,"PHOS",mapping);
d62e649a	177	AliPHOSRawFitterv0 fitter;
8083e819	178	fitter.SubtractPedestals(kTRUE); // assume that data is non-ZS
f4333ce5	179
	180	if(!failZS) {
	181	fitter.SubtractPedestals(kFALSE);
	182	fitter.SetAmpOffset(offset);
	183	fitter.SetAmpThreshold(threshold);
	184	}
68aaec35	185
8083e819	186	while (stream.NextDDL()) {
8083e819	187	while (stream.NextChannel()) {
d62e649a	188
8083e819	189	cellX = stream.GetCellX();
	190	cellZ = stream.GetCellZ();
	191	caloFlag = stream.GetCaloFlag(); // 0=LG, 1=HG, 2=TRU
d62e649a	192
2905f08d	193	if(caloFlag!=0 && caloFlag!=1) continue; //TRU data!
2905f08d	194
8083e819	195	// In case of oscillating signals with ZS, a channel can have several bunches
	196	nBunches = 0;
	197	while (stream.NextBunch()) {
	198	nBunches++;
	199	if (nBunches > 1) continue;
d62e649a	200	sigStart = stream.GetStartTimeBin();
d62e649a	201	sigLength = stream.GetBunchLength();
92236b27	202	fitter.SetChannelGeo(stream.GetModule(),cellX,cellZ,caloFlag);
92236b27	203	fitter.Eval(stream.GetSignals(),sigStart,sigLength);
8083e819	204	} // End of NextBunch()
8083e819	205
d62e649a	206	if(nBunches>1) continue;
8083e819	207
	208	e[cellX][cellZ][caloFlag] = fitter.GetEnergy();
	209	t[cellX][cellZ][caloFlag] = fitter.GetTime();
d62e649a	210
8083e819	211	if(caloFlag==1 && fitter.GetEnergy()>40)
	212	nFired++;
	213	}
d62e649a	214
2905f08d	215	if(stream.GetModule()<0 \|\| stream.GetModule()>4) continue;
2905f08d	216
d62e649a	217	if(dAs[stream.GetModule()])
d62e649a	218	dAs[stream.GetModule()]->FillHistograms(e,t);
2905f08d	219	else {
d62e649a	220	dAs[stream.GetModule()] = new AliPHOSRcuDA1(stream.GetModule(),-1,0);
2905f08d	221	dAs[stream.GetModule()]->FillHistograms(e,t);
2905f08d	222	}
d62e649a	223
	224	for(Int_t iX=0; iX<64; iX++) {
	225	for(Int_t iZ=0; iZ<56; iZ++) {
	226	for(Int_t iGain=0; iGain<2; iGain++) {
	227	e[iX][iZ][iGain] = 0.;
	228	t[iX][iZ][iGain] = 0.;
	229	}
	230	}
	231	}
	232
8083e819	233	}
d62e649a	234
7708b003	235	fFiredCells.Fill(nFired);
d62e649a	236
68aaec35	237	delete rawReader;
	238	nevents_physics++;
	239	}
	240
	241	nevents_total++;
	242
	243	/* free resources */
	244	free(event);
	245
	246	/* exit when last event received, no need to wait for TERM signal */
	247	if (eventT==END_OF_RUN) {
	248	printf("EOR event detected\n");
	249	break;
	250	}
	251	}
	252
	253	for(Int_t i = 0; i < 4; i++) delete mapping[i];
	254
	255	/* Be sure that all histograms are saved */
68aaec35	256
	257	const TH2F* h2=0;
	258	const TH1F* h1=0;
d62e649a	259	char localfile[128];
68aaec35	260
	261	Int_t nGood=0; // >10 entries in peak
	262	Int_t nMax=-111; // max. number of entries in peak
	263	Int_t iXmax=-1;
	264	Int_t iZmax=-1;
d62e649a	265	Int_t iModMax=-1;
	266
	267	for(Int_t iMod=0; iMod<5; iMod++) {
	268	if(!dAs[iMod]) continue;
	269
	270	printf("DA1 for module %d detected.\n",iMod);
	271	sprintf(localfile,"PHOS_Module%d_LED.root",iMod);
	272	TFile* f = new TFile(localfile,"recreate");
	273
	274	for(Int_t iX=0; iX<64; iX++) {
	275	for(Int_t iZ=0; iZ<56; iZ++) {
	276
	277	h1 = dAs[iMod]->GetHgLgRatioHistogram(iX,iZ); // High Gain/Low Gain ratio
	278	if(h1) {
	279	if(h1->GetMaximum()>10.) nGood++;
	280	if(h1->GetMaximum()>nMax) {
	281	nMax = (Int_t)h1->GetMaximum(); iXmax=iX; iZmax=iZ; iModMax=iMod;
	282	}
	283	h1->Write();
	284	}
68aaec35	285
d62e649a	286	for(Int_t iGain=0; iGain<2; iGain++) {
	287	h2 = dAs[iMod]->GetTimeEnergyHistogram(iX,iZ,iGain); // Time vs Energy
	288	if(h2) h2->Write();
	289	}
68aaec35	290
68aaec35	291	}
68aaec35	292	}
d62e649a	293
	294	fFiredCells.Write();
	295	f->Close();
	296
	297	/* Store output files to the File Exchange Server */
	298	daqDA_FES_storeFile(localfile,"LED");
68aaec35	299	}
68aaec35	300
68aaec35	301	printf("%d physics events of %d total processed.\n",nevents_physics,nevents_total);
68aaec35	302	printf("%d histograms has >10 entries in maximum, max. is %d entries ",nGood,nMax);
d62e649a	303	printf("(module,iX,iZ)=(%d,%d,%d)",iModMax,iXmax,iZmax);
68aaec35	304	printf("\n");
	305
	306	return status;
	307	}