Inheritance diagram for python.variable.DCSC_Global_Variable:

Collaboration diagram for python.variable.DCSC_Global_Variable:

Public Types
typedef HLT::TypeInformation::for_each_type_c< typenameEDMLIST::map, my_functor, my_result<>, my_arg< HLT::TypeInformation::get_cont, CONTAINER > >::type	result

Public Member Functions
	__init__ (self, folder_name, evaluator, caution_evaluator=None, **kwargs)
	make_good_iov (self, iov)
	quantize (self, lbtime, iovs)
	__hash__ (self)
	__repr__ (self)
	read (self, query_range, folder_base, folder_name)
	print_time_info (self, iovs)
	map_input_channels (self, iovs)
	make_good_iovs (self, iovs)
	calculate_good_iovs (self, lbtime, subdetector)

Public Attributes
	caution_evaluator = caution_evaluator
str	input_db = 'COOLOFL_DCS/CONDBR2'
	folder_name = folder_name
	evaluator = evaluator
dict	fetch_args = {}
list	input_hashes = []
	subdetector = subdetector
	iovs = iovs

Static Public Attributes
bool	is_global = False
bool	is_config_variable = False
bool	timewise_folder = True

Detailed Description

A global variable.

This class over-rides the behaviour for evaluating the "goodness" of an 
input channel. It allows for an intermediate state (caution) between good
and bad.

Definition at line 231 of file variable.py.

Member Typedef Documentation

◆ result

typedef HLT::TypeInformation::for_each_type_c<typenameEDMLIST::map,my_functor,my_result<>,my_arg<HLT::TypeInformation::get_cont,CONTAINER>>::type master_search< typenameEDMLIST::map, HLT::TypeInformation::get_cont, CONTAINER >::result

inherited

Definition at line 90 of file EDM_MasterSearch.h.

Constructor & Destructor Documentation

◆ init()

python.variable.DCSC_Global_Variable.__init__	(		self,
			folder_name,
			evaluator,
			caution_evaluator = None,
		**	kwargs )

Definition at line 241 of file variable.py.

    def __init__(self, folder_name, evaluator, caution_evaluator=None, **kwargs):
        super(DCSC_Global_Variable, self).__init__(folder_name, evaluator, **kwargs)
        
        self.caution_evaluator = caution_evaluator
        

Member Function Documentation

◆ hash()

python.variable.DCSC_Variable.__hash__ ( self )

inherited

Useful for verifying if input variables have changed.

Definition at line 60 of file variable.py.

    def __hash__(self):
        """
        Useful for verifying if input variables have changed.
        """
        # Consider the fact that hash((hash(x), hash(y))) == hash((x, y)) where
        # x and y are tuples.
        return hash(tuple(self.input_hashes))
    

◆ repr()

python.variable.DCSC_Variable.__repr__ ( self )

inherited

Definition at line 68 of file variable.py.

    def __repr__(self):
        return "<DCSCVariable %s>" % self.folder_name
    

◆ calculate_good_iovs()

python.variable.DCSC_Variable.calculate_good_iovs	(	self,
		lbtime,
		subdetector )

inherited

Calculate LB-wise "good" states

Definition at line 179 of file variable.py.

    def calculate_good_iovs(self, lbtime, subdetector):
        """
        Calculate LB-wise "good" states
        """
 
        self.subdetector = subdetector
        
        if self.timewise_folder:
            query_range = RANGEIOV_VAL(lbtime.first.since, lbtime.last.until)
        else:
            a, b = lbtime.first, lbtime.last
            query_range = RANGEIOV_VAL(RunLumi(a.Run, a.LumiBlock), 
                                       RunLumi(b.Run, b.LumiBlock))
        
        # Read the database
        iovs = self.read(query_range, subdetector.folder_base, self.folder_name)
        #iovs.pprint()
 
        # Decide the states of the input iovs
        iovs = self.make_good_iovs(iovs)
        #iovs.pprint()
        
        # Apply a mapping for input channels if necessary
        # This only does something for variables that require additional mapping
        # i.e., if the channel numbers for different DCS variables don't match up
        iovs = self.map_input_channels(iovs)
 
        if self.timewise_folder and not config.opts.timewise:
            # we might already know the defect mapping
            with timer("Quantize %s (%i iovs over %i lbs)" % 
                       (self.folder_name, len(iovs), len(lbtime))):
                # Quantize to luminosity block
                iovs = self.quantize(lbtime, iovs)
        #iovs.pprint()
            
        # Debug printout of problematic channels
        # DQUtils messes with the logging and isEnabledFor doesn't work
        #if log.isEnabledFor(logging.DEBUG):
        #log.verbose("Bad input channels for %s:", self.folder_name)
        #log.verbose("= [%r]", ", ".join(str(i.channel) for i in iovs if not i.good))
 
        self.iovs = iovs
        
        return self
 

◆ make_good_iov()

python.variable.DCSC_Global_Variable.make_good_iov	(		self,
			iov )

Determine DQ colour for this global variable iov.

Reimplemented from python.variable.DCSC_Variable.

Definition at line 246 of file variable.py.

    def make_good_iov(self, iov):
        """
        Determine DQ colour for this global variable iov.
        """
        
        if self.evaluator(iov):
            state = GREEN
            
        elif self.caution_evaluator and self.caution_evaluator(iov):
            state = YELLOW
        
        else:
            state = RED
            
        return CodeIOV(iov.since, iov.until, iov.channel, state)
 

◆ make_good_iovs()

python.variable.DCSC_Variable.make_good_iovs	(		self,
			iovs )

inherited

Determine whether each iov signifies a good or bad state.

Reimplemented in python.subdetectors.sct.DCSC_Variable_SCT_Config, and python.subdetectors.tile.Tile_NoHighVoltage.

Definition at line 172 of file variable.py.

    def make_good_iovs(self, iovs):
        """
        Determine whether each iov signifies a good or bad state.
        """
        make_good_iov = self.make_good_iov
        return IOVSet(make_good_iov(iov) for iov in iovs)
    

◆ map_input_channels()

python.variable.DCSC_Variable.map_input_channels	(		self,
			iovs )

inherited

By default, do nothing. Overloaded by DCSC_Variable_With_Mapping.

Reimplemented in python.variable.DCSC_Variable_With_Mapping.

Definition at line 141 of file variable.py.

    def map_input_channels(self, iovs):
        """
        By default, do nothing. Overloaded by DCSC_Variable_With_Mapping.
        """
        return iovs
    

◆ print_time_info()

python.variable.DCSC_Variable.print_time_info	(		self,
			iovs )

inherited

Logs the first and last insertion times of the IoVs, and their ranges.

Definition at line 124 of file variable.py.

    def print_time_info(self, iovs):
        """
        Logs the first and last insertion times of the IoVs, and their ranges.
        """
        first_value, last_value = iovs.range_iov
        
        log.info("Times for %s:", self)
        log.info("  IoV      : (first)%26s (last)%26s", 
                    first_value.date, last_value.date)
        
        if not hasattr(iovs.first, "insertion_time"):
            log.info("Insertion time not available")
        else:
            insertion_times = [iov.insertion_time for iov in iovs]
            log.info("  Insertion: (first)%26s (last)%26s", 
                        min(insertion_times), max(insertion_times))
    

◆ quantize()

python.variable.DCSC_Global_Variable.quantize	(	self,
		lbtime,
		iovs )

Needs a different quantizer. (The default DQ quantizer will do)

Reimplemented from python.variable.DCSC_Variable.

Definition at line 262 of file variable.py.

    def quantize(self, lbtime, iovs):
        """
        Needs a different quantizer. (The default DQ quantizer will do)
        """
        iovs = [iovs_ for c, iovs_ in sorted(iovs.by_channel.items())]
        # Custom quantizer not needed        
        result = quantize_iovs_slow_mc(lbtime, iovs)
        return IOVSet(CodeIOV(*iov) 
                      for iovs in result 
                      for iov in iovs 
                      if iov[0].run == iov[1].run)
 

◆ read()

python.variable.DCSC_Variable.read	(	self,
		query_range,
		folder_base,
		folder_name )

inherited

Read the relevant data from COOL for this variable

Definition at line 71 of file variable.py.

    def read(self, query_range, folder_base, folder_name):
        """
        Read the relevant data from COOL for this variable
        """
        if folder_name.startswith("/"):
            folder_path = folder_name
        else:
            # For relative folders prepend the folder_base
            folder_path = "/".join((folder_base, folder_name))
        
        log.info("Querying COOL folder %s", folder_path)
        
        if config.opts.check_input_time:
            self.fetch_args["with_time"] = True
        
        # Massage DB access
        if '/' in self.input_db:
            newdbstring = self.input_db.rsplit('/', 1)[0]
        else:
            newdbstring = self.input_db
        if config.opts.input_database.startswith('sqlite'):
            self.fetch_args['database'] = config.opts.input_database
        else:
            self.fetch_args['database'] = ('%s/%s' % (newdbstring, config.opts.input_database))
        if self.fetch_args:
            log.debug("Fetching with args: %r", self.fetch_args)
            
        iovs = fetch_iovs(folder_path, *query_range, **self.fetch_args)
 
        # Prints even when not doing debug.
        # TODO: fix this. Might be broken in DQUtils.logger
        #if log.isEnabledFor(logging.DEBUG):
        #    log.debug("Dumping input IOVs:")
        #    for iov in iovs:
        #        print iov
 
        #Remove Old TGC Chambers
        original_length=len(list(iovs))
        if folder_path=='/TGC/DCS/PSHVCHSTATE':
            for i in range(original_length-1, -1, -1):
                if  list(iovs)[i].channel in range(5504,5552) or list(iovs)[i].channel in range(7362,7411):
                    iovs.pop(i)
        
        if config.opts.check_input_time:
            self.print_time_info(iovs)
            
        if log.isEnabledFor(logging.INFO):
            input_hash = hash(iovs)
            self.input_hashes.append(input_hash)
            log.info("  -> Input hash: % 09x (len=%i)", input_hash, len(iovs))
            
        return iovs
    

Member Data Documentation

◆ caution_evaluator

python.variable.DCSC_Global_Variable.caution_evaluator = caution_evaluator

Definition at line 244 of file variable.py.

◆ evaluator

python.variable.DCSC_Variable.evaluator = evaluator

inherited

Definition at line 54 of file variable.py.

◆ fetch_args

python.variable.DCSC_Variable.fetch_args = {}

inherited

Definition at line 56 of file variable.py.

◆ folder_name

python.variable.DCSC_Variable.folder_name = folder_name

inherited

Definition at line 53 of file variable.py.

◆ input_db

str python.variable.DCSC_Variable.input_db = 'COOLOFL_DCS/CONDBR2'

inherited

Definition at line 52 of file variable.py.

◆ input_hashes

python.variable.DCSC_Variable.input_hashes = []

inherited

Definition at line 58 of file variable.py.

◆ iovs

python.variable.DCSC_Variable.iovs = iovs

inherited

Definition at line 220 of file variable.py.

◆ is_config_variable

bool python.variable.DCSC_Variable.is_config_variable = False

staticinherited

Definition at line 47 of file variable.py.

◆ is_global

bool python.variable.DCSC_Variable.is_global = False

staticinherited

Definition at line 46 of file variable.py.

◆ subdetector

python.variable.DCSC_Variable.subdetector = subdetector

inherited

Definition at line 184 of file variable.py.

◆ timewise_folder

bool python.variable.DCSC_Variable.timewise_folder = True

staticinherited

Definition at line 48 of file variable.py.

The documentation for this class was generated from the following file:

variable.py

Public Types

Public Member Functions

Public Attributes

Static Public Attributes

Detailed Description

Member Typedef Documentation

◆ result

Constructor & Destructor Documentation

◆ __init__()

Member Function Documentation

◆ __hash__()

◆ __repr__()

◆ calculate_good_iovs()

◆ make_good_iov()

◆ make_good_iovs()

◆ map_input_channels()

◆ print_time_info()

◆ quantize()

◆ read()

Member Data Documentation

◆ caution_evaluator

◆ evaluator

◆ fetch_args

◆ folder_name

◆ input_db

◆ input_hashes

◆ iovs

◆ is_config_variable

◆ is_global

◆ subdetector

◆ timewise_folder

◆ init()

◆ hash()

◆ repr()