CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
List of all members | Public Member Functions | Public Attributes
esMonitoring.FDJsonServer Class Reference
Inheritance diagram for esMonitoring.FDJsonServer:

Public Member Functions

def __init__
 
def cleanup
 
def handle_accept
 
def handle_close
 

Public Attributes

 es
 
 fn
 

Detailed Description

Definition at line 293 of file esMonitoring.py.

Constructor & Destructor Documentation

def esMonitoring.FDJsonServer.__init__ (   self,
  es 
)

Definition at line 294 of file esMonitoring.py.

295  def __init__(self, es):
296  asyncore.dispatcher.__init__(self)
298  self.fn = None
299  self.es = es
300 
301  prefix = "/tmp"
302  if os.path.isdir("/tmp/dqm_monitoring"):
303  prefix = "/tmp/dqm_monitoring"
304 
305  base = ".es_monitoring_pid%08d" % os.getpid()
306  self.fn = os.path.join(prefix, base)
307 
308  if os.path.exists(self.fn):
309  os.unlink(self.fn)
310 
311  self.create_socket(socket.AF_UNIX, socket.SOCK_STREAM)
312  oldmask = os.umask(0077)
313  try:
314  self.bind(self.fn)
315  self.listen(5)
316  finally:
317  os.umask(oldmask)
318  pass
319 
320  atexit.register(self.cleanup)

Member Function Documentation

def esMonitoring.FDJsonServer.cleanup (   self)

Definition at line 321 of file esMonitoring.py.

References esMonitoring.FDJsonServer.fn.

Referenced by esMonitoring.FDJsonServer.handle_close().

322  def cleanup(self):
323  if self.fn is not None:
324  if os.path.exists(self.fn):
325  os.unlink(self.fn)
def esMonitoring.FDJsonServer.handle_accept (   self)

Definition at line 326 of file esMonitoring.py.

References fwlite::EventSelector.accept(), BaseRawParticleFilter.accept(), ParticleDecayDrawer.accept(), DTNeutronWriter.accept(), CSCNeutronWriter.accept(), RPCNeutronWriter.accept(), DDFilter.accept(), smartSelector.accept(), fwlite::RunLumiSelector.accept(), ParticleTreeDrawer.accept(), EcalZeroSuppressor< C >.accept(), EcalZeroSuppressor< EEDataFrame >.accept(), EcalZeroSuppressor< EBDataFrame >.accept(), Filter.accept(), SubsystemNeutronWriter.accept(), edm::HLTGlobalStatus.accept(), DDSpecificsFilter.accept(), HLTLogMonitorFilter::CategoryEntry.accept(), edm::HLTPathStatus.accept(), edm::TriggerResultsByName.accept(), fwlite::ObjectCountSelector< Collection >.accept(), TriggerHelper.accept(), TkPixelMeasurementDet.accept(), GenericTriggerEventFlag.accept(), EcalSelectiveReadoutSuppressor.accept(), TriggerRatesMonitor::HLTRatesPlots.accept, FilterOR.accept(), Selection< C, Selector, StoreContainer >.accept(), FastTimerService::PathInfo.accept, TkStripMeasurementDet.accept(), esMonitoring.FDJsonHandler.es, and esMonitoring.FDJsonServer.es.

327  def handle_accept(self):
328  pair = self.accept()
329  if pair is not None:
330  handler = FDJsonHandler(pair[0], self.es)
def esMonitoring.FDJsonServer.handle_close (   self)

Definition at line 331 of file esMonitoring.py.

References ESDataCertificationTask.cleanup(), HcalNZSClient.cleanup(), HcalTrigPrimClient.cleanup(), HcalBeamClient.cleanup(), HcalCoarsePedestalClient.cleanup(), HcalDeadCellClient.cleanup(), HcalDetDiagLaserClient.cleanup(), HcalDetDiagLEDClient.cleanup(), HcalDetDiagNoiseMonitorClient.cleanup(), HcalDetDiagPedestalClient.cleanup(), HcalDetDiagTimingClient.cleanup(), HcalDigiClient.cleanup(), HcalHotCellClient.cleanup(), HcalRecHitClient.cleanup(), HcalSummaryClient.cleanup(), HcalRawDataClient.cleanup(), HcalLaserClient.cleanup(), PFCandIsolatorFromDeposits::SingleDeposit.cleanup(), HcalBaseDQClient.cleanup(), ESDaqInfoTask.cleanup(), ESDcsInfoTask.cleanup(), HcalLEDClient.cleanup(), HcalPedestalClient.cleanup(), HcalMonitorModule.cleanup(), HcalMonitorClient.cleanup(), HcalBaseDQMonitor.cleanup(), esMonitoring.FDJsonServer.cleanup(), cmsHarvester.CMSHarvester.cleanup(), Vispa.Plugins.EventBrowser.EventFileAccessor.EventFileAccessor.close(), RemoteFile.close(), csvReporter.csvReporter.close(), AlignmentCorrelationsIO.close(), cond::DbConnection::ConnectionImpl.close(), AlignmentCorrelationsIORoot.close(), Vispa.Plugins.EventBrowser.EventBrowserTabController.EventBrowserTabController.close(), AlignmentParametersIO.close(), AlignableDataIORoot.close(), AlignableDataIO.close(), ora::SharedSession.close(), AlignmentUserVariablesIO.close(), PhysicsTools::TrainerMonitoring.close(), IOChannel.close(), LocalCacheFile.close(), binary_ifstream.close(), binary_ofstream.close(), AlignmentParametersIORoot.close(), StorageAccountProxy.close(), MuonErrorMatrix.close(), LStoreFile.close(), RFIOFile.close(), looper.Setup.close(), DCacheFile.close(), ThePEG::LesHouchesInterface.close(), HIPUserVariablesIORoot.close(), ALIFileIn.close(), Storage.close(), cond::DbConnection.close(), L1GtVhdlTemplateFile.close(), cond::persistency::SessionImpl.close(), XrdFile.close(), L1GtPatternWriter.close(), File.close(), MillePedeVariablesIORoot.close(), cond::DbSession.close(), DTTPGLutFile.close(), L1TriggerLutFile.close(), cond::persistency::Session.close(), edm::RootTree.close(), edm::RootFile.close(), edm::RootOutputTree.close(), edm::FileBlock.close(), cond::SessionImpl.close(), cond::CSScopedSession.close(), cond::persistency::TransactionScope.close(), Vispa.Plugins.Browser.BrowserTabController.BrowserTabController.close(), and Vispa.Main.TabController.TabController.close().

332  def handle_close(self):
333  self.close()
334  self.cleanup()

Member Data Documentation

esMonitoring.FDJsonServer.es

Definition at line 298 of file esMonitoring.py.

Referenced by esMonitoring.FDJsonServer.handle_accept().

esMonitoring.FDJsonServer.fn

Definition at line 297 of file esMonitoring.py.

Referenced by esMonitoring.FDJsonServer.cleanup().