yoda/event/EventCounter.cpp

/** @file
 * $Source: /home/cvsmanager/yoda/event/EventCounter.cpp,v $
 * $Id: EventCounter.cpp,v 1.5 2004/07/29 16:18:53 kusanagi Exp $
 * $Author: kusanagi $
 * 
 * Implementation of the EventCounter class.
 */
#include <log4cpp/Category.hh>

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

static log4cpp::Category& cat = log4cpp::Category::getInstance("pamela.techmodel.EventCounter");  

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),
  Log(0),
  VarDump(0),
  ArrDump(0),
  TabDump(0),
  Tmtc(0),
  Mcmd(0),
  ForcedFECmd(0),
  AcInit(0),
  CalInit(0),
  TrkInit(0),
  TofInit(0),
  TrgInit(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::CalibCalPulse2,  &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::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));
}

/**
 * Increment the event counter for a certain packet.
 * @param type Event type to be incremented.
 */
void EventCounter::Increment(PacketType const * type) {
  CounterMap::iterator p = CMap.find(type);
  if (p != CMap.end()) {
    int *counter = p->second;
    (*counter)++;
    cat <<  log4cpp::Priority::DEBUG
        <<  " Counter." <<  type->GetName() << " = " <<  (*counter)
        <<  "\n " << log4cpp::CategoryStream::ENDLINE;
  } else {
    cat <<  log4cpp::Priority::WARN
        <<  " No counter for packet type " <<  type->GetName()
        <<  "\n " << log4cpp::CategoryStream::ENDLINE;
  }
}

/**
 * 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 {
  const CounterMap::const_iterator p = CMap.find(type);
  if (p != CMap.end()) {
    const int *counter = p->second;
    return *counter;
  } else {
        cat <<  log4cpp::Priority::WARN
        <<  " No counter for packet type " <<  type->GetName()
        <<  "\n " << log4cpp::CategoryStream::ENDLINE;
    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 {
  const CounterMap::const_iterator p = CMap.find(type);
  if (p != CMap.end()) {
    const int *counter = p->second;
    return *counter + 1;
  } else {
        cat <<  log4cpp::Priority::WARN
        <<  " No counter for packet type " <<  type->GetName()
        <<  "\n " << log4cpp::CategoryStream::ENDLINE;
    return -1;
  }
}

/**
 * Get the all the counters 
  * @retval -1 if there was no event of this type.
 */
void EventCounter::PrintCounters() const {
  for(CounterMap::const_iterator p = CMap.begin(); p != CMap.end(); p++) {
  cat <<  log4cpp::Priority::INFO <<  " Counter." <<  (p->first)->GetName()  <<   " = " <<  (*p->second)
      <<  "\n " << log4cpp::CategoryStream::ENDLINE;
  } 
}
1	/** @file
2	* $Source: /home/cvsmanager/yoda/event/EventCounter.cpp,v $
3	* $Id: EventCounter.cpp,v 1.5 2004/07/29 16:18:53 kusanagi Exp $
4	* $Author: kusanagi $
5	*
6	* Implementation of the EventCounter class.
7	*/
8	#include <log4cpp/Category.hh>
9
10	#include "EventCounter.h"
11	#include "PscuHeader.h"
12
13	static log4cpp::Category& cat = log4cpp::Category::getInstance("pamela.techmodel.EventCounter");
14
15	using namespace pamela;
16
17	/**
18	* Create a new event counter for a certain run.
19	* @param run Run number.
20	*/
21	EventCounter::EventCounter(int run):
22	// New Packets.
23	Pscu(0),
24	PhysEndRun(0),
25	CalibCalPulse1(0),
26	CalibCalPulse2(0),
27	Physics(0),
28	CalibTrkBoth(0),
29	Calib_Trk1(0),
30	Calib_Trk2(0),
31	Calib_Trd(0),
32	Calib_Tof(0),
33	Calib_S4(0),
34	Calib_CalPed(0),
35	Calib_Ac(0),
36	Run_Header(0),
37	Run_Trailer(0),
38	CalibHeader(0),
39	CalibTrailer(0),
40	InitHeader(0),
41	InitTrailer(0),
42	EventTrk(0),
43	TestTrk(0),
44	Log(0),
45	VarDump(0),
46	ArrDump(0),
47	TabDump(0),
48	Tmtc(0),
49	Mcmd(0),
50	ForcedFECmd(0),
51	AcInit(0),
52	CalInit(0),
53	TrkInit(0),
54	TofInit(0),
55	TrgInit(0),
56	RunNumber(run) {
57	CMap.insert(CounterMap::value_type(PacketType::Pscu, &Pscu));
58	CMap.insert(CounterMap::value_type(PacketType::PhysEndRun, &PhysEndRun));
59	CMap.insert(CounterMap::value_type(PacketType::CalibCalPulse2, &CalibCalPulse1));
60	CMap.insert(CounterMap::value_type(PacketType::CalibCalPulse2, &CalibCalPulse2));
61	CMap.insert(CounterMap::value_type(PacketType::Physics, &Physics));
62	CMap.insert(CounterMap::value_type(PacketType::CalibTrkBoth, &CalibTrkBoth));
63	CMap.insert(CounterMap::value_type(PacketType::CalibTrk1, &Calib_Trk1));
64	CMap.insert(CounterMap::value_type(PacketType::CalibTrk2, &Calib_Trk2));
65	CMap.insert(CounterMap::value_type(PacketType::CalibTrd, &Calib_Trd));
66	CMap.insert(CounterMap::value_type(PacketType::CalibTof, &Calib_Tof));
67	CMap.insert(CounterMap::value_type(PacketType::CalibS4, &Calib_S4));
68	CMap.insert(CounterMap::value_type(PacketType::CalibCalPed, &Calib_CalPed));
69	CMap.insert(CounterMap::value_type(PacketType::CalibAc, &Calib_Ac));
70	CMap.insert(CounterMap::value_type(PacketType::RunHeader, &Run_Header));
71	CMap.insert(CounterMap::value_type(PacketType::RunTrailer, &Run_Trailer));
72	CMap.insert(CounterMap::value_type(PacketType::CalibHeader, &CalibHeader));
73	CMap.insert(CounterMap::value_type(PacketType::CalibTrailer, &CalibTrailer));
74	CMap.insert(CounterMap::value_type(PacketType::InitHeader, &InitHeader));
75	CMap.insert(CounterMap::value_type(PacketType::InitTrailer, &InitTrailer));
76	CMap.insert(CounterMap::value_type(PacketType::EventTrk, &EventTrk));
77	CMap.insert(CounterMap::value_type(PacketType::TestTrk, &TestTrk));
78	CMap.insert(CounterMap::value_type(PacketType::Log, &Log));
79	CMap.insert(CounterMap::value_type(PacketType::VarDump, &VarDump));
80	CMap.insert(CounterMap::value_type(PacketType::ArrDump, &ArrDump));
81	CMap.insert(CounterMap::value_type(PacketType::TabDump, &TabDump));
82	CMap.insert(CounterMap::value_type(PacketType::Tmtc, &Tmtc));
83	CMap.insert(CounterMap::value_type(PacketType::Mcmd, &Mcmd));
84	CMap.insert(CounterMap::value_type(PacketType::ForcedFECmd, &ForcedFECmd));
85	CMap.insert(CounterMap::value_type(PacketType::AcInit, &AcInit));
86	CMap.insert(CounterMap::value_type(PacketType::CalInit, &CalInit));
87	CMap.insert(CounterMap::value_type(PacketType::TrkInit, &TrkInit));
88	CMap.insert(CounterMap::value_type(PacketType::TofInit, &TofInit));
89	CMap.insert(CounterMap::value_type(PacketType::TrgInit, &TrgInit));
90	}
91
92	/**
93	* Increment the event counter for a certain packet.
94	* @param type Event type to be incremented.
95	*/
96	void EventCounter::Increment(PacketType const * type) {
97	CounterMap::iterator p = CMap.find(type);
98	if (p != CMap.end()) {
99	int *counter = p->second;
100	(*counter)++;
101	cat << log4cpp::Priority::DEBUG
102	<< " Counter." << type->GetName() << " = " << (*counter)
103	<< "\n " << log4cpp::CategoryStream::ENDLINE;
104	} else {
105	cat << log4cpp::Priority::WARN
106	<< " No counter for packet type " << type->GetName()
107	<< "\n " << log4cpp::CategoryStream::ENDLINE;
108	}
109	}
110
111	/**
112	* Get the counter corresponding to a certain packet type.
113	* @param type Event type to be incremented.
114	* @return The counter of that packet type. For the current event type,
115	* this is the actual event number. For all other types, this is the event
116	* number of the last read event of that type.
117	* @retval -1 if there was no event of this type.
118	*/
119	int EventCounter::Get(PacketType const * type) const {
120	const CounterMap::const_iterator p = CMap.find(type);
121	if (p != CMap.end()) {
122	const int *counter = p->second;
123	return *counter;
124	} else {
125	cat << log4cpp::Priority::WARN
126	<< " No counter for packet type " << type->GetName()
127	<< "\n " << log4cpp::CategoryStream::ENDLINE;
128	return -1;
129	}
130	}
131
132	/**
133	* Get the counter of the next event corresponding to a certain packet type.
134	* @param type Event type to be incremented.
135	* @return The next counter of that packet type.
136	* @retval -1 if there was no event of this type.
137	*/
138	int EventCounter::Next(PacketType const * type) const {
139	const CounterMap::const_iterator p = CMap.find(type);
140	if (p != CMap.end()) {
141	const int *counter = p->second;
142	return *counter + 1;
143	} else {
144	cat << log4cpp::Priority::WARN
145	<< " No counter for packet type " << type->GetName()
146	<< "\n " << log4cpp::CategoryStream::ENDLINE;
147	return -1;
148	}
149	}
150
151	/**
152	* Get the all the counters
153	* @retval -1 if there was no event of this type.
154	*/
155	void EventCounter::PrintCounters() const {
156	for(CounterMap::const_iterator p = CMap.begin(); p != CMap.end(); p++) {
157	cat << log4cpp::Priority::INFO << " Counter." << (p->first)->GetName() << " = " << (*p->second)
158	<< "\n " << log4cpp::CategoryStream::ENDLINE;
159	}
160	}