yoda/event/EventCounter.cpp

/** @file
 * $Source: /home/cvsmanager/yoda/event/EventCounter.cpp,v $
 * $Id: EventCounter.cpp,v 2.1 2004/09/24 11:57:32 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),
  CalAlarm(0),
  AcAlarm(0),
  TrkAlarm(0),
  TrgAlarm(0),
  TofAlarm(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::TrgInit,         &TrgInit));
    CMap.insert(CounterMap::value_type(PacketType::TrgInit,         &NdInit));
    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));
}

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