Inheritance diagram for esMonitoring.AsyncLineReaderMixin:

Public Member Functions
def	__init__ (self)

def	handle_close (self)

def	handle_line (self)

def	handle_read (self)

Public Attributes
	line_buf
	not needed, since asyncore automatically handles close if len(rbuf) == 0: self.handle_close() return More...

Detailed Description

Definition at line 208 of file esMonitoring.py.

Constructor & Destructor Documentation

◆ init()

def esMonitoring.AsyncLineReaderMixin.__init__ ( self )

Definition at line 209 of file esMonitoring.py.

     def __init__(self):
         self.line_buf = []
  

Member Function Documentation

◆ handle_close()

def esMonitoring.AsyncLineReaderMixin.handle_close ( self )

Reimplemented in esMonitoring.FDOutputListener.

Definition at line 212 of file esMonitoring.py.

     def handle_close(self):
         # closing fd
         if len(self.line_buf):
             self.handle_line("".join(self.line_buf))
             self.line_buf = []
  
         self.close()
  

References RemoteFile.close(), StorageAccount.close, AlignmentCorrelationsIO.close(), TritonMemResource< IO >.close(), AlignmentParametersIO.close(), AlignmentCorrelationsIORoot.close(), trklet::HistBase.close(), l1tpf_impl::COEFile.close(), AlignmentUserVariablesIO.close(), AlignableDataIO.close(), RawFile.close(), evf::EvFOutputEventWriter.close(), IOChannel.close(), AlignableDataIORoot.close(), LStoreFile.close(), DavixFile.close(), binary_ifstream.close(), binary_ofstream.close(), DCacheFile.close(), LocalCacheFile.close(), MuonErrorMatrix.close(), AlignmentParametersIORoot.close(), edm::streamer::OutputFile.close(), StorageAccountProxy.close(), HIPUserVariablesIORoot.close(), ALIFileIn.close(), looper.Setup.close(), XrdFile.close(), File.close(), evf::GlobalEvFOutputEventWriter.close(), cond::persistency::PayloadReader.close(), TritonCpuShmResource< IO >.close(), cond::persistency::SessionImpl.close(), L1GtVhdlTemplateFile.close(), Storage.close(), L1GtPatternWriter.close(), StreamerOutputFile.close(), MillePedeVariablesIORoot.close(), DTTPGLutFile.close(), L1TriggerLutFile.close(), cond::persistency::Session.close(), DQM.DQMReader.close(), edm::RootOutputTree.close(), edm::RootTree.close(), edm::FileBlock.close(), cond::CSScopedSession.close(), edm::RootFile.close(), cond::persistency::TransactionScope.close(), esMonitoring.AsyncLineReaderMixin.handle_line(), join(), and esMonitoring.AsyncLineReaderMixin.line_buf.

◆ handle_line()

def esMonitoring.AsyncLineReaderMixin.handle_line ( self )

Definition at line 242 of file esMonitoring.py.

     def handle_line(self):
         # override this!
         pass
  

Referenced by esMonitoring.AsyncLineReaderMixin.handle_close(), and esMonitoring.AsyncLineReaderMixin.handle_read().

◆ handle_read()

def esMonitoring.AsyncLineReaderMixin.handle_read ( self )

Reimplemented in esMonitoring.AsyncLineReaderTimeoutMixin.

Definition at line 220 of file esMonitoring.py.

     def handle_read(self):
         rbuf = self.recv(1024*16)
         rbuf = rbuf.decode('utf-8')
         
  
         self.line_buf.append(rbuf)
         if "\n" in rbuf:
             # split whatever we have
             spl = "".join(self.line_buf).split("\n")
  
             while len(spl) > 1:
                 line = spl.pop(0)
                 self.handle_line(line + "\n")
  
             if len(spl[0]):
                 self.line_buf = [spl[0]]
             else:
                 self.line_buf = []
  