[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");
  }
  AliESD *esd = new AliESD;
  //  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	}
b77a0228	107	AliESD *esd = new AliESD;
aa95f9f7	108	// AliKalmanTrack::SetConvConst(
4aa41877	109	// 1000/0.299792458/AliHLTTransform::GetSolenoidField()
aa95f9f7	110	// );
c557b4f1	111	AliITSgeom *geom = new AliITSgeom();
b77a0228	112	geom->ReadNewFile("$ALICE_ROOT/ITS/ITSgeometry_vPPRasymmFMD.det");
b77a0228	113	if (!geom) return 1;
aa95f9f7	114	Int_t sfield = 0;
4aa41877	115	switch ((Int_t)(AliHLTTransform::GetSolenoidField()+0.5)) {
aa95f9f7	116	case 2:
	117	sfield = AliMagFMaps::k2kG;
	118	break;
	119	case 4:
	120	sfield = AliMagFMaps::k4kG;
	121	break;
	122	case 5:
	123	sfield = AliMagFMaps::k5kG;
	124	break;
	125	default:
4aa41877	126	::Fatal("AliHLTTransform::GetSolenoidField", "Incorrect magnetic field");
aa95f9f7	127	}
	128	AliMagF* field = new AliMagFMaps("Maps","Maps", 2, 1., 10., sfield);
	129	AliTracker::SetFieldMap(field,kTRUE);
	130
	131	// Init PID
	132	AliPID pid;
b5279783	133
	134	// create the signal handler
	135	AliGDCInterruptHandler* handler = new AliGDCInterruptHandler;
	136	gSystem->AddSignalHandler(handler);
	137
	138	// endless loop
	139	void* ptr = NULL;
	140	while (!handler->Stop()) {
	141	// get the next event
	142	status = monitorGetEventDynamic(&ptr);
	143	if (status == (Int_t)MON_ERR_EOF) break;
	144	if (status) ::Fatal("monitorGetEventDynamic", monitorDecodeError(status));
	145
	146	// if no new event
	147	if (!ptr) {
	148	gSystem->Sleep(1000); // sleep for 1 second
	149	continue;
	150	}
	151
04b48a95	152	AliRawReaderDate rawReader(ptr);
a8ffd46b	153	// if ((rawReader.GetAttributes()[0] & 0x02) != 0) {
04b48a95	154
a8ffd46b	155	// Int_t errorCode = rawReader.CheckData();
a8ffd46b	156	Int_t errorCode = 0;
3256212a	157	if (errorCode && (errorCode != AliRawReader::kErrSize)) {
	158	time.Set();
	159	if (file) fprintf(file, "%s\n", time.AsString());
	160	if (file) fprintf(file, "run: %d event: %d %d\n",
	161	rawReader.GetRunNumber(),
	162	rawReader.GetEventId()[0],
	163	rawReader.GetEventId()[1]);
	164	fprintf(file, "ERROR: %d\n\n", errorCode);
	165
	166	} else {
	167
4aa41877	168	AliHLTBenchmark *fBenchmark = new AliHLTBenchmark();
a8ffd46b	169	fBenchmark->Start("Overall timing");
a8ffd46b	170
b77a0228	171	// ITS clusterer and vertexer
b77a0228	172	fBenchmark->Start("ITS Clusterer");
79c75366	173	AliHLTITSclusterer clusterer(0);
b77a0228	174	AliRawReader *itsrawreader=new AliRawReaderDate(ptr);
	175	TTree* treeClusters = new TTree("TreeL3ITSclusters"," "); //make a tree
	176	clusterer.Digits2Clusters(itsrawreader,treeClusters);
	177	fBenchmark->Stop("ITS Clusterer");
	178
4aa41877	179	AliHLTITSVertexerZ vertexer;
b77a0228	180	AliESDVertex *vertex = vertexer.FindVertexForCurrentEvent(geom,treeClusters);
	181	Double_t vtxPos[3];
	182	Double_t vtxErr[3]={0.005,0.005,0.010};
	183	vertex->GetXYZ(vtxPos);
	184	// vertex->GetSigmaXYZ(vtxErr);
	185	esd->SetVertex(vertex);
	186
	187	// TPC Hough reconstruction
4aa41877	188	Float_t ptmin = 0.1*AliHLTTransform::GetSolenoidField();
b77a0228	189	Float_t zvertex = vtxPos[2];
add57a93	190
a8ffd46b	191	// Run the Hough Transformer
a8ffd46b	192	fBenchmark->Start("Init");
4aa41877	193	AliHLTHough *hough1 = new AliHLTHough();
a8ffd46b	194
a8ffd46b	195	hough1->SetThreshold(4);
add57a93	196	hough1->CalcTransformerParams(ptmin);
a8ffd46b	197	hough1->SetPeakThreshold(70,-1);
a8ffd46b	198	// printf("Pointer is %x\n",ptr);
b77a0228	199	hough1->Init("./", kFALSE, 100, kFALSE,4,0,(Char_t*)ptr,zvertex);
a8ffd46b	200	hough1->SetAddHistograms();
	201	fBenchmark->Stop("Init");
	202
	203	fBenchmark->Start("Init");
4aa41877	204	AliHLTHough *hough2 = new AliHLTHough();
a8ffd46b	205
a8ffd46b	206	hough2->SetThreshold(4);
add57a93	207	hough2->CalcTransformerParams(ptmin);
a8ffd46b	208	hough2->SetPeakThreshold(70,-1);
a8ffd46b	209	// printf("Pointer is %x\n",ptr);
b77a0228	210	hough2->Init("./", kFALSE, 100, kFALSE,4,0,(Char_t*)ptr,zvertex);
a8ffd46b	211	hough2->SetAddHistograms();
	212	fBenchmark->Stop("Init");
	213
b77a0228	214	Int_t nglobaltracks = 0;
b77a0228	215	/*
a8ffd46b	216	hough1->StartProcessInThread(0,17);
	217	hough2->StartProcessInThread(18,35);
	218
	219	// gSystem->Sleep(20000);
	220	if(hough1->WaitForThreadFinish())
4aa41877	221	::Fatal("AliHLTHough::WaitForThreadFinish"," Can not join the required thread! ");
a8ffd46b	222	if(hough2->WaitForThreadFinish())
4aa41877	223	::Fatal("AliHLTHough::WaitForThreadFinish"," Can not join the required thread! ");
a8ffd46b	224
	225	gSystem->MakeDirectory("hough1");
	226	hough1->WriteTracks("./hough1");
	227	gSystem->MakeDirectory("hough2");
	228	hough2->WriteTracks("./hough2");
b77a0228	229	*/
a8ffd46b	230
b77a0228	231	for(int slice=0; slice<=17; slice++)
a8ffd46b	232	{
	233	// cout<<"Processing slice "<<slice<<endl;
	234	fBenchmark->Start("ReadData");
b77a0228	235	hough1->ReadData(slice,0);
a8ffd46b	236	fBenchmark->Stop("ReadData");
a8ffd46b	237	fBenchmark->Start("Transform");
b77a0228	238	hough1->Transform();
a8ffd46b	239	fBenchmark->Stop("Transform");
b77a0228	240	hough1->AddAllHistogramsRows();
b77a0228	241	hough1->FindTrackCandidatesRow();
a8ffd46b	242	fBenchmark->Start("AddTracks");
b77a0228	243	hough1->AddTracks();
a8ffd46b	244	fBenchmark->Stop("AddTracks");
a8ffd46b	245
4aa41877	246	// AliHLTTrackArray* tracks = (AliHLTTrackArray*)hough1->GetTracks(0);
b77a0228	247	// nglobaltracks += tracks->GetNTracks();
a8ffd46b	248	}
b77a0228	249	for(int slice=18; slice<=35; slice++)
	250	{
	251	// cout<<"Processing slice "<<slice<<endl;
	252	fBenchmark->Start("ReadData");
	253	hough2->ReadData(slice,0);
	254	fBenchmark->Stop("ReadData");
	255	fBenchmark->Start("Transform");
	256	hough2->Transform();
	257	fBenchmark->Stop("Transform");
	258	hough2->AddAllHistogramsRows();
	259	hough2->FindTrackCandidatesRow();
	260	fBenchmark->Start("AddTracks");
	261	hough2->AddTracks();
	262	fBenchmark->Stop("AddTracks");
	263
4aa41877	264	// AliHLTTrackArray* tracks = (AliHLTTrackArray*)hough2->GetTracks(0);
b77a0228	265	// nglobaltracks += tracks->GetNTracks();
	266	}
	267
	268	nglobaltracks += hough1->FillESD(esd);
	269	nglobaltracks += hough2->FillESD(esd);
	270
	271	// ITS tracker
1f3e997f	272	AliHLTITStracker itsTracker(0);
b77a0228	273	itsTracker.SetVertex(vtxPos,vtxErr);
	274
	275	itsTracker.LoadClusters(treeClusters);
	276	itsTracker.Clusters2Tracks(esd);
	277	itsTracker.UnloadClusters();
	278
a8ffd46b	279	fBenchmark->Stop("Overall timing");
3256212a	280	time.Set();
	281	if (file) fprintf(file, "%s\n", time.AsString());
	282	if (file) fprintf(file, "run: %d event: %d %d\n",
	283	rawReader.GetRunNumber(),
	284	rawReader.GetEventId()[0],
	285	rawReader.GetEventId()[1]);
	286	if (errorCode) fprintf(file, "ERROR: %d\n", errorCode);
	287
b77a0228	288	if (file) fprintf(file, "Hough Transformer found %d tracks\n",nglobaltracks);
3256212a	289
a8ffd46b	290	hough1->DoBench("hough1");
	291	hough2->DoBench("hough2");
	292	fBenchmark->Analyze("overall");
	293	if (file) {
	294	FILE* bench = fopen("hough1.dat", "r");
	295	while (bench && !feof(bench)) {
	296	char buffer[256];
	297	if (!fgets(buffer, 256, bench)) break;
	298	fprintf(file, "%s", buffer);
	299	}
	300	fclose(bench);
	301	}
3256212a	302	if (file) {
a8ffd46b	303	FILE* bench = fopen("hough2.dat", "r");
3256212a	304	while (bench && !feof(bench)) {
	305	char buffer[256];
	306	if (!fgets(buffer, 256, bench)) break;
	307	fprintf(file, "%s", buffer);
	308	}
	309	fclose(bench);
a8ffd46b	310	}
	311	if (file) {
	312	FILE* bench = fopen("overall.dat", "r");
	313	while (bench && !feof(bench)) {
	314	char buffer[256];
	315	if (!fgets(buffer, 256, bench)) break;
	316	fprintf(file, "%s", buffer);
	317	}
	318	fclose(bench);
	319	fprintf(file, "\n\n");
04b48a95	320	}
b5279783	321
a8ffd46b	322	delete hough1;
a8ffd46b	323	delete hough2;
b77a0228	324
b77a0228	325	esd->Reset();
3256212a	326	}
a8ffd46b	327	// }
	328
	329	/*
	330	// read run, event, detector, DDL numbers and data size
	331	AliRawReaderDate rawReader(ptr);
	332	time.Set();
	333	printf("\n%s\n", time.AsString());
	334	printf("run: %d event: %d %d\n", rawReader.GetRunNumber(),
	335	rawReader.GetEventId()[0], rawReader.GetEventId()[1]);
	336	while (rawReader.ReadMiniHeader()) {
	337	printf(" detector: %d DDL: %d size: %d\n",
	338	rawReader.GetDetectorID(), rawReader.GetDDLID(),
	339	rawReader.GetDataSize());
04b48a95	340	}
b5279783	341
a8ffd46b	342	*/
a8ffd46b	343
df0f3179	344	gSystem->Sleep(100); // sleep for 0.1 second
b5279783	345	free(ptr);
	346
	347	gSystem->ProcessEvents();
	348	if (file) fflush(file);
a8ffd46b	349
b5279783	350	}
	351
	352	gSystem->RemoveSignalHandler(handler);
	353	if (file) fclose(file);
	354
120b3c73	355	return 0;
	356	}
	357
b5279783	358	#else
120b3c73	359	int main(int /argc/, char** /argv/)
120b3c73	360	{
b5279783	361	::Fatal("main", "this program was compiled without DATE");
b5279783	362
120b3c73	363	return 1;
b5279783	364	}
120b3c73	365	#endif