watchdog Namespace Reference

Classes
class	Timeout

Functions
def	alarm_handler (signum, frame)
def	launch (args)
def	log (s)
def	main (args)

Variables
	action
	args
	const
	default
	description
	dest
	False
	group
	help
	int
	nargs
	parser
	SIGTERM
	stdin_
	stdout_
	type

Function Documentation

alarm_handler()

def watchdog.alarm_handler	(		signum,
			frame
	)

Definition at line 15 of file watchdog.py.

def alarm_handler(signum, frame):
    if signum != 14: return
    raise Timeout("Timeout reached.")

signal.signal(signal.SIGALRM, alarm_handler)

launch()

def watchdog.launch

(

args

)

Definition at line 25 of file watchdog.py.

References log(), and str.

Referenced by main().

def launch(args):
    fd, wd = os.pipe()

    def preexec():
        os.close(fd)

        env = os.environ
        env["WATCHDOG_FD"] = str(wd)

    p = subprocess.Popen(args.pargs, preexec_fn=preexec, stdin=stdin_, stdout=stdout_)
    os.close(wd)

    while True:
        try:
            signal.alarm(args.t)
            ch = os.read(fd, 1024)
            signal.alarm(0)
            
            if not ch:
                os.close(fd)
                return False, p.wait() # normal exit
            
            log("Received: %s, timer reset." % repr(ch))

        except Timeout as t:
            signal.alarm(0)

            log("Timeout reached, taking action.")

            if p.poll() is None:
                p.send_signal(args.action)

            os.close(fd)
            return True, p.wait()

    for p in open_procs_:
        if p.poll() is None:
            p.send_signal(sig)

log()

def watchdog.log

(

s

)

Definition at line 21 of file watchdog.py.

Referenced by launch(), and main().

def log(s):
    sys.stderr.write("watchdog: " + s + "\n");
    sys.stderr.flush()

main()

def watchdog.main

(

args

)

Definition at line 64 of file watchdog.py.

References launch(), and log().

def main(args):
    while True:
        killed, ret = launch(args)
        log("Program exitted, killed: %s, code: %d." % (killed, ret, ))

        if killed and args.restart:
            log("Restarting.")
            continue
    
        break

Variable Documentation

action

watchdog.action

Definition at line 79 of file watchdog.py.

args

watchdog.args

Definition at line 87 of file watchdog.py.

const

watchdog.const

Definition at line 83 of file watchdog.py.

default

watchdog.default

Definition at line 77 of file watchdog.py.

description

watchdog.description

Definition at line 76 of file watchdog.py.

dest

watchdog.dest

Definition at line 83 of file watchdog.py.

False

watchdog.False

Definition at line 79 of file watchdog.py.

group

watchdog.group

Definition at line 82 of file watchdog.py.

Referenced by MuonPFAnalyzer.analyze(), emtf::phase2::algo::TrackBuildingLayer.attachSegments(), edm::EventProcessor.beginRunAsync(), ExternalLHEProducer.beginRunProduce(), edm::EventProcessor.beginStreams(), FastTimerService::PlotsPerJob.book(), MuonPFAnalyzer.bookHistos(), CSCWireTopology.channel(), ProcessorBase< GoldenPatternType >.configure(), LateralityCoarsedProvider.convertString(), EcalShowerContainmentCorrections.correctionCoefficients(), EcalShowerContainmentCorrections.correctionXY(), evf::GlobalEvFOutputEventWriter.doOutputEventAsync(), edm::Worker.doWorkAsync(), edm::Worker.doWorkNoPrefetchingAsync(), PatternGenerator.endJob(), edm::EventProcessor.endStreams(), edm::Worker::RunModuleTask< T >.execute(), SimG4HcalValidation.fetchHits(), FastTimerService::PlotsPerJob.fill(), HcalTB04Analysis.fillBuffer(), EcalShowerContainmentCorrections.fillCorrectionCoefficients(), HcalTB04Analysis.fillEvent(), HcalTestHistoClass.fillHits(), HcalTB04Analysis.finalAnalysis(), utils.get_relval_id(), contentValuesLib.getDatasetName(), SiStripPsuDetIdMap.getDetectorLocation(), RPCAMCLinkEvent.getId(), OMTFConfiguration.getPatternGroups(), MuonPFAnalyzer.getPlot(), SiStripPsuDetIdMap.getPSUName(), HcalTBNumberingScheme.getUnitID(), GenWeightsTableProducer.globalBeginLuminosityBlock(), PatternGenerator.groupPatterns(), edm::EventProcessor.handleNextEventForStreamAsync(), edm::EventProcessor.init(), HcalTestAnalysis.layerGrouping(), SimpleNavigationSchool.linkForwardLayers(), SimpleNavigationSchool.linkNextLayerInGroup(), SimpleNavigationSchool.linkOuterGroup(), SimpleNavigationSchool.linkWithinGroup(), GenObject.GenObject.loadConfigFile(), edm::eventsetup::CallbackExternalWork< T, TAcquireFunc, TAcquireReturn, TProduceFunc, TProduceReturn, TRecord, TDecorator >.makeAcquireTask(), edm::eventsetup::CallbackExternalWork< T, TAcquireFunc, TAcquireReturn, TProduceFunc, TProduceReturn, TRecord, TDecorator >.makeExceptionHandlerTask(), edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >.makeProduceTask(), mergeLHE.DefaultLHEMerger.merge(), mergeLHE.DefaultLHEMerger.merge_headers(), NanoAODDQM.NanoAODDQM(), L1CaloEcalScaleConfigOnlineProd.newObject(), edm::EventProcessor.nextTransitionTypeAsync(), MeasurementByLayerGrouper.operator()(), ALPAKA_ACCELERATOR_NAMESPACE::hcal::reconstruction::mahi::Kernel_prep1d_sameNumberOfSamples.operator()(), ALPAKA_ACCELERATOR_NAMESPACE::hcal::reconstruction::mahi::Kernel_minimize< NSAMPLES, NPULSES >.operator()(), SimpleNavigationSchool.outerRadiusIncrease(), FastTimerService.postBeginJob(), FastTimerService.postEvent(), edm::eventsetup::Callback< T, TProduceFunc, TReturn, TRecord, TDecorator >.prefetchAsync(), edm::eventsetup::CallbackExternalWork< T, TAcquireFunc, TAcquireReturn, TProduceFunc, TProduceReturn, TRecord, TDecorator >.prefetchAsync(), edm::eventsetup::CallbackBase< T, TProduceFunc, TProduceReturn, TRecord, TDecorator >.prefetchAsyncImpl(), edm::eventsetup::ESSourceProductResolverBase.prefetchAsyncImplTemplate(), edm::Worker.prePrefetchSelectionAsync(), FastTimerService.printEvent(), FastTimerService.printSummary(), PixelTemplateSmearerBase.process(), edm::StreamSchedule.processOneStreamAsync(), HcalTTPDigiProducer.produce(), cms::cuda::impl::ScopedContextHolderHelper.pushNextTask(), HcalTestAnalysis.qieAnalysis(), edm::EventProcessor.readAndMergeLumiEntriesAsync(), edm::EventProcessor.readAndMergeRunEntriesAsync(), EcalWeightGroupXMLTranslator.readXML(), TauDiscriminatorTools.recoTauTypeMapper(), L1MuBMTrackAssembler.runAddressAssignment1(), L1MuDTTrackAssembler.runAddressAssignment1(), L1MuDTTrackAssembler.runAddressAssignment2(), L1MuBMTrackAssembler.runAddressAssignment2(), hippyaddtobaddatafiles.runcfg(), L1MuBMTrackAssembler.runEncoderSubUnit1(), L1MuDTTrackAssembler.runEncoderSubUnit1(), L1MuDTTrackAssembler.runEncoderSubUnit2(), L1MuBMTrackAssembler.runEncoderSubUnit2(), edm::eventsetup::EventSetupsController.runOrQueueEventSetupForInstanceAsync(), jsoncollector::DataPointDefinition.setDefaultGroup(), Key.setGroup(), TrackingMaterialAnalyser.split(), DD4hep_TrackingMaterialAnalyser.split(), LA_Filler_Fitter.summarize_ensembles(), edm.syncWait(), edm::NoProcessProductResolver.tryPrefetchResolverAsync(), and HcalTB04Analysis.unitID().

help

watchdog.help

Definition at line 77 of file watchdog.py.

int

watchdog.int

Definition at line 77 of file watchdog.py.

nargs

watchdog.nargs

Definition at line 80 of file watchdog.py.

parser

watchdog.parser

Definition at line 76 of file watchdog.py.

SIGTERM

watchdog.SIGTERM

Definition at line 83 of file watchdog.py.

Referenced by edm::service::InitRootHandlers.InitRootHandlers(), edm::shared_memory::WorkerMonitorThread.run(), and edm::shared_memory::WorkerMonitorThread.setupSignalHandling().

stdin_

watchdog.stdin_

Definition at line 7 of file watchdog.py.

stdout_

watchdog.stdout_

Definition at line 8 of file watchdog.py.

type

watchdog.type

Definition at line 77 of file watchdog.py.