python.libcore Namespace Reference

Functions
def	dcsofl_cool_record ()
def	make_multi_mapping (iterable)
def	map_channels (iovs, mapping, folder)
def	connect_adjacent_iovs_defect (generator)

Variables
	log

Function Documentation

connect_adjacent_iovs_defect()

def python.libcore.connect_adjacent_iovs_defect

(

generator

)

Definition at line 69 of file libcore.py.

def connect_adjacent_iovs_defect(generator):
    previous = None
    for iov in generator:
        if (previous and previous.connected_to(iov) and
            previous.comment==iov.comment and previous.channel==iov.channel and
            previous.present==iov.present):
            previous = previous._replace(until=iov.until)
        else:
            if previous:
                yield previous
            previous = iov
    if previous:
        yield previous
    

dcsofl_cool_record()

def python.libcore.dcsofl_cool_record

(

)

Definition at line 8 of file libcore.py.

def dcsofl_cool_record():
    from PyCool import cool
    ST = cool.StorageType
    return [("Code",     ST.Int32),
             ("deadFrac", ST.Float),
             ("Thrust",   ST.Float),
             ("NConfig",  ST.Int32),
             ("NWorking", ST.Int32)]
 

make_multi_mapping()

def python.libcore.make_multi_mapping

(

iterable

)

When more than one value can map to the same key, we need 
{key, [value1, value2]}. 

This function builds it out of [(key, value1), (key, value2)]

Beware, values cannot be lists.

Definition at line 17 of file libcore.py.

def make_multi_mapping(iterable):
    """
    When more than one value can map to the same key, we need 
    {key, [value1, value2]}. 
    
    This function builds it out of [(key, value1), (key, value2)]
    
    Beware, values cannot be lists.
    """
    
    result = {}
    
    for key, value in iterable:
        if key in result and not isinstance(result[key], list):
            result[key] = [result[key], value]
        elif key in result:
            result[key].append(value)
        else:
            result[key] = value
        
    return result
 

map_channels()

def python.libcore.map_channels	(		iovs,
			mapping,
			folder
	)

Remap the input channel identifiers.  Returns a new IOVSet 
with the channel number changed according to the provided mapping

Definition at line 39 of file libcore.py.

def map_channels(iovs, mapping, folder):
    """
    Remap the input channel identifiers.  Returns a new IOVSet 
    with the channel number changed according to the provided mapping
    """
 
    # look for unmapped channels
    bad_channels = set()
    def has_channel(c):
        result = c in mapping
        if not result:
            bad_channels.add(c)
        return result
    
    IOVSet = iovs.empty
    iovs = IOVSet(iov._replace(channel=mapping[iov.channel]) 
                      for iov in iovs if has_channel(iov.channel))
    
    if bad_channels:
        log.debug("WARNING: %s has %i unmapped channels %r",
                  folder, len(bad_channels), repr(bad_channels))
    
    # Remove lists from channel field of iovs
    iovs = flatten_channels(iovs)
    
    # Traditional COOL ordering
    iovs.sort(key=lambda iov: (iov.channel, iov.since))
 
    return IOVSet(iovs)
 

Variable Documentation

log

python.libcore.log

Definition at line 3 of file libcore.py.