chewbacca/event/EventCounter.cpp

/** @file
 * $Source: /afs/ba.infn.it/user/pamela/src/CVS/chewbacca/event/EventCounter.cpp,v $
 * $Id: EventCounter.cpp,v 1.5 2010/02/11 09:02:15 mocchiut Exp $
 * $Author: mocchiut $
 * 
 * Implementation of the EventCounter class.
 */
////#include <log4cxx/logger.h>
#include <sstream>
#include <iostream>//mmmm

#include "EventCounter.h"
#include "PscuHeader.h"

//marco
////static log4cxx::LoggerPtr logger = log4cxx::Logger::getLogger(_T("pamela.techmodel.EventCounter"));
static std::stringstream oss;

using namespace pamela;


mapval::mapval(): count(0), name(""){ }

mapval::mapval(TString n, Int_t *i): count(i), name(n){ }

mappa::mappa(){  
  val = 0;
  this->Clear();
}

void mappa::Clear(Option_t *t){
  //    cout << " mappa clear" << endl;
  t="";
  if ( val ){
    //    printf("val delete in clear\n");
    val->Delete();
    delete val;
    val = 0;
  };
  fend = false;
  entries = 0;
}

void mappa::Set(){
  //  cout << " in mappa set" << endl;
  if (val){
    val->Delete();
    delete val;
    val = 0;
  }
  val = new TClonesArray("pamela::mapval",47);
  //  cout << " out mappa set" << endl;
}

void mappa::Delete(Option_t *t){
  //  cout << " mappa del" << endl;
  if ( val ){
    //    printf("val delete in delete\n");
    val->Delete();
    delete val;
    val = 0;
    //          delete val;
  };
  delete this;
}

void mappa::Insert(TString nme, Int_t *valu){
  //  cout << " mappa insert " << nme.Data() << " valu " << *valu << endl;
  if ( !val ) this->Set();
  TClonesArray &t = *val;
  new(t[entries]) mapval(nme,valu);
  entries++;
}

mapval::mapval(const mapval &t){
  name = t.name;
  count = t.count;
}

mapval* mappa::Find(TString n){
  Bool_t fo = false;
  fend = false;
  mapval *c = NULL;
  for (Int_t i=0; i < entries; i++){
    c = (mapval*)val->At(i);
    if ( c && !strcmp(c->name.Data(),n.Data()) ){
      fo = true;
      break;
    };
  };
  if ( !fo ) fend = true;
  return c;
}

/**
 * Create a new event counter for a certain run.
 * @param run Run number.
 */
EventCounter::EventCounter(int run):
        // New Packets.
  RunNumber(run),
  Pscu(0),
  PhysEndRun(0),
  CalibCalPulse1(0),
  CalibCalPulse2(0),
  Physics(0),
  CalibTrkBoth(0),
  CalibTrk1(0),
  CalibTrk2(0),
  CalibCal(0),
  CalibTof(0),
  CalibS4(0),
  CalibCalPed(0),
  Calib1_Ac1(0),
  Calib1_Ac2(0),
  Calib2_Ac1(0),
  Calib2_Ac2(0),
  RunHeader(0),
  RunTrailer(0),
  CalibHeader(0),
  CalibTrailer(0),
  InitHeader(0),
  InitTrailer(0),
  EventTrk(0),
  Log(0),
  VarDump(0),
  ArrDump(0),
  TabDump(0),
  Tmtc(0),
  Mcmd(0),
  ForcedFECmd(0),
  Ac1Init(0),
  CalInit(0),
  TrkInit(0),
  TofInit(0),
  TrgInit(0),
  NdInit(0),
  S4Init(0),
  Ac2Init(0),
  CalAlarm(0),
  Ac1Alarm(0),
  TrkAlarm(0),
  TrgAlarm(0),
  TofAlarm(0),
  S4Alarm(0),
  Ac2Alarm(0),
  TsbT(0),
  TsbB(0) { 
    CMap.Set();
    CMap.Insert(PacketType::Physics->GetName(),         &Physics);
    CMap.Insert(PacketType::Pscu->GetName(),            &Pscu);
    CMap.Insert(PacketType::RunHeader->GetName(),       &RunHeader);
    CMap.Insert(PacketType::RunTrailer->GetName(),      &RunTrailer);
    CMap.Insert(PacketType::PhysEndRun->GetName(),      &PhysEndRun);
    CMap.Insert(PacketType::InitHeader->GetName(),      &InitHeader);
    CMap.Insert(PacketType::InitTrailer->GetName(),     &InitTrailer);  
    CMap.Insert(PacketType::Log->GetName(),             &Log);
    CMap.Insert(PacketType::VarDump->GetName(),         &VarDump);
    CMap.Insert(PacketType::ArrDump->GetName(),         &ArrDump);
    CMap.Insert(PacketType::TabDump->GetName(),         &TabDump);
    CMap.Insert(PacketType::Tmtc->GetName(),            &Tmtc);
    CMap.Insert(PacketType::Mcmd->GetName(),            &Mcmd);
    CMap.Insert(PacketType::TsbT->GetName(),            &TsbT);
    CMap.Insert(PacketType::TsbB->GetName(),            &TsbB);
    CMap.Insert(PacketType::CalibHeader->GetName(),     &CalibHeader);
    CMap.Insert(PacketType::CalibTrailer->GetName(),    &CalibTrailer);  
    CMap.Insert(PacketType::CalibCalPulse1->GetName(),  &CalibCalPulse1);
    CMap.Insert(PacketType::CalibCalPulse2->GetName(),  &CalibCalPulse2);
    CMap.Insert(PacketType::CalibTrkBoth->GetName(),    &CalibTrkBoth);
    CMap.Insert(PacketType::CalibTrk1->GetName(),       &CalibTrk1);
    CMap.Insert(PacketType::CalibTrk2->GetName(),       &CalibTrk2);
    CMap.Insert(PacketType::CalibS4->GetName(),         &CalibS4);
    CMap.Insert(PacketType::CalibCalPed->GetName(),     &CalibCalPed);
    CMap.Insert(PacketType::Calib1_Ac1->GetName(),      &Calib1_Ac1);
    CMap.Insert(PacketType::Calib2_Ac1->GetName(),      &Calib2_Ac1);
    CMap.Insert(PacketType::Calib1_Ac2->GetName(),      &Calib1_Ac2);
    CMap.Insert(PacketType::Calib2_Ac2->GetName(),      &Calib2_Ac2);
    CMap.Insert(PacketType::CalibCal->GetName(),        &CalibCal);
    CMap.Insert(PacketType::EventTrk->GetName(),        &EventTrk);  
    CMap.Insert(PacketType::Ac1Init->GetName(),         &Ac1Init);
    CMap.Insert(PacketType::CalInit->GetName(),         &CalInit);
    CMap.Insert(PacketType::TrkInit->GetName(),         &TrkInit);
    CMap.Insert(PacketType::TofInit->GetName(),         &TofInit);
    CMap.Insert(PacketType::TrgInit->GetName(),         &TrgInit);
    CMap.Insert(PacketType::NdInit->GetName(),          &NdInit);
    CMap.Insert(PacketType::S4Init->GetName(),          &S4Init);
    CMap.Insert(PacketType::Ac2Init->GetName(),         &Ac2Init);
    CMap.Insert(PacketType::CalAlarm->GetName(),        &CalAlarm);
    CMap.Insert(PacketType::Ac1Alarm->GetName(),        &Ac1Alarm);
    CMap.Insert(PacketType::TrkAlarm->GetName(),        &TrkAlarm);
    CMap.Insert(PacketType::TrgAlarm->GetName(),        &TrgAlarm);
    CMap.Insert(PacketType::TofAlarm->GetName(),        &TofAlarm);
    CMap.Insert(PacketType::S4Alarm->GetName(),         &S4Alarm);
    CMap.Insert(PacketType::Ac2Alarm->GetName(),        &Ac2Alarm);
    CMap.Insert(PacketType::ForcedFECmd->GetName(),     &ForcedFECmd);
    CMap.Insert(PacketType::CalibTof->GetName(),        &CalibTof);
  
}

/**
 * Increment the event counter for a certain packet.
 * @param type Event type to be incremented.
 */
void EventCounter::Increment(PacketType const * type) throw (NotExistingCounterException){
  //  cout << " increment "<< endl;
  mapval *p = CMap.Find(type->GetName());
  if ( !CMap.end()) {    
    //    cout << " A Counter." <<  type->GetName() << " = " <<  (*(&p->count)) << endl;
    (*(p->count))++; 
    //(*(&p->count))++; 
    //    cout << " B Counter." <<  type->GetName() << " = " <<  (*(&p->count)) << endl;
  } else {    
    oss.str("");
    oss << "\n No counter of type  " << type->GetName();
    throw NotExistingCounterException(oss.str().c_str());
  }
}

/**
 * Get the counter corresponding to a certain packet type.
 * @param type Event type to be incremented.
 * @return The counter of that packet type. For the current event type, 
 * this is the actual event number. For all other types, this is the event 
 * number of the last read event of that type.
 * @retval -1 if there was no event of this type.
 */
int EventCounter::Get(PacketType const * type) throw (NotExistingCounterException){
  //  cout << " get "<< endl;
  mapval *p = CMap.Find(type->GetName());
  if ( !CMap.end()) { 
    //    cout << " C Counter." <<  type->GetName() << " = " <<  (*(p->count)) << endl;
    return ((*(p->count)));
    //    return ((*(&p->count)));
  } else {
    throw NotExistingCounterException(type->GetName());
    return -1;
  }
}

/**
 * Get the counter of the next event corresponding to a certain packet type.
 * @param type Event type to be incremented.
 * @return The next counter of that packet type. 
 * @retval -1 if there was no event of this type.
 */
int EventCounter::Next(PacketType const * type) throw (NotExistingCounterException){
  //  cout << " next "<< endl;
  mapval *p = CMap.Find(type->GetName());
  if ( !CMap.end()) { 
    //    cout << " NEXT Counter." <<  type->GetName() << " = " <<  (*(p->count))+1 << endl;
    return ((*(p->count)) + 1);
    //    return ((*(&p->count)) + 1);
    //    return ((&(p->count)) + 1);
  } else {
    throw NotExistingCounterException(type->GetName());
    return -1;
  }
}

/**
 * Get the all the counters 
  * @retval 0 if there was no event of this type.
 */
void EventCounter::PrintCounters(){
  std::cout<<"PrintCounters:"<<std::endl;
  //
  for (Int_t i=0; i < CMap.GetEntries(); i++){
    mapval *p = CMap.Get(i);
    oss.str("");
    oss <<  " Counter." <<  (p->name).Data()  <<   " \t \t " <<  (*(p->count));
    //    oss <<  " Counter." <<  (p->name).Data()  <<   " \t \t " <<  (*(&p->count));
    //    oss <<  " Counter." <<  (p->name).Data()  <<   " \t \t " <<  (&(p->count));
    std::cout<<oss.str()<<std::endl;
  };
}

ClassImp(mapval)
ClassImp(mappa)
ClassImp(EventCounter)  
1	mocchiut	1.1	/** @file
2	mocchiut	1.2	* $Source: /afs/ba.infn.it/user/pamela/src/CVS/chewbacca/event/EventCounter.cpp,v $
3	mocchiut	1.6	* $Id: EventCounter.cpp,v 1.5 2010/02/11 09:02:15 mocchiut Exp $
4	mocchiut	1.2	* $Author: mocchiut $
5	mocchiut	1.1	*
6			* Implementation of the EventCounter class.
7			*/
8			////#include <log4cxx/logger.h>
9			#include <sstream>
10			#include <iostream>//mmmm
11
12			#include "EventCounter.h"
13			#include "PscuHeader.h"
14
15			//marco
16			////static log4cxx::LoggerPtr logger = log4cxx::Logger::getLogger(_T("pamela.techmodel.EventCounter"));
17			static std::stringstream oss;
18	mocchiut	1.4
19	mocchiut	1.1	using namespace pamela;
20
21	mocchiut	1.4
22			mapval::mapval(): count(0), name(""){ }
23
24			mapval::mapval(TString n, Int_t *i): count(i), name(n){ }
25
26			mappa::mappa(){
27			val = 0;
28			this->Clear();
29			}
30
31			void mappa::Clear(Option_t *t){
32			// cout << " mappa clear" << endl;
33			t="";
34			if ( val ){
35	mocchiut	1.6	// printf("val delete in clear\n");
36	mocchiut	1.4	val->Delete();
37	mocchiut	1.6	delete val;
38	mocchiut	1.4	val = 0;
39			};
40			fend = false;
41			entries = 0;
42			}
43
44			void mappa::Set(){
45			// cout << " in mappa set" << endl;
46	mocchiut	1.6	if (val){
47			val->Delete();
48			delete val;
49			val = 0;
50			}
51	mocchiut	1.5	val = new TClonesArray("pamela::mapval",47);
52	mocchiut	1.4	// cout << " out mappa set" << endl;
53			}
54
55			void mappa::Delete(Option_t *t){
56			// cout << " mappa del" << endl;
57			if ( val ){
58	mocchiut	1.6	// printf("val delete in delete\n");
59	mocchiut	1.4	val->Delete();
60	mocchiut	1.6	delete val;
61	mocchiut	1.4	val = 0;
62			// delete val;
63			};
64			delete this;
65			}
66
67			void mappa::Insert(TString nme, Int_t *valu){
68			// cout << " mappa insert " << nme.Data() << " valu " << *valu << endl;
69			if ( !val ) this->Set();
70			TClonesArray &t = *val;
71			new(t[entries]) mapval(nme,valu);
72			entries++;
73			}
74
75			mapval::mapval(const mapval &t){
76			name = t.name;
77			count = t.count;
78			}
79
80			mapval* mappa::Find(TString n){
81			Bool_t fo = false;
82			fend = false;
83			mapval *c = NULL;
84			for (Int_t i=0; i < entries; i++){
85			c = (mapval*)val->At(i);
86			if ( c && !strcmp(c->name.Data(),n.Data()) ){
87			fo = true;
88			break;
89			};
90			};
91			if ( !fo ) fend = true;
92			return c;
93			}
94
95	mocchiut	1.1	/**
96			* Create a new event counter for a certain run.
97			* @param run Run number.
98			*/
99			EventCounter::EventCounter(int run):
100			// New Packets.
101	mocchiut	1.3	RunNumber(run),
102	mocchiut	1.1	Pscu(0),
103			PhysEndRun(0),
104			CalibCalPulse1(0),
105			CalibCalPulse2(0),
106			Physics(0),
107			CalibTrkBoth(0),
108			CalibTrk1(0),
109			CalibTrk2(0),
110	mocchiut	1.2	CalibCal(0),
111	mocchiut	1.1	CalibTof(0),
112			CalibS4(0),
113			CalibCalPed(0),
114			Calib1_Ac1(0),
115	mocchiut	1.2	Calib1_Ac2(0),
116	mocchiut	1.1	Calib2_Ac1(0),
117			Calib2_Ac2(0),
118			RunHeader(0),
119			RunTrailer(0),
120			CalibHeader(0),
121			CalibTrailer(0),
122			InitHeader(0),
123			InitTrailer(0),
124			EventTrk(0),
125			Log(0),
126			VarDump(0),
127			ArrDump(0),
128			TabDump(0),
129			Tmtc(0),
130			Mcmd(0),
131			ForcedFECmd(0),
132			Ac1Init(0),
133			CalInit(0),
134			TrkInit(0),
135			TofInit(0),
136			TrgInit(0),
137			NdInit(0),
138			S4Init(0),
139			Ac2Init(0),
140			CalAlarm(0),
141			Ac1Alarm(0),
142			TrkAlarm(0),
143			TrgAlarm(0),
144			TofAlarm(0),
145			S4Alarm(0),
146			Ac2Alarm(0),
147			TsbT(0),
148	mocchiut	1.3	TsbB(0) {
149	mocchiut	1.4	CMap.Set();
150			CMap.Insert(PacketType::Physics->GetName(), &Physics);
151			CMap.Insert(PacketType::Pscu->GetName(), &Pscu);
152			CMap.Insert(PacketType::RunHeader->GetName(), &RunHeader);
153			CMap.Insert(PacketType::RunTrailer->GetName(), &RunTrailer);
154			CMap.Insert(PacketType::PhysEndRun->GetName(), &PhysEndRun);
155			CMap.Insert(PacketType::InitHeader->GetName(), &InitHeader);
156			CMap.Insert(PacketType::InitTrailer->GetName(), &InitTrailer);
157			CMap.Insert(PacketType::Log->GetName(), &Log);
158			CMap.Insert(PacketType::VarDump->GetName(), &VarDump);
159			CMap.Insert(PacketType::ArrDump->GetName(), &ArrDump);
160			CMap.Insert(PacketType::TabDump->GetName(), &TabDump);
161			CMap.Insert(PacketType::Tmtc->GetName(), &Tmtc);
162			CMap.Insert(PacketType::Mcmd->GetName(), &Mcmd);
163			CMap.Insert(PacketType::TsbT->GetName(), &TsbT);
164			CMap.Insert(PacketType::TsbB->GetName(), &TsbB);
165			CMap.Insert(PacketType::CalibHeader->GetName(), &CalibHeader);
166			CMap.Insert(PacketType::CalibTrailer->GetName(), &CalibTrailer);
167			CMap.Insert(PacketType::CalibCalPulse1->GetName(), &CalibCalPulse1);
168			CMap.Insert(PacketType::CalibCalPulse2->GetName(), &CalibCalPulse2);
169			CMap.Insert(PacketType::CalibTrkBoth->GetName(), &CalibTrkBoth);
170			CMap.Insert(PacketType::CalibTrk1->GetName(), &CalibTrk1);
171			CMap.Insert(PacketType::CalibTrk2->GetName(), &CalibTrk2);
172			CMap.Insert(PacketType::CalibS4->GetName(), &CalibS4);
173			CMap.Insert(PacketType::CalibCalPed->GetName(), &CalibCalPed);
174			CMap.Insert(PacketType::Calib1_Ac1->GetName(), &Calib1_Ac1);
175			CMap.Insert(PacketType::Calib2_Ac1->GetName(), &Calib2_Ac1);
176			CMap.Insert(PacketType::Calib1_Ac2->GetName(), &Calib1_Ac2);
177			CMap.Insert(PacketType::Calib2_Ac2->GetName(), &Calib2_Ac2);
178			CMap.Insert(PacketType::CalibCal->GetName(), &CalibCal);
179			CMap.Insert(PacketType::EventTrk->GetName(), &EventTrk);
180			CMap.Insert(PacketType::Ac1Init->GetName(), &Ac1Init);
181			CMap.Insert(PacketType::CalInit->GetName(), &CalInit);
182			CMap.Insert(PacketType::TrkInit->GetName(), &TrkInit);
183			CMap.Insert(PacketType::TofInit->GetName(), &TofInit);
184			CMap.Insert(PacketType::TrgInit->GetName(), &TrgInit);
185			CMap.Insert(PacketType::NdInit->GetName(), &NdInit);
186			CMap.Insert(PacketType::S4Init->GetName(), &S4Init);
187			CMap.Insert(PacketType::Ac2Init->GetName(), &Ac2Init);
188			CMap.Insert(PacketType::CalAlarm->GetName(), &CalAlarm);
189			CMap.Insert(PacketType::Ac1Alarm->GetName(), &Ac1Alarm);
190			CMap.Insert(PacketType::TrkAlarm->GetName(), &TrkAlarm);
191			CMap.Insert(PacketType::TrgAlarm->GetName(), &TrgAlarm);
192			CMap.Insert(PacketType::TofAlarm->GetName(), &TofAlarm);
193			CMap.Insert(PacketType::S4Alarm->GetName(), &S4Alarm);
194			CMap.Insert(PacketType::Ac2Alarm->GetName(), &Ac2Alarm);
195			CMap.Insert(PacketType::ForcedFECmd->GetName(), &ForcedFECmd);
196			CMap.Insert(PacketType::CalibTof->GetName(), &CalibTof);
197
198	mocchiut	1.1	}
199
200			/**
201			* Increment the event counter for a certain packet.
202			* @param type Event type to be incremented.
203			*/
204			void EventCounter::Increment(PacketType const * type) throw (NotExistingCounterException){
205	mocchiut	1.4	// cout << " increment "<< endl;
206			mapval *p = CMap.Find(type->GetName());
207			if ( !CMap.end()) {
208			// cout << " A Counter." << type->GetName() << " = " << (*(&p->count)) << endl;
209			(*(p->count))++;
210			//(*(&p->count))++;
211			// cout << " B Counter." << type->GetName() << " = " << (*(&p->count)) << endl;
212			} else {
213	mocchiut	1.1	oss.str("");
214	mocchiut	1.2	oss << "\n No counter of type " << type->GetName();
215	mocchiut	1.1	throw NotExistingCounterException(oss.str().c_str());
216			}
217			}
218
219			/**
220			* Get the counter corresponding to a certain packet type.
221			* @param type Event type to be incremented.
222			* @return The counter of that packet type. For the current event type,
223			* this is the actual event number. For all other types, this is the event
224			* number of the last read event of that type.
225			* @retval -1 if there was no event of this type.
226			*/
227	mocchiut	1.4	int EventCounter::Get(PacketType const * type) throw (NotExistingCounterException){
228			// cout << " get "<< endl;
229			mapval *p = CMap.Find(type->GetName());
230			if ( !CMap.end()) {
231			// cout << " C Counter." << type->GetName() << " = " << (*(p->count)) << endl;
232			return ((*(p->count)));
233			// return ((*(&p->count)));
234	mocchiut	1.1	} else {
235	mocchiut	1.2	throw NotExistingCounterException(type->GetName());
236	mocchiut	1.1	return -1;
237			}
238			}
239
240			/**
241			* Get the counter of the next event corresponding to a certain packet type.
242			* @param type Event type to be incremented.
243			* @return The next counter of that packet type.
244			* @retval -1 if there was no event of this type.
245			*/
246	mocchiut	1.4	int EventCounter::Next(PacketType const * type) throw (NotExistingCounterException){
247			// cout << " next "<< endl;
248			mapval *p = CMap.Find(type->GetName());
249			if ( !CMap.end()) {
250			// cout << " NEXT Counter." << type->GetName() << " = " << (*(p->count))+1 << endl;
251			return ((*(p->count)) + 1);
252			// return ((*(&p->count)) + 1);
253			// return ((&(p->count)) + 1);
254	mocchiut	1.1	} else {
255	mocchiut	1.2	throw NotExistingCounterException(type->GetName());
256	mocchiut	1.1	return -1;
257			}
258			}
259
260			/**
261			* Get the all the counters
262			* @retval 0 if there was no event of this type.
263			*/
264	mocchiut	1.4	void EventCounter::PrintCounters(){
265			std::cout<<"PrintCounters:"<<std::endl;
266			//
267			for (Int_t i=0; i < CMap.GetEntries(); i++){
268			mapval *p = CMap.Get(i);
269			oss.str("");
270			oss << " Counter." << (p->name).Data() << " \t \t " << (*(p->count));
271			// oss << " Counter." << (p->name).Data() << " \t \t " << (*(&p->count));
272			// oss << " Counter." << (p->name).Data() << " \t \t " << (&(p->count));
273			std::cout<<oss.str()<<std::endl;
274			};
275	mocchiut	1.1	}
276	mocchiut	1.2
277	mocchiut	1.4	ClassImp(mapval)
278			ClassImp(mappa)
279	mocchiut	1.2	ClassImp(EventCounter)