mia/bumper
1
0
Fork 0
Code Issues 47 Pull requests 11 Projects Releases Packages Wiki Activity Actions

fix restart test

Browse source
This commit is contained in:
Brian Martin 2020-01-03 00:19:27 -05:00
parent c77f464c9d
commit 80c412afd1
1 changed files with 6 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
bumper/confserver.py
View file

@ -341,17 +341,18 @@ class ConfServer:
if sessobj.session.transitions.state == "connected":
await sessobj.writer.close()
#await bumper.mqtt_server.broker.shutdown()
aloop = asyncio.get_event_loop()
aloop.call_later(
0.1, lambda: asyncio.create_task(bumper.mqtt_server.broker.shutdown())
) # In .1 seconds shutdown broker
aloop = asyncio.get_event_loop()
aloop.call_later(
1.5, lambda: asyncio.create_task(bumper.mqtt_server.broker_coro())
1.5, lambda: asyncio.create_task(bumper.mqtt_server.broker_coro())
) # In 1.5 seconds start broker
async def restart_XMPP(self):
bumper.xmpp_server.disconnect()
await bumper.xmpp_server.start_async_server()
@ -363,11 +364,12 @@ class ConfServer:
await self.restart_Helper()
return web.json_response({"status": "complete"})
elif service == "MQTTServer":
await self.restart_MQTT()
asyncio.create_task(self.restart_MQTT())
aloop = asyncio.get_event_loop()
aloop.call_later(
5, lambda: asyncio.create_task(self.restart_Helper())
) # In 5 seconds restart Helperbot
return web.json_response({"status": "complete"})
elif service == "XMPPServer":
await self.restart_XMPP()