[u/mrichter/AliRoot.git] / TOF / TOFda.cxx

/*

DAcase2.c

This program connects to the DAQ data source passed as argument
and populates local "./result.txt" file with the ids of events received
during the run.

The program exits when being asked to shut down (daqDA_checkshutdown)
or End of Run event.

Messages on stdout are exported to DAQ log system.

contact: alice-datesupport@cern.ch

*/
extern "C" {
#include <daqDA.h>
}

#include "event.h"
#include "monitor.h"
//#include "daqDA.h"

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

//AliRoot
#include "AliTOFRawStream.h"
#include "AliRawReaderDate.h"
#include "AliTOFGeometry.h"
#include "AliTOFGeometryV5.h"
#include "AliT0digit.h"
#include "AliT0RawReader.h"

//ROOT
#include "TFile.h"
#include "TKey.h"
#include "TH2S.h"
#include "TObject.h"
#include "TBenchmark.h"
#include "TMath.h"
#include "TRandom.h"


/* Main routine
      Arguments: 
      1- monitoring data source
*/
int main(int argc, char **argv) {
  
  AliTOFGeometry * geomV5 = new AliTOFGeometryV5();
  AliTOFGeometry * geom = new AliTOFGeometry();

  static const Int_t size = geomV5->NPadXSector()*geomV5->NSectors();
  static const Int_t nbins = 500;
  static const Int_t binmin = -20;
  const Float_t c = 2.99792458E10; //speed of light
  TH1F::AddDirectory(0);
  TH2S * htofPartial = new TH2S("htof","histo with delays", size,-0.5,size*1.-0.5,nbins,binmin-0.5,nbins*1.+binmin-0.5);
  
  TRandom *rand = new TRandom();  //to be used for testing with cosmic data
  rand->SetSeed(0);               //to be used for testing with cosmic data

  //TTree *tree = 0x0;  // tree for T0 decoder
      
  // decoding the events
  
  int status;
  bool decodeStatus;
  if (argc!=2) {
    printf("Wrong number of arguments\n");
    return -1;
  }

  /* open result file */
  FILE *fp=NULL;
  fp=fopen("./result.txt","a");
  if (fp==NULL) {
    printf("Failed to open file\n");
    return -1;
  }

  /* 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("DA example case2 monitoring program started\n");  

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

  struct equipmentStruct *equipment;
  int *eventEnd;
  int *eventData;
  int *equipmentEnd;
  int *equipmentData;
  int *equipmentID;
  struct eventHeaderStruct *event;
  eventTypeType eventT;
  Int_t iev=0;

  /* main loop (infinite) */
  for(;;) {
    
    /* 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;
    }

    iev++; 

   /* use event - here, just write event id to result file */
    eventT=event->eventType;
    switch (event->eventType){
      
      /* START OF RUN */
    case START_OF_RUN:
      break;
      /* END START OF RUN */
      
    /* END OF RUN */
    case END_OF_RUN:
      break;
      
    case PHYSICS_EVENT:
      printf(" event number = %i \n",iev);
      //if (iev%10000 ==0) printf(" event number = %i \n",iev);
      //if (iev > 50000) break;
      AliRawReader *rawReader = new AliRawReaderDate((void*)event);
      //      rawReader->RequireHeader(kFALSE);
      //rawReader->LoadEquipmentIdsMap("TOFmap.txt");  //to be used if no exact mapping implemented 
      Int_t meantime = 0;     

            
      //      TTree *tree = new TTree();  // tree for T0 decoder
      AliT0RawReader *rawReaderT0 = new AliT0RawReader(rawReader);
      //      printf("rawReaderT0 = %p \n", rawReaderT0);
      //printf("rawReader = %p \n", rawReader);
      //printf("event = %p \n", event);
      //      AliT0digit *digit = 0x0;
      //tree->SetBranchAddress("T0",&digit);
      
      if (!rawReaderT0->Next())
       printf(" no raw data found!! %i", rawReaderT0->Next());
      Int_t allData[110][5];
      for (Int_t i=0; i<110; i++) {
	allData[i][0]=rawReaderT0->GetData(i,0);
      }
      meantime = allData[49][0];
      printf("time zero (ns) = %i (%f) \n", meantime, meantime*25*1E-3-200);
      
      delete rawReaderT0;
      rawReaderT0 = 0x0;
      rawReader->Reset();
      
      AliTOFRawStream *rawStreamTOF = new AliTOFRawStream(rawReader);
      
      //loop the event data	  	  
      Int_t detectorIndex[5] = {-1, -1, -1, -1, -1};
      
      printf("before T0 \n");
      
      while(rawStreamTOF->Next()){
	for (Int_t ii=0; ii<5; ii++) detectorIndex[ii] = -1;
	
	detectorIndex[0] = (Int_t)rawStreamTOF->GetSector();
	detectorIndex[1] = (Int_t)rawStreamTOF->GetPlate();
	detectorIndex[2] = (Int_t)rawStreamTOF->GetStrip();
	detectorIndex[3] = (Int_t)rawStreamTOF->GetPadZ();
	detectorIndex[4] = (Int_t)rawStreamTOF->GetPadX();
	
	if (detectorIndex[0]==-1 ||
	    detectorIndex[1]==-1 ||
	    detectorIndex[2]==-1 ||
	    detectorIndex[3]==-1 ||
	    detectorIndex[4]==-1) continue;
	else {
	  Float_t tdc = (Float_t)rawStreamTOF->GetTDC();
	  Int_t tof = (Int_t)rawStreamTOF->GetTofBin();
	  Int_t detID[5]={0,0,0,0,0};
	  detectorIndex[0] = rawStreamTOF->GetSector(); 
	  detectorIndex[1] = rawStreamTOF->GetPlate();
	  detectorIndex[2] = rawStreamTOF->GetStrip(); 
	  detectorIndex[3] = rawStreamTOF->GetPadZ(); 
	  detectorIndex[4] = rawStreamTOF->GetPadX(); 
	  Int_t index = rawStreamTOF->GetIndex(detectorIndex);
	  Float_t pos[3];
 	  geomV5->GetPosPar(detectorIndex,pos);
	  Float_t texp=TMath::Sqrt(pos[0]*pos[0]+pos[1]*pos[1]+pos[2]*pos[2])/c*1E9; //expected time in ns
	  Float_t texpBin=(texp*1E3-32)/AliTOFGeometry::TdcBinWidth(); //expected time in number of TDC bin
	  //to be uded with cosmics
	  //Float_t tsim = (Float_t)rand->Gaus(texp,1E-1); //TDC measured time in ns, simulated to be used for testing with cosmic data  
	  //Float_t delta = tsim-texp;  
	  //Int_t deltabin = (Int_t)((delta*1E3-32)/AliTOFGeometry::TdcBinWidth());    //to be used for testing with cosmics data
	  Int_t deltabin = tof-TMath::Nint(texpBin);   //to be used with real data; rounding expected time to Int_t
	  htofPartial->Fill(index,deltabin); //channel index start from 0, bin index from 1
	  //debugging printings
	  printf("sector %i, plate %i, strip %i, padz %i, padx %i \n",detectorIndex[0],detectorIndex[1],detectorIndex[2],detectorIndex[3],detectorIndex[4]);
	  //printf("pos x = %f, pos y = %f, pos z = %f \n",pos[0],pos[1],pos[2]);
	  //printf ("expected time = %f (ns)\n",texp);
	  //printf ("expected time bin = %f (TDC bin)\n",texpBin);
	  printf ("measured time bin = %i (TDC bin)\n",tof);
	  //	  printf("index = %i, deltabin = %i , filling index = %i, and bin = % i\n",index, deltabin, index, deltabin);
	}
      }
      
      delete rawStreamTOF;
      rawStreamTOF = 0x0;
 
      delete rawReader;
      rawReader = 0x0;

    }
       
    /* 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;
    }
  }
  
  delete geomV5;
  geomV5 = 0x0;
  delete geom;
  geom = 0x0;

  //write the Run level file   
  TFile * fileRun = new TFile ("outciccioTOFT0daRun.root","RECREATE"); 
  TBenchmark *bench = new TBenchmark();
  bench->Start("t0");
  htofPartial->Write();
  bench->Stop("t0");
  bench->Print("t0");
  fileRun->Close();

  TFile * filetot = new TFile ("outciccioTOFT0daTotal.root","READ"); 
  printf("dopo aver aperto il file in modalita' lettura \n");
  TH2S *htoftot = 0x0;
  //look for the file
  if (!filetot->IsZombie()){
    printf("il file non e' zombie \n");
    TIter next(filetot->GetListOfKeys());
    TKey *key;
    //look for the histogram
    while ((key=(TKey*)next())){
      const char * namekey = key->GetName();
      if (strcmp(namekey,"htoftot")==0){
	printf(" histo found \n");
	htoftot = (TH2S*) filetot->Get("htoftot");
	htoftot->AddDirectory(0);
	htoftot->Add(htofPartial);
	break;
      }
    }
  filetot->Close();
  }
  else {
    printf(" no file found \n");
    htoftot = new TH2S(*htofPartial);
    htoftot->SetName("htoftot");
    htoftot->AddDirectory(0);
  }
  filetot=0x0;
  filetot = new TFile ("outciccioTOFT0daTotal.root","RECREATE");
  filetot->cd();
  htoftot->Write();
  filetot->Close();
  
  delete fileRun;
  delete filetot;
  delete bench;
  delete htofPartial;
  delete htoftot;

  fileRun = 0x0;
  filetot = 0x0;
  bench = 0x0;
  htofPartial = 0x0;
  htoftot = 0x0;

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


  return status;
}
Commit	Line	Data
7b81ffe5	1	/*
	2
	3	DAcase2.c
	4
	5	This program connects to the DAQ data source passed as argument
	6	and populates local "./result.txt" file with the ids of events received
	7	during the run.
	8
	9	The program exits when being asked to shut down (daqDA_checkshutdown)
	10	or End of Run event.
	11
	12	Messages on stdout are exported to DAQ log system.
	13
	14	contact: alice-datesupport@cern.ch
	15
	16	*/
	17	extern "C" {
	18	#include <daqDA.h>
	19	}
	20
	21	#include "event.h"
	22	#include "monitor.h"
	23	//#include "daqDA.h"
	24
	25	#include <Riostream.h>
	26	#include <stdio.h>
	27	#include <stdlib.h>
	28
	29	//AliRoot
	30	#include "AliTOFRawStream.h"
	31	#include "AliRawReaderDate.h"
	32	#include "AliTOFGeometry.h"
	33	#include "AliTOFGeometryV5.h"
	34	#include "AliT0digit.h"
	35	#include "AliT0RawReader.h"
	36
	37	//ROOT
	38	#include "TFile.h"
	39	#include "TKey.h"
	40	#include "TH2S.h"
	41	#include "TObject.h"
	42	#include "TBenchmark.h"
d6133054	43	#include "TMath.h"
7b81ffe5	44	#include "TRandom.h"
	45
	46
	47	/* Main routine
	48	Arguments:
	49	1- monitoring data source
	50	*/
	51	int main(int argc, char **argv) {
	52
	53	AliTOFGeometry * geomV5 = new AliTOFGeometryV5();
	54	AliTOFGeometry * geom = new AliTOFGeometry();
	55
	56	static const Int_t size = geomV5->NPadXSector()*geomV5->NSectors();
	57	static const Int_t nbins = 500;
	58	static const Int_t binmin = -20;
	59	const Float_t c = 2.99792458E10; //speed of light
	60	TH1F::AddDirectory(0);
	61	TH2S * htofPartial = new TH2S("htof","histo with delays", size,-0.5,size1.-0.5,nbins,binmin-0.5,nbins1.+binmin-0.5);
	62
	63	TRandom *rand = new TRandom(); //to be used for testing with cosmic data
	64	rand->SetSeed(0); //to be used for testing with cosmic data
	65
	66	//TTree *tree = 0x0; // tree for T0 decoder
	67
	68	// decoding the events
	69
	70	int status;
	71	bool decodeStatus;
	72	if (argc!=2) {
	73	printf("Wrong number of arguments\n");
	74	return -1;
	75	}
	76
	77	/* open result file */
	78	FILE *fp=NULL;
	79	fp=fopen("./result.txt","a");
	80	if (fp==NULL) {
	81	printf("Failed to open file\n");
	82	return -1;
	83	}
	84
	85	/* define data source : this is argument 1 */
	86	status=monitorSetDataSource( argv[1] );
	87	if (status!=0) {
	88	printf("monitorSetDataSource() failed : %s\n",monitorDecodeError(status));
	89	return -1;
	90	}
	91
	92	/* declare monitoring program */
	93	status=monitorDeclareMp( __FILE__ );
	94	if (status!=0) {
	95	printf("monitorDeclareMp() failed : %s\n",monitorDecodeError(status));
	96	return -1;
	97	}
	98
	99	/* define wait event timeout - 1s max */
	100	monitorSetNowait();
	101	monitorSetNoWaitNetworkTimeout(1000);
	102
	103	/* log start of process */
	104	printf("DA example case2 monitoring program started\n");
	105
	106	/* init some counters */
	107	int nevents_physics=0;
108	int nevents_total=0;
109
110	struct equipmentStruct *equipment;
111	int *eventEnd;
112	int *eventData;
113	int *equipmentEnd;
114	int *equipmentData;
115	int *equipmentID;
116	struct eventHeaderStruct *event;
117	eventTypeType eventT;
118	Int_t iev=0;
119
120	/* main loop (infinite) */
121	for(;;) {
122
123	/* check shutdown condition */
124	if (daqDA_checkShutdown()) {break;}
125
126	/* get next event (blocking call until timeout) */
127	status=monitorGetEventDynamic((void **)&event);
128	if (status==MON_ERR_EOF) {
129	printf ("End of File detected\n");
130	break; /* end of monitoring file has been reached */
131	}
132
133	if (status!=0) {
134	printf("monitorGetEventDynamic() failed : %s\n",monitorDecodeError(status));
135	break;
136	}
137
138	/* retry if got no event */
139	if (event==NULL) {
140	continue;
141	}
142
143	iev++;
144
145	/* use event - here, just write event id to result file */
146	eventT=event->eventType;
147	switch (event->eventType){
148
149	/* START OF RUN */
150	case START_OF_RUN:
151	break;
152	/* END START OF RUN */
153
154	/* END OF RUN */
155	case END_OF_RUN:
156	break;
157
158	case PHYSICS_EVENT:
159	printf(" event number = %i \n",iev);
160	//if (iev%10000 ==0) printf(" event number = %i \n",iev);
161	//if (iev > 50000) break;
162	AliRawReader rawReader = new AliRawReaderDate((void)event);
163	// rawReader->RequireHeader(kFALSE);
164	//rawReader->LoadEquipmentIdsMap("TOFmap.txt"); //to be used if no exact mapping implemented
165	Int_t meantime = 0;
166
167
168	// TTree *tree = new TTree(); // tree for T0 decoder
169	AliT0RawReader *rawReaderT0 = new AliT0RawReader(rawReader);
170	// printf("rawReaderT0 = %p \n", rawReaderT0);
171	//printf("rawReader = %p \n", rawReader);
172	//printf("event = %p \n", event);
173	// AliT0digit *digit = 0x0;
174	//tree->SetBranchAddress("T0",&digit);
175
176	if (!rawReaderT0->Next())
177	printf(" no raw data found!! %i", rawReaderT0->Next());
178	Int_t allData[110][5];
179	for (Int_t i=0; i<110; i++) {
180	allData[i][0]=rawReaderT0->GetData(i,0);
181	}
182	meantime = allData[49][0];
183	printf("time zero (ns) = %i (%f) \n", meantime, meantime251E-3-200);
184
185	delete rawReaderT0;
186	rawReaderT0 = 0x0;
187	rawReader->Reset();
188
189	AliTOFRawStream *rawStreamTOF = new AliTOFRawStream(rawReader);
190
191	//loop the event data
192	Int_t detectorIndex[5] = {-1, -1, -1, -1, -1};
193
194	printf("before T0 \n");
195
196	while(rawStreamTOF->Next()){
197	for (Int_t ii=0; ii<5; ii++) detectorIndex[ii] = -1;
198
199	detectorIndex[0] = (Int_t)rawStreamTOF->GetSector();
200	detectorIndex[1] = (Int_t)rawStreamTOF->GetPlate();
201	detectorIndex[2] = (Int_t)rawStreamTOF->GetStrip();
202	detectorIndex[3] = (Int_t)rawStreamTOF->GetPadZ();
203	detectorIndex[4] = (Int_t)rawStreamTOF->GetPadX();
204
205	if (detectorIndex[0]==-1 \|\|
206	detectorIndex[1]==-1 \|\|
207	detectorIndex[2]==-1 \|\|
208	detectorIndex[3]==-1 \|\|
209	detectorIndex[4]==-1) continue;
210	else {
211	Float_t tdc = (Float_t)rawStreamTOF->GetTDC();
212	Int_t tof = (Int_t)rawStreamTOF->GetTofBin();
213	Int_t detID[5]={0,0,0,0,0};
214	detectorIndex[0] = rawStreamTOF->GetSector();
215	detectorIndex[1] = rawStreamTOF->GetPlate();
216	detectorIndex[2] = rawStreamTOF->GetStrip();
217	detectorIndex[3] = rawStreamTOF->GetPadZ();
218	detectorIndex[4] = rawStreamTOF->GetPadX();
219	Int_t index = rawStreamTOF->GetIndex(detectorIndex);
220	Float_t pos[3];
221	geomV5->GetPosPar(detectorIndex,pos);
222	Float_t texp=TMath::Sqrt(pos[0]pos[0]+pos[1]pos[1]+pos[2]pos[2])/c1E9; //expected time in ns
223	Float_t texpBin=(texp*1E3-32)/AliTOFGeometry::TdcBinWidth(); //expected time in number of TDC bin
224	//to be uded with cosmics
225	//Float_t tsim = (Float_t)rand->Gaus(texp,1E-1); //TDC measured time in ns, simulated to be used for testing with cosmic data
226	//Float_t delta = tsim-texp;
227	//Int_t deltabin = (Int_t)((delta*1E3-32)/AliTOFGeometry::TdcBinWidth()); //to be used for testing with cosmics data
228	Int_t deltabin = tof-TMath::Nint(texpBin); //to be used with real data; rounding expected time to Int_t
229	htofPartial->Fill(index,deltabin); //channel index start from 0, bin index from 1
230	//debugging printings
231	printf("sector %i, plate %i, strip %i, padz %i, padx %i \n",detectorIndex[0],detectorIndex[1],detectorIndex[2],detectorIndex[3],detectorIndex[4]);
232	//printf("pos x = %f, pos y = %f, pos z = %f \n",pos[0],pos[1],pos[2]);
233	//printf ("expected time = %f (ns)\n",texp);
234	//printf ("expected time bin = %f (TDC bin)\n",texpBin);
235	printf ("measured time bin = %i (TDC bin)\n",tof);
236	// printf("index = %i, deltabin = %i , filling index = %i, and bin = % i\n",index, deltabin, index, deltabin);
237	}
238	}
239
240	delete rawStreamTOF;
241	rawStreamTOF = 0x0;
242
243	delete rawReader;
244	rawReader = 0x0;
245
246	}
247
248	/* free resources */
249	free(event);
250
251	/* exit when last event received, no need to wait for TERM signal */
252	if (eventT==END_OF_RUN) {
253	printf("EOR event detected\n");
254	break;
255	}
256	}
257
258	delete geomV5;
259	geomV5 = 0x0;
260	delete geom;
261	geom = 0x0;
262
263	//write the Run level file
264	TFile * fileRun = new TFile ("outciccioTOFT0daRun.root","RECREATE");
265	TBenchmark *bench = new TBenchmark();
266	bench->Start("t0");
267	htofPartial->Write();
268	bench->Stop("t0");
269	bench->Print("t0");
270	fileRun->Close();
271
272	TFile * filetot = new TFile ("outciccioTOFT0daTotal.root","READ");
273	printf("dopo aver aperto il file in modalita' lettura \n");
274	TH2S *htoftot = 0x0;
275	//look for the file
276	if (!filetot->IsZombie()){
277	printf("il file non e' zombie \n");
278	TIter next(filetot->GetListOfKeys());
279	TKey *key;
280	//look for the histogram
281	while ((key=(TKey*)next())){
282	const char * namekey = key->GetName();
283	if (strcmp(namekey,"htoftot")==0){
284	printf(" histo found \n");
285	htoftot = (TH2S*) filetot->Get("htoftot");
286	htoftot->AddDirectory(0);
287	htoftot->Add(htofPartial);
288	break;
289	}
290	}
291	filetot->Close();
292	}
293	else {
294	printf(" no file found \n");
295	htoftot = new TH2S(*htofPartial);
296	htoftot->SetName("htoftot");
297	htoftot->AddDirectory(0);
298	}
299	filetot=0x0;
300	filetot = new TFile ("outciccioTOFT0daTotal.root","RECREATE");
301	filetot->cd();
302	htoftot->Write();
303	filetot->Close();
304
305	delete fileRun;
306	delete filetot;
307	delete bench;
308	delete htofPartial;
309	delete htoftot;
310
311	fileRun = 0x0;
312	filetot = 0x0;
313	bench = 0x0;
314	htofPartial = 0x0;
315	htoftot = 0x0;
316
317	/* write report */
318	fprintf(fp,"Run #%s, received %d physics events out of %d\n",getenv("DATE_RUN_NUMBER"),nevents_physics,nevents_total);
319
320	/* close result file */
321	fclose(fp);
322
323
324	return status;
325	}