CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Groups 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 56 of file personalPlayback.py.

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

Variable Documentation

list personalPlayback.applets = []

Definition at line 499 of file personalPlayback.py.

list personalPlayback.args = parser.parse_args()

Definition at line 474 of file personalPlayback.py.

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

Definition at line 507 of file personalPlayback.py.

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

Definition at line 441 of file personalPlayback.py.

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

Definition at line 515 of file personalPlayback.py.

Referenced by HcalForwardLibWriter.analyze(), dqm::RamdiskMonitor.analyzeFile(), gen::FortranInstance.call(), gen::Herwig6Instance.callWithTimeout(), gen.cms_hwwarn_(), dqmservices::DQMFileIterator.collect(), L1MuGMTConfig.dumpLUTs(), FWGeometry.findFile(), dqm::RamdiskMonitor.globalBeginLuminosityBlock(), initGeom(), CSCThrTurnOnFcn.operator()(), python.rootplot.rootmath.operator_func(), TotemDAQMappingESSourceXML.produce(), CTPPSPixelDAQMappingESSourceXML.produceCTPPSPixelAnalysisMask(), CTPPSPixelDAQMappingESSourceXML.produceCTPPSPixelDAQMapping(), tensorflow::NoThreadPool.Schedule(), tensorflow::TBBThreadPool.Schedule(), tensorflow::NoThreadPool.ScheduleWithHint(), tensorflow::TBBThreadPool.ScheduleWithHint(), L1GctHtMissLut.setEtScale(), L1GctHfEtSumsLut.setFunction(), LRHelpFunctions.setObsFitParameters(), BPHWriteSpecificDecay.setRecoParameters(), CmsTrackerPhase1DiskBuilder< FilteredView >.sortNS(), CmsTrackerPhase2TPDiskBuilder< FilteredView >.sortNS(), CmsTrackerDiskBuilder< FilteredView >.sortNS(), HDRShower.thetaFunction(), and gen::Herwig6Instance.timeout().

personalPlayback.fp = a.control_fp

Definition at line 523 of file personalPlayback.py.

Referenced by FWOverlapTableManager.addOverlapEntry(), BPHKinematicFit.addParticles(), DetIdSelectorTest.analyze(), edm::BeamMomentumGunProducer.BeamMomentumGunProducer(), CaloMeanResponse.CaloMeanResponse(), CastorTextCalibrations.CastorTextCalibrations(), CTPPSPixelDAQMappingESSourceXML.ChipFramePosition(), TotemDAQMappingESSourceXML.ChipFramePosition(), CSCMonitorModule.CSCMonitorModule(), CustomPhysicsList.CustomPhysicsList(), CustomPhysicsListSS.CustomPhysicsListSS(), dqm::DQMFileSaverBase.DQMFileSaverBase(), DTGeometryValidate.DTGeometryValidate(), EmulateCPPF.EmulateCPPF(), edm::FileRandomKEThetaGunProducer.FileRandomKEThetaGunProducer(), edm::FileRandomMultiParticlePGunProducer.FileRandomMultiParticlePGunProducer(), dqm::DQMFileSaverOnline.fillOrigin(), FWGeometry.findFile(), G4ProcessHelper.G4ProcessHelper(), GeometryConfiguration.GeometryConfiguration(), SiStripGainsPCLHarvester.getPeakOfLandau(), dqm::DQMFileSaverBase.globalEndLuminosityBlock(), dqm::DQMFileSaverBase.globalEndRun(), HcalForwardLibWriter.HcalForwardLibWriter(), HcalTextCalibrations.HcalTextCalibrations(), HFShowerLibrary.HFShowerLibrary(), CastorShowerLibrary.initFile(), L1NNTauProducer.initializeGlobalCache(), CTPPSPixelDAQMapping.insert(), TotemDAQMapping.insert(), SiStripFedCablingManipulator.manipulate(), MultiEventFilter.MultiEventFilter(), DDLParser.parseOneFile(), pps::RawDataUnpacker.processOptoRxFrameSampic(), pps::RawDataUnpacker.processOptoRxFrameSerial(), pps::RawDataUnpacker.processVFATDataParallel(), HBHEDarkeningEP.produce(), mkfit::Event.read_in(), FIPConfiguration.readConfig(), HGCalRadiationMap.readDosePars(), HGCalSciNoiseMap.readSipmPars(), RPCTriggerConfig.RPCTriggerConfig(), edm::EventProcessor.runToCompletion(), FWTEveViewer.SaveJpg(), FWTEveViewer.SavePng(), BPHKinematicFit.setIndependentFit(), evf::FastMonitoringThread.start(), TauNNId.TauNNId(), test_standard(), mkfit::Event.write_out(), and MillePedeFileExtractor.writeGzipped().

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

Definition at line 21 of file personalPlayback.py.

tuple personalPlayback.obj = Applet.read(f)

Definition at line 442 of file personalPlayback.py.

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

Definition at line 451 of file personalPlayback.py.

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

Definition at line 484 of file personalPlayback.py.

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

Definition at line 503 of file personalPlayback.py.

Referenced by edm::SecSourceAnalyzer.SecSourceAnalyzer().

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

Definition at line 463 of file personalPlayback.py.

tuple personalPlayback.ret = obj.do_exec()

Definition at line 444 of file personalPlayback.py.

tuple personalPlayback.root_log = logging.getLogger()

Definition at line 23 of file personalPlayback.py.

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

Definition at line 468 of file personalPlayback.py.

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

Definition at line 243 of file personalPlayback.py.

Referenced by personalPlayback.FrameworkJob.discover_latest().

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

Definition at line 244 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 214 of file personalPlayback.py.

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

Definition at line 448 of file personalPlayback.py.

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

tuple personalPlayback.username = getpass.getuser()

Definition at line 449 of file personalPlayback.py.

Referenced by ConnectionManager.connect().

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

Definition at line 459 of file personalPlayback.py.