[u/mrichter/AliRoot.git] / ZDC / ZDCLASERda.cxx

/*

This program reads the DAQ data files passed as argument using the monitoring library.

It computes the average event size and populates local "./result.txt" file with the 
result.

The program reports about its processing progress.

Messages on stdout are exported to DAQ log system.

DA for ZDC standalone pedestal runs

Contact: Chiara.Oppedisano@to.infn.it
Link: 
Run Type: STANDALONE_LASER_RUN
DA Type: LDC
Number of events needed: no constraint (tipically ~10^3)
Input Files: 
Output Files: ZDCLaser.dat
Trigger Types Used: Standalone Trigger

*/
#define PEDDATA_FILE  "ZDCPedestal.dat"

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

// DATE
#include <event.h>
#include <monitor.h>
#include <daqDA.h>

//ROOT
#include <TRandom.h>
#include <TH1F.h>
#include <TF1.h>
#include <TFile.h>
#include <TFitter.h>

//AliRoot
#include <AliRawReaderDate.h>
#include <AliRawEventHeaderBase.h>
#include <AliZDCRawStream.h>


/* Main routine
      Arguments: list of DATE raw data files
*/
int main(int argc, char **argv) {
  
  TFitter *minuitFit = new TFitter(4);
  TVirtualFitter::SetFitter(minuitFit);

  int status = 0;

  /* log start of process */
  printf("\nZDC LASER program started\n");  

  /* check that we got some arguments = list of files */
  if (argc<2) {
    printf("Wrong number of arguments\n");
    return -1;
  }

  // --- Histograms for LASER runs 
  //     20 signal channels + 2 reference PTMs
  //
  TH1F::AddDirectory(0);
  //
  TH1F *hPMRefChg = new TH1F("hPMRefChg","hPMRefChg", 100,0.,1000.);
  TH1F *hPMRefAhg = new TH1F("hPMRefAhg","hPMRefAhg", 100,0.,1000.);
  //
  TH1F *hPMRefClg = new TH1F("hPMRefClg","hPMRefClg", 100,0.,4000.);
  TH1F *hPMRefAlg = new TH1F("hPMRefAlg","hPMRefAlg", 100,0.,4000.);


  /* open result file */
  FILE *fp=NULL;
  fp=fopen("./result.txt","a");
  if (fp==NULL) {
    printf("Failed to open file\n");
    return -1;
  }
  
  FILE *mapFile4Shuttle;
  const char *mapfName = "ZDCChMapping.dat";  
        
  // *** To analyze LASER events you MUST have a pedestal data file!!!
  // *** -> check if a pedestal run has been analyzied
  int read = 0;
  read = daqDA_FES_storeFile(PEDDATA_FILE,"ZDCPEDESTAL_data");
  if(read){
    printf("\t ERROR!!! ZDCPedestal.dat file NOT FOUND in DAQ db!!!\n");
    return -1;
  }
  else printf("\t ZDCPedestal.dat file retrieved from DAQ db\n");
  
  FILE *filePed = fopen(PEDDATA_FILE,"r");
  if (filePed==NULL) {
    printf("\t ERROR!!! Can't open ZDCPedestal.dat file!!!\n");
    return -1;
  }

  // 144 = 48 in-time + 48 out-of-time + 48 correlations
  Float_t readValues[2][144], MeanPed[44], MeanPedWidth[44], 
  	MeanPedOOT[44], MeanPedWidthOOT[44];
  // ***************************************************
  //   Unless we have a narrow correlation to fit we
  //	don't fit and store in-time vs. out-of-time
  //	histograms -> mean pedstal subtracted!!!!!!
  // ***************************************************
  //Float_t CorrCoeff0[44], CorrCoeff1[44];
  //
  for(int jj=0; jj<144; jj++){
    for(int ii=0; ii<2; ii++){
       fscanf(filePed,"%f",&readValues[ii][jj]);
    }
    if(jj<48){
      MeanPed[jj] = readValues[0][jj];
      MeanPedWidth[jj] = readValues[1][jj];
      //printf("\t MeanPed[%d] = %1.1f\n",jj, MeanPed[jj]);
    }
    else if(jj>48 && jj<96){
      MeanPedOOT[jj-48] = readValues[0][jj];
      MeanPedWidthOOT[jj-48] = readValues[1][jj];
    }
    /*else if(jj>144){
      CorrCoeff0[jj-96] = readValues[0][jj]; 
      CorrCoeff1[jj-96] = readValues[1][jj];;
    }
    */
  }

  /* report progress */
  daqDA_progressReport(10);


  /* init some counters */
  int nevents_physics=0;
  int nevents_total=0;

  /* read the data files */
  int n;
  for (n=1;n<argc;n++) {
   
    status=monitorSetDataSource( argv[n] );
    if (status!=0) {
      printf("monitorSetDataSource() failed : %s\n",monitorDecodeError(status));
      return -1;
    }

    /* report progress */
    /* in this example, indexed on the number of files */
    daqDA_progressReport(10+80*n/argc);

    /* read the file */
    for(;;) {
      struct eventHeaderStruct *event;
      eventTypeType eventT;

      /* get next event */
      status=monitorGetEventDynamic((void **)&event);
      if (status==MON_ERR_EOF) break; /* end of monitoring file has been reached */
      if (status!=0) {
        printf("monitorGetEventDynamic() failed : %s\n",monitorDecodeError(status));
        return -1;
      }

      /* retry if got no event */
      if (event==NULL) {
        break;
      }

      // Initalize raw-data reading and decoding
      AliRawReader *reader = new AliRawReaderDate((void*)event);
      reader->Select("ZDC");
      // --- Reading event header
      //UInt_t evtype = reader->GetType();
      //printf("\n\t ZDCLASERda -> ev. type %d\n",evtype);
      //printf("\t ZDCLASERda -> run # %d\n",reader->GetRunNumber());
      //
      AliZDCRawStream *rawStreamZDC = new AliZDCRawStream(reader);
        

      /* use event - here, just write event id to result file */
      eventT=event->eventType;
      
      Int_t ich=0, adcMod[48], adcCh[48], sigCode[48], det[48], sec[48];
      if(eventT==START_OF_DATA){
	  	
	if(!rawStreamZDC->Next()) printf(" \t No raw data found!! \n");
        else{
	  while(rawStreamZDC->Next()){
            if(rawStreamZDC->IsChMapping()){
	      adcMod[ich] = rawStreamZDC->GetADCModFromMap(ich);
	      adcCh[ich] = rawStreamZDC->GetADCChFromMap(ich);
	      sigCode[ich] = rawStreamZDC->GetADCSignFromMap(ich);
	      det[ich] = rawStreamZDC->GetDetectorFromMap(ich);
	      sec[ich] = rawStreamZDC->GetTowerFromMap(ich);
	      ich++;
	    }
	  }
	}
	// --------------------------------------------------------
	// --- Writing ascii data file for the Shuttle preprocessor
        mapFile4Shuttle = fopen(mapfName,"w");
        for(Int_t i=0; i<ich; i++){
	   fprintf(mapFile4Shuttle,"\t%d\t%d\t%d\t%d\t%d\t%d\n",i,
	     adcMod[i],adcCh[i],sigCode[i],det[i],sec[i]);
	   //
	   //printf("ZDCLASERDA.cxx ->  ch.%d mod %d, ch %d, code %d det %d, sec %d\n",
	   //	   i,adcMod[i],adcCh[i],sigCode[i],det[i],sec[i]);
        }
        fclose(mapFile4Shuttle);
      }

      /* use event - here, just write event id to result file */
      eventT=event->eventType;
    
      if(eventT==PHYSICS_EVENT){
        //
	// --- Reading data header
        reader->ReadHeader();
        const AliRawDataHeader* header = reader->GetDataHeader();
        if(header) {
         UChar_t message = header->GetAttributes();
	 if(message & 0x20){ // DEDICATED LASER RUN
	    //printf("\t STANDALONE_LASER_RUN raw data found\n");
	    continue;
	 }
	 else{
	    printf("\t NO STANDALONE_LASER_RUN raw data found\n");
	    return -1;
	 }
  	}
  	else{
  	   printf("\t ATTENTION! No Raw Data Header found!!!\n");
  	   return -1;
  	}

  	if (!rawStreamZDC->Next()) printf(" \t No raw data found!! \n");
	//
	// ----- Setting ch. mapping -----
	for(Int_t jk=0; jk<48; jk++){
	  rawStreamZDC->SetMapADCMod(jk, adcMod[jk]);
	  rawStreamZDC->SetMapADCCh(jk, adcCh[jk]);
	  rawStreamZDC->SetMapADCSig(jk, sigCode[jk]);
	  rawStreamZDC->SetMapDet(jk, det[jk]);
	  rawStreamZDC->SetMapTow(jk, sec[jk]);
	}
  	//
	while(rawStreamZDC->Next()){
  	  Int_t index=-1;
	  // Getting data only for reference PMTs (sector[1]=5)
  	  if((rawStreamZDC->IsADCDataWord()) && (rawStreamZDC->GetSector(1)==5)){
	    index = rawStreamZDC->GetADCChannel();
	    Float_t Pedestal = MeanPed[index];
	    Float_t CorrADC = rawStreamZDC->GetADCValue() - Pedestal;
	    
	    // ==== HIGH GAIN CHAIN
	    if(rawStreamZDC->GetADCGain() == 0){
	      // %%%%% PMRef chain side C
	      if(rawStreamZDC->GetSector(0)==1) hPMRefChg->Fill(CorrADC);
	      // %%%%% PMRef side A
	      else if(rawStreamZDC->GetSector(0)==4) hPMRefAhg->Fill(CorrADC);
	    }
	    // ==== LOW GAIN CHAIN
	    else{
	      // %%%%% PMRef chain side C
	      if(rawStreamZDC->GetSector(0)==1) hPMRefClg->Fill(CorrADC);
	      // %%%%% PMRef side A
	      else if(rawStreamZDC->GetSector(0)==4) hPMRefAlg->Fill(CorrADC);
	    }
  	  }//IsADCDataWord()
  	  //
         }
         //
         nevents_physics++;
         //
	 delete reader;
         delete rawStreamZDC;

      }//(if PHYSICS_EVENT) 
      nevents_total++;

      /* free resources */
      free(event);
    
    }
  }  
  
  /* Analysis of the histograms */
  //
  Int_t maxBinRef[4], nBinRef[4];
  Float_t xMaxRef[4], maxXvalRef[4], xlowRef[4]; 
  Float_t meanRef[2], sigmaRef[2];
  TF1 *funRef[4];
  
  // ~~~~~~~~ PM Ref side C high gain chain ~~~~~~~~
  maxBinRef[0] = hPMRefChg->GetMaximumBin();
  nBinRef[0] = (hPMRefChg->GetXaxis())->GetNbins();
  xMaxRef[0] = (hPMRefChg->GetXaxis())->GetXmax();
  maxXvalRef[0] = maxBinRef[0]*xMaxRef[0]/nBinRef[0];
  // 
  if(maxXvalRef[0]-100.<0.) {xlowRef[0]=0.;}
  else xlowRef[0] = maxXvalRef[0];
  hPMRefChg->Fit("gaus","Q","",xlowRef[0],maxXvalRef[0]+100.);
  funRef[0] = hPMRefChg->GetFunction("gaus");
  meanRef[0] = (Float_t) (funRef[0]->GetParameter(1));
  sigmaRef[0] = (Float_t) (funRef[0]->GetParameter(2));
  
  // ~~~~~~~~ PM Ref side A high gain chain ~~~~~~~~
  maxBinRef[1] = hPMRefAhg->GetMaximumBin();
  nBinRef[1] = (hPMRefAhg->GetXaxis())->GetNbins();
  xMaxRef[1] = (hPMRefAhg->GetXaxis())->GetXmax();
  maxXvalRef[1] = maxBinRef[1]*xMaxRef[1]/nBinRef[1];
  //
  if(maxXvalRef[1]-100.<0.) {xlowRef[1]=0.;}
  else xlowRef[1] = maxXvalRef[1];
  hPMRefAhg->Fit("gaus","Q","",xlowRef[1],maxXvalRef[1]+100.);
  funRef[1] = hPMRefAhg->GetFunction("gaus");
  meanRef[1] = (Float_t) (funRef[1]->GetParameter(1));
  sigmaRef[1] = (Float_t) (funRef[1]->GetParameter(2));
  
  // ~~~~~~~~ PM Ref side C low gain chain ~~~~~~~~
  maxBinRef[2] = hPMRefClg->GetMaximumBin();
  nBinRef[2] = (hPMRefClg->GetXaxis())->GetNbins();
  xMaxRef[2] = (hPMRefClg->GetXaxis())->GetXmax();
  maxXvalRef[2] = maxBinRef[2]*xMaxRef[2]/nBinRef[2];
  //
  if(maxXvalRef[2]-100.<0.) {xlowRef[2]=0.;}
  else xlowRef[2] = maxXvalRef[2];
  hPMRefClg->Fit("gaus","Q","",xlowRef[2],maxXvalRef[2]+100.);
  funRef[2] = hPMRefClg->GetFunction("gaus");
  meanRef[2] = (Float_t) (funRef[2]->GetParameter(1));
  sigmaRef[2] = (Float_t) (funRef[2]->GetParameter(2));
  
  // ~~~~~~~~ PM Ref side A low gain chain ~~~~~~~~
  maxBinRef[3] = hPMRefAlg->GetMaximumBin();
  nBinRef[3] = (hPMRefAlg->GetXaxis())->GetNbins();
  xMaxRef[3] = (hPMRefAlg->GetXaxis())->GetXmax();
  maxXvalRef[3] = maxBinRef[3]*xMaxRef[3]/nBinRef[3];
  //
  if(maxXvalRef[3]-100.<0.) {xlowRef[3]=0.;}
  else xlowRef[3] = maxXvalRef[3];
  hPMRefAlg->Fit("gaus","Q","",xlowRef[3],maxXvalRef[3]+100.);
  funRef[3] = hPMRefAlg->GetFunction("gaus");
  meanRef[3] = (Float_t) (funRef[3]->GetParameter(1));
  sigmaRef[3] = (Float_t) (funRef[3]->GetParameter(2));
  //
  FILE *fileShuttle;
  const char *fName = "ZDCLaser.dat";
  fileShuttle = fopen(fName,"w");
  for(Int_t i=0; i<4; i++)  fprintf(fileShuttle,"\t%f\t%f\n",meanRef[i], sigmaRef[i]); 
  //						       
  fclose(fileShuttle);
  //
  delete hPMRefChg;
  delete hPMRefAhg;
  delete hPMRefClg;
  delete hPMRefAlg;

  //delete minuitFit;
  TVirtualFitter::SetFitter(0);

  /* write report */
  fprintf(fp,"Run #%s, received %d physics events out of %d\n",getenv("DATE_RUN_NUMBER"),nevents_physics,nevents_total);

  /* close result file */
  fclose(fp);
  
  /* report progress */
  daqDA_progressReport(90);

  /* store the result file on FES */
  status = daqDA_FES_storeFile(mapfName,"ZDCCHMAPPING_data");
  if(status){
    printf("Failed to export file : %d\n",status);
    return -1;
  }
  //
  status = daqDA_FES_storeFile(fName,"ZDCLASER_data");
  if(status){
    printf("Failed to export file : %d\n",status);
    return -1;
  }

  /* report progress */
  daqDA_progressReport(100);


  return status;
}
Commit	Line	Data
ead118d8	1	/*
	2
	3	This program reads the DAQ data files passed as argument using the monitoring library.
	4
	5	It computes the average event size and populates local "./result.txt" file with the
	6	result.
	7
	8	The program reports about its processing progress.
	9
	10	Messages on stdout are exported to DAQ log system.
	11
	12	DA for ZDC standalone pedestal runs
	13
	14	Contact: Chiara.Oppedisano@to.infn.it
	15	Link:
	16	Run Type: STANDALONE_LASER_RUN
442e1b18	17	DA Type: LDC
ead118d8	18	Number of events needed: no constraint (tipically ~10^3)
	19	Input Files:
	20	Output Files: ZDCLaser.dat
	21	Trigger Types Used: Standalone Trigger
	22
	23	*/
78beff0d	24	#define PEDDATA_FILE "ZDCPedestal.dat"
ead118d8	25
	26	#include <stdio.h>
	27	#include <stdlib.h>
	28	#include <Riostream.h>
	29
	30	// DATE
	31	#include <event.h>
	32	#include <monitor.h>
	33	#include <daqDA.h>
	34
	35	//ROOT
	36	#include <TRandom.h>
	37	#include <TH1F.h>
	38	#include <TF1.h>
	39	#include <TFile.h>
442e1b18	40	#include <TFitter.h>
ead118d8	41
	42	//AliRoot
	43	#include <AliRawReaderDate.h>
442e1b18	44	#include <AliRawEventHeaderBase.h>
ead118d8	45	#include <AliZDCRawStream.h>
	46
	47
	48	/* Main routine
	49	Arguments: list of DATE raw data files
	50	*/
	51	int main(int argc, char **argv) {
442e1b18	52
	53	TFitter *minuitFit = new TFitter(4);
	54	TVirtualFitter::SetFitter(minuitFit);
ead118d8	55
	56	int status = 0;
	57
	58	/* log start of process */
78beff0d	59	printf("\nZDC LASER program started\n");
ead118d8	60
	61	/* check that we got some arguments = list of files */
	62	if (argc<2) {
	63	printf("Wrong number of arguments\n");
	64	return -1;
	65	}
	66
	67	// --- Histograms for LASER runs
	68	// 20 signal channels + 2 reference PTMs
	69	//
	70	TH1F::AddDirectory(0);
78beff0d	71	//
	72	TH1F *hPMRefChg = new TH1F("hPMRefChg","hPMRefChg", 100,0.,1000.);
	73	TH1F *hPMRefAhg = new TH1F("hPMRefAhg","hPMRefAhg", 100,0.,1000.);
	74	//
	75	TH1F *hPMRefClg = new TH1F("hPMRefClg","hPMRefClg", 100,0.,4000.);
	76	TH1F *hPMRefAlg = new TH1F("hPMRefAlg","hPMRefAlg", 100,0.,4000.);
ead118d8	77
	78
	79	/* open result file */
	80	FILE *fp=NULL;
	81	fp=fopen("./result.txt","a");
	82	if (fp==NULL) {
	83	printf("Failed to open file\n");
	84	return -1;
	85	}
	86
442e1b18	87	FILE *mapFile4Shuttle;
442e1b18	88	const char *mapfName = "ZDCChMapping.dat";
78beff0d	89
	90	// *** To analyze LASER events you MUST have a pedestal data file!!!
	91	// *** -> check if a pedestal run has been analyzied
	92	int read = 0;
	93	read = daqDA_FES_storeFile(PEDDATA_FILE,"ZDCPEDESTAL_data");
	94	if(read){
	95	printf("\t ERROR!!! ZDCPedestal.dat file NOT FOUND in DAQ db!!!\n");
	96	return -1;
	97	}
	98	else printf("\t ZDCPedestal.dat file retrieved from DAQ db\n");
	99
	100	FILE *filePed = fopen(PEDDATA_FILE,"r");
	101	if (filePed==NULL) {
	102	printf("\t ERROR!!! Can't open ZDCPedestal.dat file!!!\n");
	103	return -1;
	104	}
	105
	106	// 144 = 48 in-time + 48 out-of-time + 48 correlations
	107	Float_t readValues[2][144], MeanPed[44], MeanPedWidth[44],
	108	MeanPedOOT[44], MeanPedWidthOOT[44];
	109	// ***************************************************
	110	// Unless we have a narrow correlation to fit we
	111	// don't fit and store in-time vs. out-of-time
	112	// histograms -> mean pedstal subtracted!!!!!!
	113	// ***************************************************
	114	//Float_t CorrCoeff0[44], CorrCoeff1[44];
	115	//
	116	for(int jj=0; jj<144; jj++){
	117	for(int ii=0; ii<2; ii++){
	118	fscanf(filePed,"%f",&readValues[ii][jj]);
	119	}
	120	if(jj<48){
	121	MeanPed[jj] = readValues[0][jj];
	122	MeanPedWidth[jj] = readValues[1][jj];
	123	//printf("\t MeanPed[%d] = %1.1f\n",jj, MeanPed[jj]);
	124	}
	125	else if(jj>48 && jj<96){
	126	MeanPedOOT[jj-48] = readValues[0][jj];
	127	MeanPedWidthOOT[jj-48] = readValues[1][jj];
	128	}
	129	/*else if(jj>144){
	130	CorrCoeff0[jj-96] = readValues[0][jj];
	131	CorrCoeff1[jj-96] = readValues[1][jj];;
	132	}
	133	*/
	134	}
ead118d8	135
	136	/* report progress */
	137	daqDA_progressReport(10);
	138
	139
	140	/* init some counters */
	141	int nevents_physics=0;
	142	int nevents_total=0;
	143
	144	/* read the data files */
	145	int n;
	146	for (n=1;n<argc;n++) {
	147
	148	status=monitorSetDataSource( argv[n] );
	149	if (status!=0) {
	150	printf("monitorSetDataSource() failed : %s\n",monitorDecodeError(status));
	151	return -1;
	152	}
	153
	154	/* report progress */
	155	/* in this example, indexed on the number of files */
	156	daqDA_progressReport(10+80*n/argc);
	157
	158	/* read the file */
	159	for(;;) {
	160	struct eventHeaderStruct *event;
	161	eventTypeType eventT;
	162
	163	/* get next event */
	164	status=monitorGetEventDynamic((void **)&event);
	165	if (status==MON_ERR_EOF) break; /* end of monitoring file has been reached */
	166	if (status!=0) {
	167	printf("monitorGetEventDynamic() failed : %s\n",monitorDecodeError(status));
	168	return -1;
	169	}
	170
	171	/* retry if got no event */
	172	if (event==NULL) {
	173	break;
	174	}
	175
442e1b18	176	// Initalize raw-data reading and decoding
	177	AliRawReader reader = new AliRawReaderDate((void)event);
	178	reader->Select("ZDC");
	179	// --- Reading event header
78beff0d	180	//UInt_t evtype = reader->GetType();
	181	//printf("\n\t ZDCLASERda -> ev. type %d\n",evtype);
	182	//printf("\t ZDCLASERda -> run # %d\n",reader->GetRunNumber());
442e1b18	183	//
	184	AliZDCRawStream *rawStreamZDC = new AliZDCRawStream(reader);
	185
	186
	187	/* use event - here, just write event id to result file */
	188	eventT=event->eventType;
	189
	190	Int_t ich=0, adcMod[48], adcCh[48], sigCode[48], det[48], sec[48];
	191	if(eventT==START_OF_DATA){
	192
	193	if(!rawStreamZDC->Next()) printf(" \t No raw data found!! \n");
	194	else{
	195	while(rawStreamZDC->Next()){
	196	if(rawStreamZDC->IsChMapping()){
	197	adcMod[ich] = rawStreamZDC->GetADCModFromMap(ich);
	198	adcCh[ich] = rawStreamZDC->GetADCChFromMap(ich);
	199	sigCode[ich] = rawStreamZDC->GetADCSignFromMap(ich);
	200	det[ich] = rawStreamZDC->GetDetectorFromMap(ich);
	201	sec[ich] = rawStreamZDC->GetTowerFromMap(ich);
	202	ich++;
	203	}
	204	}
	205	}
	206	// --------------------------------------------------------
	207	// --- Writing ascii data file for the Shuttle preprocessor
	208	mapFile4Shuttle = fopen(mapfName,"w");
	209	for(Int_t i=0; i<ich; i++){
	210	fprintf(mapFile4Shuttle,"\t%d\t%d\t%d\t%d\t%d\t%d\n",i,
	211	adcMod[i],adcCh[i],sigCode[i],det[i],sec[i]);
	212	//
78beff0d	213	//printf("ZDCLASERDA.cxx -> ch.%d mod %d, ch %d, code %d det %d, sec %d\n",
442e1b18	214	// i,adcMod[i],adcCh[i],sigCode[i],det[i],sec[i]);
	215	}
	216	fclose(mapFile4Shuttle);
	217	}
ead118d8	218
	219	/* use event - here, just write event id to result file */
	220	eventT=event->eventType;
	221
	222	if(eventT==PHYSICS_EVENT){
ead118d8	223	//
442e1b18	224	// --- Reading data header
442e1b18	225	reader->ReadHeader();
ead118d8	226	const AliRawDataHeader* header = reader->GetDataHeader();
	227	if(header) {
	228	UChar_t message = header->GetAttributes();
	229	if(message & 0x20){ // DEDICATED LASER RUN
442e1b18	230	//printf("\t STANDALONE_LASER_RUN raw data found\n");
ead118d8	231	continue;
	232	}
	233	else{
	234	printf("\t NO STANDALONE_LASER_RUN raw data found\n");
	235	return -1;
	236	}
	237	}
442e1b18	238	else{
	239	printf("\t ATTENTION! No Raw Data Header found!!!\n");
	240	return -1;
	241	}
	242
ead118d8	243	if (!rawStreamZDC->Next()) printf(" \t No raw data found!! \n");
442e1b18	244	//
	245	// ----- Setting ch. mapping -----
	246	for(Int_t jk=0; jk<48; jk++){
	247	rawStreamZDC->SetMapADCMod(jk, adcMod[jk]);
	248	rawStreamZDC->SetMapADCCh(jk, adcCh[jk]);
	249	rawStreamZDC->SetMapADCSig(jk, sigCode[jk]);
	250	rawStreamZDC->SetMapDet(jk, det[jk]);
	251	rawStreamZDC->SetMapTow(jk, sec[jk]);
	252	}
ead118d8	253	//
	254	while(rawStreamZDC->Next()){
	255	Int_t index=-1;
78beff0d	256	// Getting data only for reference PMTs (sector[1]=5)
78beff0d	257	if((rawStreamZDC->IsADCDataWord()) && (rawStreamZDC->GetSector(1)==5)){
ead118d8	258	index = rawStreamZDC->GetADCChannel();
	259	Float_t Pedestal = MeanPed[index];
	260	Float_t CorrADC = rawStreamZDC->GetADCValue() - Pedestal;
78beff0d	261
	262	// ==== HIGH GAIN CHAIN
	263	if(rawStreamZDC->GetADCGain() == 0){
	264	// %%%%% PMRef chain side C
	265	if(rawStreamZDC->GetSector(0)==1) hPMRefChg->Fill(CorrADC);
	266	// %%%%% PMRef side A
	267	else if(rawStreamZDC->GetSector(0)==4) hPMRefAhg->Fill(CorrADC);
ead118d8	268	}
78beff0d	269	// ==== LOW GAIN CHAIN
	270	else{
	271	// %%%%% PMRef chain side C
	272	if(rawStreamZDC->GetSector(0)==1) hPMRefClg->Fill(CorrADC);
	273	// %%%%% PMRef side A
	274	else if(rawStreamZDC->GetSector(0)==4) hPMRefAlg->Fill(CorrADC);
ead118d8	275	}
	276	}//IsADCDataWord()
	277	//
	278	}
	279	//
	280	nevents_physics++;
	281	//
	282	delete reader;
	283	delete rawStreamZDC;
	284
	285	}//(if PHYSICS_EVENT)
	286	nevents_total++;
	287
	288	/* free resources */
	289	free(event);
	290
	291	}
	292	}
	293
	294	/* Analysis of the histograms */
	295	//
78beff0d	296	Int_t maxBinRef[4], nBinRef[4];
	297	Float_t xMaxRef[4], maxXvalRef[4], xlowRef[4];
	298	Float_t meanRef[2], sigmaRef[2];
	299	TF1 *funRef[4];
6f427255	300
6f427255	301	// ~~~~~~~~ PM Ref side C high gain chain ~~~~~~~~
78beff0d	302	maxBinRef[0] = hPMRefChg->GetMaximumBin();
	303	nBinRef[0] = (hPMRefChg->GetXaxis())->GetNbins();
	304	xMaxRef[0] = (hPMRefChg->GetXaxis())->GetXmax();
ead118d8	305	maxXvalRef[0] = maxBinRef[0]*xMaxRef[0]/nBinRef[0];
6f427255	306	//
ead118d8	307	if(maxXvalRef[0]-100.<0.) {xlowRef[0]=0.;}
ead118d8	308	else xlowRef[0] = maxXvalRef[0];
78beff0d	309	hPMRefChg->Fit("gaus","Q","",xlowRef[0],maxXvalRef[0]+100.);
78beff0d	310	funRef[0] = hPMRefChg->GetFunction("gaus");
ead118d8	311	meanRef[0] = (Float_t) (funRef[0]->GetParameter(1));
ead118d8	312	sigmaRef[0] = (Float_t) (funRef[0]->GetParameter(2));
6f427255	313
6f427255	314	// ~~~~~~~~ PM Ref side A high gain chain ~~~~~~~~
78beff0d	315	maxBinRef[1] = hPMRefAhg->GetMaximumBin();
	316	nBinRef[1] = (hPMRefAhg->GetXaxis())->GetNbins();
	317	xMaxRef[1] = (hPMRefAhg->GetXaxis())->GetXmax();
ead118d8	318	maxXvalRef[1] = maxBinRef[1]*xMaxRef[1]/nBinRef[1];
	319	//
	320	if(maxXvalRef[1]-100.<0.) {xlowRef[1]=0.;}
	321	else xlowRef[1] = maxXvalRef[1];
78beff0d	322	hPMRefAhg->Fit("gaus","Q","",xlowRef[1],maxXvalRef[1]+100.);
78beff0d	323	funRef[1] = hPMRefAhg->GetFunction("gaus");
ead118d8	324	meanRef[1] = (Float_t) (funRef[1]->GetParameter(1));
ead118d8	325	sigmaRef[1] = (Float_t) (funRef[1]->GetParameter(2));
6f427255	326
6f427255	327	// ~~~~~~~~ PM Ref side C low gain chain ~~~~~~~~
78beff0d	328	maxBinRef[2] = hPMRefClg->GetMaximumBin();
	329	nBinRef[2] = (hPMRefClg->GetXaxis())->GetNbins();
	330	xMaxRef[2] = (hPMRefClg->GetXaxis())->GetXmax();
	331	maxXvalRef[2] = maxBinRef[2]*xMaxRef[2]/nBinRef[2];
	332	//
	333	if(maxXvalRef[2]-100.<0.) {xlowRef[2]=0.;}
	334	else xlowRef[2] = maxXvalRef[2];
	335	hPMRefClg->Fit("gaus","Q","",xlowRef[2],maxXvalRef[2]+100.);
	336	funRef[2] = hPMRefClg->GetFunction("gaus");
	337	meanRef[2] = (Float_t) (funRef[2]->GetParameter(1));
	338	sigmaRef[2] = (Float_t) (funRef[2]->GetParameter(2));
6f427255	339
6f427255	340	// ~~~~~~~~ PM Ref side A low gain chain ~~~~~~~~
78beff0d	341	maxBinRef[3] = hPMRefAlg->GetMaximumBin();
	342	nBinRef[3] = (hPMRefAlg->GetXaxis())->GetNbins();
	343	xMaxRef[3] = (hPMRefAlg->GetXaxis())->GetXmax();
	344	maxXvalRef[3] = maxBinRef[3]*xMaxRef[3]/nBinRef[3];
	345	//
	346	if(maxXvalRef[3]-100.<0.) {xlowRef[3]=0.;}
	347	else xlowRef[3] = maxXvalRef[3];
	348	hPMRefAlg->Fit("gaus","Q","",xlowRef[3],maxXvalRef[3]+100.);
	349	funRef[3] = hPMRefAlg->GetFunction("gaus");
	350	meanRef[3] = (Float_t) (funRef[3]->GetParameter(1));
	351	sigmaRef[3] = (Float_t) (funRef[3]->GetParameter(2));
	352	//
ead118d8	353	FILE *fileShuttle;
	354	const char *fName = "ZDCLaser.dat";
	355	fileShuttle = fopen(fName,"w");
78beff0d	356	for(Int_t i=0; i<4; i++) fprintf(fileShuttle,"\t%f\t%f\n",meanRef[i], sigmaRef[i]);
ead118d8	357	//
	358	fclose(fileShuttle);
	359	//
78beff0d	360	delete hPMRefChg;
	361	delete hPMRefAhg;
	362	delete hPMRefClg;
	363	delete hPMRefAlg;
ead118d8	364
442e1b18	365	//delete minuitFit;
	366	TVirtualFitter::SetFitter(0);
	367
ead118d8	368	/* write report */
	369	fprintf(fp,"Run #%s, received %d physics events out of %d\n",getenv("DATE_RUN_NUMBER"),nevents_physics,nevents_total);
	370
	371	/* close result file */
	372	fclose(fp);
	373
	374	/* report progress */
	375	daqDA_progressReport(90);
	376
	377	/* store the result file on FES */
442e1b18	378	status = daqDA_FES_storeFile(mapfName,"ZDCCHMAPPING_data");
	379	if(status){
	380	printf("Failed to export file : %d\n",status);
	381	return -1;
	382	}
	383	//
ead118d8	384	status = daqDA_FES_storeFile(fName,"ZDCLASER_data");
	385	if(status){
	386	printf("Failed to export file : %d\n",status);
	387	return -1;
	388	}
	389
	390	/* report progress */
	391	daqDA_progressReport(100);
	392
	393
	394	return status;
	395	}