MTJobOptCfg.py

Go to the documentation of this file.

# Copyright (C) 2002-2020 CERN for the benefit of the ATLAS collaboration
 
# Job options configuration file for PerfMonMTSvc
 
from PerfMonComps.PerfMonCompsConf import PerfMonMTSvc as _PerfMonMTSvc
 
class PerfMonMTSvc ( _PerfMonMTSvc  ):
 
    def __init__(self, name = "PerfMonMTSvc", **kwargs):
 
        kwargs['name'] = name
        super( PerfMonMTSvc, self ).__init__( **kwargs )
 
        return
 
    def setDefaults(cls, handle):
 
        
        from PerfMonComps.PerfMonFlags import jobproperties
 
        
        if not jobproperties.PerfMonFlags.doMonitoringMT():
            return
 
        
        if not isinstance(handle, PerfMonMTSvc):
            return
 
        
        from AthenaCommon.AppMgr import theApp
        theApp.AuditAlgorithms = True
        theApp.AuditTools      = True
        theApp.AuditServices   = True
 
        from AthenaCommon.AppMgr import ServiceMgr as svcMgr
 
        if hasattr(handle, "getFullJobOptName") :
            handleName = handle.getFullJobOptName()
            if handleName not in theApp.CreateSvc:
                # Be the very first service to be initialized
                theApp.CreateSvc = [ handleName ] + theApp.CreateSvc
 
        
        handle.jsonFileName = jobproperties.PerfMonFlags.OutputJSON()
 
        
        import os,psutil
        handle.wallTimeOffset = psutil.Process(os.getpid()).create_time() * 1000
 
        
        from AthenaCommon.ConcurrencyFlags import jobproperties as jp
        handle.numberOfThreads = max(1,jp.ConcurrencyFlags.NumThreads())
        handle.numberOfSlots = max(1,jp.ConcurrencyFlags.NumConcurrentEvents())
 
        
        if not hasattr(svcMgr, 'AuditorSvc'):
            from GaudiCommonSvc.GaudiCommonSvcConf import AuditorSvc
            svcMgr += AuditorSvc()
 
        
        if jobproperties.PerfMonFlags.doFullMonMT():
            handle.doComponentLevelMonitoring = True
 
        return
 
    pass # class PerfMonMTSvc