earlyDeleteSettings_cff Namespace Reference

Classes
class	TestHasInputTagModuleLabel

Functions
def	_hasInputTagModuleLabel (process, pset, moduleLabel)
def	customiseEarlyDelete (process)

Function Documentation

def earlyDeleteSettings_cff._hasInputTagModuleLabel (   process,   pset,   moduleLabel  )

private

Definition at line 10 of file earlyDeleteSettings_cff.py.

Referenced by customiseEarlyDelete().

def _hasInputTagModuleLabel(process, pset, moduleLabel):
    for name in pset.parameterNames_():
        value = getattr(pset,name)
        if isinstance(value, cms.PSet):
            if _hasInputTagModuleLabel(process, value, moduleLabel):
                return True
        elif isinstance(value, cms.VPSet):
            for ps in value:
                if _hasInputTagModuleLabel(process, ps, moduleLabel):
                    return True
        elif isinstance(value, cms.VInputTag):
            for t in value:
                t2 = t
                if not isinstance(t, cms.InputTag):
                    t2 = cms.InputTag(t2)
                if t2.getModuleLabel() == moduleLabel:
                    return True
        elif isinstance(value, cms.InputTag):
            if value.getModuleLabel() == moduleLabel:
                return True
        if isinstance(value, cms.string) and name == "refToPSet_":
            return _hasInputTagModuleLabel(process, getattr(process, value.value()), moduleLabel)
    return False

def earlyDeleteSettings_cff.customiseEarlyDelete

(

process

)

Definition at line 34 of file earlyDeleteSettings_cff.py.

References _hasInputTagModuleLabel(), and list().

Referenced by ConfigBuilder.ConfigBuilder.prepare().

def customiseEarlyDelete(process):
    # Mapping label -> [branches]
    # for the producers whose products are to be deleted early
    products = collections.defaultdict(list)

    products = customiseEarlyDeleteForSeeding(process, products)

    products = customiseEarlyDeleteForCandIsoDeposits(process, products)

    # Set process.options.canDeleteEarly
    if not hasattr(process.options, "canDeleteEarly"):
        process.options.canDeleteEarly = cms.untracked.vstring()

    branchSet = set()
    for branches in products.itervalues():
        for branch in branches:
            branchSet.add(branch)
    process.options.canDeleteEarly.extend(list(branchSet))

    # Find the consumers
    for moduleType in [process.producers_(), process.filters_(), process.analyzers_()]:
        for name, module in moduleType.iteritems():
            for producer, branches in products.iteritems():
                if _hasInputTagModuleLabel(process, module, producer):
                    #print "Module %s mightGet %s" % (name, str(branches))
                    if hasattr(module, "mightGet"):
                        module.mightGet.extend(branches)
                    else:
                        module.mightGet = cms.untracked.vstring(branches)
    return process