test
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

 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.

295 
296  def __init__(self, es, args):
297  asyncore.dispatcher.__init__(self)
298 
299  self.fn = None
300  self.es = es
301  self.args = args
302 
303  prefix = "/tmp"
304  if os.path.isdir(self.args.path):
305  prefix = self.args.path
306 
307  base = ".es_monitoring_pid%08d" % os.getpid()
308  self.fn = os.path.join(prefix, base)
309 
310  if self.args.debug:
311  log("Socket path: %s" % self.fn)
312 
313  if os.path.exists(self.fn):
314  os.unlink(self.fn)
315 
316  self.create_socket(socket.AF_UNIX, socket.SOCK_STREAM)
317  oldmask = os.umask(0o077)
318  try:
319  self.bind(self.fn)
320  self.listen(5)
321  finally:
322  os.umask(oldmask)
323  pass
324 
325  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().

326 
327  def cleanup(self):
328  if self.fn is not None:
329  if os.path.exists(self.fn):
330  os.unlink(self.fn)
def esMonitoring.FDJsonServer.handle_accept (   self)

Definition at line 331 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(), DDSpecificsFilter.accept(), SubsystemNeutronWriter.accept(), edm::HLTGlobalStatus.accept(), HLTLogMonitorFilter::CategoryEntry.accept(), edm::HLTPathStatus.accept(), edm::TriggerResultsByName.accept(), fwlite::ObjectCountSelector< Collection >.accept(), TriggerHelper.accept(), TkPixelMeasurementDet.accept(), GenericTriggerEventFlag.accept(), EcalSelectiveReadoutSuppressor.accept(), FilterOR.accept(), TriggerRatesMonitor::HLTRatesPlots.accept, Selection< C, Selector, StoreContainer >.accept(), FastTimerService::PathInfo.accept, TkStripMeasurementDet.accept(), esMonitoring.FDJsonHandler.es, and esMonitoring.FDJsonServer.es.

331 
332  def handle_accept(self):
333  pair = self.accept()
334  if pair is not None:
335  handler = FDJsonHandler(pair[0], self.es)
def esMonitoring.FDJsonServer.handle_close (   self)

Definition at line 336 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(), ESDaqInfoTask.cleanup(), HcalBaseDQClient.cleanup(), DrawPlot.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(), StorageAccount.close, RemoteFile.close(), AlignmentCorrelationsIO.close(), csvReporter.csvReporter.close(), AlignmentCorrelationsIORoot.close(), Vispa.Plugins.EventBrowser.EventBrowserTabController.EventBrowserTabController.close(), AlignmentParametersIO.close(), AlignableDataIO.close(), AlignableDataIORoot.close(), RawFile.close(), ora::SharedSession.close(), PhysicsTools::TrainerMonitoring.close(), AlignmentUserVariablesIO.close(), IOChannel.close(), LocalCacheFile.close(), binary_ofstream.close(), binary_ifstream.close(), AlignmentParametersIORoot.close(), MuonErrorMatrix.close(), LStoreFile.close(), StorageAccountProxy.close(), RFIOFile.close(), DCacheFile.close(), HIPUserVariablesIORoot.close(), ThePEG::LesHouchesInterface.close(), looper.Setup.close(), ALIFileIn.close(), cond::persistency::SessionImpl.close(), Storage.close(), cond::persistency::PayloadReader.close(), L1GtVhdlTemplateFile.close(), XrdFile.close(), L1GtPatternWriter.close(), MillePedeVariablesIORoot.close(), File.close(), DTTPGLutFile.close(), L1TriggerLutFile.close(), cond::persistency::Session.close(), edm::RootTree.close(), edm::RootOutputTree.close(), edm::FileBlock.close(), edm::RootFile.close(), cond::CSScopedSession.close(), cond::persistency::TransactionScope.close(), Vispa.Plugins.Browser.BrowserTabController.BrowserTabController.close(), and Vispa.Main.TabController.TabController.close().

336 
337  def handle_close(self):
338  self.close()
339  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().

Generated for CMSSW Reference Manual by doxygen 1.8.5