[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];

  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
	  
	  // 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;
// 	  if (nBunches>1 || caloFlag!=0 || caloFlag!=1 || fitter.GetSignalQuality()>1) continue;
	  
	  e[cellX][cellZ][caloFlag] = fitter.GetEnergy();
	  t[cellX][cellZ][caloFlag] = fitter.GetTime();
	  
	  if(caloFlag==1 && fitter.GetEnergy()>40)
	    nFired++;
	}
	
	if(dAs[stream.GetModule()])
	  dAs[stream.GetModule()]->FillHistograms(e,t);
	else
	  dAs[stream.GetModule()] = new AliPHOSRcuDA1(stream.GetModule(),-1,0);
	
	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];
	121	Float_t t[64][56][2];
	122
8083e819	123	Int_t cellX = -1;
	124	Int_t cellZ = -1;
	125	Int_t nBunches = 0;
	126	Int_t nFired = -1;
	127	Int_t sigStart, sigLength;
d62e649a	128	Int_t caloFlag;
d62e649a	129
7708b003	130
7708b003	131	TH1I fFiredCells("fFiredCells","Number of fired cells per event",100,0,1000);
68aaec35	132
	133	/* main loop (infinite) */
	134	for(;;) {
	135	struct eventHeaderStruct *event;
	136	eventTypeType eventT;
	137
	138	/* check shutdown condition */
	139	if (daqDA_checkShutdown()) {break;}
	140
	141	/* get next event (blocking call until timeout) */
	142	status=monitorGetEventDynamic((void **)&event);
	143	if (status==MON_ERR_EOF) {
	144	printf ("End of File detected\n");
	145	break; /* end of monitoring file has been reached */
	146	}
	147
	148	if (status!=0) {
	149	printf("monitorGetEventDynamic() failed : %s\n",monitorDecodeError(status));
	150	break;
	151	}
	152
	153	/* retry if got no event */
	154	if (event==NULL) {
	155	continue;
	156	}
	157
	158
	159	/* use event - here, just write event id to result file */
	160	eventT=event->eventType;
	161
	162	if (eventT==PHYSICS_EVENT) {
	163
7708b003	164	nFired = 0;
d62e649a	165
68aaec35	166	rawReader = new AliRawReaderDate((void*)event);
8083e819	167	AliCaloRawStreamV3 stream(rawReader,"PHOS",mapping);
d62e649a	168	AliPHOSRawFitterv0 fitter;
8083e819	169	fitter.SubtractPedestals(kTRUE); // assume that data is non-ZS
f4333ce5	170
	171	if(!failZS) {
	172	fitter.SubtractPedestals(kFALSE);
	173	fitter.SetAmpOffset(offset);
	174	fitter.SetAmpThreshold(threshold);
	175	}
68aaec35	176
8083e819	177	while (stream.NextDDL()) {
8083e819	178	while (stream.NextChannel()) {
d62e649a	179
8083e819	180	cellX = stream.GetCellX();
	181	cellZ = stream.GetCellZ();
	182	caloFlag = stream.GetCaloFlag(); // 0=LG, 1=HG, 2=TRU
d62e649a	183
8083e819	184	// In case of oscillating signals with ZS, a channel can have several bunches
	185	nBunches = 0;
	186	while (stream.NextBunch()) {
	187	nBunches++;
	188	if (nBunches > 1) continue;
d62e649a	189	sigStart = stream.GetStartTimeBin();
d62e649a	190	sigLength = stream.GetBunchLength();
92236b27	191	fitter.SetChannelGeo(stream.GetModule(),cellX,cellZ,caloFlag);
92236b27	192	fitter.Eval(stream.GetSignals(),sigStart,sigLength);
8083e819	193	} // End of NextBunch()
8083e819	194
d62e649a	195	if(nBunches>1) continue;
d62e649a	196	// if (nBunches>1 \|\| caloFlag!=0 \|\| caloFlag!=1 \|\| fitter.GetSignalQuality()>1) continue;
8083e819	197
	198	e[cellX][cellZ][caloFlag] = fitter.GetEnergy();
	199	t[cellX][cellZ][caloFlag] = fitter.GetTime();
d62e649a	200
8083e819	201	if(caloFlag==1 && fitter.GetEnergy()>40)
	202	nFired++;
	203	}
d62e649a	204
	205	if(dAs[stream.GetModule()])
	206	dAs[stream.GetModule()]->FillHistograms(e,t);
	207	else
	208	dAs[stream.GetModule()] = new AliPHOSRcuDA1(stream.GetModule(),-1,0);
	209
	210	for(Int_t iX=0; iX<64; iX++) {
	211	for(Int_t iZ=0; iZ<56; iZ++) {
	212	for(Int_t iGain=0; iGain<2; iGain++) {
	213	e[iX][iZ][iGain] = 0.;
	214	t[iX][iZ][iGain] = 0.;
	215	}
	216	}
	217	}
	218
8083e819	219	}
d62e649a	220
7708b003	221	fFiredCells.Fill(nFired);
d62e649a	222
68aaec35	223	delete rawReader;
	224	nevents_physics++;
	225	}
	226
	227	nevents_total++;
	228
	229	/* free resources */
	230	free(event);
	231
	232	/* exit when last event received, no need to wait for TERM signal */
	233	if (eventT==END_OF_RUN) {
	234	printf("EOR event detected\n");
	235	break;
	236	}
	237	}
	238
	239	for(Int_t i = 0; i < 4; i++) delete mapping[i];
	240
	241	/* Be sure that all histograms are saved */
68aaec35	242
	243	const TH2F* h2=0;
	244	const TH1F* h1=0;
d62e649a	245	char localfile[128];
68aaec35	246
	247	Int_t nGood=0; // >10 entries in peak
	248	Int_t nMax=-111; // max. number of entries in peak
	249	Int_t iXmax=-1;
	250	Int_t iZmax=-1;
d62e649a	251	Int_t iModMax=-1;
	252
	253	for(Int_t iMod=0; iMod<5; iMod++) {
	254	if(!dAs[iMod]) continue;
	255
	256	printf("DA1 for module %d detected.\n",iMod);
	257	sprintf(localfile,"PHOS_Module%d_LED.root",iMod);
	258	TFile* f = new TFile(localfile,"recreate");
	259
	260	for(Int_t iX=0; iX<64; iX++) {
	261	for(Int_t iZ=0; iZ<56; iZ++) {
	262
	263	h1 = dAs[iMod]->GetHgLgRatioHistogram(iX,iZ); // High Gain/Low Gain ratio
	264	if(h1) {
	265	if(h1->GetMaximum()>10.) nGood++;
	266	if(h1->GetMaximum()>nMax) {
	267	nMax = (Int_t)h1->GetMaximum(); iXmax=iX; iZmax=iZ; iModMax=iMod;
	268	}
	269	h1->Write();
	270	}
68aaec35	271
d62e649a	272	for(Int_t iGain=0; iGain<2; iGain++) {
	273	h2 = dAs[iMod]->GetTimeEnergyHistogram(iX,iZ,iGain); // Time vs Energy
	274	if(h2) h2->Write();
	275	}
68aaec35	276
68aaec35	277	}
68aaec35	278	}
d62e649a	279
	280	fFiredCells.Write();
	281	f->Close();
	282
	283	/* Store output files to the File Exchange Server */
	284	daqDA_FES_storeFile(localfile,"LED");
68aaec35	285	}
68aaec35	286
68aaec35	287	printf("%d physics events of %d total processed.\n",nevents_physics,nevents_total);
68aaec35	288	printf("%d histograms has >10 entries in maximum, max. is %d entries ",nGood,nMax);
d62e649a	289	printf("(module,iX,iZ)=(%d,%d,%d)",iModMax,iXmax,iZmax);
68aaec35	290	printf("\n");
	291
	292	return status;
	293	}