Public Member Functions | |
| def | __init__ |
| def | initialize |
| def | execute |
| def | finalize |
Public Attributes | |
| eventnum | |
Definition at line 211 of file OnlineOfflineTestRefactored.py.
| def DataQuality::OnlineOfflineTestRefactored::OnlineOfflineAlg::__init__ | ( | self, | ||
| name | ||||
| ) |
Definition at line 213 of file OnlineOfflineTestRefactored.py.
00213 : 00214 DybPythonAlg.__init__(self,name) 00215 self.eventnum = 0 00216 return 00217 def initialize(self):
| def DataQuality::OnlineOfflineTestRefactored::OnlineOfflineAlg::initialize | ( | self | ) |
Definition at line 218 of file OnlineOfflineTestRefactored.py.
00218 : 00219 status = DybPythonAlg.initialize(self) 00220 if status.isFailure(): return status 00221 self.info("initializing") 00222 return SUCCESS 00223 def execute(self):
| def DataQuality::OnlineOfflineTestRefactored::OnlineOfflineAlg::execute | ( | self | ) |
Definition at line 224 of file OnlineOfflineTestRefactored.py.
00224 : 00225 self.eventnum += 1 # for debuggin 00226 self.debug("executing event %d"%self.eventnum) 00227 00228 # Access current data 00229 evt = self.evtSvc() 00230 readoutHdr = evt["/Event/Readout/ReadoutHeader"] 00231 if readoutHdr == None: 00232 self.error("Failed to get current readout header") 00233 return FAILURE 00234 00235 readout = readoutHdr.readout() 00236 if readout == None: 00237 self.error("Failed to get readout from header") 00238 return FAILURE 00239 00240 detector = readout.detector() 00241 detint = detector.fullPackedData() 00242 00243 # Fill per-detector hists 00244 try: 00245 prh = PerReadoutHistograms.hists[detint] 00246 except KeyError: 00247 prh = PerReadoutHistograms(self,detector) 00248 prh.fill_readout(readout) 00249 00250 00251 # Loop over channel data 00252 self.verbose('Event %d with %d channels'%(self.eventnum,len(readout.channelReadout()))) 00253 for channelPair in readout.channelReadout(): 00254 channel = channelPair.second 00255 channelId = channel.channelId() 00256 chanint = channelId.fullPackedData() 00257 try: 00258 pch = PerChannelHistograms.hists[chanint] 00259 except KeyError: 00260 pch = PerChannelHistograms(self,detector,channelId) 00261 pch.fill(channel) 00262 prh.fill_channelId(channelId) 00263 continue 00264 00265 return SUCCESS 00266 def finalize(self):
| def DataQuality::OnlineOfflineTestRefactored::OnlineOfflineAlg::finalize | ( | self | ) |
Definition at line 267 of file OnlineOfflineTestRefactored.py.
00267 : 00268 self.info("finalizing") 00269 # Fill summary histograms 00270 for id,pch in PerChannelHistograms.hists.iteritems(): 00271 detint = pch.detector.fullPackedData() 00272 try: 00273 csh = ChannelSummaryHistograms.hists[detint] 00274 except KeyError: 00275 csh = ChannelSummaryHistograms(self,pch.detector) 00276 00277 csh.fill(pch.chanint,pch.adc) 00278 continue 00279 00280 for prh in PerReadoutHistograms.hists.itervalues(): 00281 prh.norm() 00282 continue 00283 00284 status = DybPythonAlg.finalize(self) 00285 return status 00286 00287 ##### Job Configuration for nuwa.py ########################################
Definition at line 215 of file OnlineOfflineTestRefactored.py.
1.4.7