test
CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
Classes | Functions | Variables
personalPlayback Namespace Reference

Classes

class  Applet
 
class  FrameworkJob
 
class  Playback
 

Functions

def preexec_kill_on_pdeath
 

Variables

list applets = []
 
tuple args = parser.parse_args()
 
tuple cfg_a = FrameworkJob("framework_job", opts=args, cfg_file=cfg)
 
list f = sys.argv[-1]
 
string fn = "%s_%s.pkl"
 
 fp = a.control_fp
 
string log_format = '%(asctime)s: %(name)-20s - %(levelname)-8s - %(message)s'
 
tuple obj = Applet.read(f)
 
tuple parser = argparse.ArgumentParser(description="Emulate DQM@P5 environment and launch cmssw jobs.")
 
tuple path = getattr(args, "work_" + subdirectory)
 
tuple playback = Playback("playback_emu", opts=args)
 
tuple playback_group = parser.add_argument_group('Playback', 'Playback configuration/parameters.')
 
tuple ret = obj.do_exec()
 
tuple root_log = logging.getLogger()
 
tuple run_group = parser.add_argument_group('Run', 'Run configuration/parameters.')
 
tuple RunDesc = collections.namedtuple('Run', ['run', 'run_fp', 'global_fp', 'global_param'])
 
tuple RunState = collections.namedtuple('RunState', ['desc', 'proc'])
 
string start_dqm_job
 
list subdirectories = ["ramdisk", "output", "control", "home", "logs", "dqm_monitoring"]
 
tuple username = getpass.getuser()
 
tuple work_group = parser.add_argument_group('Paths', 'Path options for cmssw jobs, auto generated if not specified.')
 

Function Documentation

def personalPlayback.preexec_kill_on_pdeath ( )

Definition at line 55 of file personalPlayback.py.

55 
57  import ctypes
58  libc = ctypes.CDLL("libc.so.6")
59  PR_SET_PDEATHSIG = 1
60  libc.prctl(PR_SET_PDEATHSIG, signal.SIGKILL)
61 
62 # Actual implementation of the workers

Variable Documentation

list personalPlayback.applets = []

Definition at line 498 of file personalPlayback.py.

list personalPlayback.args = parser.parse_args()

Definition at line 473 of file personalPlayback.py.

tuple personalPlayback.cfg_a = FrameworkJob("framework_job", opts=args, cfg_file=cfg)

Definition at line 506 of file personalPlayback.py.

list personalPlayback.f = sys.argv[-1]

Definition at line 440 of file personalPlayback.py.

string personalPlayback.fn = "%s_%s.pkl"

Definition at line 514 of file personalPlayback.py.

Referenced by HcalForwardLibWriter.analyze(), dqm::RamdiskMonitor.analyzeFile(), dqm::RamdiskMonitor.beginLuminosityBlock(), gen::FortranInstance.call(), gen::Herwig6Instance.callWithTimeout(), gen.cms_hwwarn_(), dqmservices::DQMFileIterator.collect(), MonitorElement.copyFunctions(), BinomialInterval.dump(), L1MuGMTConfig.dumpLUTs(), FWGeometry.findFile(), RPAlignmentCorrectionsMethods.GetCorrectionsDataFromFile(), RPAlignmentCorrectionsDataSequence.LoadXMLFile(), CSCThrTurnOnFcn.operator()(), python.rootplot.rootmath.operator_func(), L1GctHtMissLut.setEtScale(), L1GctHfEtSumsLut.setFunction(), LRHelpFunctions.setObsFitParameters(), CmsTrackerDiskBuilder.sortNS(), CmsTrackerPhase1DiskBuilder.sortNS(), HDRShower.thetaFunction(), and gen::Herwig6Instance.timeout().

personalPlayback.fp = a.control_fp

Definition at line 522 of file personalPlayback.py.

Referenced by abcd(), FWOverlapTableManager.addOverlapEntry(), DetIdSelectorTest.analyze(), SiStripDetVOffBuilder.BuildDetVOffObj(), CaloMeanResponse.CaloMeanResponse(), CastorTextCalibrations.CastorTextCalibrations(), TotemDAQMappingESSourceXML.ChipFramePosition(), ora::MappingRules.columnNameForVariable(), CSCMonitorModule.CSCMonitorModule(), CustomPhysicsList.CustomPhysicsList(), CustomPhysicsListSS.CustomPhysicsListSS(), dqm::DQMFileSaverBase.DQMFileSaverBase(), edm::FileRandomKEThetaGunProducer.FileRandomKEThetaGunProducer(), CSCReadoutMappingFromFile.fill(), SiStripGain.fillNewGain(), dqm::DQMFileSaverOnline.fillOrigin(), CosmicGenFilterLowE.filter(), FWGeometry.findFile(), GeometryConfiguration.GeometryConfiguration(), dqm::DQMFileSaverBase.globalEndLuminosityBlock(), dqm::DQMFileSaverBase.globalEndRun(), HcalForwardLibWriter.HcalForwardLibWriter(), HcalTextCalibrations.HcalTextCalibrations(), HFShowerLibrary.HFShowerLibrary(), CastorShowerLibrary.initFile(), TotemDAQMapping.insert(), SiStripFedCablingManipulator.manipulate(), MultiEventFilter.MultiEventFilter(), DDLParser.parseOneFile(), RawDataUnpacker.ProcessOptoRxFrameSerial(), RawDataUnpacker.ProcessVFATDataParallel(), FIPConfiguration.readConfig(), RPCRecHitProducer.RPCRecHitProducer(), RPCTriggerConfig.RPCTriggerConfig(), TiXmlDocument.SaveFile(), FWTEveViewer.SaveJpg(), FWTEveViewer.SavePng(), SiStripDetInfoFileReader.SiStripDetInfoFileReader(), TiXmlFOpen(), and MillePedeFileExtractor.writeGzipped().

string personalPlayback.log_format = '%(asctime)s: %(name)-20s - %(levelname)-8s - %(message)s'

Definition at line 20 of file personalPlayback.py.

tuple personalPlayback.obj = Applet.read(f)

Definition at line 441 of file personalPlayback.py.

tuple personalPlayback.parser = argparse.ArgumentParser(description="Emulate DQM@P5 environment and launch cmssw jobs.")

Definition at line 450 of file personalPlayback.py.

tuple personalPlayback.path = getattr(args, "work_" + subdirectory)

Definition at line 483 of file personalPlayback.py.

tuple personalPlayback.playback = Playback("playback_emu", opts=args)

Definition at line 502 of file personalPlayback.py.

Referenced by edm::SecSourceAnalyzer.SecSourceAnalyzer().

tuple personalPlayback.playback_group = parser.add_argument_group('Playback', 'Playback configuration/parameters.')

Definition at line 462 of file personalPlayback.py.

tuple personalPlayback.ret = obj.do_exec()

Definition at line 443 of file personalPlayback.py.

tuple personalPlayback.root_log = logging.getLogger()

Definition at line 22 of file personalPlayback.py.

tuple personalPlayback.run_group = parser.add_argument_group('Run', 'Run configuration/parameters.')

Definition at line 467 of file personalPlayback.py.

tuple personalPlayback.RunDesc = collections.namedtuple('Run', ['run', 'run_fp', 'global_fp', 'global_param'])

Definition at line 242 of file personalPlayback.py.

Referenced by personalPlayback.FrameworkJob.discover_latest().

tuple personalPlayback.RunState = collections.namedtuple('RunState', ['desc', 'proc'])

Definition at line 243 of file personalPlayback.py.

tuple personalPlayback.start_dqm_job
Initial value:
1 = """
2 #!/bin/env /bin/bash
3 set -x #echo on
4 TODAY=$(date)
5 logname="/var/log/hltd/pid/hlt_run$4_pid$$.log"
6 lognamez="/var/log/hltd/pid/hlt_run$4_pid$$_gzip.log.gz"
7 #override the noclobber option by using >| operator for redirection - then keep appending to log
8 echo startDqmRun invoked $TODAY with arguments $1 $2 $3 $4 $5 $6 $7 $8 >| $logname
9 export http_proxy="http://cmsproxy.cms:3128"
10 export https_proxy="https://cmsproxy.cms:3128/"
11 export NO_PROXY=".cms"
12 export SCRAM_ARCH=$2
13 cd $1
14 cd base
15 source cmsset_default.sh >> $logname
16 cd $1
17 cd current
18 pwd >> $logname 2>&1
19 eval `scram runtime -sh`;
20 cd $3;
21 pwd >> $logname 2>&1
22 #exec esMonitoring.py -z $lognamez cmsRun `readlink $6` runInputDir=$5 runNumber=$4 $7 $8 >> $logname 2>&1
23 exec esMonitoring.py cmsRun `readlink $6` runInputDir=$5 runNumber=$4 $7 $8
24 """

Definition at line 213 of file personalPlayback.py.

list personalPlayback.subdirectories = ["ramdisk", "output", "control", "home", "logs", "dqm_monitoring"]

Definition at line 447 of file personalPlayback.py.

Referenced by EmDQMPostProcessor.dqmEndJob(), and JetMETDQMPostProcessor.dqmEndJob().

tuple personalPlayback.username = getpass.getuser()

Definition at line 448 of file personalPlayback.py.

Referenced by HcalChannelDataXml.add_dataset(), ConnectionManager.connect(), and HcalChannelDataXml.init_data().

tuple personalPlayback.work_group = parser.add_argument_group('Paths', 'Path options for cmssw jobs, auto generated if not specified.')

Definition at line 458 of file personalPlayback.py.