Inheritance diagram for DQM.DQMReader:

Public Member Functions
def	__init__ (self, input_filename)

def	close (self)

def	read_objects (self)

def	read_objects_dqmio (self)

def	read_objects_root (self)

Public Attributes
	type

Static Public Attributes
	DQMIO_TYPES

Private Attributes
	_root_file

Detailed Description

Reader for  DQM IO and DQM root files.

Definition at line 8 of file DQM.py.

Constructor & Destructor Documentation

◆ init()

def DQM.DQMReader.__init__	(	self,
		input_filename
	)

Definition at line 19 of file DQM.py.

     def __init__(self, input_filename):
         self._root_file = R.TFile.Open(input_filename)
  
         ioTest = self._root_file.Get("Indices")
         if bool(ioTest):
             self.type = "DQMIO"
         else:
             self.type = "ROOT"
  

Member Function Documentation

◆ close()

def DQM.DQMReader.close ( self )

Definition at line 95 of file DQM.py.

     def close(self):
         self._root_file.Close()
  

References DQM.DQMReader._root_file.

Referenced by esMonitoring.AsyncLineReaderMixin.handle_close(), and esMonitoring.FDJsonServer.handle_close().

◆ read_objects()

def DQM.DQMReader.read_objects ( self )

Definition at line 28 of file DQM.py.

     def read_objects(self):
         if (self.type == "DQMIO"):
             return self.read_objects_dqmio()
         else:
             return self.read_objects_root()
  

References DQM.DQMReader.read_objects_dqmio(), DQM.DQMReader.read_objects_root(), AlignableObjectId::entry.type, BCoptions.type, HcalSiPMParametersGPU::Product.type, ticl::TileConstants.type, TotemTriggerCounters.type, DQM.DQMReader.type, ticl::TileConstantsHFNose.type, plottingOptions.BasePlottingOptions.type, DB_ME.type, cond::TimeTypeSpecs.type, SummationStep.type, DQMGenericClient::EfficOption.type, DTTMax::TMax.type, metsig::SigInputObj.type, PrimaryVertexMonitor.type, MuonGeometrySanityCheckPoint.type, ME::Settings.type, SiStripOfflineDQM::MapOptions.type, BeamSpotDipServer.type, HcalRaddamMuon.type, ME.type, and nanoaod::FlatTable::Column.type.

◆ read_objects_dqmio()

def DQM.DQMReader.read_objects_dqmio ( self )

Definition at line 34 of file DQM.py.

     def read_objects_dqmio(self):
         indices = self._root_file.Get("Indices")
  
         for y in range(indices.GetEntries()):
             indices.GetEntry(y)
             # print indices.Run, indices.Lumi, indices.Type
  
             if indices.Type == 1000:
                 # nothing is stored here
                 # see https://github.com/cms-sw/cmssw/blob/8be445ac6fd9983d69156199d4d1fd3350f05d92/DQMServices/FwkIO/plugins/DQMRootOutputModule.cc#L437
                 continue
  
             object_type = self.DQMIO_TYPES[indices.Type]
             t_tree = self._root_file.Get(object_type)
  
             for i in range(indices.FirstIndex, indices.LastIndex + 1):
                 t_tree.GetEntry(i)
  
                 fullname = str(t_tree.FullName)
                 yield (fullname, t_tree.Value, )
  

References DQM.DQMReader._root_file, DQM.DQMReader.DQMIO_TYPES, FastTimerService_cff.range, and str.

Referenced by DQM.DQMReader.read_objects().

◆ read_objects_root()

def DQM.DQMReader.read_objects_root ( self )

Definition at line 55 of file DQM.py.

     def read_objects_root(self):
         xml_re = re.compile(r"^<(.+)>(.+)=(.*)<\/\1>$")
         def parse_directory(di):
             directory = self._root_file.GetDirectory(di)
             for key in directory.GetListOfKeys():
                 entry = key.GetName()
                 rtype = key.GetClassName()
                 fullpath = "%s/%s" % (di, entry)
  
                 if (rtype == "TDirectoryFile"):
                     for k, v in parse_directory(fullpath):
                         yield (k, v, )
                 else:
                     obj = self._root_file.Get(fullpath)
                     if obj:
                         yield (fullpath, obj, )
                     else:
                         # special case to parse the xml abomination
                         m = xml_re.search(entry)
                         if m:
                             name = m.group(1)
                             typecode = m.group(2)
                             value = m.group(3)
  
                             fp = "%s/%s" % (di, name)
                             yield (fp, value, )
                         else:
                             raise Exception("Invalid xml:" + entry)
  
  
         path_fix = re.compile(r"^\/Run \d+")
         for fullname, obj in parse_directory(""):
             f = fullname.replace("/DQMData", "")
             f = f.replace("/Run summary", "")
             f = path_fix.sub(r"", f)
             if f[0] == "/":
                 f = f[1:]
  
             yield f, obj
  