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

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

def esMonitoring.FDJsonHandler.handle_line	(		self,
			line
	)

Definition at line 270 of file esMonitoring.py.

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

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

def esMonitoring.FDJsonHandler.handle_write

(

self

)

Definition at line 288 of file esMonitoring.py.

    def handle_write(self):
        pass

def esMonitoring.FDJsonHandler.writable

(

self

)

Definition at line 291 of file esMonitoring.py.

    def writable(self):
        return False

Member Data Documentation

esMonitoring.FDJsonHandler.es

Definition at line 268 of file esMonitoring.py.

Referenced by esMonitoring.FDJsonServer.handle_accept().