CMS 3D CMS Logo

List of all members | Public Member Functions | Public Attributes
esMonitoring.FDOutputListener Class Reference
Inheritance diagram for esMonitoring.FDOutputListener:
esMonitoring.AsyncLineReaderTimeoutMixin esMonitoring.AsyncLineReaderMixin

Public Member Functions

def __init__ (self, fd, es, zlog, close_socket=None)
 
def finish (self)
 
def handle_close (self)
 
def handle_line (self, line)
 
def handle_timeout (self)
 
def writable (self)
 
- Public Member Functions inherited from esMonitoring.AsyncLineReaderTimeoutMixin
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

 close_socket
 
 end
 
 es
 
 start
 
 zlog
 
- Public Attributes inherited from esMonitoring.AsyncLineReaderTimeoutMixin
 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 340 of file esMonitoring.py.

Constructor & Destructor Documentation

def esMonitoring.FDOutputListener.__init__ (   self,
  fd,
  es,
  zlog,
  close_socket = None 
)

Definition at line 341 of file esMonitoring.py.

341  def __init__(self, fd, es, zlog, close_socket=None):
342  AsyncLineReaderTimeoutMixin.__init__(self, 5)
343  asyncore.file_dispatcher.__init__(self, fd)
344 
345  self.es = es
346  self.zlog = zlog
347  self.close_socket = close_socket
348 
351 
352  self.es.update_doc({ 'extra': { 'stdlog_start': self.start } })
353  self.es.update_doc({ 'extra': { 'stdlog_end': self.end } })
354 
def __init__(self, fd, es, zlog, close_socket=None)

Member Function Documentation

def esMonitoring.FDOutputListener.finish (   self)

Definition at line 381 of file esMonitoring.py.

References esMonitoring.FDOutputListener.zlog.

Referenced by progressbar.ProgressBar.__next__().

381  def finish(self):
382  if self.zlog is not None:
383  self.zlog.finish()
384 
385 
def esMonitoring.FDOutputListener.handle_close (   self)

Definition at line 375 of file esMonitoring.py.

References esMonitoring.FDOutputListener.close_socket.

375  def handle_close(self):
376  super(FDOutputListener, self).handle_close()
377 
378  if self.close_socket is not None:
379  self.close_socket.handle_close()
380 
def esMonitoring.FDOutputListener.handle_line (   self,
  line 
)

Definition at line 358 of file esMonitoring.py.

References esMonitoring.FDOutputListener.zlog.

358  def handle_line(self, line):
359  if self.zlog is not None:
360  self.zlog.write(line)
361  else:
362  sys.stdout.write(line)
363  sys.stdout.flush()
364 
365  self.start.write(line)
366  self.end.write(line)
367  self.es.try_update()
368 
def esMonitoring.FDOutputListener.handle_timeout (   self)

Definition at line 369 of file esMonitoring.py.

References esMonitoring.FDOutputListener.zlog.

Referenced by esMonitoring.AsyncLineReaderTimeoutMixin.readable().

369  def handle_timeout(self):
370  self.es.try_update()
371 
372  if self.zlog is not None:
373  self.zlog.handle_timeout()
374 
def esMonitoring.FDOutputListener.writable (   self)

Definition at line 355 of file esMonitoring.py.

355  def writable(self):
356  return False
357 

Member Data Documentation

esMonitoring.FDOutputListener.close_socket

Definition at line 347 of file esMonitoring.py.

Referenced by esMonitoring.FDOutputListener.handle_close().

esMonitoring.FDOutputListener.end
esMonitoring.FDOutputListener.es

Definition at line 345 of file esMonitoring.py.

esMonitoring.FDOutputListener.start
esMonitoring.FDOutputListener.zlog