ViewVC Help

View File | Revision Log | Show Annotations | Root Listing

root/cvsroot/UserCode/MitAna/TreeMod/src/AnaFwkMod.cc

Comparing UserCode/MitAna/TreeMod/src/AnaFwkMod.cc (file contents):
Revision 1.8 by loizides, Mon Mar 23 08:30:59 2009 UTC vs.
Revision 1.12 by loizides, Fri Jun 19 07:39:01 2009 UTC

#	Line 18 | Line 18 | AnaFwkMod::AnaFwkMod(const char *name, c
18		fAllHeadTreeName(Names::gkAllEvtTreeName),
19		fAllHeadBrName(Names::gkAllEvtHeaderBrn),
20		fSkipNEvents(0),
21	+	fPrintScale(100),
22		fSWtotal(0),
23		fSWevent(0),
24		fAllHeaders(0,Names::gkSkimmedHeaders),
#	Line 49 | Line 50 | void AnaFwkMod::BeginRun()
50		if (!file)
51		return;
52
53	<	// get HLT tree
53	>	// get all event header tree
54		fAllHeadTree = dynamic_cast<TTree*>(file->Get(fAllHeadTreeName));
55		if (!fAllHeadTree) {
56		SendError(kWarning, "BeginRun",
57	<	"Can not find tree '%s' in file '%s'",
57	>	"Cannot find tree '%s' in file '%s'",
58		fAllHeadTreeName.Data(),file->GetName());
59		return;
60		}
60	–	}
61
62	<	// get HLT trigger name branch
63	<	if (fAllHeadTree->GetBranch(fAllHeadBrName)) {
64	<	fAllHeadTree->SetBranchAddress(fAllHeadBrName, &fAllEventHeader);
65	<	} else {
66	<	SendError(kWarning, "BeginRun",
67	<	"Can not find branch '%s' in tree '%s'",
68	<	fAllHeadBrName.Data(), fAllHeadTreeName.Data());
69	<	return;
62	>	// get all event header branch
63	>	if (fAllHeadTree->GetBranch(fAllHeadBrName)) {
64	>	fAllHeadTree->SetBranchAddress(fAllHeadBrName, &fAllEventHeader);
65	>	} else {
66	>	SendError(kWarning, "BeginRun",
67	>	"Cannot find branch '%s' in tree '%s'",
68	>	fAllHeadBrName.Data(), fAllHeadTreeName.Data());
69	>	return;
70	>	}
71		}
72		}
73
#	Line 79 | Line 80 | void AnaFwkMod::CopyAllEventHeaders()
80
81		const EventHeader *curev = GetEventHeader();
82		if (!curev) {
83	<	SendError(kWarning, "CopyAllEventHeaders", "Can not obtain current event");
83	>	SendError(kWarning, "CopyAllEventHeaders", "Cannot obtain current event");
84		return;
85		}
86
#	Line 167 | Line 168 | void AnaFwkMod::Process()
168		if (fNEventsSkipped<fSkipNEvents) {
169		++fNEventsSkipped;
170		MDB(kAnalysis, 3) {
171	<	SendError(kWarning, "Process", "Skipping (aborting) %d out of %d first events.",
172	<	fNEventsSkipped, fSkipNEvents);
171	>	Info("Process", "Skipping (aborting) %d out of %d first events.",
172	>	fNEventsSkipped, fSkipNEvents);
173		}
174		AbortEvent();
175		return;
#	Line 178 | Line 179 | void AnaFwkMod::Process()
179		Bool_t doPrint = 0;
180
181		MDB(kAnalysis, 4) {
182	<	if (GetNEventsProcessed() % 250  == 0)
182	>	if (GetNEventsProcessed() % (fPrintScale)  == 0)
183		doPrint = 1;
184		} else {
185		MDB(kAnalysis, 3) {
186	<	if (GetNEventsProcessed() % 2500  == 0)
186	>	if (GetNEventsProcessed() % (fPrintScale*10)  == 0)
187		doPrint = 1;
188		} else {
189		MDB(kAnalysis, 2) {
190	<	if (GetNEventsProcessed() % 10000  == 0)
190	>	if (GetNEventsProcessed() % (fPrintScale*100)  == 0)
191		doPrint = 1;
192		} else {
193		MDB(kAnalysis, 1) {
194	<	if (GetNEventsProcessed() % 50000 == 0)
194	>	if (GetNEventsProcessed() % (fPrintScale*1000) == 0)
195		doPrint = 1;
196		}
197		}
#	Line 199 | Line 200 | void AnaFwkMod::Process()
200
201		if (doPrint) {
202		fSWevent->Stop();
203	<	SendError(kWarning, "Process",
204	<	"Events %d -> %.2gs real, %.2gs cpu (%.2g real, %.2g cpu per event)",
205	<	GetNEventsProcessed(), fSWevent->RealTime(), fSWevent->CpuTime(),
206	<	fSWevent->RealTime()/GetNEventsProcessed(),
207	<	fSWevent->CpuTime()/GetNEventsProcessed());
203	>	Info("Process",
204	>	"Events %d -> %.2gs real, %.2gs cpu (%.2g real, %.2g cpu per event)",
205	>	GetNEventsProcessed(), fSWevent->RealTime(), fSWevent->CpuTime(),
206	>	fSWevent->RealTime()/GetNEventsProcessed(),
207	>	fSWevent->CpuTime()/GetNEventsProcessed());
208		fSWevent->Start();
209		}
210		}
#	Line 215 | Line 216 | void AnaFwkMod::SlaveBegin()
216
217		fSWtotal = new TStopwatch;
218		fSWevent = new TStopwatch;
219	+	cout << fSkipNEvents << endl;
220
221		if (!PublishObj(&fAllHeaders)) {
222		SendError(kAbortAnalysis, "SlaveBegin",
#	Line 245 | Line 247 | void AnaFwkMod::SlaveTerminate()
247		fSWevent->Stop();
248
249		MDB(kAnalysis, 1)
250	<	SendError(kWarning, "SlaveTerminate",
251	<	"Events %d -> %.2gs real, %.2gs cpu (%.2gs real, %.2gs cpu per event)",
252	<	GetNEventsProcessed(), fSWtotal->RealTime(), fSWtotal->CpuTime(),
253	<	fSWtotal->RealTime()/GetNEventsProcessed(),
254	<	fSWtotal->CpuTime()/GetNEventsProcessed());
250	>	Info("SlaveTerminate",
251	>	"Events %d -> %.2gs real, %.2gs cpu (%.2gs real, %.2gs cpu per event)",
252	>	GetNEventsProcessed(), fSWtotal->RealTime(), fSWtotal->CpuTime(),
253	>	fSWtotal->RealTime()/GetNEventsProcessed(),
254	>	fSWtotal->CpuTime()/GetNEventsProcessed());
255
256		delete fSWtotal;
257		delete fSWevent;

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines