yoda/event/EventCounter.cpp

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