yoda/event/EventCounter.cpp

/** @file
 * $Source: /home/cvsmanager/yoda/event/EventCounter.cpp,v $
 * $Id: EventCounter.cpp,v 3.0 2005/03/04 15:54:11 kusanagi Exp $
 * $Author: kusanagi $
 * 
 * Implementation of the EventCounter class.
 */
#include <log4cxx/logger.h>
#include <sstream>

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


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

/**
 * Create a new event counter for a certain run.
 * @param run Run number.
 */
EventCounter::EventCounter(int run):
  // New Packets.
  Pscu(0),
  PhysEndRun(0),
  CalibCalPulse1(0),
  CalibCalPulse2(0),
  Physics(0),
  CalibTrkBoth(0),
  CalibTrk1(0),
  CalibTrk2(0),
  CalibTrd(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),
  TestTrk(0),
  TestTof(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),
  AcAlarm(0),
  TrkAlarm(0),
  TrgAlarm(0),
  TofAlarm(0),
  S4Alarm(0),
  TsbT(0),
  TsbB(0),
  RunNumber(run) { 
    CMap.insert(CounterMap::value_type(PacketType::Pscu,            &Pscu));
    CMap.insert(CounterMap::value_type(PacketType::PhysEndRun,      &PhysEndRun));
    CMap.insert(CounterMap::value_type(PacketType::CalibCalPulse1,  &CalibCalPulse1));
    CMap.insert(CounterMap::value_type(PacketType::CalibCalPulse2,  &CalibCalPulse2));
    CMap.insert(CounterMap::value_type(PacketType::Physics,         &Physics));
    CMap.insert(CounterMap::value_type(PacketType::CalibTrkBoth,    &CalibTrkBoth));
    CMap.insert(CounterMap::value_type(PacketType::CalibTrk1,       &CalibTrk1));
    CMap.insert(CounterMap::value_type(PacketType::CalibTrk2,       &CalibTrk2));
    CMap.insert(CounterMap::value_type(PacketType::CalibTrd,        &CalibTrd));
    CMap.insert(CounterMap::value_type(PacketType::CalibTof,        &CalibTof));
    CMap.insert(CounterMap::value_type(PacketType::CalibS4,         &CalibS4));
    CMap.insert(CounterMap::value_type(PacketType::CalibCalPed,     &CalibCalPed));
    CMap.insert(CounterMap::value_type(PacketType::Calib1_Ac1,      &Calib1_Ac1));
    CMap.insert(CounterMap::value_type(PacketType::Calib1_Ac2,      &Calib1_Ac2));
    CMap.insert(CounterMap::value_type(PacketType::Calib2_Ac1,      &Calib2_Ac1));
    CMap.insert(CounterMap::value_type(PacketType::Calib2_Ac2,      &Calib2_Ac2));
    CMap.insert(CounterMap::value_type(PacketType::RunHeader,       &RunHeader));
    CMap.insert(CounterMap::value_type(PacketType::RunTrailer,      &RunTrailer));
    CMap.insert(CounterMap::value_type(PacketType::CalibHeader,     &CalibHeader));
    CMap.insert(CounterMap::value_type(PacketType::CalibTrailer,    &CalibTrailer));  
    CMap.insert(CounterMap::value_type(PacketType::InitHeader,      &InitHeader));
    CMap.insert(CounterMap::value_type(PacketType::InitTrailer,     &InitTrailer));  
    CMap.insert(CounterMap::value_type(PacketType::EventTrk,        &EventTrk));  
    CMap.insert(CounterMap::value_type(PacketType::TestTrk,         &TestTrk));  
    CMap.insert(CounterMap::value_type(PacketType::TestTof,         &TestTof));  
    CMap.insert(CounterMap::value_type(PacketType::Log,             &Log));
    CMap.insert(CounterMap::value_type(PacketType::VarDump,         &VarDump));
    CMap.insert(CounterMap::value_type(PacketType::ArrDump,         &ArrDump));
    CMap.insert(CounterMap::value_type(PacketType::TabDump,         &TabDump));
    CMap.insert(CounterMap::value_type(PacketType::Tmtc,            &Tmtc));
    CMap.insert(CounterMap::value_type(PacketType::Mcmd,            &Mcmd));
    CMap.insert(CounterMap::value_type(PacketType::ForcedFECmd,     &ForcedFECmd));
    CMap.insert(CounterMap::value_type(PacketType::Ac1Init,         &Ac1Init));
    CMap.insert(CounterMap::value_type(PacketType::CalInit,         &CalInit));
    CMap.insert(CounterMap::value_type(PacketType::TrkInit,         &TrkInit));
    CMap.insert(CounterMap::value_type(PacketType::TofInit,         &TofInit));
    CMap.insert(CounterMap::value_type(PacketType::NdInit,          &NdInit));
    CMap.insert(CounterMap::value_type(PacketType::S4Init,          &S4Init));
    CMap.insert(CounterMap::value_type(PacketType::Ac2Init,         &Ac2Init));
    CMap.insert(CounterMap::value_type(PacketType::CalAlarm,        &CalAlarm));
    CMap.insert(CounterMap::value_type(PacketType::AcAlarm,         &AcAlarm));
    CMap.insert(CounterMap::value_type(PacketType::TrkAlarm,        &TrkAlarm));
    CMap.insert(CounterMap::value_type(PacketType::TrgAlarm,        &TrgAlarm));
    CMap.insert(CounterMap::value_type(PacketType::TofAlarm,        &TofAlarm));
    CMap.insert(CounterMap::value_type(PacketType::S4Alarm,         &S4Alarm));
    CMap.insert(CounterMap::value_type(PacketType::TsbT,            &TsbT));
    CMap.insert(CounterMap::value_type(PacketType::TsbB,            &TsbB));
}

/**
 * Increment the event counter for a certain packet.
 * @param type Event type to be incremented.
 */
void EventCounter::Increment(PacketType const * type) throw (NotExistingCounterException){
  CounterMap::iterator p = CMap.find(type);
  if (p != CMap.end()) {
    int *counter = p->second;
    (*counter)++;
    oss.str("");
    oss << " Counter." <<  type->GetName() << " = " <<  (*counter);
    logger->info(oss.str().c_str());
  } else {
    oss.str("");
    oss << "\n No counter of type  " << type->GetName().c_str();
    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) const throw (NotExistingCounterException){
  const CounterMap::const_iterator p = CMap.find(type);
  if (p != CMap.end()) {
    const int *counter = p->second;
    return *counter;
  } else {
    throw NotExistingCounterException(type->GetName().c_str());
    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) const throw (NotExistingCounterException){
  const CounterMap::const_iterator p = CMap.find(type);
  if (p != CMap.end()) {
    const int *counter = p->second;
    return *counter + 1;
  } else {
    throw NotExistingCounterException(type->GetName().c_str());
    return -1;
  }
}

/**
 * Get the all the counters 
  * @retval 0 if there was no event of this type.
 */
void EventCounter::PrintCounters() const {
  for(CounterMap::const_iterator p = CMap.begin(); p != CMap.end(); p++) {
  oss.str("");
  oss <<  " Counter." <<  (p->first)->GetName()  <<   " \t \t " <<  (*p->second);
  logger->info(oss.str().c_str());
  } 
}
1	kusanagi	1.1	/** @file
2	kusanagi	1.2	* $Source: /home/cvsmanager/yoda/event/EventCounter.cpp,v $
3	kusanagi	4.0	* $Id: EventCounter.cpp,v 3.0 2005/03/04 15:54:11 kusanagi Exp $
4	kusanagi	1.2	* $Author: kusanagi $
5	kusanagi	1.1	*
6			* Implementation of the EventCounter class.
7			*/
8	kusanagi	1.7	#include <log4cxx/logger.h>
9			#include <sstream>
10	kusanagi	1.1
11			#include "EventCounter.h"
12			#include "PscuHeader.h"
13
14
15	kusanagi	1.7	static log4cxx::LoggerPtr logger = log4cxx::Logger::getLogger(_T("pamela.techmodel.EventCounter"));
16			static std::stringstream oss;
17	kusanagi	1.1	using namespace pamela;
18
19			/**
20			* Create a new event counter for a certain run.
21			* @param run Run number.
22			*/
23			EventCounter::EventCounter(int run):
24			// New Packets.
25	kusanagi	1.4	Pscu(0),
26	kusanagi	1.5	PhysEndRun(0),
27			CalibCalPulse1(0),
28			CalibCalPulse2(0),
29	kusanagi	1.4	Physics(0),
30	kusanagi	1.5	CalibTrkBoth(0),
31	kusanagi	2.6	CalibTrk1(0),
32			CalibTrk2(0),
33			CalibTrd(0),
34			CalibTof(0),
35			CalibS4(0),
36			CalibCalPed(0),
37	kusanagi	2.4	Calib1_Ac1(0),
38			Calib1_Ac2(0),
39			Calib2_Ac1(0),
40			Calib2_Ac2(0),
41	kusanagi	2.6	RunHeader(0),
42			RunTrailer(0),
43	kusanagi	1.5	CalibHeader(0),
44			CalibTrailer(0),
45			InitHeader(0),
46			InitTrailer(0),
47			EventTrk(0),
48			TestTrk(0),
49	kusanagi	1.7	TestTof(0),
50	kusanagi	1.4	Log(0),
51			VarDump(0),
52			ArrDump(0),
53			TabDump(0),
54			Tmtc(0),
55			Mcmd(0),
56	kusanagi	1.5	ForcedFECmd(0),
57	kusanagi	2.4	Ac1Init(0),
58	kusanagi	1.5	CalInit(0),
59			TrkInit(0),
60			TofInit(0),
61			TrgInit(0),
62	kusanagi	2.1	NdInit(0),
63	kusanagi	2.3	S4Init(0),
64	kusanagi	2.4	Ac2Init(0),
65	kusanagi	1.7	CalAlarm(0),
66			AcAlarm(0),
67			TrkAlarm(0),
68			TrgAlarm(0),
69			TofAlarm(0),
70	kusanagi	2.3	S4Alarm(0),
71	kusanagi	2.8	TsbT(0),
72			TsbB(0),
73	kusanagi	1.1	RunNumber(run) {
74	kusanagi	1.5	CMap.insert(CounterMap::value_type(PacketType::Pscu, &Pscu));
75			CMap.insert(CounterMap::value_type(PacketType::PhysEndRun, &PhysEndRun));
76	kusanagi	2.2	CMap.insert(CounterMap::value_type(PacketType::CalibCalPulse1, &CalibCalPulse1));
77	kusanagi	1.5	CMap.insert(CounterMap::value_type(PacketType::CalibCalPulse2, &CalibCalPulse2));
78			CMap.insert(CounterMap::value_type(PacketType::Physics, &Physics));
79			CMap.insert(CounterMap::value_type(PacketType::CalibTrkBoth, &CalibTrkBoth));
80	kusanagi	2.6	CMap.insert(CounterMap::value_type(PacketType::CalibTrk1, &CalibTrk1));
81			CMap.insert(CounterMap::value_type(PacketType::CalibTrk2, &CalibTrk2));
82			CMap.insert(CounterMap::value_type(PacketType::CalibTrd, &CalibTrd));
83			CMap.insert(CounterMap::value_type(PacketType::CalibTof, &CalibTof));
84			CMap.insert(CounterMap::value_type(PacketType::CalibS4, &CalibS4));
85			CMap.insert(CounterMap::value_type(PacketType::CalibCalPed, &CalibCalPed));
86	kusanagi	2.4	CMap.insert(CounterMap::value_type(PacketType::Calib1_Ac1, &Calib1_Ac1));
87			CMap.insert(CounterMap::value_type(PacketType::Calib1_Ac2, &Calib1_Ac2));
88			CMap.insert(CounterMap::value_type(PacketType::Calib2_Ac1, &Calib2_Ac1));
89			CMap.insert(CounterMap::value_type(PacketType::Calib2_Ac2, &Calib2_Ac2));
90	kusanagi	2.6	CMap.insert(CounterMap::value_type(PacketType::RunHeader, &RunHeader));
91			CMap.insert(CounterMap::value_type(PacketType::RunTrailer, &RunTrailer));
92	kusanagi	1.5	CMap.insert(CounterMap::value_type(PacketType::CalibHeader, &CalibHeader));
93			CMap.insert(CounterMap::value_type(PacketType::CalibTrailer, &CalibTrailer));
94			CMap.insert(CounterMap::value_type(PacketType::InitHeader, &InitHeader));
95			CMap.insert(CounterMap::value_type(PacketType::InitTrailer, &InitTrailer));
96			CMap.insert(CounterMap::value_type(PacketType::EventTrk, &EventTrk));
97			CMap.insert(CounterMap::value_type(PacketType::TestTrk, &TestTrk));
98	kusanagi	1.7	CMap.insert(CounterMap::value_type(PacketType::TestTof, &TestTof));
99	kusanagi	1.5	CMap.insert(CounterMap::value_type(PacketType::Log, &Log));
100			CMap.insert(CounterMap::value_type(PacketType::VarDump, &VarDump));
101			CMap.insert(CounterMap::value_type(PacketType::ArrDump, &ArrDump));
102			CMap.insert(CounterMap::value_type(PacketType::TabDump, &TabDump));
103			CMap.insert(CounterMap::value_type(PacketType::Tmtc, &Tmtc));
104			CMap.insert(CounterMap::value_type(PacketType::Mcmd, &Mcmd));
105			CMap.insert(CounterMap::value_type(PacketType::ForcedFECmd, &ForcedFECmd));
106	kusanagi	2.4	CMap.insert(CounterMap::value_type(PacketType::Ac1Init, &Ac1Init));
107	kusanagi	1.5	CMap.insert(CounterMap::value_type(PacketType::CalInit, &CalInit));
108			CMap.insert(CounterMap::value_type(PacketType::TrkInit, &TrkInit));
109			CMap.insert(CounterMap::value_type(PacketType::TofInit, &TofInit));
110	kusanagi	2.3	CMap.insert(CounterMap::value_type(PacketType::NdInit, &NdInit));
111			CMap.insert(CounterMap::value_type(PacketType::S4Init, &S4Init));
112	kusanagi	2.4	CMap.insert(CounterMap::value_type(PacketType::Ac2Init, &Ac2Init));
113	kusanagi	1.7	CMap.insert(CounterMap::value_type(PacketType::CalAlarm, &CalAlarm));
114			CMap.insert(CounterMap::value_type(PacketType::AcAlarm, &AcAlarm));
115			CMap.insert(CounterMap::value_type(PacketType::TrkAlarm, &TrkAlarm));
116			CMap.insert(CounterMap::value_type(PacketType::TrgAlarm, &TrgAlarm));
117			CMap.insert(CounterMap::value_type(PacketType::TofAlarm, &TofAlarm));
118	kusanagi	2.3	CMap.insert(CounterMap::value_type(PacketType::S4Alarm, &S4Alarm));
119	kusanagi	2.8	CMap.insert(CounterMap::value_type(PacketType::TsbT, &TsbT));
120			CMap.insert(CounterMap::value_type(PacketType::TsbB, &TsbB));
121	kusanagi	1.1	}
122
123			/**
124			* Increment the event counter for a certain packet.
125			* @param type Event type to be incremented.
126			*/
127	kusanagi	2.2	void EventCounter::Increment(PacketType const * type) throw (NotExistingCounterException){
128	kusanagi	1.1	CounterMap::iterator p = CMap.find(type);
129			if (p != CMap.end()) {
130			int *counter = p->second;
131			(*counter)++;
132	kusanagi	2.2	oss.str("");
133	kusanagi	1.7	oss << " Counter." << type->GetName() << " = " << (*counter);
134	kusanagi	2.7	logger->info(oss.str().c_str());
135	kusanagi	1.1	} else {
136	kusanagi	2.5	oss.str("");
137			oss << "\n No counter of type " << type->GetName().c_str();
138			throw NotExistingCounterException(oss.str().c_str());
139	kusanagi	1.1	}
140			}
141
142			/**
143			* Get the counter corresponding to a certain packet type.
144			* @param type Event type to be incremented.
145			* @return The counter of that packet type. For the current event type,
146			* this is the actual event number. For all other types, this is the event
147			* number of the last read event of that type.
148			* @retval -1 if there was no event of this type.
149			*/
150	kusanagi	2.2	int EventCounter::Get(PacketType const * type) const throw (NotExistingCounterException){
151	kusanagi	1.1	const CounterMap::const_iterator p = CMap.find(type);
152			if (p != CMap.end()) {
153			const int *counter = p->second;
154			return *counter;
155			} else {
156	kusanagi	2.2	throw NotExistingCounterException(type->GetName().c_str());
157	kusanagi	1.1	return -1;
158			}
159			}
160
161			/**
162			* Get the counter of the next event corresponding to a certain packet type.
163			* @param type Event type to be incremented.
164			* @return The next counter of that packet type.
165			* @retval -1 if there was no event of this type.
166			*/
167	kusanagi	2.2	int EventCounter::Next(PacketType const * type) const throw (NotExistingCounterException){
168	kusanagi	1.1	const CounterMap::const_iterator p = CMap.find(type);
169			if (p != CMap.end()) {
170			const int *counter = p->second;
171			return *counter + 1;
172			} else {
173	kusanagi	2.2	throw NotExistingCounterException(type->GetName().c_str());
174	kusanagi	1.1	return -1;
175			}
176			}
177
178			/**
179			* Get the all the counters
180	kusanagi	1.7	* @retval 0 if there was no event of this type.
181	kusanagi	1.1	*/
182			void EventCounter::PrintCounters() const {
183			for(CounterMap::const_iterator p = CMap.begin(); p != CMap.end(); p++) {
184	kusanagi	2.2	oss.str("");
185			oss << " Counter." << (p->first)->GetName() << " \t \t " << (*p->second);
186	kusanagi	2.7	logger->info(oss.str().c_str());
187	kusanagi	1.1	}
188			}