o2o_db_gain.DbManagerGain Class Reference

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

__init__()

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

_readPartitions()

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)

_readSkippedDevices()

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

update_gain_logs()

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!')

Member Data Documentation

GainO2OPartition

o2o_db_gain.DbManagerGain.GainO2OPartition

Definition at line 67 of file o2o_db_gain.py.

GainO2OSkippedDevices

o2o_db_gain.DbManagerGain.GainO2OSkippedDevices

Definition at line 68 of file o2o_db_gain.py.

Referenced by o2o_db_gain.DbManagerGain._readSkippedDevices().

GainO2OWhitelistedDevices

o2o_db_gain.DbManagerGain.GainO2OWhitelistedDevices

Definition at line 69 of file o2o_db_gain.py.

Referenced by o2o_db_gain.DbManagerGain._readSkippedDevices().

iovstart

o2o_db_gain.DbManagerGain.iovstart

Definition at line 140 of file o2o_db_gain.py.

o2o_partitions

o2o_db_gain.DbManagerGain.o2o_partitions

Definition at line 72 of file o2o_db_gain.py.

o2oid

o2o_db_gain.DbManagerGain.o2oid

Definition at line 152 of file o2o_db_gain.py.

Referenced by o2o_db_gain.DbManagerGain._readSkippedDevices().