esMonitoring.FDJsonServer Class Reference

Inheritance diagram for esMonitoring.FDJsonServer:

Public Member Functions
def	__init__ (self, es, args)
def	cleanup (self)
def	handle_accept (self)
def	handle_close (self)

Public Attributes
	args
	es
	fn

Detailed Description

Definition at line 294 of file esMonitoring.py.

Constructor & Destructor Documentation

def esMonitoring.FDJsonServer.__init__	(		self,
			es,
			args
	)

Definition at line 295 of file esMonitoring.py.

    def __init__(self, es, args):
        asyncore.dispatcher.__init__(self)

        self.fn = None
        self.es = es
        self.args = args

        prefix = "/tmp"
        if os.path.isdir(self.args.path):
            prefix = self.args.path

        base = ".es_monitoring_pid%08d" % os.getpid()
        self.fn = os.path.join(prefix, base)

        if self.args.debug:
            log("Socket path: %s" % self.fn)

        if os.path.exists(self.fn):
            os.unlink(self.fn)

        self.create_socket(socket.AF_UNIX, socket.SOCK_STREAM)
        oldmask = os.umask(0o077)
        try:
            self.bind(self.fn)
            self.listen(5)
        finally:
            os.umask(oldmask)
            pass

        atexit.register(self.cleanup)

Member Function Documentation

def esMonitoring.FDJsonServer.cleanup

(

self

)

Definition at line 326 of file esMonitoring.py.

References esMonitoring.FDJsonServer.fn.

Referenced by esMonitoring.FDJsonServer.handle_close().

    def cleanup(self):
        if self.fn is not None:
            if os.path.exists(self.fn):
                os.unlink(self.fn)

def esMonitoring.FDJsonServer.handle_accept

(

self

)

Definition at line 331 of file esMonitoring.py.

References fwlite::EventSelector.accept(), DDFilter.accept(), ParticleDecayDrawer.accept(), DTNeutronWriter.accept(), CSCNeutronWriter.accept(), RPCNeutronWriter.accept(), smartSelector.accept(), DDPassAllFilter.accept(), fwlite::RunLumiSelector.accept(), ParticleTreeDrawer.accept(), EcalZeroSuppressor< C >.accept(), EcalZeroSuppressor< EEDataFrame >.accept(), EcalZeroSuppressor< EBDataFrame >.accept(), BPHHistoSpecificDecay::CandidateSelect.accept(), Filter.accept(), DDSpecificsFilter.accept(), BPHVertexSelect.accept(), BPHMuonChargeSelect.accept(), BPHMuonEtaSelect.accept(), BPHParticleEtaSelect.accept(), BPHMuonPtSelect.accept(), BPHFitSelect.accept(), BPHParticleChargeSelect.accept(), BPHParticleNeutralVeto.accept(), BPHMomentumSelect.accept(), BPHParticlePtSelect.accept(), BPHChi2Select.accept(), BPHMassSelect.accept(), SubsystemNeutronWriter.accept(), BPHMassSymSelect.accept(), edm::HLTGlobalStatus.accept(), BPHRecoSelect.accept(), HLTLogMonitorFilter::CategoryEntry.accept(), edm::HLTPathStatus.accept(), edm::TriggerResultsByName.accept(), BPHMassFitSelect.accept(), RunBasedHistograms::HLTRatesPlots.accept, fwlite::ObjectCountSelector< Collection >.accept(), DDSpecificsHasNamedValueFilter.accept(), BPHMultiSelect< T >.accept(), DDSpecificsMatchesValueFilter.accept(), TriggerHelper.accept(), BPHSoftMuonSelect.accept(), TkPixelMeasurementDet.accept(), DDAndFilter< F1, F2 >.accept(), DDAndFilter< DDSpecificsMatchesValueFilter, DDSpecificsMatchesValueFilter >.accept(), EcalSelectiveReadoutSuppressor.accept(), GenericTriggerEventFlag.accept(), FilterOR.accept(), BPHRecoBuilder.accept(), BPHDaughterSelect.accept(), FilterSelection.accept(), BPHCompositeBasicSelect.accept(), BPHFittedBasicSelect.accept(), BPHCompositeVertexSelect.accept(), TkStripMeasurementDet.accept(), BPHFittedVertexSelect.accept(), esMonitoring.FDJsonHandler.es, and esMonitoring.FDJsonServer.es.

    def handle_accept(self):
        pair = self.accept()
        if pair is not None:
            handler = FDJsonHandler(pair[0], self.es)

def esMonitoring.FDJsonServer.handle_close

(

self

)

Definition at line 336 of file esMonitoring.py.

References ESDataCertificationTask.cleanup(), PFCandIsolatorFromDeposits::SingleDeposit.cleanup(), ESDaqInfoTask.cleanup(), ESDcsInfoTask.cleanup(), DrawPlot.cleanup(), esMonitoring.FDJsonServer.cleanup(), cmsHarvester.CMSHarvester.cleanup(), Vispa.Plugins.EventBrowser.EventFileAccessor.EventFileAccessor.close(), StorageAccount.close, RemoteFile.close(), csvReporter.csvReporter.close(), AlignmentCorrelationsIO.close(), AlignmentCorrelationsIORoot.close(), Vispa.Plugins.EventBrowser.EventBrowserTabController.EventBrowserTabController.close(), AlignmentParametersIO.close(), RawFile.close(), PhysicsTools::TrainerMonitoring.close(), AlignmentUserVariablesIO.close(), AlignableDataIORoot.close(), IOChannel.close(), AlignableDataIO.close(), LocalCacheFile.close(), binary_ifstream.close(), binary_ofstream.close(), HIPUserVariablesIORoot.close(), AlignmentParametersIORoot.close(), DavixFile.close(), MuonErrorMatrix.close(), LStoreFile.close(), StorageAccountProxy.close(), DCacheFile.close(), looper.Setup.close(), ALIFileIn.close(), cond::persistency::SessionImpl.close(), Storage.close(), cond::persistency::PayloadReader.close(), L1GtVhdlTemplateFile.close(), XrdFile.close(), L1GtPatternWriter.close(), File.close(), MillePedeVariablesIORoot.close(), DTTPGLutFile.close(), L1TriggerLutFile.close(), cond::persistency::Session.close(), DQM.DQMReader.close(), edm::RootOutputTree.close(), edm::FileBlock.close(), edm::RootTree.close(), edm::RootFile.close(), cond::CSScopedSession.close(), cond::persistency::TransactionScope.close(), Vispa.Plugins.Browser.BrowserTabController.BrowserTabController.close(), and Vispa.Main.TabController.TabController.close().

    def handle_close(self):
        self.close()
        self.cleanup()

Member Data Documentation

esMonitoring.FDJsonServer.args

Definition at line 300 of file esMonitoring.py.

esMonitoring.FDJsonServer.es

Definition at line 299 of file esMonitoring.py.

Referenced by esMonitoring.FDJsonServer.handle_accept().

esMonitoring.FDJsonServer.fn

Definition at line 298 of file esMonitoring.py.

Referenced by esMonitoring.FDJsonServer.cleanup().