Wip asyncio #20

Merged
bmartin5692 merged 4 commits from wip_asyncio into dev_broken-XMPP 2019-04-17 02:49:02 +02:00
Showing only changes of commit b8f95d5b9c - Show all commits

View file

@ -391,10 +391,11 @@ class XMPPAsyncClient:
xmppserverlog.exception("{}".format(e)) xmppserverlog.exception("{}".format(e))
async def send_ping(self, time): async def send_ping(self, time):
pingstring = "<iq from='{}' to='{}' id='s2c1' type='get'><ping xmlns='urn:xmpp:ping'/></iq>".format(XMPPServer.server_id, self.bumper_jid) if not self.state == 5: #disconnected
await self.send(pingstring) pingstring = "<iq from='{}' to='{}' id='s2c1' type='get'><ping xmlns='urn:xmpp:ping'/></iq>".format(XMPPServer.server_id, self.bumper_jid)
await asyncio.sleep(time) await self.send(pingstring)
pingtask = asyncio.Task(self.send_ping(time)) await asyncio.sleep(time)
asyncio.Task(self.send_ping(time))
async def _handle_result(self, xml, data): async def _handle_result(self, xml, data):
try: try: