esMonitoring.AsyncLineReaderMixin Class Reference

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

def esMonitoring.AsyncLineReaderMixin.__init__

(

self

)

Definition at line 209 of file esMonitoring.py.

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

Member Function Documentation

def esMonitoring.AsyncLineReaderMixin.handle_close

(

self

)

Definition at line 212 of file esMonitoring.py.

References Vispa.Plugins.EventBrowser.EventFileAccessor.EventFileAccessor.close(), AlignmentCorrelationsIO.close(), StorageAccount.close, RemoteFile.close(), csvReporter.csvReporter.close(), AlignmentParametersIO.close(), AlignmentCorrelationsIORoot.close(), AlignmentUserVariablesIO.close(), Vispa.Plugins.EventBrowser.EventBrowserTabController.EventBrowserTabController.close(), RawFile.close(), AlignableDataIO.close(), PhysicsTools::TrainerMonitoring.close(), AlignableDataIORoot.close(), IOChannel.close(), evf::EvFOutputEventWriter.close(), binary_ofstream.close(), binary_ifstream.close(), LocalCacheFile.close(), AlignmentParametersIORoot.close(), HIPUserVariablesIORoot.close(), DavixFile.close(), OutputFile.close(), MuonErrorMatrix.close(), LStoreFile.close(), StorageAccountProxy.close(), DCacheFile.close(), ALIFileIn.close(), looper.Setup.close(), cond::persistency::SessionImpl.close(), Storage.close(), cond::persistency::PayloadReader.close(), L1GtVhdlTemplateFile.close(), L1GtPatternWriter.close(), XrdFile.close(), File.close(), StreamerOutputFile.close(), MillePedeVariablesIORoot.close(), DTTPGLutFile.close(), L1TriggerLutFile.close(), cond::persistency::Session.close(), edm::RootOutputTree.close(), DQM.DQMReader.close(), edm::FileBlock.close(), edm::RootTree.close(), cond::CSScopedSession.close(), edm::RootFile.close(), cond::persistency::TransactionScope.close(), Vispa.Plugins.Browser.BrowserTabController.BrowserTabController.close(), Vispa.Main.TabController.TabController.close(), esMonitoring.AsyncLineReaderMixin.handle_line(), join(), and esMonitoring.AsyncLineReaderMixin.line_buf.

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

        self.close()

def esMonitoring.AsyncLineReaderMixin.handle_line

(

self

)

Definition at line 241 of file esMonitoring.py.

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

    def handle_line(self):
        # override this!
        pass

def esMonitoring.AsyncLineReaderMixin.handle_read

(

self

)

Definition at line 220 of file esMonitoring.py.

References esMonitoring.AsyncLineReaderMixin.handle_line(), join(), esMonitoring.AsyncLineReaderMixin.line_buf, and split.

    def handle_read(self):
        rbuf = self.recv(1024*16)
        ## not needed, since asyncore automatically handles close
        #if len(rbuf) == 0:
        #    self.handle_close()
        #    return

        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 = []

Member Data Documentation

esMonitoring.AsyncLineReaderMixin.line_buf

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

Definition at line 210 of file esMonitoring.py.

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