CMS 3D CMS Logo
Functions | Variables
fileCollector Namespace Reference

Functions

def convert (infile, ofile)
 
def filecheck (rootfile)
 
def logme (msg, *args)
 
def sendmail (body="Hello from visDQMZipCastorVerifier")
 

Variables

 cmp
 
 COLLECTDIR
 
 done
 
 donefile
 
 dqmfile
 
 DROPBOX
 
 EMAIL
 
 EMAILINTERVAL
 
 f
 
 files
 
 finalfile
 
 finalTdir
 
 finalTfile
 
 finalTMPfile
 
 fMatch
 
 HOSTNAME
 
 keeper
 
 lastEmailSent
 
 lFile
 
 md5Digest
 
 NEW
 
 NFOUND
 
 now
 
 NRUNS
 
 originFile
 
 originFileName
 
 originStr
 
 originTMPFile
 
 RETRIES
 
 reverse
 
 runnr
 
 runstr
 
 SBASEDIR
 
 seed
 
 SENDMAIL
 
 stdout
 
 subsystem
 
 TAGRUNEND
 
 TAGS
 
 Tfile
 
 TFILEDONEDIR
 
 Tfiles
 
 TMPDROPBOX
 
 version
 
 WAITTIME
 

Function Documentation

◆ convert()

def fileCollector.convert (   infile,
  ofile 
)

Definition at line 47 of file fileCollector.py.

47 def convert(infile, ofile):
48  cmd = 'root -l -b -q %s/sistrip_reduce_file.C++"' \
49  '(\\"%s\\", \\"%s\\")" >& /dev/null' % (SBASEDIR,infile, ofile)
50  os.system(cmd)
51 

Referenced by helper::CollectionStoreManager< OutputCollection, ClonePolicy >.cloneAndStore(), Herwig7Interface.convert(), EventMsgBuilder.EventMsgBuilder(), GlobalVariablesTableProducer::VariableT< ValType, ColType, Converter >.fill(), edm::EventItemGetter< RefType, EventType >.get(), Header.Header(), InitHeader.InitHeader(), InitMsgBuilder.InitMsgBuilder(), RunInfoTestESProducer.makeRunInfo(), InitMsgBuilder.setDataLength(), EventMsgBuilder.setEventLength(), CmsShowCommon.setFrom(), FWViewEnergyScale.SetFromCmsShowCommonConfig(), and EventMsgBuilder.setOrigDataSize().

◆ filecheck()

def fileCollector.filecheck (   rootfile)

Definition at line 35 of file fileCollector.py.

35 def filecheck(rootfile):
36  cmd = 'root -l -b -q %s/filechk.C"(\\"%s\\")"' % (SBASEDIR,rootfile)
37  a = os.popen(cmd).read().split()
38  tag=a.pop()
39  if tag == '(int)(-1)' or tag == '(int)0':
40  return 0
41 
42  if tag == '(int)1':
43  return 1
44 
45  return 0
46 

References readEcalDQMStatus.read, and cms::dd.split().

◆ logme()

def fileCollector.logme (   msg,
*  args 
)

Definition at line 31 of file fileCollector.py.

31 def logme(msg, *args):
32  procid = "[%s/%d]" % (__file__.rsplit("/", 1)[-1], os.getpid())
33  print(datetime.now(), procid, msg % args)
34 

References edm.print().

Referenced by DQMNet.losePeer(), DQMNet.onLocalNotify(), DQMNet.onMessage(), DQMNet.onPeerConnect(), DQMNet.onPeerData(), sendmail(), and DQMNet.updateMask().

◆ sendmail()

def fileCollector.sendmail (   body = "Hello from visDQMZipCastorVerifier")

Definition at line 52 of file fileCollector.py.

52 def sendmail(body="Hello from visDQMZipCastorVerifier"):
53  scall = Popen("%s -t" % SENDMAIL, shell=True, stdin=PIPE)
54  scall.stdin.write("To: %s\n" % EMAIL)
55  scall.stdin.write("Subject: File Collector on server %s has a Critical Error\n" %
56  HOSTNAME)
57  scall.stdin.write("\n") # blank line separating headers from body
58  scall.stdin.write("%s\n" % body)
59  scall.stdin.close()
60  rc = scall.wait()
61  if rc != 0:
62  logme("ERROR: Sendmail exit with status %s", rc)
63 
64 # --------------------------------------------------------------------

References logme().

Variable Documentation

◆ cmp

fileCollector.cmp

Definition at line 125 of file fileCollector.py.

Referenced by helper::CandDecayStoreManager.add(), combiner::helpers::NormalClone.addDaughter(), combiner::helpers::ShallowClone.addDaughter(), combiner::helpers::ShallowClonePtr.addDaughter(), CandCombiner< Selector, PairSelector, Cloner, OutputCollection, Setup >.addDaughter(), NamedCandCombiner< Selector, PairSelector, Cloner, Setup >.addDaughter(), PFAnalysis.associateClusterToSimCluster(), cloneDecayTree(), EMTFSubsystemCollector.cluster_rpc(), NamedCandCombinerBase.combine(), CandCombinerBase< OutputCollection, Cloner::CandPtr >.combine(), geometryXMLparser.cscorder(), dqmMemoryStats.HistogramAnalyzer.difference(), geometryXMLparser.dtorder(), edmNew::DetSetVector< T >.equal_range(), CSCDigiValidator.filter(), LocalMaximumSeedFinder.findSeeds(), makeCompositeCandidate(), makeCompositeCandidateWithRefsToMaster(), makeCompositePtrCandidate(), makeNamedCompositeCandidate(), makeNamedCompositeCandidateWithRefsToMaster(), CompositeCandSelector< Selector, T1, T2, nDau >.operator()(), L1Comparator.process(), and TotemVFATStatus.setNumberOfClustersSpecified().

◆ COLLECTDIR

fileCollector.COLLECTDIR

Definition at line 14 of file fileCollector.py.

◆ done

fileCollector.done

Definition at line 123 of file fileCollector.py.

Referenced by LMFDat.adjustParameters(), EcalLaserCondTools.analyze(), HcalIsoTrkAnalyzer.analyze(), BaseParticlePropagator.backPropagate(), EcalCoder.encode(), SimG4FluxProducer.endOfEvent(), Thrust.finalAxis(), reco::PositiveSideGhostTrackFitter.fit(), edm.loadExtraClasses(), Combinatorics.next_subset(), DQMNet.onPeerData(), ParticlePropagator.propagateToBoundSurface(), BaseParticlePropagator.propagateToClosestApproach(), BaseParticlePropagator.propagateToEcalEntrance(), BaseParticlePropagator.propagateToHcalEntrance(), BaseParticlePropagator.propagateToHcalExit(), BaseParticlePropagator.propagateToHOLayer(), TrajectoryManager.propagateToLayer(), BaseParticlePropagator.propagateToPreshowerLayer1(), BaseParticlePropagator.propagateToPreshowerLayer2(), BaseParticlePropagator.propagateToVFcalEntrance(), LStoreFile.read(), DavixFile.read(), DCacheFile.read(), IOInput.readv(), TPNPulse.setPulse(), TAPDPulse.setPulse(), LStoreFile.write(), DCacheFile.write(), IOOutput.writev(), IOInput.xread(), IOInput.xreadv(), IOOutput.xwrite(), and IOOutput.xwritev().

◆ donefile

fileCollector.donefile

Definition at line 90 of file fileCollector.py.

◆ dqmfile

fileCollector.dqmfile

Definition at line 162 of file fileCollector.py.

Referenced by get_filename(), read_badmodlist(), and read_runflag().

◆ DROPBOX

fileCollector.DROPBOX

Definition at line 16 of file fileCollector.py.

◆ EMAIL

fileCollector.EMAIL

Definition at line 13 of file fileCollector.py.

◆ EMAILINTERVAL

fileCollector.EMAILINTERVAL

Definition at line 20 of file fileCollector.py.

◆ f

fileCollector.f

Definition at line 91 of file fileCollector.py.

◆ files

fileCollector.files

Definition at line 125 of file fileCollector.py.

◆ finalfile

fileCollector.finalfile

Definition at line 191 of file fileCollector.py.

◆ finalTdir

fileCollector.finalTdir

Definition at line 131 of file fileCollector.py.

◆ finalTfile

fileCollector.finalTfile

Definition at line 130 of file fileCollector.py.

◆ finalTMPfile

fileCollector.finalTMPfile

Definition at line 128 of file fileCollector.py.

◆ fMatch

fileCollector.fMatch

Definition at line 82 of file fileCollector.py.

◆ HOSTNAME

fileCollector.HOSTNAME

Definition at line 25 of file fileCollector.py.

◆ keeper

fileCollector.keeper

Definition at line 124 of file fileCollector.py.

◆ lastEmailSent

fileCollector.lastEmailSent

Definition at line 28 of file fileCollector.py.

◆ lFile

fileCollector.lFile

Definition at line 181 of file fileCollector.py.

Referenced by l1tpf::corrector.init_(), and l1tpf::corrector.writeToFile().

◆ md5Digest

fileCollector.md5Digest

Definition at line 173 of file fileCollector.py.

◆ NEW

fileCollector.NEW

Definition at line 78 of file fileCollector.py.

◆ NFOUND

fileCollector.NFOUND

Definition at line 77 of file fileCollector.py.

◆ now

fileCollector.now

Definition at line 207 of file fileCollector.py.

Referenced by SonicEDProducer< Client, Capabilities >.acquire(), edm::CountAndLimit.add(), lumi::RevisionDML.addEntry(), lumi::RevisionDML.addRevision(), lumi::RevisionDML.addRunToCurrentHFDataTag(), dqmservices::DQMFileIterator.advanceToLumi(), DQMEventInfo.analyze(), HcalLuttoDB.beginJob(), RawEventOutputModuleForBU< Consumer >.beginLuminosityBlock(), edm::service::CondorStatusService.beginPost(), condbon.cdbon_write(), XrdAdaptor::RequestManager.checkSources(), XrdAdaptor::RequestManager.checkSourcesImpl(), dqmservices::DQMFileIterator.collect(), XrdAdaptor::RequestManager.compareSources(), DQMEventInfo.DQMEventInfo(), DQMHarvestingMetadata.DQMHarvestingMetadata(), dqmservices::DQMMonitoringService.DQMMonitoringService(), DTHVStatusHandler.dumpSnapshot(), XrdAdaptor::XrdReadStatistics.elapsedNS(), dqmservices::DQMMonitoringService.evLumi(), DaqFakeReader.fillRawData(), DaqFakeReader.fillTCDSFED(), BeamMonitor.FitAndFill(), FakeBeamMonitor.FitAndFill(), XrdAdaptor::QualityMetricFactory.get(), cond::persistency.get_timestamp(), cond::persistency.get_timestamp_for_filename(), Fit.getFitQuality(), DTHVStatusHandler.getNewObjects(), XrdAdaptor::RequestManager.handle(), XrdAdaptor::RequestManager::OpenHandler.HandleResponseWithHosts(), HtrXmlPatternWriter.HtrXmlPatternWriter(), cond::persistency.importPayload(), cond::FileBasedEmptySource.initialize(), edm::InputSource.InputSource(), cond::persistency::IOVEditor.insert(), cond::RunInfo_t.isOnGoing(), edm::service::CondorStatusService.lastUpdate(), LHCInfoPopConSourceHandler.LHCInfoPopConSourceHandler(), DQMNet.logme(), edm::InputSource.lumiLimitReached(), FastTimerService::Measurement.measure(), FastTimerService::Measurement.measure_and_accumulate(), FastTimerService::Measurement.measure_and_store(), Fit.multiplyMatrices(), XrdAdaptor::QualityMetricUniqueSource.newSource(), operator<<(), dqmservices::DQMMonitoringService.outputLumiUpdate(), dqmservices::DQMMonitoringService.outputUpdate(), edm::service::StallMonitor.postBeginJob(), ThroughputService.postEvent(), edm::service::StallMonitor.postEvent(), edm::service::StallMonitor.postEventReadFromSource(), edm::service::StallMonitor.postModuleEvent(), edm::service::StallMonitor.postModuleEventAcquire(), edm::service::StallMonitor.postModuleEventPrefetching(), edm::service::StallMonitor.postModuleGlobalTransition(), edm::service::StallMonitor.postModuleStreamTransition(), edm::service::StallMonitor.postSourceEvent(), edm::service::StallMonitor.preEvent(), edm::service::StallMonitor.preEventReadFromSource(), edm::service::StallMonitor.preModuleEvent(), edm::service::StallMonitor.preModuleEventAcquire(), edm::service::StallMonitor.preModuleGlobalTransition(), edm::service::StallMonitor.preModuleStreamTransition(), ThroughputService.preSourceEvent(), edm::service::StallMonitor.preSourceEvent(), Fit.PropagateErrors(), XrdFile.readv(), FedRawDataInputSource.readWorker(), XrdAdaptor::RequestManager.requestFailure(), dqmservices::DQMFileIterator.reset(), lumi::CMSRunSummaryDummy2DB.retrieveData(), DQMNet.run(), edm::StreamerOutputModuleCommon.serializeEvent(), ALIUtils.set_time_now(), XrdAdaptor::Source.setLastDowngrade(), cond::FileBasedEmptySource.setRunAndEventInfo(), SonicClientBase.setStartTime(), edm::TimeoutPoolOutputModule.shouldWeCloseFile(), trklet::Timer.start(), edm::service::ConcurrentModuleTimer.start(), trklet::Timer.stop(), edm::service::ConcurrentModuleTimer.stop(), edm::StreamerOutputModuleCommon.StreamerOutputModuleCommon(), StorageAccount::Stamp.tick(), dqmservices::DQMMonitoringService.tryUpdate(), edm::service::CondorStatusService.update(), dqmservices::DQMFileIterator.update_state(), SiStripPayloadHandler< SiStripPayload >.updateConfigMap(), edm::service::CondorStatusService.updateImpl(), cond::service::OnlineDBOutputService.writeForNextLumisection(), and BenchmarkGrd.~BenchmarkGrd().

◆ NRUNS

fileCollector.NRUNS

Definition at line 76 of file fileCollector.py.

◆ originFile

fileCollector.originFile

Definition at line 176 of file fileCollector.py.

◆ originFileName

fileCollector.originFileName

Definition at line 192 of file fileCollector.py.

◆ originStr

fileCollector.originStr

Definition at line 174 of file fileCollector.py.

◆ originTMPFile

fileCollector.originTMPFile

Definition at line 175 of file fileCollector.py.

◆ RETRIES

fileCollector.RETRIES

Definition at line 23 of file fileCollector.py.

◆ reverse

fileCollector.reverse

Definition at line 104 of file fileCollector.py.

◆ runnr

fileCollector.runnr

Definition at line 87 of file fileCollector.py.

Referenced by EnergyScaleCorrection.getScaleCorr(), EnergyScaleCorrection.getSmearCorr(), EnergyScaleCorrection::CorrectionCategory.inCategory(), L1MuGMTHWFileReader.readNextEvent(), L1MuGMTInputEvent.setRunNumber(), and EnergyScaleCorrection.smearingSigma().

◆ runstr

fileCollector.runstr

Definition at line 89 of file fileCollector.py.

◆ SBASEDIR

fileCollector.SBASEDIR

Definition at line 21 of file fileCollector.py.

◆ seed

fileCollector.seed

Definition at line 127 of file fileCollector.py.

◆ SENDMAIL

fileCollector.SENDMAIL

Definition at line 24 of file fileCollector.py.

◆ stdout

fileCollector.stdout

Definition at line 11 of file fileCollector.py.

◆ subsystem

fileCollector.subsystem

Definition at line 88 of file fileCollector.py.

◆ TAGRUNEND

fileCollector.TAGRUNEND

Definition at line 110 of file fileCollector.py.

◆ TAGS

fileCollector.TAGS

Definition at line 79 of file fileCollector.py.

◆ Tfile

fileCollector.Tfile

Definition at line 170 of file fileCollector.py.

◆ TFILEDONEDIR

fileCollector.TFILEDONEDIR

Definition at line 15 of file fileCollector.py.

◆ Tfiles

fileCollector.Tfiles

Definition at line 125 of file fileCollector.py.

◆ TMPDROPBOX

fileCollector.TMPDROPBOX

Definition at line 22 of file fileCollector.py.

◆ version

fileCollector.version

Definition at line 180 of file fileCollector.py.

◆ WAITTIME

fileCollector.WAITTIME

Definition at line 19 of file fileCollector.py.

cms::dd::split
std::vector< std::string_view > split(std::string_view, const char *)
fileCollector.filecheck
def filecheck(rootfile)
Definition: fileCollector.py:35
fileCollector.convert
def convert(infile, ofile)
Definition: fileCollector.py:47
edm::print
S & print(S &os, JobReport::InputFile const &f)
Definition: JobReport.cc:66
readEcalDQMStatus.read
read
Definition: readEcalDQMStatus.py:38
fileCollector.sendmail
def sendmail(body="Hello from visDQMZipCastorVerifier")
Definition: fileCollector.py:52
fileCollector.logme
def logme(msg, *args)
Definition: fileCollector.py:31
Generated for CMSSW Reference Manual by doxygen 1.8.16