yoda/event/EventCounter.cpp

/** @file
 * $Source: /home/cvsmanager/yoda/event/EventCounter.cpp,v $
 * $Id: EventCounter.cpp,v 2.4 2004/12/16 17:32:46 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),
  Calib_Trk1(0),
  Calib_Trk2(0),
  Calib_Trd(0),
  Calib_Tof(0),
  Calib_S4(0),
  Calib_CalPed(0),
  Calib1_Ac1(0),
  Calib1_Ac2(0),
  Calib2_Ac1(0),
  Calib2_Ac2(0),
  Run_Header(0),
  Run_Trailer(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),
  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,       &Calib_Trk1));
    CMap.insert(CounterMap::value_type(PacketType::CalibTrk2,       &Calib_Trk2));
    CMap.insert(CounterMap::value_type(PacketType::CalibTrd,        &Calib_Trd));
    CMap.insert(CounterMap::value_type(PacketType::CalibTof,        &Calib_Tof));
    CMap.insert(CounterMap::value_type(PacketType::CalibS4,         &Calib_S4));
    CMap.insert(CounterMap::value_type(PacketType::CalibCalPed,     &Calib_CalPed));
    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,       &Run_Header));
    CMap.insert(CounterMap::value_type(PacketType::RunTrailer,      &Run_Trailer));
    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));
}

/**
 * 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->debug(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->warn(oss.str().c_str());
  } 
}
1	kusanagi	1.1	/** @file
2	kusanagi	1.2	* $Source: /home/cvsmanager/yoda/event/EventCounter.cpp,v $
3	kusanagi	2.5	* $Id: EventCounter.cpp,v 2.4 2004/12/16 17:32:46 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	1.4	Calib_Trk1(0),
32			Calib_Trk2(0),
33			Calib_Trd(0),
34			Calib_Tof(0),
35			Calib_S4(0),
36	kusanagi	1.5	Calib_CalPed(0),
37	kusanagi	2.4	Calib1_Ac1(0),
38			Calib1_Ac2(0),
39			Calib2_Ac1(0),
40			Calib2_Ac2(0),
41	kusanagi	1.4	Run_Header(0),
42			Run_Trailer(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	1.1	RunNumber(run) {
72	kusanagi	1.5	CMap.insert(CounterMap::value_type(PacketType::Pscu, &Pscu));
73			CMap.insert(CounterMap::value_type(PacketType::PhysEndRun, &PhysEndRun));
74	kusanagi	2.2	CMap.insert(CounterMap::value_type(PacketType::CalibCalPulse1, &CalibCalPulse1));
75	kusanagi	1.5	CMap.insert(CounterMap::value_type(PacketType::CalibCalPulse2, &CalibCalPulse2));
76			CMap.insert(CounterMap::value_type(PacketType::Physics, &Physics));
77			CMap.insert(CounterMap::value_type(PacketType::CalibTrkBoth, &CalibTrkBoth));
78			CMap.insert(CounterMap::value_type(PacketType::CalibTrk1, &Calib_Trk1));
79			CMap.insert(CounterMap::value_type(PacketType::CalibTrk2, &Calib_Trk2));
80			CMap.insert(CounterMap::value_type(PacketType::CalibTrd, &Calib_Trd));
81			CMap.insert(CounterMap::value_type(PacketType::CalibTof, &Calib_Tof));
82			CMap.insert(CounterMap::value_type(PacketType::CalibS4, &Calib_S4));
83			CMap.insert(CounterMap::value_type(PacketType::CalibCalPed, &Calib_CalPed));
84	kusanagi	2.4	CMap.insert(CounterMap::value_type(PacketType::Calib1_Ac1, &Calib1_Ac1));
85			CMap.insert(CounterMap::value_type(PacketType::Calib1_Ac2, &Calib1_Ac2));
86			CMap.insert(CounterMap::value_type(PacketType::Calib2_Ac1, &Calib2_Ac1));
87			CMap.insert(CounterMap::value_type(PacketType::Calib2_Ac2, &Calib2_Ac2));
88	kusanagi	1.5	CMap.insert(CounterMap::value_type(PacketType::RunHeader, &Run_Header));
89			CMap.insert(CounterMap::value_type(PacketType::RunTrailer, &Run_Trailer));
90			CMap.insert(CounterMap::value_type(PacketType::CalibHeader, &CalibHeader));
91			CMap.insert(CounterMap::value_type(PacketType::CalibTrailer, &CalibTrailer));
92			CMap.insert(CounterMap::value_type(PacketType::InitHeader, &InitHeader));
93			CMap.insert(CounterMap::value_type(PacketType::InitTrailer, &InitTrailer));
94			CMap.insert(CounterMap::value_type(PacketType::EventTrk, &EventTrk));
95			CMap.insert(CounterMap::value_type(PacketType::TestTrk, &TestTrk));
96	kusanagi	1.7	CMap.insert(CounterMap::value_type(PacketType::TestTof, &TestTof));
97	kusanagi	1.5	CMap.insert(CounterMap::value_type(PacketType::Log, &Log));
98			CMap.insert(CounterMap::value_type(PacketType::VarDump, &VarDump));
99			CMap.insert(CounterMap::value_type(PacketType::ArrDump, &ArrDump));
100			CMap.insert(CounterMap::value_type(PacketType::TabDump, &TabDump));
101			CMap.insert(CounterMap::value_type(PacketType::Tmtc, &Tmtc));
102			CMap.insert(CounterMap::value_type(PacketType::Mcmd, &Mcmd));
103			CMap.insert(CounterMap::value_type(PacketType::ForcedFECmd, &ForcedFECmd));
104	kusanagi	2.4	CMap.insert(CounterMap::value_type(PacketType::Ac1Init, &Ac1Init));
105	kusanagi	1.5	CMap.insert(CounterMap::value_type(PacketType::CalInit, &CalInit));
106			CMap.insert(CounterMap::value_type(PacketType::TrkInit, &TrkInit));
107			CMap.insert(CounterMap::value_type(PacketType::TofInit, &TofInit));
108	kusanagi	2.3	CMap.insert(CounterMap::value_type(PacketType::NdInit, &NdInit));
109			CMap.insert(CounterMap::value_type(PacketType::S4Init, &S4Init));
110	kusanagi	2.4	CMap.insert(CounterMap::value_type(PacketType::Ac2Init, &Ac2Init));
111	kusanagi	1.7	CMap.insert(CounterMap::value_type(PacketType::CalAlarm, &CalAlarm));
112			CMap.insert(CounterMap::value_type(PacketType::AcAlarm, &AcAlarm));
113			CMap.insert(CounterMap::value_type(PacketType::TrkAlarm, &TrkAlarm));
114			CMap.insert(CounterMap::value_type(PacketType::TrgAlarm, &TrgAlarm));
115			CMap.insert(CounterMap::value_type(PacketType::TofAlarm, &TofAlarm));
116	kusanagi	2.3	CMap.insert(CounterMap::value_type(PacketType::S4Alarm, &S4Alarm));
117	kusanagi	1.1	}
118
119			/**
120			* Increment the event counter for a certain packet.
121			* @param type Event type to be incremented.
122			*/
123	kusanagi	2.2	void EventCounter::Increment(PacketType const * type) throw (NotExistingCounterException){
124	kusanagi	1.1	CounterMap::iterator p = CMap.find(type);
125			if (p != CMap.end()) {
126			int *counter = p->second;
127			(*counter)++;
128	kusanagi	2.2	oss.str("");
129	kusanagi	1.7	oss << " Counter." << type->GetName() << " = " << (*counter);
130			logger->debug(oss.str().c_str());
131	kusanagi	1.1	} else {
132	kusanagi	2.5	oss.str("");
133			oss << "\n No counter of type " << type->GetName().c_str();
134			throw NotExistingCounterException(oss.str().c_str());
135	kusanagi	1.1	}
136			}
137
138			/**
139			* Get the counter corresponding to a certain packet type.
140			* @param type Event type to be incremented.
141			* @return The counter of that packet type. For the current event type,
142			* this is the actual event number. For all other types, this is the event
143			* number of the last read event of that type.
144			* @retval -1 if there was no event of this type.
145			*/
146	kusanagi	2.2	int EventCounter::Get(PacketType const * type) const throw (NotExistingCounterException){
147	kusanagi	1.1	const CounterMap::const_iterator p = CMap.find(type);
148			if (p != CMap.end()) {
149			const int *counter = p->second;
150			return *counter;
151			} else {
152	kusanagi	2.2	throw NotExistingCounterException(type->GetName().c_str());
153	kusanagi	1.1	return -1;
154			}
155			}
156
157			/**
158			* Get the counter of the next event corresponding to a certain packet type.
159			* @param type Event type to be incremented.
160			* @return The next counter of that packet type.
161			* @retval -1 if there was no event of this type.
162			*/
163	kusanagi	2.2	int EventCounter::Next(PacketType const * type) const throw (NotExistingCounterException){
164	kusanagi	1.1	const CounterMap::const_iterator p = CMap.find(type);
165			if (p != CMap.end()) {
166			const int *counter = p->second;
167			return *counter + 1;
168			} else {
169	kusanagi	2.2	throw NotExistingCounterException(type->GetName().c_str());
170	kusanagi	1.1	return -1;
171			}
172			}
173
174			/**
175			* Get the all the counters
176	kusanagi	1.7	* @retval 0 if there was no event of this type.
177	kusanagi	1.1	*/
178			void EventCounter::PrintCounters() const {
179			for(CounterMap::const_iterator p = CMap.begin(); p != CMap.end(); p++) {
180	kusanagi	2.2	oss.str("");
181			oss << " Counter." << (p->first)->GetName() << " \t \t " << (*p->second);
182	kusanagi	1.7	logger->warn(oss.str().c_str());
183	kusanagi	1.1	}
184			}