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)

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

◆ init()

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

◆ handle_read()

def esMonitoring.AsyncLineReaderTimeoutMixin.handle_read ( self )

Reimplemented from esMonitoring.AsyncLineReaderMixin.

Definition at line 252 of file esMonitoring.py.

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

References esMonitoring.AsyncLineReaderTimeoutMixin.last_read.

◆ readable()

def esMonitoring.AsyncLineReaderTimeoutMixin.readable ( self )

Definition at line 256 of file esMonitoring.py.

     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()
  