[u/mrichter/AliRoot.git] / MONITOR / monitorGDC.cxx

/**************************************************************************
 * Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
 *                                                                        *
 * Author: The ALICE Off-line Project.                                    *
 * Contributors are mentioned in the code where appropriate.              *
 *                                                                        *
 * Permission to use, copy, modify and distribute this software and its   *
 * documentation strictly for non-commercial purposes is hereby granted   *
 * without fee, provided that the above copyright notice appears in all   *
 * copies and that both the copyright notice and this permission notice   *
 * appear in the supporting documentation. The authors make no claims     *
 * about the suitability of this software for any purpose. It is          *
 * provided "as is" without express or implied warranty.                  *
 **************************************************************************/

/* $Id$ */

///////////////////////////////////////////////////////////////////////////////
//                                                                           //
// this program performs local monitoring on a GDC by running the HLT code   //
//                                                                           //
// If an argument is given, this is taken as the name of a date file which   //
// is used instead of the local node.                                        //
// The program can be stopped by pressing CTRL-C.                            //
//                                                                           //
///////////////////////////////////////////////////////////////////////////////

#include <TError.h>
#include <TSysEvtHandler.h>
#ifdef ALI_DATE
#include <TROOT.h>
#include <TSystem.h>
#include <TDatime.h>
#include "AliRawReaderDate.h"
#include "event.h"
#include "monitor.h"
#include <AliHLTStandardIncludes.h>
#include <AliHLTTransform.h>
#include <AliHLTMemHandler.h>
#include <AliHLTTrackArray.h>
#include <AliHLTHoughMaxFinder.h>
#include <AliHLTHoughBaseTransformer.h>
#include <AliHLTHough.h>
#include <AliHLTBenchmark.h>
#include <AliKalmanTrack.h>
#include "AliITSgeomTGeo.h"
#include "AliITSgeom.h"
#include "AliMagF.h"
#include "AliMagFMaps.h"
#include <AliHLTITSclusterer.h>
#include <AliHLTITSVertexerZ.h>
#include <AliHLTITStracker.h>
#endif

//_____________________________________________________________________________
class AliGDCInterruptHandler : public TSignalHandler {
public:
  AliGDCInterruptHandler();
  Bool_t Notify() {fStop = kTRUE; return kTRUE;};
  Bool_t Stop() const {return fStop;};
private:
  Bool_t fStop;  // CTRL-C pressed
};

//_____________________________________________________________________________
AliGDCInterruptHandler::AliGDCInterruptHandler() : 
  TSignalHandler(kSigInterrupt, kFALSE) 
{
  fStop = kFALSE;
};


//_____________________________________________________________________________
#ifdef ALI_DATE
int main(int argc, char** argv)
{
  // set ROOT in batch mode
  gROOT->SetBatch();   

  // open a log file
  FILE* file = fopen("monitorGDC.log", "w");

  TDatime time;

  // get data from a file or online from this node
  Int_t status = 0;
  if (argc > 1) {
    status = monitorSetDataSource(argv[1]);
  } else {
    status = monitorSetDataSource(":");
  }
  if (status) ::Fatal("monitorSetDataSource", monitorDecodeError(status));

  // monitor only a sample of physics events
  char* table[] = {"Physics event", "yes", NULL};
  status = monitorDeclareTable(table);
  if (status) ::Fatal("monitorDeclareTable", monitorDecodeError(status));

  // declare this monitoring program to DATE
  status = monitorDeclareMp("GDC physics monitoring");
  if (status) ::Fatal("monitorDeclareMp", monitorDecodeError(status));

  // initialize HLT transformations
  if (!AliHLTTransform::Init("./", kFALSE)) {
    ::Fatal("AliHLTTransform::Init", "HLT initialization failed");
  }
  AliESDEvent *esd = new AliESDEvent;
  esd->CreateStdContent();
  //  AliKalmanTrack::SetConvConst(
  //     1000/0.299792458/AliHLTTransform::GetSolenoidField()
  //  );
  AliITSgeom *geom = new AliITSgeom();
  geom->ReadNewFile("$ALICE_ROOT/ITS/ITSgeometry_vPPRasymmFMD.det");
  if (!geom) return 1;
  Int_t sfield = 0;
  switch ((Int_t)(AliHLTTransform::GetSolenoidField()+0.5)) {
  case 2:
    sfield = AliMagFMaps::k2kG;
    break;
  case 4:
    sfield = AliMagFMaps::k4kG;
    break;
  case 5:
    sfield = AliMagFMaps::k5kG;
    break;
  default:
    ::Fatal("AliHLTTransform::GetSolenoidField", "Incorrect magnetic field");
  }
  AliMagF* field = new AliMagFMaps("Maps","Maps", 2, 1., 10., sfield);
  AliTracker::SetFieldMap(field,kTRUE);

  // Init PID
  AliPID pid;

  // create the signal handler
  AliGDCInterruptHandler* handler = new AliGDCInterruptHandler;
  gSystem->AddSignalHandler(handler);

  // endless loop
  void* ptr = NULL;
  while (!handler->Stop()) {
    // get the next event
    status = monitorGetEventDynamic(&ptr);
    if (status == (Int_t)MON_ERR_EOF) break;
    if (status) ::Fatal("monitorGetEventDynamic", monitorDecodeError(status));

    // if no new event
    if (!ptr) {
      gSystem->Sleep(1000);   // sleep for 1 second
      continue;
    }

    AliRawReaderDate rawReader(ptr);
    //    if ((rawReader.GetAttributes()[0] & 0x02) != 0) {

    //      Int_t errorCode = rawReader.CheckData();
    Int_t errorCode = 0;
      if (errorCode && (errorCode != AliRawReader::kErrSize)) {
	time.Set();
	if (file) fprintf(file, "%s\n", time.AsString());
	if (file) fprintf(file, "run: %d  event: %d %d\n", 
			  rawReader.GetRunNumber(), 
			  rawReader.GetEventId()[0], 
			  rawReader.GetEventId()[1]);
	fprintf(file, "ERROR: %d\n\n", errorCode);

      } else {

	AliHLTBenchmark *fBenchmark = new AliHLTBenchmark();
	fBenchmark->Start("Overall timing");

	// ITS clusterer and vertexer
	fBenchmark->Start("ITS Clusterer");
	AliHLTITSclusterer clusterer(0);
	AliRawReader *itsrawreader=new AliRawReaderDate(ptr);
	TTree* treeClusters = new TTree("TreeL3ITSclusters"," "); //make a tree
	clusterer.Digits2Clusters(itsrawreader,treeClusters);
	fBenchmark->Stop("ITS Clusterer");
	
	AliHLTITSVertexerZ vertexer;
	AliESDVertex *vertex = vertexer.FindVertexForCurrentEvent(geom,treeClusters);
	Double_t vtxPos[3];
	Double_t vtxErr[3]={0.005,0.005,0.010};
	vertex->GetXYZ(vtxPos);
	//	vertex->GetSigmaXYZ(vtxErr);
	esd->SetVertex(vertex);

	// TPC Hough reconstruction
	Float_t ptmin = 0.1*AliHLTTransform::GetSolenoidField();
	Float_t zvertex = vtxPos[2];

	// Run the Hough Transformer
	fBenchmark->Start("Init");
	AliHLTHough *hough1 = new AliHLTHough();

	hough1->SetThreshold(4);
	hough1->CalcTransformerParams(ptmin);
	hough1->SetPeakThreshold(70,-1);
	//	printf("Pointer is %x\n",ptr);
	hough1->Init("./", kFALSE, 100, kFALSE,4,0,(Char_t*)ptr,zvertex);
	hough1->SetAddHistograms();
	fBenchmark->Stop("Init");

	fBenchmark->Start("Init");
	AliHLTHough *hough2 = new AliHLTHough();

	hough2->SetThreshold(4);
	hough2->CalcTransformerParams(ptmin);
	hough2->SetPeakThreshold(70,-1);
	//	printf("Pointer is %x\n",ptr);
	hough2->Init("./", kFALSE, 100, kFALSE,4,0,(Char_t*)ptr,zvertex);
	hough2->SetAddHistograms();
	fBenchmark->Stop("Init");

	Int_t nglobaltracks = 0;
	/*
	hough1->StartProcessInThread(0,17);
	hough2->StartProcessInThread(18,35);

	//	gSystem->Sleep(20000);
	if(hough1->WaitForThreadFinish())
	  ::Fatal("AliHLTHough::WaitForThreadFinish"," Can not join the required thread! ");
	if(hough2->WaitForThreadFinish())
	  ::Fatal("AliHLTHough::WaitForThreadFinish"," Can not join the required thread! ");

	gSystem->MakeDirectory("hough1");
	hough1->WriteTracks("./hough1");
	gSystem->MakeDirectory("hough2");
	hough2->WriteTracks("./hough2");
	*/

	for(int slice=0; slice<=17; slice++)
	{
	  //	  cout<<"Processing slice "<<slice<<endl;
	  fBenchmark->Start("ReadData");
	  hough1->ReadData(slice,0);
	  fBenchmark->Stop("ReadData");
	  fBenchmark->Start("Transform");
	  hough1->Transform();
	  fBenchmark->Stop("Transform");
	  hough1->AddAllHistogramsRows();
	  hough1->FindTrackCandidatesRow();
	  fBenchmark->Start("AddTracks");
	  hough1->AddTracks();
	  fBenchmark->Stop("AddTracks");

	  //	  AliHLTTrackArray* tracks = (AliHLTTrackArray*)hough1->GetTracks(0);
	  //	  nglobaltracks += tracks->GetNTracks();
	}
	for(int slice=18; slice<=35; slice++)
	{
	  //	  cout<<"Processing slice "<<slice<<endl;
	  fBenchmark->Start("ReadData");
	  hough2->ReadData(slice,0);
	  fBenchmark->Stop("ReadData");
	  fBenchmark->Start("Transform");
	  hough2->Transform();
	  fBenchmark->Stop("Transform");
	  hough2->AddAllHistogramsRows();
	  hough2->FindTrackCandidatesRow();
	  fBenchmark->Start("AddTracks");
	  hough2->AddTracks();
	  fBenchmark->Stop("AddTracks");

	  //	  AliHLTTrackArray* tracks = (AliHLTTrackArray*)hough2->GetTracks(0);
	  //	  nglobaltracks += tracks->GetNTracks();
	}

	nglobaltracks += hough1->FillESD(esd);
	nglobaltracks += hough2->FillESD(esd);

	// ITS tracker
	AliHLTITStracker itsTracker(0);
	itsTracker.SetVertex(vtxPos,vtxErr);

	itsTracker.LoadClusters(treeClusters);
	itsTracker.Clusters2Tracks(esd);
	itsTracker.UnloadClusters();

	fBenchmark->Stop("Overall timing");
	time.Set();
	if (file) fprintf(file, "%s\n", time.AsString());
	if (file) fprintf(file, "run: %d  event: %d %d\n", 
			  rawReader.GetRunNumber(), 
			  rawReader.GetEventId()[0], 
			  rawReader.GetEventId()[1]);
	if (errorCode) fprintf(file, "ERROR: %d\n", errorCode);

	if (file) fprintf(file, "Hough Transformer found %d tracks\n",nglobaltracks);

	hough1->DoBench("hough1");
	hough2->DoBench("hough2");
	fBenchmark->Analyze("overall");
	if (file) {
	  FILE* bench = fopen("hough1.dat", "r");
	  while (bench && !feof(bench)) {
	    char buffer[256];
	    if (!fgets(buffer, 256, bench)) break;
	    fprintf(file, "%s", buffer);
	  }
	  fclose(bench);
	}
	if (file) {
	  FILE* bench = fopen("hough2.dat", "r");
	  while (bench && !feof(bench)) {
	    char buffer[256];
	    if (!fgets(buffer, 256, bench)) break;
	    fprintf(file, "%s", buffer);
	  }
	  fclose(bench);
	}
	if (file) {
	  FILE* bench = fopen("overall.dat", "r");
	  while (bench && !feof(bench)) {
	    char buffer[256];
	    if (!fgets(buffer, 256, bench)) break;
	    fprintf(file, "%s", buffer);
	  }
	  fclose(bench);
	  fprintf(file, "\n\n");
	}

	delete hough1;
	delete hough2;

	esd->Reset();
      }
    //    }

    /*
    // read run, event, detector, DDL numbers and data size
    AliRawReaderDate rawReader(ptr);
    time.Set();
    printf("\n%s\n", time.AsString());
    printf("run: %d  event: %d %d\n", rawReader.GetRunNumber(), 
	   rawReader.GetEventId()[0], rawReader.GetEventId()[1]);
    while (rawReader.ReadMiniHeader()) {
      printf(" detector: %d   DDL: %d  size: %d\n", 
	     rawReader.GetDetectorID(), rawReader.GetDDLID(), 
	     rawReader.GetDataSize());
    }

    */

    gSystem->Sleep(100);   // sleep for 0.1 second
    free(ptr);

    gSystem->ProcessEvents();
    if (file) fflush(file);

  }

  gSystem->RemoveSignalHandler(handler);
  if (file) fclose(file);

  return 0;
}

#else
int main(int /*argc*/, char** /*argv*/)
{
  ::Fatal("main", "this program was compiled without DATE");

  return 1;
}
#endif
Commit	Line	Data
b5279783	1	/**************************************************************************
	2	* Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
	3	* *
	4	* Author: The ALICE Off-line Project. *
	5	* Contributors are mentioned in the code where appropriate. *
	6	* *
	7	* Permission to use, copy, modify and distribute this software and its *
	8	* documentation strictly for non-commercial purposes is hereby granted *
	9	* without fee, provided that the above copyright notice appears in all *
	10	* copies and that both the copyright notice and this permission notice *
	11	* appear in the supporting documentation. The authors make no claims *
	12	* about the suitability of this software for any purpose. It is *
	13	* provided "as is" without express or implied warranty. *
	14	**************************************************************************/
	15
	16	/* $Id$ */
	17
	18	///////////////////////////////////////////////////////////////////////////////
	19	// //
	20	// this program performs local monitoring on a GDC by running the HLT code //
	21	// //
	22	// If an argument is given, this is taken as the name of a date file which //
	23	// is used instead of the local node. //
	24	// The program can be stopped by pressing CTRL-C. //
	25	// //
	26	///////////////////////////////////////////////////////////////////////////////
	27
	28	#include <TError.h>
8ecba4b2	29	#include <TSysEvtHandler.h>
8c50acf2	30	#ifdef ALI_DATE
b5279783	31	#include <TROOT.h>
b5279783	32	#include <TSystem.h>
b5279783	33	#include <TDatime.h>
	34	#include "AliRawReaderDate.h"
	35	#include "event.h"
	36	#include "monitor.h"
4aa41877	37	#include <AliHLTStandardIncludes.h>
	38	#include <AliHLTTransform.h>
	39	#include <AliHLTMemHandler.h>
	40	#include <AliHLTTrackArray.h>
	41	#include <AliHLTHoughMaxFinder.h>
	42	#include <AliHLTHoughBaseTransformer.h>
	43	#include <AliHLTHough.h>
	44	#include <AliHLTBenchmark.h>
b77a0228	45	#include <AliKalmanTrack.h>
ad693bc1	46	#include "AliITSgeomTGeo.h"
f7ea67db	47	#include "AliITSgeom.h"
b77a0228	48	#include "AliMagF.h"
b77a0228	49	#include "AliMagFMaps.h"
4aa41877	50	#include <AliHLTITSclusterer.h>
	51	#include <AliHLTITSVertexerZ.h>
	52	#include <AliHLTITStracker.h>
b5279783	53	#endif
b5279783	54
b5279783	55	//_____________________________________________________________________________
	56	class AliGDCInterruptHandler : public TSignalHandler {
	57	public:
	58	AliGDCInterruptHandler();
	59	Bool_t Notify() {fStop = kTRUE; return kTRUE;};
	60	Bool_t Stop() const {return fStop;};
	61	private:
	62	Bool_t fStop; // CTRL-C pressed
	63	};
	64
	65	//_____________________________________________________________________________
	66	AliGDCInterruptHandler::AliGDCInterruptHandler() :
	67	TSignalHandler(kSigInterrupt, kFALSE)
	68	{
	69	fStop = kFALSE;
	70	};
	71
	72
	73	//_____________________________________________________________________________
8c50acf2	74	#ifdef ALI_DATE
120b3c73	75	int main(int argc, char** argv)
120b3c73	76	{
b5279783	77	// set ROOT in batch mode
	78	gROOT->SetBatch();
	79
	80	// open a log file
	81	FILE* file = fopen("monitorGDC.log", "w");
a8ffd46b	82
b5279783	83	TDatime time;
	84
	85	// get data from a file or online from this node
	86	Int_t status = 0;
	87	if (argc > 1) {
	88	status = monitorSetDataSource(argv[1]);
	89	} else {
	90	status = monitorSetDataSource(":");
	91	}
	92	if (status) ::Fatal("monitorSetDataSource", monitorDecodeError(status));
	93
	94	// monitor only a sample of physics events
	95	char* table[] = {"Physics event", "yes", NULL};
	96	status = monitorDeclareTable(table);
	97	if (status) ::Fatal("monitorDeclareTable", monitorDecodeError(status));
	98
	99	// declare this monitoring program to DATE
04b48a95	100	status = monitorDeclareMp("GDC physics monitoring");
b5279783	101	if (status) ::Fatal("monitorDeclareMp", monitorDecodeError(status));
b5279783	102
b5279783	103	// initialize HLT transformations
4aa41877	104	if (!AliHLTTransform::Init("./", kFALSE)) {
4aa41877	105	::Fatal("AliHLTTransform::Init", "HLT initialization failed");
b5279783	106	}
af885e0f	107	AliESDEvent *esd = new AliESDEvent;
af885e0f	108	esd->CreateStdContent();
aa95f9f7	109	// AliKalmanTrack::SetConvConst(
4aa41877	110	// 1000/0.299792458/AliHLTTransform::GetSolenoidField()
aa95f9f7	111	// );
c557b4f1	112	AliITSgeom *geom = new AliITSgeom();
b77a0228	113	geom->ReadNewFile("$ALICE_ROOT/ITS/ITSgeometry_vPPRasymmFMD.det");
b77a0228	114	if (!geom) return 1;
aa95f9f7	115	Int_t sfield = 0;
4aa41877	116	switch ((Int_t)(AliHLTTransform::GetSolenoidField()+0.5)) {
aa95f9f7	117	case 2:
	118	sfield = AliMagFMaps::k2kG;
	119	break;
	120	case 4:
	121	sfield = AliMagFMaps::k4kG;
	122	break;
	123	case 5:
	124	sfield = AliMagFMaps::k5kG;
	125	break;
	126	default:
4aa41877	127	::Fatal("AliHLTTransform::GetSolenoidField", "Incorrect magnetic field");
aa95f9f7	128	}
	129	AliMagF* field = new AliMagFMaps("Maps","Maps", 2, 1., 10., sfield);
	130	AliTracker::SetFieldMap(field,kTRUE);
	131
	132	// Init PID
	133	AliPID pid;
b5279783	134
	135	// create the signal handler
	136	AliGDCInterruptHandler* handler = new AliGDCInterruptHandler;
	137	gSystem->AddSignalHandler(handler);
	138
	139	// endless loop
	140	void* ptr = NULL;
	141	while (!handler->Stop()) {
	142	// get the next event
	143	status = monitorGetEventDynamic(&ptr);
	144	if (status == (Int_t)MON_ERR_EOF) break;
	145	if (status) ::Fatal("monitorGetEventDynamic", monitorDecodeError(status));
	146
	147	// if no new event
	148	if (!ptr) {
	149	gSystem->Sleep(1000); // sleep for 1 second
	150	continue;
	151	}
	152
04b48a95	153	AliRawReaderDate rawReader(ptr);
a8ffd46b	154	// if ((rawReader.GetAttributes()[0] & 0x02) != 0) {
04b48a95	155
a8ffd46b	156	// Int_t errorCode = rawReader.CheckData();
a8ffd46b	157	Int_t errorCode = 0;
3256212a	158	if (errorCode && (errorCode != AliRawReader::kErrSize)) {
	159	time.Set();
	160	if (file) fprintf(file, "%s\n", time.AsString());
	161	if (file) fprintf(file, "run: %d event: %d %d\n",
	162	rawReader.GetRunNumber(),
	163	rawReader.GetEventId()[0],
	164	rawReader.GetEventId()[1]);
	165	fprintf(file, "ERROR: %d\n\n", errorCode);
	166
	167	} else {
	168
4aa41877	169	AliHLTBenchmark *fBenchmark = new AliHLTBenchmark();
a8ffd46b	170	fBenchmark->Start("Overall timing");
a8ffd46b	171
b77a0228	172	// ITS clusterer and vertexer
b77a0228	173	fBenchmark->Start("ITS Clusterer");
79c75366	174	AliHLTITSclusterer clusterer(0);
b77a0228	175	AliRawReader *itsrawreader=new AliRawReaderDate(ptr);
	176	TTree* treeClusters = new TTree("TreeL3ITSclusters"," "); //make a tree
	177	clusterer.Digits2Clusters(itsrawreader,treeClusters);
	178	fBenchmark->Stop("ITS Clusterer");
	179
4aa41877	180	AliHLTITSVertexerZ vertexer;
b77a0228	181	AliESDVertex *vertex = vertexer.FindVertexForCurrentEvent(geom,treeClusters);
	182	Double_t vtxPos[3];
	183	Double_t vtxErr[3]={0.005,0.005,0.010};
	184	vertex->GetXYZ(vtxPos);
	185	// vertex->GetSigmaXYZ(vtxErr);
	186	esd->SetVertex(vertex);
	187
	188	// TPC Hough reconstruction
4aa41877	189	Float_t ptmin = 0.1*AliHLTTransform::GetSolenoidField();
b77a0228	190	Float_t zvertex = vtxPos[2];
add57a93	191
a8ffd46b	192	// Run the Hough Transformer
a8ffd46b	193	fBenchmark->Start("Init");
4aa41877	194	AliHLTHough *hough1 = new AliHLTHough();
a8ffd46b	195
a8ffd46b	196	hough1->SetThreshold(4);
add57a93	197	hough1->CalcTransformerParams(ptmin);
a8ffd46b	198	hough1->SetPeakThreshold(70,-1);
a8ffd46b	199	// printf("Pointer is %x\n",ptr);
b77a0228	200	hough1->Init("./", kFALSE, 100, kFALSE,4,0,(Char_t*)ptr,zvertex);
a8ffd46b	201	hough1->SetAddHistograms();
	202	fBenchmark->Stop("Init");
	203
	204	fBenchmark->Start("Init");
4aa41877	205	AliHLTHough *hough2 = new AliHLTHough();
a8ffd46b	206
a8ffd46b	207	hough2->SetThreshold(4);
add57a93	208	hough2->CalcTransformerParams(ptmin);
a8ffd46b	209	hough2->SetPeakThreshold(70,-1);
a8ffd46b	210	// printf("Pointer is %x\n",ptr);
b77a0228	211	hough2->Init("./", kFALSE, 100, kFALSE,4,0,(Char_t*)ptr,zvertex);
a8ffd46b	212	hough2->SetAddHistograms();
	213	fBenchmark->Stop("Init");
	214
b77a0228	215	Int_t nglobaltracks = 0;
b77a0228	216	/*
a8ffd46b	217	hough1->StartProcessInThread(0,17);
	218	hough2->StartProcessInThread(18,35);
	219
	220	// gSystem->Sleep(20000);
	221	if(hough1->WaitForThreadFinish())
4aa41877	222	::Fatal("AliHLTHough::WaitForThreadFinish"," Can not join the required thread! ");
a8ffd46b	223	if(hough2->WaitForThreadFinish())
4aa41877	224	::Fatal("AliHLTHough::WaitForThreadFinish"," Can not join the required thread! ");
a8ffd46b	225
	226	gSystem->MakeDirectory("hough1");
	227	hough1->WriteTracks("./hough1");
	228	gSystem->MakeDirectory("hough2");
	229	hough2->WriteTracks("./hough2");
b77a0228	230	*/
a8ffd46b	231
b77a0228	232	for(int slice=0; slice<=17; slice++)
a8ffd46b	233	{
	234	// cout<<"Processing slice "<<slice<<endl;
	235	fBenchmark->Start("ReadData");
b77a0228	236	hough1->ReadData(slice,0);
a8ffd46b	237	fBenchmark->Stop("ReadData");
a8ffd46b	238	fBenchmark->Start("Transform");
b77a0228	239	hough1->Transform();
a8ffd46b	240	fBenchmark->Stop("Transform");
b77a0228	241	hough1->AddAllHistogramsRows();
b77a0228	242	hough1->FindTrackCandidatesRow();
a8ffd46b	243	fBenchmark->Start("AddTracks");
b77a0228	244	hough1->AddTracks();
a8ffd46b	245	fBenchmark->Stop("AddTracks");
a8ffd46b	246
4aa41877	247	// AliHLTTrackArray* tracks = (AliHLTTrackArray*)hough1->GetTracks(0);
b77a0228	248	// nglobaltracks += tracks->GetNTracks();
a8ffd46b	249	}
b77a0228	250	for(int slice=18; slice<=35; slice++)
	251	{
	252	// cout<<"Processing slice "<<slice<<endl;
	253	fBenchmark->Start("ReadData");
	254	hough2->ReadData(slice,0);
	255	fBenchmark->Stop("ReadData");
	256	fBenchmark->Start("Transform");
	257	hough2->Transform();
	258	fBenchmark->Stop("Transform");
	259	hough2->AddAllHistogramsRows();
	260	hough2->FindTrackCandidatesRow();
	261	fBenchmark->Start("AddTracks");
	262	hough2->AddTracks();
	263	fBenchmark->Stop("AddTracks");
	264
4aa41877	265	// AliHLTTrackArray* tracks = (AliHLTTrackArray*)hough2->GetTracks(0);
b77a0228	266	// nglobaltracks += tracks->GetNTracks();
	267	}
	268
	269	nglobaltracks += hough1->FillESD(esd);
	270	nglobaltracks += hough2->FillESD(esd);
	271
	272	// ITS tracker
1f3e997f	273	AliHLTITStracker itsTracker(0);
b77a0228	274	itsTracker.SetVertex(vtxPos,vtxErr);
	275
	276	itsTracker.LoadClusters(treeClusters);
	277	itsTracker.Clusters2Tracks(esd);
	278	itsTracker.UnloadClusters();
	279
a8ffd46b	280	fBenchmark->Stop("Overall timing");
3256212a	281	time.Set();
	282	if (file) fprintf(file, "%s\n", time.AsString());
	283	if (file) fprintf(file, "run: %d event: %d %d\n",
	284	rawReader.GetRunNumber(),
	285	rawReader.GetEventId()[0],
	286	rawReader.GetEventId()[1]);
	287	if (errorCode) fprintf(file, "ERROR: %d\n", errorCode);
	288
b77a0228	289	if (file) fprintf(file, "Hough Transformer found %d tracks\n",nglobaltracks);
3256212a	290
a8ffd46b	291	hough1->DoBench("hough1");
	292	hough2->DoBench("hough2");
	293	fBenchmark->Analyze("overall");
	294	if (file) {
	295	FILE* bench = fopen("hough1.dat", "r");
	296	while (bench && !feof(bench)) {
	297	char buffer[256];
	298	if (!fgets(buffer, 256, bench)) break;
	299	fprintf(file, "%s", buffer);
	300	}
	301	fclose(bench);
	302	}
3256212a	303	if (file) {
a8ffd46b	304	FILE* bench = fopen("hough2.dat", "r");
3256212a	305	while (bench && !feof(bench)) {
	306	char buffer[256];
	307	if (!fgets(buffer, 256, bench)) break;
	308	fprintf(file, "%s", buffer);
	309	}
	310	fclose(bench);
a8ffd46b	311	}
	312	if (file) {
	313	FILE* bench = fopen("overall.dat", "r");
	314	while (bench && !feof(bench)) {
	315	char buffer[256];
	316	if (!fgets(buffer, 256, bench)) break;
	317	fprintf(file, "%s", buffer);
	318	}
	319	fclose(bench);
	320	fprintf(file, "\n\n");
04b48a95	321	}
b5279783	322
a8ffd46b	323	delete hough1;
a8ffd46b	324	delete hough2;
b77a0228	325
b77a0228	326	esd->Reset();
3256212a	327	}
a8ffd46b	328	// }
	329
	330	/*
	331	// read run, event, detector, DDL numbers and data size
	332	AliRawReaderDate rawReader(ptr);
	333	time.Set();
	334	printf("\n%s\n", time.AsString());
	335	printf("run: %d event: %d %d\n", rawReader.GetRunNumber(),
	336	rawReader.GetEventId()[0], rawReader.GetEventId()[1]);
	337	while (rawReader.ReadMiniHeader()) {
	338	printf(" detector: %d DDL: %d size: %d\n",
	339	rawReader.GetDetectorID(), rawReader.GetDDLID(),
	340	rawReader.GetDataSize());
04b48a95	341	}
b5279783	342
a8ffd46b	343	*/
a8ffd46b	344
df0f3179	345	gSystem->Sleep(100); // sleep for 0.1 second
b5279783	346	free(ptr);
	347
	348	gSystem->ProcessEvents();
	349	if (file) fflush(file);
a8ffd46b	350
b5279783	351	}
	352
	353	gSystem->RemoveSignalHandler(handler);
	354	if (file) fclose(file);
	355
120b3c73	356	return 0;
	357	}
	358
b5279783	359	#else
120b3c73	360	int main(int /argc/, char** /argv/)
120b3c73	361	{
b5279783	362	::Fatal("main", "this program was compiled without DATE");
b5279783	363
120b3c73	364	return 1;
b5279783	365	}
120b3c73	366	#endif