[u/mrichter/AliRoot.git] / T0 / T0Laserda.cxx

/*
T0 DA for online calibration
 
Contact: Michal.Oledzki@cern.ch
Link: http://users.jyu.fi/~mioledzk/
Run Type: STANDALONE
DA Type: MON
Number of events needed: 400000 
Input Files: inLaser.dat, external parameters
Output Files: daLaser.root, to be exported to the DAQ FXS
Trigger types used: CALIBRATION_EVENT

*/

#define FILE_OUT "daLaser.root"
#define FILE_IN "inLaser.dat"
#include <daqDA.h>
#include <event.h>
#include <monitor.h>
 
#include <Riostream.h>
#include <stdio.h>
#include <stdlib.h>

//AliRoot
#include <AliRawReaderDate.h>
#include <AliRawReader.h>
#include <AliT0RawReader.h>
#include <AliT0CalibAmp.h>

//ROOT
#include "TROOT.h"
#include "TPluginManager.h"
#include "TFile.h"
#include "TKey.h"
#include "TH2S.h"
#include "TObject.h"
#include "TBenchmark.h"
#include "TRandom.h"
#include "TMath.h"
#include "TCanvas.h"
#include "TString.h"
#include "TH1.h"
#include "TF1.h"
#include "TSpectrum.h"
#include "TVirtualFitter.h"
//AMORE
//
#ifdef ALI_AMORE
#include <AmoreDA.h>
#endif


float lcfd, hcfd;
/* Main routine
      Arguments: 
      1- monitoring data source
*/
int main(int argc, char **argv) {
  int status;
  
  /* magic line */
  gROOT->GetPluginManager()->AddHandler("TVirtualStreamerInfo",
					"*",
					"TStreamerInfo",
					"RIO",
					"TStreamerInfo()"); 
  
  Int_t nEntries = daqDA_ECS_getTotalIteration(); // usually = 11 = Nb of calibration runs
 cout<<" nEntries "<<nEntries<<endl;
 Int_t nInit=1;  // = 0 all DAC values ; = 1 DAC=0 excluded (default=1)
  // Reading current iteration
  Int_t nIndex = daqDA_ECS_getCurrentIteration();
  if(nIndex<0 || nIndex>nEntries) {printf("\n Failed: nIndex = %d\n",nIndex); return -1 ;}
  

// decode the input line
  if (argc!=2) {
    printf("Wrong number of arguments\n");
    return -1;
  }
 

  Float_t mipsin[20];
   if(daqDA_DB_getFile(FILE_IN, FILE_IN)){
     printf("Couldn't get input file >>inLaser.dat<< from DAQ_DB !!!\n");
     return -1;
  }

  ifstream filein(FILE_IN,ios::in); 
  Int_t k=0;
  while (k<nEntries ) { 
    filein >>mipsin[k] ;
    cout<<" "<<mipsin[k]<<endl;
    k++; }
  filein>>lcfd;
  filein>>hcfd;
  filein.close();


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

  // Char_t inputFile[256]="";


  /* 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);
  

  /* log start of process */
  printf("T0 monitoring program started\n");  
  
  // Allocation of histograms - start
  
  TH1F *hQTC[24];  TH1F *hLED[24]; TH1F *hCFD[24];
  printf(" CFD low limit %f high %f",lcfd, hcfd);
  
  for(Int_t ic=0; ic<24; ic++) 
    {
      hQTC[ic] = new TH1F(Form("hQTC%d_%d",ic+1,nIndex),"QTC",1000, 500, 4500);
      hLED[ic] = new TH1F(Form("hLED%d_%d",ic+1,nIndex),"LED",300,300,600);
      hCFD[ic] = new TH1F(Form("hCFD%d_%d",ic+1,nIndex),"CFD", Int_t ((hcfd-lcfd)/2), lcfd, hcfd);
    }
 
  // Allocation of histograms - end
  
  // Reading current iteration
   
  Int_t iev=0;
 
  /* 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==(int)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;
    
    switch (event->eventType){
      
    case START_OF_RUN:
      break;
      
    case END_OF_RUN:
      break;
      
    case CALIBRATION_EVENT:
      //      case PHYSICS_EVENT:
      iev++; 
      
      if(iev==1) printf("First event  %i\n",iev);
      
      
      // Initalize raw-data reading and decoding
      AliRawReader *reader = new AliRawReaderDate((void*)event);
      
      // Enable the following two lines in case of real-data
      reader->RequireHeader(kTRUE);
      AliT0RawReader *start = new AliT0RawReader(reader, kTRUE);

      // Read raw data
      Int_t allData[106][5];
      for(Int_t i0=0;i0<106;i0++)
      	for(Int_t j0=0;j0<5;j0++)
		allData[i0][j0] = 0;
      
      if(start->Next()){
        for (Int_t i=0; i<106; i++) {
	  for(Int_t iHit=0;iHit<5;iHit++){
	    allData[i][iHit]= start->GetData(i,iHit);
	  }
        }
      }
      else 
	printf("No data for T0 found!!!\n");
 
      
      // Fill the histograms
      
      for (Int_t ik = 0; ik<24; ik+=2)
	{
	  Int_t cc = ik/2;
	  if(allData[ik+25][0]>0 && allData[ik+26][0]>0)
	    hQTC[cc]->Fill((allData[ik+25][0]-allData[ik+26][0]));
	  if(allData[cc+13][0]>0 && allData[cc+1][0]>0)
	    hLED[cc]->Fill(allData[cc+13][0]-allData[cc+1][0]);
	  if(allData[cc+1][0] > 0) hCFD[cc]->Fill(allData[cc+1][0]);
	  //	  printf("%i %i CFD %i LED_CFD %i\n",
	  //	  ik,cc,allData[cc+1][0],allData[cc+1][0]);

	}	   
      
      
      for (Int_t ik = 24; ik<48; ik+=2)
	{
	  Int_t cc = ik/2;
	   if(allData[ik+57][0]>0 && allData[ik+58][0]>0 && allData[cc+45][0]>0)
	     hQTC[cc]->Fill(allData[ik+57][0]-allData[ik+58][0]);
	   
	   if(allData[cc+57][0]>0 && allData[cc+45][0]>0)
	     hLED[cc]->Fill(allData[cc+57][0]-allData[cc+45][0]);
	   if(allData[cc+45][0] > 0) hCFD[cc]->Fill(allData[cc+45][0]);
	   //  printf("%i %i CFD %i LED_CFD %i\n",
	   //  ik,cc,allData[cc+45][0],allData[cc+45][0]);

	}
      
      delete start;
      start = 0x0;
      reader->Reset();
      // End of fill histograms

    }
    
    /* 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");
      printf("Number of events processed - %i\n ",iev);
      break;
    }
  }

  printf("After loop, before writing histos\n");
  TH1F* hAmp = new TH1F("hAmpLaser"," Laser amplitude ", 1000, 0.5, 10.5);  
  for(Int_t k=0; k<nEntries; k++)   hAmp->Fill(mipsin[k]); 
  // write a file with the histograms
  TFile *hist=0;
  if(nIndex == 1 )
    hist = new TFile(FILE_OUT,"RECREATE");
  else
    hist = new TFile(FILE_OUT,"UPDATE");
  hist->cd();
  
  for(Int_t j=0;j<24;j++)
    {
      if(hQTC[j]->GetEntries()>0) hQTC[j]->Write();
      if(hLED[j]->GetEntries()>0) hLED[j]->Write();
      if(hCFD[j]->GetEntries()>0) hCFD[j]->Write();
    }
  hAmp->Write();
  
  hist->Close();
  delete hist;
  
  status=0;
  
  /* export file to FXS */
  if (daqDA_FES_storeFile(FILE_OUT, "AMPLITUDE_CALIBRATION")) {
    status=-2;
  }
  
  return status;
}
Commit	Line	Data
f16a53cf	1	/*
6145b1a7	2	T0 DA for online calibration
271b5bd3	3
f16a53cf	4	Contact: Michal.Oledzki@cern.ch
6145b1a7	5	Link: http://users.jyu.fi/~mioledzk/
49ab1618	6	Run Type: STANDALONE
f16a53cf	7	DA Type: MON
6145b1a7	8	Number of events needed: 400000
6145b1a7	9	Input Files: inLaser.dat, external parameters
f16a53cf	10	Output Files: daLaser.root, to be exported to the DAQ FXS
49ab1618	11	Trigger types used: CALIBRATION_EVENT
f16a53cf	12
f16a53cf	13	*/
99194e07	14
f16a53cf	15	#define FILE_OUT "daLaser.root"
6145b1a7	16	#define FILE_IN "inLaser.dat"
f16a53cf	17	#include <daqDA.h>
99194e07	18	#include <event.h>
	19	#include <monitor.h>
	20
	21	#include <Riostream.h>
	22	#include <stdio.h>
	23	#include <stdlib.h>
	24
	25	//AliRoot
	26	#include <AliRawReaderDate.h>
	27	#include <AliRawReader.h>
	28	#include <AliT0RawReader.h>
933d9707	29	#include <AliT0CalibAmp.h>
99194e07	30
99194e07	31	//ROOT
0acfe114	32	#include "TROOT.h"
	33	#include "TPluginManager.h"
	34	#include "TFile.h"
99194e07	35	#include "TKey.h"
	36	#include "TH2S.h"
	37	#include "TObject.h"
	38	#include "TBenchmark.h"
	39	#include "TRandom.h"
	40	#include "TMath.h"
	41	#include "TCanvas.h"
	42	#include "TString.h"
	43	#include "TH1.h"
	44	#include "TF1.h"
	45	#include "TSpectrum.h"
	46	#include "TVirtualFitter.h"
933d9707	47	//AMORE
	48	//
	49	#ifdef ALI_AMORE
	50	#include <AmoreDA.h>
	51	#endif
	52
	53
	54	float lcfd, hcfd;
99194e07	55	/* Main routine
	56	Arguments:
	57	1- monitoring data source
	58	*/
	59	int main(int argc, char **argv) {
	60	int status;
	61
0acfe114	62	/* magic line */
	63	gROOT->GetPluginManager()->AddHandler("TVirtualStreamerInfo",
	64	"*",
	65	"TStreamerInfo",
	66	"RIO",
	67	"TStreamerInfo()");
19e2ac29	68
933d9707	69	Int_t nEntries = daqDA_ECS_getTotalIteration(); // usually = 11 = Nb of calibration runs
	70	cout<<" nEntries "<<nEntries<<endl;
	71	Int_t nInit=1; // = 0 all DAC values ; = 1 DAC=0 excluded (default=1)
	72	// Reading current iteration
	73	Int_t nIndex = daqDA_ECS_getCurrentIteration();
	74	if(nIndex<0 \|\| nIndex>nEntries) {printf("\n Failed: nIndex = %d\n",nIndex); return -1 ;}
19e2ac29	75
933d9707	76
	77	// decode the input line
	78	if (argc!=2) {
	79	printf("Wrong number of arguments\n");
	80	return -1;
19e2ac29	81	}
933d9707	82
19e2ac29	83
933d9707	84	Float_t mipsin[20];
	85	if(daqDA_DB_getFile(FILE_IN, FILE_IN)){
	86	printf("Couldn't get input file >>inLaser.dat<< from DAQ_DB !!!\n");
	87	return -1;
6145b1a7	88	}
6145b1a7	89
933d9707	90	ifstream filein(FILE_IN,ios::in);
	91	Int_t k=0;
	92	while (k<nEntries ) {
	93	filein >>mipsin[k] ;
	94	cout<<" "<<mipsin[k]<<endl;
	95	k++; }
	96	filein>>lcfd;
	97	filein>>hcfd;
	98	filein.close();
	99
	100
	101
	102	/*
99194e07	103	if (argc!=2) {
	104	printf("Wrong number of arguments\n");
	105	return -1;
	106	}
933d9707	107	*/
	108
	109	// Char_t inputFile[256]="";
99194e07	110
	111
	112	/* define data source : this is argument 1 */
	113	status=monitorSetDataSource( argv[1] );
	114	if (status!=0) {
	115	printf("monitorSetDataSource() failed : %s\n",monitorDecodeError(status));
	116	return -1;
	117	}
	118
	119
	120	/* declare monitoring program */
	121	status=monitorDeclareMp( __FILE__ );
	122	if (status!=0) {
	123	printf("monitorDeclareMp() failed : %s\n",monitorDecodeError(status));
	124	return -1;
	125	}
	126
	127
	128	/* define wait event timeout - 1s max */
	129	monitorSetNowait();
	130	monitorSetNoWaitNetworkTimeout(1000);
	131
	132
	133	/* log start of process */
	134	printf("T0 monitoring program started\n");
933d9707	135
99194e07	136	// Allocation of histograms - start
933d9707	137
	138	TH1F hQTC[24]; TH1F hLED[24]; TH1F *hCFD[24];
	139	printf(" CFD low limit %f high %f",lcfd, hcfd);
	140
	141	for(Int_t ic=0; ic<24; ic++)
271b5bd3	142	{
933d9707	143	hQTC[ic] = new TH1F(Form("hQTC%d_%d",ic+1,nIndex),"QTC",1000, 500, 4500);
	144	hLED[ic] = new TH1F(Form("hLED%d_%d",ic+1,nIndex),"LED",300,300,600);
	145	hCFD[ic] = new TH1F(Form("hCFD%d_%d",ic+1,nIndex),"CFD", Int_t ((hcfd-lcfd)/2), lcfd, hcfd);
99194e07	146	}
933d9707	147
99194e07	148	// Allocation of histograms - end
933d9707	149
	150	// Reading current iteration
	151
99194e07	152	Int_t iev=0;
933d9707	153
99194e07	154	/* main loop (infinite) */
	155	for(;;) {
	156	struct eventHeaderStruct *event;
	157	eventTypeType eventT;
933d9707	158
99194e07	159	/* check shutdown condition */
	160	if (daqDA_checkShutdown()) {break;}
	161
	162	/* get next event (blocking call until timeout) */
	163	status=monitorGetEventDynamic((void **)&event);
	164	if (status==(int)MON_ERR_EOF) {
	165	printf ("End of File detected\n");
	166	break; /* end of monitoring file has been reached */
	167	}
	168
	169	if (status!=0) {
	170	printf("monitorGetEventDynamic() failed : %s\n",monitorDecodeError(status));
	171	break;
	172	}
933d9707	173
99194e07	174	/* retry if got no event */
	175	if (event==NULL) {
	176	continue;
	177	}
933d9707	178
99194e07	179	/* use event - here, just write event id to result file */
99194e07	180	eventT=event->eventType;
933d9707	181
99194e07	182	switch (event->eventType){
933d9707	183
	184	case START_OF_RUN:
	185	break;
	186
	187	case END_OF_RUN:
	188	break;
	189
	190	case CALIBRATION_EVENT:
	191	// case PHYSICS_EVENT:
19e2ac29	192	iev++;
933d9707	193
	194	if(iev==1) printf("First event %i\n",iev);
	195
	196
99194e07	197	// Initalize raw-data reading and decoding
99194e07	198	AliRawReader reader = new AliRawReaderDate((void)event);
933d9707	199
99194e07	200	// Enable the following two lines in case of real-data
933d9707	201	reader->RequireHeader(kTRUE);
99194e07	202	AliT0RawReader *start = new AliT0RawReader(reader, kTRUE);
	203
	204	// Read raw data
271b5bd3	205	Int_t allData[106][5];
271b5bd3	206	for(Int_t i0=0;i0<106;i0++)
99194e07	207	for(Int_t j0=0;j0<5;j0++)
99194e07	208	allData[i0][j0] = 0;
933d9707	209
933d9707	210	if(start->Next()){
271b5bd3	211	for (Int_t i=0; i<106; i++) {
933d9707	212	for(Int_t iHit=0;iHit<5;iHit++){
	213	allData[i][iHit]= start->GetData(i,iHit);
	214	}
99194e07	215	}
933d9707	216	}
	217	else
	218	printf("No data for T0 found!!!\n");
	219
	220
99194e07	221	// Fill the histograms
271b5bd3	222
99194e07	223	for (Int_t ik = 0; ik<24; ik+=2)
933d9707	224	{
	225	Int_t cc = ik/2;
	226	if(allData[ik+25][0]>0 && allData[ik+26][0]>0)
	227	hQTC[cc]->Fill((allData[ik+25][0]-allData[ik+26][0]));
	228	if(allData[cc+13][0]>0 && allData[cc+1][0]>0)
	229	hLED[cc]->Fill(allData[cc+13][0]-allData[cc+1][0]);
	230	if(allData[cc+1][0] > 0) hCFD[cc]->Fill(allData[cc+1][0]);
	231	// printf("%i %i CFD %i LED_CFD %i\n",
	232	// ik,cc,allData[cc+1][0],allData[cc+1][0]);
	233
	234	}
	235
	236
99194e07	237	for (Int_t ik = 24; ik<48; ik+=2)
933d9707	238	{
	239	Int_t cc = ik/2;
	240	if(allData[ik+57][0]>0 && allData[ik+58][0]>0 && allData[cc+45][0]>0)
	241	hQTC[cc]->Fill(allData[ik+57][0]-allData[ik+58][0]);
	242
	243	if(allData[cc+57][0]>0 && allData[cc+45][0]>0)
	244	hLED[cc]->Fill(allData[cc+57][0]-allData[cc+45][0]);
	245	if(allData[cc+45][0] > 0) hCFD[cc]->Fill(allData[cc+45][0]);
	246	// printf("%i %i CFD %i LED_CFD %i\n",
	247	// ik,cc,allData[cc+45][0],allData[cc+45][0]);
	248
99194e07	249	}
271b5bd3	250
933d9707	251	delete start;
	252	start = 0x0;
	253	reader->Reset();
99194e07	254	// End of fill histograms
	255
	256	}
933d9707	257
99194e07	258	/* free resources */
	259	free(event);
	260
	261	/* exit when last event received, no need to wait for TERM signal */
	262	if (eventT==END_OF_RUN) {
	263	printf("EOR event detected\n");
19e2ac29	264	printf("Number of events processed - %i\n ",iev);
99194e07	265	break;
	266	}
	267	}
933d9707	268
6145b1a7	269	printf("After loop, before writing histos\n");
933d9707	270	TH1F* hAmp = new TH1F("hAmpLaser"," Laser amplitude ", 1000, 0.5, 10.5);
933d9707	271	for(Int_t k=0; k<nEntries; k++) hAmp->Fill(mipsin[k]);
99194e07	272	// write a file with the histograms
933d9707	273	TFile *hist=0;
	274	if(nIndex == 1 )
	275	hist = new TFile(FILE_OUT,"RECREATE");
	276	else
	277	hist = new TFile(FILE_OUT,"UPDATE");
	278	hist->cd();
	279
271b5bd3	280	for(Int_t j=0;j<24;j++)
271b5bd3	281	{
933d9707	282	if(hQTC[j]->GetEntries()>0) hQTC[j]->Write();
	283	if(hLED[j]->GetEntries()>0) hLED[j]->Write();
	284	if(hCFD[j]->GetEntries()>0) hCFD[j]->Write();
99194e07	285	}
933d9707	286	hAmp->Write();
933d9707	287
99194e07	288	hist->Close();
99194e07	289	delete hist;
933d9707	290
6145b1a7	291	status=0;
933d9707	292
6145b1a7	293	/* export file to FXS */
933d9707	294	if (daqDA_FES_storeFile(FILE_OUT, "AMPLITUDE_CALIBRATION")) {
6145b1a7	295	status=-2;
6145b1a7	296	}
933d9707	297
99194e07	298	return status;
	299	}
	300