Inheritance diagram for o2o_db_gain.DbManagerGain:

Public Member Functions
def	__init__ (self, db, authFile=None)

def	update_gain_logs (self, iov, cfgname)

Public Attributes
	GainO2OPartition

	GainO2OSkippedDevices

	GainO2OWhitelistedDevices

	iovstart

	o2o_partitions

	o2oid

Private Member Functions
def	_readPartitions (self, p)

def	_readSkippedDevices (self, p, whitelist=False)

Detailed Description

Definition at line 64 of file o2o_db_gain.py.

Constructor & Destructor Documentation

def o2o_db_gain.DbManagerGain.__init__	(	self,
		db,
		authFile = `None`
	)

Definition at line 65 of file o2o_db_gain.py.

     def __init__(self, db, authFile=None):
         DbManager.__init__(self, db, authFile)
         self.GainO2OPartition = make_dbtype(GainO2OPartitionDef, self.schema)
         self.GainO2OSkippedDevices = make_dbtype(GainO2OSkippedDevicesDef, self.schema)
         self.GainO2OWhitelistedDevices = make_dbtype(GainO2OWhitelistedDevicesDef, self.schema)
 

Member Function Documentation

def o2o_db_gain.DbManagerGain._readPartitions	(	self,
		p
	)

private

Definition at line 71 of file o2o_db_gain.py.

     def _readPartitions(self, p):
         self.o2o_partitions = []
         partitionDict = {'PartTECM':'TEC-','PartTECP':'TEC+','PartTIBD':'TIB/TID','PartTOB':'TOB'}
         o2otimestamp = datetime.datetime.utcnow()
         for part in partitionDict:
             psetPart = p.SiStripConfigDb.Partitions.getParameter(part)
             if not psetPart: continue
             entry = self.GainO2OPartition(
                 o2oid = self.o2oid,
                 iovstart = self.iovstart,
                 o2otimestamp = o2otimestamp,
                 subDetector = partitionDict[part],
                 partitionname = psetPart.getParameter('PartitionName').value(),
                 fecVersionMajorId = psetPart.getParameter('FecVersion')[0],
                 fecVersionMinorId = psetPart.getParameter('FecVersion')[1],
                 fedVersionMajorId = psetPart.getParameter('FedVersion')[0],
                 fedVersionMinorId = psetPart.getParameter('FedVersion')[1],
                 connectionVersionMajorId = psetPart.getParameter('CablingVersion')[0],
                 connectionVersionMinorId = psetPart.getParameter('CablingVersion')[1],
                 dcuInfoVersionMajorId = psetPart.getParameter('DcuDetIdsVersion')[0],
                 dcuInfoVersionMinorId = psetPart.getParameter('DcuDetIdsVersion')[1],
                 dcuPsuMapVersionMajorId = psetPart.getParameter('DcuPsuMapVersion')[0],
                 dcuPsuMapVersionMinorId = psetPart.getParameter('DcuPsuMapVersion')[1],
                 maskVersionMajorId = psetPart.getParameter('MaskVersion')[0],
                 maskVersionMinorId = psetPart.getParameter('MaskVersion')[1],
                 apvTimingVersionMajorId = psetPart.getParameter('ApvTimingVersion')[0],
                 apvTimingVersionMinorId = psetPart.getParameter('ApvTimingVersion')[1],
                 timingRunNumber = psetPart.getParameter('RunNumber').value()
                 )
             self.o2o_partitions.append(entry)
 

def o2o_db_gain.DbManagerGain._readSkippedDevices	(	self,
		p,
		whitelist = `False`
	)

private

Definition at line 102 of file o2o_db_gain.py.

References o2o_db_gain.DbManagerGain.GainO2OSkippedDevices, o2o_db_gain.DbManagerGain.GainO2OWhitelistedDevices, and o2o_db_gain.DbManagerGain.o2oid.

     def _readSkippedDevices(self, p, whitelist=False):
         dev_type = self.GainO2OSkippedDevices
         attr_name = 'SkippedDevices'
         if whitelist:
             dev_type = self.GainO2OWhitelistedDevices
             attr_name = 'WhitelistedDevices'
 
         dev_list = []
         value = lambda p: None if p is None else p.value()
         for itemid, pset in enumerate(getattr(p.SiStripCondObjBuilderFromDb, attr_name)):
             entry = dev_type(
                 o2oid = self.o2oid,
                 itemid = itemid,
                 fecCrate = value(pset.getParameter('fecCrate')),
                 fecSlot = value(pset.getParameter('fecSlot')),
                 fecRing = value(pset.getParameter('fecRing')),
                 ccuAddr = value(pset.getParameter('ccuAddr')),
                 ccuChan = value(pset.getParameter('ccuChan')),
                 lldChan = value(pset.getParameter('lldChan')),
                 i2cAddr = value(pset.getParameter('i2cAddr')),
                 fedId = value(pset.getParameter('fedId')),
                 feUnit = value(pset.getParameter('feUnit')),
                 feChan = value(pset.getParameter('feChan')),
                 fedApv = value(pset.getParameter('fedApv')),
                 detid = value(pset.getParameter('detid'))
                 )
             dev_list.append(entry)
 
         return dev_list
 

def o2o_db_gain.DbManagerGain.update_gain_logs	(	self,
		iov,
		cfgname
	)

Insert bookkeeping info to the tables.
Args:
    iov (int or str): IOV number
    cfgname (str): name of the CMSSW cfg file.
The cfg file need to be placed in the current directory.

Definition at line 132 of file o2o_db_gain.py.

     def update_gain_logs(self, iov, cfgname):
         """Insert bookkeeping info to the tables.
         Args:
             iov (int or str): IOV number
             cfgname (str): name of the CMSSW cfg file.
                 The cfg file need to be placed in the current directory.
         """
 
         self.iovstart = int(iov)
         sys.path.append(os.getcwd())
         if cfgname.endswith('.py'):
             cfgname = cfgname.replace('.py', '')
         cfg = import_module(cfgname)
 
         self.check_table(GainO2OPartitionDef, self.GainO2OPartition)
         self.check_table(GainO2OSkippedDevicesDef, self.GainO2OSkippedDevices)
         self.check_table(GainO2OWhitelistedDevicesDef, self.GainO2OWhitelistedDevices)
         destSession = self.connect()
         o2oid = destSession.query(self.GainO2OPartition.o2oid).order_by(self.GainO2OPartition.o2oid.desc()).first()
         if o2oid:
             self.o2oid = o2oid[0] + 1
         else:
             self.o2oid = 0
 
         self._readPartitions(cfg.process)
         for entry in self.o2o_partitions:
             destSession.add(entry)
 
         o2o_skipped = self._readSkippedDevices(cfg.process)
         for entry in o2o_skipped:
             destSession.add(entry)
 
         o2o_whitelisted = self._readSkippedDevices(cfg.process, whitelist=True)
         for entry in o2o_whitelisted:
             destSession.add(entry)
 
         destSession.commit()
         logging.info('Inserted Gain O2O info to DB!')
 
 