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 295 of file esMonitoring.py.

Constructor & Destructor Documentation

__init__()

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

Definition at line 296 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

cleanup()

def esMonitoring.FDJsonServer.cleanup

(

self

)

Definition at line 327 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)

handle_accept()

def esMonitoring.FDJsonServer.handle_accept

(

self

)

Definition at line 332 of file esMonitoring.py.

References fwlite::EventSelector.accept(), DDFilter.accept(), DDNameFilter.accept(), DTNeutronWriter.accept(), CSCNeutronWriter.accept(), RPCNeutronWriter.accept(), ParticleDecayDrawer.accept(), DDPassAllFilter.accept(), fwlite::RunLumiSelector.accept(), ParticleTreeDrawer.accept(), EcalZeroSuppressor< C >.accept(), EcalZeroSuppressor< EEDataFrame >.accept(), EcalZeroSuppressor< EBDataFrame >.accept(), FileReaderDCC.accept(), FileReaderDDU.accept(), DDSpecificsFilter.accept(), BPHHistoSpecificDecay::CandidateSelect.accept(), SubsystemNeutronWriter.accept(), BPHParticleNeutralVeto.accept(), BPHParticlePtSelect.accept(), BPHParticleEtaSelect.accept(), BPHMuonEtaSelect.accept(), BPHMuonPtSelect.accept(), BPHMuonChargeSelect.accept(), BPHParticleChargeSelect.accept(), BPHChi2Select.accept(), BPHKinFitChi2Select.accept(), Filter.accept(), BPHMassSelect.accept(), BPHMomentumSelect.accept(), edm::HLTGlobalStatus.accept(), BPHVertexSelect.accept(), BPHFitSelect.accept(), BPHMassSymSelect.accept(), BPHRecoSelect.accept(), edm::HLTPathStatus.accept(), edm::TriggerResultsByName.accept(), RunBasedHistograms::HLTRatesPlots.accept, DDSpecificsHasNamedValueFilter.accept(), HLTLogMonitorFilter::CategoryEntry.accept(), BPHMassFitSelect.accept(), DDSpecificsMatchesValueFilter.accept(), fwlite::ObjectCountSelector< Collection >.accept(), DDAndFilter< F1, F2 >.accept(), BPHDecayToResResBuilderBase::DZSelect.accept(), TriggerHelper.accept(), TkPixelMeasurementDet.accept(), EcalSelectiveReadoutSuppressor.accept(), BPHRecoBuilder.accept(), FilterOR.accept(), BPHSlimSelect< T >.accept(), GenericTriggerEventFlag.accept(), BPHSoftMuonSelect.accept(), BPHFullSelect< T >.accept(), FilterSelection.accept(), BPHDaughterSelect.accept(), BPHCompositeBasicSelect.accept(), cms::DDFilteredView.accept(), BPHFittedBasicSelect.accept(), TkStripMeasurementDet.accept(), BPHGenericVertexSelect.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)

handle_close()

def esMonitoring.FDJsonServer.handle_close

(

self

)

Definition at line 337 of file esMonitoring.py.

References DrawPlot.cleanup(), PFCandIsolatorFromDeposits::SingleDeposit.cleanup(), DDI::Finalize< I >.cleanup(), DDI::Finalize< I * >.cleanup(), esMonitoring.FDJsonServer.cleanup(), cmsHarvester.CMSHarvester.cleanup(), edm::storage::RemoteFile.close(), AlignmentCorrelationsIO.close(), edm::storage::StorageAccount.close, TritonMemResource< IO >.close(), AlignmentParametersIO.close(), trklet::HistBase.close(), AlignmentCorrelationsIORoot.close(), l1tpf_impl::COEFile.close(), AlignmentUserVariablesIO.close(), AlignableDataIO.close(), RawFile.close(), evf::EvFOutputEventWriter.close(), AlignableDataIORoot.close(), edm::storage::LStoreFile.close(), binary_ifstream.close(), binary_ofstream.close(), edm::storage::DavixFile.close(), edm::storage::DCacheFile.close(), edm::storage::LocalCacheFile.close(), MuonErrorMatrix.close(), AlignmentParametersIORoot.close(), edm::streamer::OutputFile.close(), edm::storage::StorageAccountProxy.close(), HIPUserVariablesIORoot.close(), looper.Setup.close(), ALIFileIn.close(), edm::storage::XrdFile.close(), cond::persistency::PayloadReader.close(), edm::storage::File.close(), evf::GlobalEvFOutputEventWriter.close(), L1GtVhdlTemplateFile.close(), TritonCpuShmResource< IO >.close(), cond::persistency::SessionImpl.close(), L1GtPatternWriter.close(), StreamerOutputFile.close(), MillePedeVariablesIORoot.close(), DTTPGLutFile.close(), L1TriggerLutFile.close(), edm::storage::Storage.close(), cond::persistency::Session.close(), DQM.DQMReader.close(), edm::RootOutputTree.close(), mkfit::DataFile.close(), edm::RootTree.close(), edm::FileBlock.close(), cond::CSScopedSession.close(), edm::RootFile.close(), and cond::persistency::TransactionScope.close().

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

Member Data Documentation

args

esMonitoring.FDJsonServer.args

Definition at line 301 of file esMonitoring.py.

es

esMonitoring.FDJsonServer.es

Definition at line 300 of file esMonitoring.py.

Referenced by esMonitoring.FDJsonServer.handle_accept(), esMonitoring.FDOutputListener.handle_line(), and esMonitoring.FDOutputListener.handle_timeout().

fn

esMonitoring.FDJsonServer.fn

Definition at line 299 of file esMonitoring.py.

Referenced by esMonitoring.FDJsonServer.cleanup().