esMonitoring.AsyncLineReaderTimeoutMixin Class Reference

Inheritance diagram for esMonitoring.AsyncLineReaderTimeoutMixin:

Public Member Functions
def	__init__ (self, timeout_secs)
def	handle_read (self)
def	readable (self)
Public Member Functions inherited from esMonitoring.AsyncLineReaderMixin
def	__init__ (self)
def	handle_close (self)
def	handle_line (self)
def	handle_read (self)

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

Detailed Description

Definition at line 245 of file esMonitoring.py.

Constructor & Destructor Documentation

def esMonitoring.AsyncLineReaderTimeoutMixin.__init__	(		self,
			timeout_secs
	)

Definition at line 246 of file esMonitoring.py.

    def __init__(self, timeout_secs):
        self.timeout_secs = timeout_secs
        self.last_read = time.time()

        super(AsyncLineReaderTimeoutMixin, self).__init__()

Member Function Documentation

def esMonitoring.AsyncLineReaderTimeoutMixin.handle_read

(

self

)

Definition at line 252 of file esMonitoring.py.

References esMonitoring.AsyncLineReaderTimeoutMixin.last_read.

    def handle_read(self):
        self.last_read = time.time()
        AsyncLineReaderMixin.handle_read(self)

def esMonitoring.AsyncLineReaderTimeoutMixin.readable

(

self

)

Definition at line 256 of file esMonitoring.py.

References ztee.GZipLog.handle_timeout(), esMonitoring.FDOutputListener.handle_timeout(), esMonitoring.AsyncLineReaderTimeoutMixin.last_read, and esMonitoring.AsyncLineReaderTimeoutMixin.timeout_secs.

    def readable(self):
        if (time.time() - self.last_read) >= self.timeout_secs:
            self.last_read = time.time()
            self.handle_timeout()

        return super(AsyncLineReaderTimeoutMixin, self).readable()

Member Data Documentation

esMonitoring.AsyncLineReaderTimeoutMixin.last_read

Definition at line 248 of file esMonitoring.py.

Referenced by esMonitoring.AsyncLineReaderTimeoutMixin.handle_read(), and esMonitoring.AsyncLineReaderTimeoutMixin.readable().

esMonitoring.AsyncLineReaderTimeoutMixin.timeout_secs

Definition at line 247 of file esMonitoring.py.

Referenced by esMonitoring.AsyncLineReaderTimeoutMixin.readable().