def on_stanza(self, doc):
        if doc.name() == 'incoming_packet':
            data = base64.b64decode(doc.get('msg'))
            raddr = (doc.get('src_addr'), int(doc.get('src_port')))
            laddr = (doc.get('dst_addr'), int(doc.get('dst_port')))
            rtime = float(doc.get('rtime'))
            reactor.callFromThread(self.__owner.handle_read, data, raddr, laddr, rtime)
dataset/ETHPy150Open sippy/b2bua/sippy/XMPP_server.py/Worker.on_stanza/original