esMonitoring.FDJsonHandler Class Reference

Inheritance diagram for esMonitoring.FDJsonHandler:

Public Member Functions
def	__init__ (self, sock, es)
def	handle_line (self, line)
def	handle_write (self)
def	writable (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
	es
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 263 of file esMonitoring.py.

Constructor & Destructor Documentation

__init__()

def esMonitoring.FDJsonHandler.__init__	(		self,
			sock,
			es
	)

Definition at line 264 of file esMonitoring.py.

    def __init__(self, sock, es):
        AsyncLineReaderMixin.__init__(self)
        asyncore.dispatcher.__init__(self, sock)
 
        self.es = es
 

Member Function Documentation

handle_line()

def esMonitoring.FDJsonHandler.handle_line	(		self,
			line
	)

Definition at line 270 of file esMonitoring.py.

    def handle_line(self, line):
        if len(line) < 4:
            # keep alive 'ping'
            self.es.try_update()
            return
 
        try:
            doc = json.loads(line)
 
            for k in ["pid", "run", "lumi"]:
                if k in doc:
                    doc[k] = int(doc[k])
 
            self.es.update_doc_recursive(self.es.doc, doc)
            self.es.try_update()
        except:
            log("cannot deserialize json len: %d content: %s" % (len(line), line))
 

References esMonitoring.FDJsonHandler.es, createfilelist.int, and esMonitoring.log().

handle_write()

def esMonitoring.FDJsonHandler.handle_write

(

self

)

Definition at line 288 of file esMonitoring.py.

    def handle_write(self):
        pass
 

writable()

def esMonitoring.FDJsonHandler.writable

(

self

)

Definition at line 291 of file esMonitoring.py.

    def writable(self):
        return False
 

Member Data Documentation

es

esMonitoring.FDJsonHandler.es

Definition at line 268 of file esMonitoring.py.

Referenced by esMonitoring.FDJsonServer.handle_accept(), esMonitoring.FDJsonHandler.handle_line(), esMonitoring.FDOutputListener.handle_line(), and esMonitoring.FDOutputListener.handle_timeout().